Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
O
opcua-asyncio
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
1
Merge Requests
1
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Nikola Balog
opcua-asyncio
Commits
fa813095
Commit
fa813095
authored
Apr 30, 2015
by
Olivier R-D
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
logging: warning and not warn(deprecated)
parent
ef784eb4
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
6 additions
and
6 deletions
+6
-6
opcua/binary_server_asyncio.py
opcua/binary_server_asyncio.py
+4
-4
opcua/subscription.py
opcua/subscription.py
+1
-1
opcua/subscription_service.py
opcua/subscription_service.py
+1
-1
No files found.
opcua/binary_server_asyncio.py
View file @
fa813095
...
...
@@ -65,19 +65,19 @@ class BinaryServer(object):
buf
=
ua
.
utils
.
Buffer
(
data
[:])
hdr
=
ua
.
Header
.
from_string
(
buf
)
if
len
(
buf
)
<
hdr
.
body_size
:
logger
.
warn
(
"We did not receive enough data from server, waiting for more"
)
logger
.
warn
ing
(
"We did not receive enough data from server, waiting for more"
)
self
.
data
=
data
return
ret
=
self
.
processor
.
process
(
hdr
,
buf
)
if
not
ret
:
logger
.
warn
(
"processor returned False, we close connection"
)
logger
.
warn
ing
(
"processor returned False, we close connection"
)
self
.
transport
.
close
()
return
if
len
(
data
)
<=
hdr
.
packet_size
:
return
data
=
data
[
hdr
.
packet_size
:]
except
utils
.
NotEnoughData
:
logger
.
warn
(
"Not a complete packet in data from client, waiting for more data"
)
logger
.
warn
ing
(
"Not a complete packet in data from client, waiting for more data"
)
self
.
data
=
buf
.
data
break
except
Exception
:
...
...
@@ -91,7 +91,7 @@ class BinaryServer(object):
logger
.
warning
(
'Listening on %s'
,
self
.
_server
.
sockets
[
0
].
getsockname
())
def
stop
(
self
):
self
.
logger
.
warn
(
"Closing asyncio socket server"
)
self
.
logger
.
warn
ing
(
"Closing asyncio socket server"
)
self
.
_server
.
close
()
self
.
loop
.
run_coro_and_wait
(
self
.
_server
.
wait_closed
())
...
...
opcua/subscription.py
View file @
fa813095
...
...
@@ -66,7 +66,7 @@ class Subscription(object):
statuschange
=
ua
.
StatusChangeNotification
.
from_binary
(
io
.
BytesIO
(
notif
.
to_binary
()))
self
.
_call_status
(
statuschange
)
else
:
self
.
logger
.
warn
(
"Notification type not supported yet for notification %s"
,
notif
)
self
.
logger
.
warn
ing
(
"Notification type not supported yet for notification %s"
,
notif
)
ack
=
ua
.
SubscriptionAcknowledgement
()
ack
.
SubscriptionId
=
self
.
subscription_id
...
...
opcua/subscription_service.py
View file @
fa813095
...
...
@@ -172,7 +172,7 @@ class InternalSubscription(object):
def
publish_results
(
self
):
if
self
.
_publish_cycles_count
>
self
.
data
.
RevisedLifetimeCount
:
self
.
logger
.
warn
(
"Subscription %s has expired, publish cycle count(%s) > lifetime count (%s)"
,
self
,
self
.
_publish_cycles_count
,
self
.
data
.
RevisedLifetimeCount
)
self
.
logger
.
warn
ing
(
"Subscription %s has expired, publish cycle count(%s) > lifetime count (%s)"
,
self
,
self
.
_publish_cycles_count
,
self
.
data
.
RevisedLifetimeCount
)
# FIXME this will never be send since we do not have publish request anyway
self
.
trigger_statuschange
(
ua
.
StatusCode
(
ua
.
StatusCodes
.
BadTimeout
))
self
.
_stopev
=
True
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment