|
|
@ -66,7 +66,6 @@ class SendOp : public framework::OperatorBase {
|
|
|
|
auto* client_var = scope.FindVar(client_var_name);
|
|
|
|
auto* client_var = scope.FindVar(client_var_name);
|
|
|
|
detail::RPCClient* rpc_client = client_var->GetMutable<detail::RPCClient>();
|
|
|
|
detail::RPCClient* rpc_client = client_var->GetMutable<detail::RPCClient>();
|
|
|
|
|
|
|
|
|
|
|
|
ctx.Wait(); // wait before sending
|
|
|
|
|
|
|
|
for (size_t i = 0; i < ins.size(); i++) {
|
|
|
|
for (size_t i = 0; i < ins.size(); i++) {
|
|
|
|
if (NeedSend(scope, ins[i])) {
|
|
|
|
if (NeedSend(scope, ins[i])) {
|
|
|
|
VLOG(3) << "sending " << ins[i] << " to " << epmap[i];
|
|
|
|
VLOG(3) << "sending " << ins[i] << " to " << epmap[i];
|
|
|
|