Revision cda215a9
| b/lib/luxi.py | ||
|---|---|---|
| 91 | 91 |
|
| 92 | 92 |
""" |
| 93 | 93 |
super(Client, self).__init__(address, timeouts, transport) |
| 94 |
# Override the version of the protocol: |
|
| 95 |
self.version = constants.LUXI_VERSION |
|
| 94 | 96 |
|
| 95 | 97 |
def SetQueueDrainFlag(self, drain_flag): |
| 96 | 98 |
return self.CallMethod(REQ_SET_DRAIN_FLAG, (drain_flag, )) |
| b/lib/rpc/client.py | ||
|---|---|---|
| 177 | 177 |
self.transport_class = transport |
| 178 | 178 |
self.transport = None |
| 179 | 179 |
self._InitTransport() |
| 180 |
# The version used in RPC communication, by default unused: |
|
| 181 |
self.version = None |
|
| 180 | 182 |
|
| 181 | 183 |
def _InitTransport(self): |
| 182 | 184 |
"""(Re)initialize the transport if needed. |
| ... | ... | |
| 228 | 230 |
raise errors.ProgrammerError("Invalid parameter passed to CallMethod:"
|
| 229 | 231 |
" expected list, got %s" % type(args)) |
| 230 | 232 |
return CallRPCMethod(self._SendMethodCall, method, args, |
| 231 |
version=constants.LUXI_VERSION) |
|
| 233 |
version=self.version) |
|
Also available in: Unified diff