Revision f863d7aa lib/rpc.py
| b/lib/rpc.py | ||
|---|---|---|
| 391 | 391 |
|
| 392 | 392 |
return results |
| 393 | 393 |
|
| 394 |
def __call__(self, hosts, procedure, body, read_timeout=None,
|
|
| 394 |
def __call__(self, hosts, procedure, body, read_timeout, |
|
| 395 | 395 |
_req_process_fn=http.client.ProcessRequests): |
| 396 | 396 |
"""Makes an RPC request to a number of nodes. |
| 397 | 397 |
|
| ... | ... | |
| 463 | 463 |
pnbody = dict((n, serializer.DumpJson(prep_fn(n, enc_args))) |
| 464 | 464 |
for n in node_list) |
| 465 | 465 |
|
| 466 |
result = self._proc(node_list, procedure, pnbody, |
|
| 467 |
read_timeout=read_timeout) |
|
| 466 |
result = self._proc(node_list, procedure, pnbody, read_timeout) |
|
| 468 | 467 |
|
| 469 | 468 |
if postproc_fn: |
| 470 | 469 |
return dict(map(lambda (key, value): (key, postproc_fn(value)), |
Also available in: Unified diff