mirrors/ryu
1
0
Fork 0
mirror of https://github.com/faucetsdn/ryu.git synced 2026-05-08 13:56:09 +02:00
Code Issues Projects Releases Wiki Activity

rpc: prefix closed_by_peer with _ as it's private

Browse Source 
Signed-off-by: YAMAMOTO Takashi <yamamoto@valinux.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
This commit is contained in:
YAMAMOTO Takashi 2013-11-28 14:30:02 +09:00 committed by FUJITA Tomonori
parent e8962c296e
commit e4aeb0e822
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ryu/lib/rpc.py
View File

@ -115,7 +115,7 @@ class EndPoint(object):
self._notifications = deque()
self._responses = {}
self._incoming = 0 # number of incoming messages in our queues
self.closed_by_peer = False
self._closed_by_peer = False
def selectable(self):
rlist = [self._sock]
@ -143,7 +143,7 @@ class EndPoint(object):
select.select(rlist, wlist, rlist + wlist)
def serve(self):
while not self.closed_by_peer:
while not self._closed_by_peer:
self.block()
self.process()
@ -185,7 +185,7 @@ class EndPoint(object):
if not packet:
if packet is not None:
# socket closed by peer
self.closed_by_peer = True
self._closed_by_peer = True
break
self._encoder.get_and_dispatch_messages(packet, self._table)
return self._incoming > 0