timur/ADC
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

...

Browse Source
This commit is contained in:
Timur A. Fatkhullin 2024-10-29 17:57:06 +03:00
parent 6a4278c247
commit 81f0f6b02d
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
net/asio/adc_device_netserver_asio.h
View File

@ -120,7 +120,10 @@ protected:
_ioContext.notify_fork(asio::io_context::fork_child); _ioContext.notify_fork(asio::io_context::fork_child);
} }
virtual void signalReceived(std::error_code, int signo) {}; virtual void signalReceived(std::error_code, int signo)
{
std::cout << "SIGNAL: " << signo << "\n";
};
}; };
} // namespace adc::impl } // namespace adc::impl

5
tests/adc_asio_netserver_test.cpp
View File

@ -15,7 +15,8 @@ int main(int argc, char* argv[])
options.add_options()("h,help", "Print usage"); options.add_options()("h,help", "Print usage");
options.add_options()( options.add_options()(
"endpoints", "endpoints server will be listening for", "endpoints", "endpoints server will be listening for",
cxxopts::value<std::vector<std::string>>()->default_value("local://stream/@ADC_ASIO_TEST_SERVER")); cxxopts::value<std::vector<std::string>>()->default_value("local://stream/ADC_ASIO_TEST_SERVER"));
// cxxopts::value<std::vector<std::string>>()->default_value("local://stream/@ADC_ASIO_TEST_SERVER"));
options.parse_positional({"endpoints"}); options.parse_positional({"endpoints"});
@ -45,7 +46,9 @@ int main(int argc, char* argv[])
} }
std::cout << "try to start listenning at '" << ep << "' ..."; std::cout << "try to start listenning at '" << ep << "' ...";
server.start<adc::AdcStopSeqSessionProto<>>(epn); server.start<adc::AdcStopSeqSessionProto<>>(epn);
std::cout << "\tOK\n"; std::cout << "\tOK\n";
} else { } else {
std::cerr << "Unrecognized endpoint: '" << ep << "'! Ignore!\n"; std::cerr << "Unrecognized endpoint: '" << ep << "'! Ignore!\n";