def type_to_string(type_):
return Message.__types[type_]
- @staticmethod
- def __validate_arg(value, name, must_have):
+ def __validate_arg(self, value, name, must_have):
if (value is not None) == (must_have != 0):
return None
else:
return "invalid JSON-RPC message type %s" % self.type
return (
- Message.__validate_arg(self.method, "method", pattern & 0x10000) or
- Message.__validate_arg(self.params, "params", pattern & 0x1000) or
- Message.__validate_arg(self.result, "result", pattern & 0x100) or
- Message.__validate_arg(self.error, "error", pattern & 0x10) or
- Message.__validate_arg(self.id, "id", pattern & 0x1))
+ self.__validate_arg(self.method, "method", pattern & 0x10000) or
+ self.__validate_arg(self.params, "params", pattern & 0x1000) or
+ self.__validate_arg(self.result, "result", pattern & 0x100) or
+ self.__validate_arg(self.error, "error", pattern & 0x10) or
+ self.__validate_arg(self.id, "id", pattern & 0x1))
@staticmethod
def from_json(json):
class Connection(object):
def __init__(self, stream):
- self.name = stream.get_name()
+ self.name = stream.name
self.stream = stream
self.status = 0
self.input = ""
return self.status, None
while True:
- if len(self.input) == 0:
+ if not self.input:
error, data = self.stream.recv(4096)
if error:
if error == errno.EAGAIN:
% (self.name, os.strerror(error)))
self.error(error)
return self.status, None
- elif len(data) == 0:
+ elif not data:
self.error(EOF)
return EOF, None
else:
return msg
def recv_wait(self, poller):
- if self.status or len(self.input) > 0:
+ if self.status or self.input:
poller.immediate_wake()
else:
self.stream.recv_wait(poller)
reconnect.enable(ovs.timeval.msec())
if ovs.stream.PassiveStream.is_valid_name(name):
- self.reconnect.set_passive(True, ovs.timeval.msec())
+ reconnect.set_passive(True, ovs.timeval.msec())
return Session(reconnect, None)