r""" a helper function to run method on the owner of rref and fetch back the result using RPC
(method, rref, *args, **kwargs)
| 12 | |
| 13 | |
| 14 | def _remote_method(method, rref, *args, **kwargs): |
| 15 | r""" |
| 16 | a helper function to run method on the owner of rref and fetch back the |
| 17 | result using RPC |
| 18 | """ |
| 19 | return rpc.rpc_sync( |
| 20 | rref.owner(), |
| 21 | _call_method, |
| 22 | args=[method, rref] + list(args), |
| 23 | kwargs=kwargs |
| 24 | ) |
| 25 | |
| 26 | |
| 27 | def _parameter_rrefs(module): |
no outgoing calls
no test coverage detected