Lines Matching refs:self
20 def __init__(self, path):
29 self.sock = sock
34 self.epoll = epoll
36 def recv(self, timeout):
44 events = self.epoll.poll(timeout)
47 if fd != self.sock.fileno():
55 msg = self.sock.recv(4096)
65 def send(self, msg):
66 self.sock.send(msg)
73 def __init__(self, conn):
74 self.cmdpos = 0
75 self.parampos = 0
76 self.bufferpos = 0
77 self.reading_cmd = False
78 self.reading_param = False
79 self.buffer = None
80 self.cmd = bytearray(4096)
81 self.param = bytearray(4096)
83 self.conn = conn
85 def readCmd(self, ncmds, timeout=TIMEOUT):
99 if self.buffer == None:
100 self.buffer = self.conn.recv(remaining)
101 self.bufferpos = 0
104 if self.buffer == None:
107 for i in range(self.bufferpos, len(self.buffer)):
108 c = self.buffer[i]
109 self.bufferpos += 1
110 if c == self.MSGBEGIN:
111 self.cmdpos = 0
112 self.parampos = 0
113 self.reading_cmd = True
114 self.reading_param = False
115 elif c == self.MSGEND:
116 if not self.reading_cmd:
118 self.reading_cmd = False
119 self.reading_param = False
121 cmd = self.cmd[0:self.cmdpos]
122 param = self.param[0:self.parampos]
123 self.reading_cmd = False
124 self.reading_param = False
130 elif c == self.MSGSEP:
131 if self.reading_cmd:
132 self.reading_param = True
134 if self.reading_param:
135 self.param[self.parampos] = c
136 self.parampos += 1
137 elif self.reading_cmd:
138 self.cmd[self.cmdpos] = c
139 self.cmdpos += 1
143 self.buffer = None