Rooba
/
odyssey
mirror of https://github.com/yandex/odyssey.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add logging for start, stop and client error

This commit is contained in:
Andrey Borodin 2019-06-17 11:35:21 +05:00
parent d784c2ad19
commit f8f8db1ac5
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
sources/frontend.c
View File

@ -704,6 +704,7 @@ od_frontend_cleanup(od_client_t *client, char *context,
od_instance_t *instance = client->global->instance; od_instance_t *instance = client->global->instance;
od_router_t *router = client->global->router; od_router_t *router = client->global->router;
od_route_t *route = client->route; od_route_t *route = client->route;
char peer[128];
int rc; int rc;
od_server_t *server = client->server; od_server_t *server = client->server;
@ -747,9 +748,11 @@ od_frontend_cleanup(od_client_t *client, char *context,
case OD_ECLIENT_WRITE: case OD_ECLIENT_WRITE:
/* close client connection and reuse server /* close client connection and reuse server
* link in case of client errors */ * link in case of client errors */
od_getpeername(client->io.io, peer, sizeof(peer), 1, 1);
od_log(&instance->logger, context, client, server, od_log(&instance->logger, context, client, server,
"client disconnected (read/write error): %s", "client disconnected (read/write error, addr %s): %s",
od_io_error(&client->io)); peer, od_io_error(&client->io));
if (! client->server) if (! client->server)
break; break;
rc = od_reset(server); rc = od_reset(server);

3
sources/instance.c
View File

@ -46,6 +46,7 @@ od_instance_free(od_instance_t *instance)
if (instance->config.pid_file) if (instance->config.pid_file)
od_pid_unlink(&instance->pid, instance->config.pid_file); od_pid_unlink(&instance->pid, instance->config.pid_file);
od_config_free(&instance->config); od_config_free(&instance->config);
od_log(&instance->logger, "shutdown", NULL, NULL, "Stopping Odyssey");
od_logger_close(&instance->logger); od_logger_close(&instance->logger);
machinarium_free(); machinarium_free();
} }
@ -71,6 +72,8 @@ od_instance_main(od_instance_t *instance, int argc, char **argv)
od_worker_pool_t worker_pool; od_worker_pool_t worker_pool;
od_global_t global; od_global_t global;
od_log(&instance->logger, "startup", NULL, NULL, "Starting Odyssey");
od_system_init(&system); od_system_init(&system);
od_router_init(&router); od_router_init(&router);
od_cron_init(&cron); od_cron_init(&cron);