Fix destroy error in test_ProtoServer. #1209
Conversation
| @@ -163,17 +162,15 @@ int main(int argc, char** argv) { | |||
| paddle::initMain(argc, argv); | |||
| testing::InitGoogleTest(&argc, argv); | |||
|
|
|||
| MyServer* server; | |||
| std::unique_ptr<MyServer> server; | |||
There was a problem hiding this comment.
这个server变量之前没有正确的做释放。
虽然，之前终归程序会退出，在程序退出的时候，server这段内存也会还给操作系统。但是，之前这么搞的话，对象析构的顺序就是不确定的了。在GLOG开启多线程的情况下，就会导致偶发的，glog本身的全局对象已经析构了，再调用server的析构函数。而server的析构里面使用了glog来print一些信息。
这就导致程序异常退出。
There was a problem hiding this comment.
根据这个描述，我理解这个PR的修改意图是：让 server 在main函数结束的时候就析构。
如果是这样，那么最朴素的C++语法既可以实现——把server定义为一个stack variable，而不是new在heap里。这样就不需要引入一个unique_ptr这样的smart pointer，也就不需要我们的读者懂得unique_ptr。
我看了一下MyServer的源码，发现最直接的解决方法貌似可以是：
MyServer server(FLAGS_port, FLAGS_rdma_tcp == "rdma" ? 0 : -1);
server.start();
相对这个PR里的修改：
MyServer* server;
std::unique_ptr<MyServer> server;
if (FLAGS_rdma_tcp == "rdma") {
server = new MyServer(FLAGS_port, 0);
server.reset(new MyServer(FLAGS_port, 0));
} else {
server = new MyServer(FLAGS_port);
server.reset(new MyServer(FLAGS_port));
}
server->start();
我这个解法貌似简单一些？
There was a problem hiding this comment.
MyServer* server;
std::unique_ptr server;
此处有笔误？ 两个相同的variable declaration？
| @@ -163,17 +162,15 @@ int main(int argc, char** argv) { | |||
| paddle::initMain(argc, argv); | |||
| testing::InitGoogleTest(&argc, argv); | |||
|
|
|||
| MyServer* server; | |||
| std::unique_ptr<MyServer> server; | |||
There was a problem hiding this comment.
根据这个描述，我理解这个PR的修改意图是：让 server 在main函数结束的时候就析构。
如果是这样，那么最朴素的C++语法既可以实现——把server定义为一个stack variable，而不是new在heap里。这样就不需要引入一个unique_ptr这样的smart pointer，也就不需要我们的读者懂得unique_ptr。
我看了一下MyServer的源码，发现最直接的解决方法貌似可以是：
MyServer server(FLAGS_port, FLAGS_rdma_tcp == "rdma" ? 0 : -1);
server.start();
相对这个PR里的修改：
MyServer* server;
std::unique_ptr<MyServer> server;
if (FLAGS_rdma_tcp == "rdma") {
server = new MyServer(FLAGS_port, 0);
server.reset(new MyServer(FLAGS_port, 0));
} else {
server = new MyServer(FLAGS_port);
server.reset(new MyServer(FLAGS_port));
}
server->start();
我这个解法貌似简单一些？
有道理，直接用栈变量就好了。。 |
No description provided.