-
Notifications
You must be signed in to change notification settings - Fork 5.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Fix sendrecv port bind #9595
Fix sendrecv port bind #9595
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just small comments.
Thanks!
@@ -242,6 +244,9 @@ void AsyncGRPCServer::TryToRegisterNewSendOne() { | |||
VLOG(3) << "shutdown, do not TryToRegisterNewSendOne"; | |||
return; | |||
} | |||
while (scope_ == nullptr) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
These should be deleted.
|
||
framework::Executor executor(dev_place); | ||
|
||
// FIXME(Yancey1989): initialize rpc server with lazy mode. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This line is not useful.
|
||
void RunServer(std::shared_ptr<detail::AsyncGRPCServer> service); | ||
|
||
static void CreateTensorFromMessageType(framework::Variable *var, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should we put functions' definition in header files?
cd09715
to
00f8e63
Compare
… fix_test_sendrecv_portbind
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for this PR!
I have a look-irrelevant comment but could be important.
@@ -193,6 +193,7 @@ if(WITH_DISTRIBUTE) | |||
set_source_files_properties(send_vars_op.cc PROPERTIES COMPILE_FLAGS ${DISTRIBUTE_COMPILE_FLAGS}) | |||
op_library(send_barrier_op DEPS ${DISTRIBUTE_DEPS}) | |||
set_source_files_properties(send_barrier_op.cc PROPERTIES COMPILE_FLAGS ${DISTRIBUTE_COMPILE_FLAGS}) | |||
set_source_files_properties(send_recv_op_test.cc PROPERTIES COMPILE_FLAGS ${DISTRIBUTE_COMPILE_FLAGS}) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please remove the use of set_source_files_properties
as discussed in #9612
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Because of grpc implementation, we have to use this when linking with grpc, and this can not be present at generic.cmake.
Need to merge this fix first, will discuss in the issue
6cd9f1e
to
a9cc9ed
Compare
… fix_test_sendrecv_portbind
a9cc9ed
to
b03fa88
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, we could merge this fix firstly to fix the unit test error.
Fix unit test
send_recv_op_test.cc
error binding used port.Fix grpc_server use an uninitialized scope.