Skip to content
Snippets Groups Projects
Commit 3b97a1a4 authored by dmitriy.gerasimov's avatar dmitriy.gerasimov
Browse files

Merge branch 'bugs-3903' into 'master'

Don't exit main thread when server=false

See merge request !134
parents 1d6a67aa d43352f4
No related branches found
No related tags found
1 merge request!134Don't exit main thread when server=false
Subproject commit ee628a2dbe412ad75ad6ff4f0b7a44859089164a Subproject commit d27598edc2acf65938983fb8e5dd38b7e75cc677
...@@ -142,7 +142,7 @@ int main( int argc, const char **argv ) ...@@ -142,7 +142,7 @@ int main( int argc, const char **argv )
{ {
dap_server_t *l_server = NULL; // DAP Server instance dap_server_t *l_server = NULL; // DAP Server instance
bool l_debug_mode = true; bool l_debug_mode = true;
bool bServerEnabled = true; bool bServerEnabled = false;
int rc = 0; int rc = 0;
dap_set_appname("cellframe-node"); dap_set_appname("cellframe-node");
...@@ -218,7 +218,11 @@ int main( int argc, const char **argv ) ...@@ -218,7 +218,11 @@ int main( int argc, const char **argv )
#endif #endif
} }
if ( dap_server_init(l_thread_cnt) != 0 ) { bServerEnabled = dap_config_get_item_bool_default( g_config, "server", "enabled", false );
log_it ( L_DEBUG,"config server->enabled = \"%u\" ", bServerEnabled );
if ( bServerEnabled && dap_server_init(l_thread_cnt) != 0 ) {
log_it( L_CRITICAL, "Can't init socket server module" ); log_it( L_CRITICAL, "Can't init socket server module" );
return -4; return -4;
} }
...@@ -372,10 +376,6 @@ int main( int argc, const char **argv ) ...@@ -372,10 +376,6 @@ int main( int argc, const char **argv )
save_process_pid_in_file(s_pid_file_path); save_process_pid_in_file(s_pid_file_path);
bServerEnabled = dap_config_get_item_bool_default( g_config, "server", "enabled", false );
log_it ( L_DEBUG,"config server->enabled = \"%u\" ", bServerEnabled );
if ( bServerEnabled ) { if ( bServerEnabled ) {
int32_t l_port = dap_config_get_item_int32(g_config, "server", "listen_port_tcp"); int32_t l_port = dap_config_get_item_int32(g_config, "server", "listen_port_tcp");
...@@ -473,10 +473,14 @@ int main( int argc, const char **argv ) ...@@ -473,10 +473,14 @@ int main( int argc, const char **argv )
dap_chain_plugins_init(g_config); dap_chain_plugins_init(g_config);
#endif #endif
// Endless loop for server's requests processing if (bServerEnabled) {
rc = dap_server_loop(l_server); // Endless loop for server's requests processing
// After loop exit actions rc = dap_server_loop(l_server);
log_it( rc ? L_CRITICAL : L_NOTICE, "Server loop stopped with return code %d", rc ); // After loop exit actions
log_it( rc ? L_CRITICAL : L_NOTICE, "Server loop stopped with return code %d", rc );
} else {
dap_events_wait(l_events);
}
// Deinit modules // Deinit modules
...@@ -490,7 +494,7 @@ int main( int argc, const char **argv ) ...@@ -490,7 +494,7 @@ int main( int argc, const char **argv )
dap_stream_ctl_deinit(); dap_stream_ctl_deinit();
dap_http_folder_deinit(); dap_http_folder_deinit();
dap_http_deinit(); dap_http_deinit();
dap_server_deinit(); if (bServerEnabled) dap_server_deinit();
dap_enc_ks_deinit(); dap_enc_ks_deinit();
dap_chain_node_mempool_deinit(); dap_chain_node_mempool_deinit();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment