diff options
| author | YAMAMOTO Takashi <yamamoto@valinux.co.jp> | 2013-11-28 14:30:02 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2013-11-29 09:23:37 +0900 |
| commit | e4aeb0e822010ed69c81d67c2aecd8df3de54b3e (patch) | |
| tree | 3c9f590a41622b9194f9687993179fcf80399804 | |
| parent | e8962c296edc52b4308394e52a1f381adb5603d4 (diff) | |
rpc: prefix closed_by_peer with _ as it's private
Signed-off-by: YAMAMOTO Takashi <yamamoto@valinux.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
| -rw-r--r-- | ryu/lib/rpc.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ryu/lib/rpc.py b/ryu/lib/rpc.py index d06180e6..3aa476dd 100644 --- a/ryu/lib/rpc.py +++ b/ryu/lib/rpc.py @@ -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 |