HEADER_LENGTH = 4
MAX_SEGMENT = 512 * 1024
- def __init__(self, address="/var/run/charon.vici"):
- self.address = address
- self.socket = socket.socket(socket.AF_UNIX)
- self.socket.connect(address)
+ def __init__(self, sock):
+ self.socket = sock
def send(self, packet):
self.socket.sendall(struct.pack("!I", len(packet)) + packet)
return len(self.getvalue())
def has_more(self):
- return self.tell() < len(self)
\ No newline at end of file
+ return self.tell() < len(self)
import collections
+import socket
from .exception import SessionException
from .protocol import Transport, Packet, Message
class Session(object):
- def __init__(self, address="/var/run/charon.vici"):
- self.handler = SessionHandler(Transport(address))
+ def __init__(self, sock=None):
+ if sock is None:
+ sock = socket.socket(socket.AF_UNIX)
+ sock.connect("/var/run/charon.vici")
+ self.handler = SessionHandler(Transport(sock))
def version(self):
"""Retrieve daemon and system specific version information.