mir/kea
2
0
Fork 0
mirror of https://gitlab.isc.org/isc-projects/kea synced 2025-08-31 14:05:33 +00:00
Code Issues Releases Wiki Activity

update from trunk

Browse Source 
git-svn-id: svn://bind10.isc.org/svn/bind10/branches/f2f200910@153 e5f2f494-b856-4b98-b285-d166d9295462
This commit is contained in:
Jelte Jansen
2009-10-29 00:06:34 +00:00
parent 9f366e921c
commit 0a6b3fc64e
1 changed files with 26 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
src/lib/cc/python/ISC/CC/session.py
View File

@@ -20,6 +20,7 @@ import struct
import Message
class ProtocolError(Exception): pass
class NetworkError(Exception): pass
class SessionError(Exception): pass
class Session:
@@ -73,8 +74,8 @@ class Session:
data = self._socket.recv(length)
except:
return None
if not data: # server closed connection
return None
if data == "": # server closed connection
raise ProtocolError("Read of 0 bytes: connection closed")
self._recvbuffer += data
if len(self._recvbuffer) < 4:
@@ -84,7 +85,12 @@ class Session:
length = self._recvlength - len(self._recvbuffer)
while (length > 0):
data = self._socket.recv(length)
try:
data = self._socket.recv(length)
except:
return None
if data == "": # server closed connection
raise ProtocolError("Read of 0 bytes: connection closed")
self._recvbuffer += data
length -= len(data)
data = self._recvbuffer
@@ -112,15 +118,17 @@ class Session:
})
def group_sendmsg(self, msg, group, instance = "*", to = "*"):
seq = self._next_sequence()
self.sendmsg({
"type": "send",
"from": self._lname,
"to": to,
"group": group,
"instance": instance,
"seq": self._next_sequence(),
"seq": seq,
"msg": Message.to_wire(msg),
})
return seq
def group_recvmsg(self, nonblock = True):
msg = self.recvmsg(nonblock)
@@ -129,6 +137,20 @@ class Session:
data = Message.from_wire(msg["msg"])
return (data, msg)
def group_reply(self, routing, msg):
seq = self._next_sequence()
self.sendmsg({
"type": "send",
"from": self._lname,
"to": routing["from"],
"group": routing["group"],
"instance": routing["instance"],
"seq": seq,
"reply": routing["seq"],
"msg": Message.to_wire(msg),
})
return seq
if __name__ == "__main__":
import doctest
doctest.testmod()