Loading system/gd/cert/gd_base_test.py +2 −0 Original line number Diff line number Diff line Loading @@ -61,6 +61,8 @@ class GdBaseTestClass(BaseTestClass): builtin=True) def teardown_class(self): self.unregister_controllers() self.rootcanal_process.send_signal(signal.SIGINT) self.rootcanal_process.wait() self.rootcanal_logs.close() system/gd/cert/gd_device.py +1 −0 Original line number Diff line number Diff line Loading @@ -117,6 +117,7 @@ class GdDevice: def clean_up(self): self.grpc_channel.close() self.backing_process.send_signal(signal.SIGINT) self.backing_process.wait() self.backing_process_logs.close() class GdDeviceLoggerAdapter(logging.LoggerAdapter): Loading system/gd/facade/stack_with_grpc_main.cc +0 −1 Original line number Diff line number Diff line Loading @@ -69,7 +69,6 @@ int main(int argc, const char** argv) { auto wait_thread = std::thread([grpc_module] { grpc_module->RunGrpcLoop(); }); wait_thread.join(); grpc_module->StopServer(); stack->ShutDown(); delete stack; Loading system/gd/grpc/grpc_module.cc +1 −0 Original line number Diff line number Diff line Loading @@ -50,6 +50,7 @@ void GrpcModule::StartServer(const std::string& address, int port) { builder.AddListeningPort(listening_port, ::grpc::InsecureServerCredentials()); completion_queue_ = builder.AddCompletionQueue(); server_ = builder.BuildAndStart(); ASSERT(server_ != nullptr); for (const auto& facade : facades_) { facade->OnServerStarted(completion_queue_.get()); Loading Loading
system/gd/cert/gd_base_test.py +2 −0 Original line number Diff line number Diff line Loading @@ -61,6 +61,8 @@ class GdBaseTestClass(BaseTestClass): builtin=True) def teardown_class(self): self.unregister_controllers() self.rootcanal_process.send_signal(signal.SIGINT) self.rootcanal_process.wait() self.rootcanal_logs.close()
system/gd/cert/gd_device.py +1 −0 Original line number Diff line number Diff line Loading @@ -117,6 +117,7 @@ class GdDevice: def clean_up(self): self.grpc_channel.close() self.backing_process.send_signal(signal.SIGINT) self.backing_process.wait() self.backing_process_logs.close() class GdDeviceLoggerAdapter(logging.LoggerAdapter): Loading
system/gd/facade/stack_with_grpc_main.cc +0 −1 Original line number Diff line number Diff line Loading @@ -69,7 +69,6 @@ int main(int argc, const char** argv) { auto wait_thread = std::thread([grpc_module] { grpc_module->RunGrpcLoop(); }); wait_thread.join(); grpc_module->StopServer(); stack->ShutDown(); delete stack; Loading
system/gd/grpc/grpc_module.cc +1 −0 Original line number Diff line number Diff line Loading @@ -50,6 +50,7 @@ void GrpcModule::StartServer(const std::string& address, int port) { builder.AddListeningPort(listening_port, ::grpc::InsecureServerCredentials()); completion_queue_ = builder.AddCompletionQueue(); server_ = builder.BuildAndStart(); ASSERT(server_ != nullptr); for (const auto& facade : facades_) { facade->OnServerStarted(completion_queue_.get()); Loading