welsonzhang

只能自己新建一个Brpc Proxy，在里面添加对应的代码： ```java } finally { if (request.getCommunicationClient() != null) { SocketAddress socketAddress = new InetSocketAddress( request.getCommunicationClient().getServiceInstance().getIp(), request.getCommunicationClient().getServiceInstance().getPort()); RpcContext.getContext().setRemoteAddress(socketAddress); } currentTryTimes++; }

``` diff --git a/tools/pb2tarscpp/CppGenCallback.cpp b/tools/pb2tarscpp/CppGenCallback.cpp index 63800cb..a5cb00f 100644 --- a/tools/pb2tarscpp/CppGenCallback.cpp +++ b/tools/pb2tarscpp/CppGenCallback.cpp @@ -157,3 +157,126 @@ std::string GenPrxCallback(const ::google::protobuf::ServiceDescriptor* desc, in return out; } +std::string GenCoroPrxCallback(const ::google::protobuf::ServiceDescriptor* desc, int indent)...

I hava a problem with WorkQueue. when i run WorkQueue in single process, it will take all filenames, then train. I expect it to take a filename, then train, then...