p
/
xK
1
1
Fork 0
Code Issues 1 Pull Requests Releases 10 Wiki Activity

ZyklonB: factor out on_plugin_death()

This commit is contained in:
Přemysl Eric Janouch 2015-06-15 00:53:42 +02:00
parent 634841ea18
commit e34ecd6bb9
1 changed files with 46 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
zyklonb.c
View File

@ -1745,45 +1745,9 @@ parse_config (struct bot_context *ctx, struct error **e)
} }
static void static void
on_signal_pipe_readable (const struct pollfd *fd, struct bot_context *ctx) on_plugin_death (struct plugin *plugin, int status)
{ {
char dummy; struct bot_context *ctx = plugin->ctx;
(void) read (fd->fd, &dummy, 1);
if (g_termination_requested && !ctx->quitting)
{
// There may be a timer set to reconnect to the server
irc_cancel_timers (ctx);
if (ctx->irc_fd != -1)
irc_send (ctx, "QUIT :Terminated by signal");
initiate_quit (ctx);
}
// Reap all dead children (since the pipe may overflow, we ask waitpid()
// to return all the zombies it knows about).
while (true)
{
int status;
pid_t zombie = waitpid (-1, &status, WNOHANG);
if (zombie == -1)
{
// No children to wait on
if (errno == ECHILD)
break;
hard_assert (errno == EINTR);
continue;
}
if (zombie == 0)
break;
struct plugin *plugin = plugin_find_by_pid (ctx, zombie);
// Something has died but we don't recognize it (re-exec?)
if (!soft_assert (plugin != NULL))
continue;
// TODO: callbacks on children death, so that we may tell the user // TODO: callbacks on children death, so that we may tell the user
// "plugin `name' died like a dirty jewish pig"; use `status' // "plugin `name' died like a dirty jewish pig"; use `status'
@ -1822,6 +1786,48 @@ on_signal_pipe_readable (const struct pollfd *fd, struct bot_context *ctx)
// Living child processes block us from quitting // Living child processes block us from quitting
try_finish_quit (ctx); try_finish_quit (ctx);
} }
static void
on_signal_pipe_readable (const struct pollfd *fd, struct bot_context *ctx)
{
char dummy;
(void) read (fd->fd, &dummy, 1);
if (g_termination_requested && !ctx->quitting)
{
// There may be a timer set to reconnect to the server
irc_cancel_timers (ctx);
if (ctx->irc_fd != -1)
irc_send (ctx, "QUIT :Terminated by signal");
initiate_quit (ctx);
}
// Reap all dead children (since the pipe may overflow, we ask waitpid()
// to return all the zombies it knows about).
while (true)
{
int status;
pid_t zombie = waitpid (-1, &status, WNOHANG);
if (zombie == -1)
{
// No children to wait on
if (errno == ECHILD)
break;
hard_assert (errno == EINTR);
continue;
}
if (zombie == 0)
break;
struct plugin *plugin = plugin_find_by_pid (ctx, zombie);
// XXX: re-exec if something has died that we don't recognize?
if (soft_assert (plugin != NULL))
on_plugin_death (plugin, status);
}
} }
int int