GNUnet  0.20.0
helper.c File Reference

API for dealing with (SUID) helper processes that communicate via GNUNET_MessageHeaders on stdin/stdout. More...

#include "gnunet_common.h"
#include "platform.h"
#include "gnunet_util_lib.h"
Include dependency graph for helper.c:

Go to the source code of this file.

Data Structures

struct  GNUNET_HELPER_SendHandle
 Entry in the queue of messages we need to transmit to the helper. More...
 
struct  GNUNET_HELPER_Handle
 The handle to a helper process. More...
 

Functions

enum GNUNET_GenericReturnValue GNUNET_HELPER_kill (struct GNUNET_HELPER_Handle *h, int soft_kill)
 Sends termination signal to the helper process. More...
 
enum GNUNET_GenericReturnValue GNUNET_HELPER_wait (struct GNUNET_HELPER_Handle *h)
 Reap the helper process. More...
 
static void stop_helper (struct GNUNET_HELPER_Handle *h, int soft_kill)
 Stop the helper process, we're closing down or had an error. More...
 
static void restart_task (void *cls)
 Restart the helper process. More...
 
static void helper_read (void *cls)
 Read from the helper-process. More...
 
static void start_helper (struct GNUNET_HELPER_Handle *h)
 Start the helper process. More...
 
struct GNUNET_HELPER_HandleGNUNET_HELPER_start (int with_control_pipe, const char *binary_name, char *const binary_argv[], GNUNET_MessageTokenizerCallback cb, GNUNET_HELPER_ExceptionCallback exp_cb, void *cb_cls)
 Starts a helper and begins reading from it. More...
 
void GNUNET_HELPER_destroy (struct GNUNET_HELPER_Handle *h)
 Free's the resources occupied by the helper handle. More...
 
void GNUNET_HELPER_stop (struct GNUNET_HELPER_Handle *h, int soft_kill)
 Kills the helper, closes the pipe and frees the handle. More...
 
static void helper_write (void *cls)
 Write to the helper-process. More...
 
struct GNUNET_HELPER_SendHandleGNUNET_HELPER_send (struct GNUNET_HELPER_Handle *h, const struct GNUNET_MessageHeader *msg, int can_drop, GNUNET_HELPER_Continuation cont, void *cont_cls)
 Send an message to the helper. More...
 
void GNUNET_HELPER_send_cancel (struct GNUNET_HELPER_SendHandle *sh)
 Cancel a GNUNET_HELPER_send operation. More...
 

Detailed Description

API for dealing with (SUID) helper processes that communicate via GNUNET_MessageHeaders on stdin/stdout.

Author
Philipp Toelke
Christian Grothoff

Definition in file helper.c.

Function Documentation

◆ stop_helper()

static void stop_helper ( struct GNUNET_HELPER_Handle h,
int  soft_kill 
)
static

Stop the helper process, we're closing down or had an error.

Parameters
hhandle to the helper process
soft_killif GNUNET_YES, signals termination by closing the helper's stdin; GNUNET_NO to signal termination by sending SIGTERM to helper

Definition at line 264 of file helper.c.

265 {
266  if (NULL != h->restart_task)
267  {
268  GNUNET_SCHEDULER_cancel (h->restart_task);
269  h->restart_task = NULL;
270  }
271  else
272  {
273  GNUNET_break (GNUNET_OK == GNUNET_HELPER_kill (h, soft_kill));
275  }
276 }
static struct GNUNET_ARM_Handle * h
Connection with ARM.
Definition: gnunet-arm.c:99
enum GNUNET_GenericReturnValue GNUNET_HELPER_wait(struct GNUNET_HELPER_Handle *h)
Reap the helper process.
Definition: helper.c:208
enum GNUNET_GenericReturnValue GNUNET_HELPER_kill(struct GNUNET_HELPER_Handle *h, int soft_kill)
Sends termination signal to the helper process.
Definition: helper.c:168
@ GNUNET_OK
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
Definition: scheduler.c:975

References GNUNET_break, GNUNET_HELPER_kill(), GNUNET_HELPER_wait(), GNUNET_OK, GNUNET_SCHEDULER_cancel(), and h.

Referenced by GNUNET_HELPER_stop(), helper_read(), helper_write(), and start_helper().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ restart_task()

static void restart_task ( void *  cls)
static

Restart the helper process.

Parameters
clshandle to the helper process

Definition at line 448 of file helper.c.

449 {
450  struct GNUNET_HELPER_Handle *h = cls;
451 
452  h->restart_task = NULL;
453  h->retry_back_off++;
455  "Restarting helper with back-off %u\n",
456  h->retry_back_off);
457  start_helper (h);
458 }
#define GNUNET_log(kind,...)
@ GNUNET_ERROR_TYPE_INFO
static void start_helper(struct GNUNET_HELPER_Handle *h)
Start the helper process.
Definition: helper.c:384
The handle to a helper process.
Definition: helper.c:79

References GNUNET_ERROR_TYPE_INFO, GNUNET_log, h, and start_helper().

Referenced by helper_read(), helper_write(), and start_helper().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ helper_read()

static void helper_read ( void *  cls)
static

Read from the helper-process.

Parameters
clshandle to the helper process

Definition at line 294 of file helper.c.

295 {
296  struct GNUNET_HELPER_Handle *h = cls;
298  ssize_t t;
299 
300  h->read_task = NULL;
301  t = GNUNET_DISK_file_read (h->fh_from_helper, &buf, sizeof(buf));
302  if (t < 0)
303  {
304  /* On read-error, restart the helper */
306  _ ("Error reading from `%s': %s\n"),
307  h->binary_name,
308  strerror (errno));
309  if (NULL != h->exp_cb)
310  {
311  h->exp_cb (h->cb_cls);
313  return;
314  }
316  /* Restart the helper */
317  h->restart_task = GNUNET_SCHEDULER_add_delayed (
319  h->retry_back_off),
320  &restart_task,
321  h);
322  return;
323  }
324  if (0 == t)
325  {
326  /* this happens if the helper is shut down via a
327  signal, so it is not a "hard" error */
329  "Got 0 bytes from helper `%s' (EOF)\n",
330  h->binary_name);
331  if (NULL != h->exp_cb)
332  {
333  h->exp_cb (h->cb_cls);
335  return;
336  }
338  /* Restart the helper */
339  h->restart_task = GNUNET_SCHEDULER_add_delayed (
341  h->retry_back_off),
342  &restart_task,
343  h);
344  return;
345  }
347  "Got %u bytes from helper `%s'\n",
348  (unsigned int) t,
349  h->binary_name);
351  h->fh_from_helper,
352  &helper_read,
353  h);
354  if (GNUNET_SYSERR ==
356  {
358  _ ("Failed to parse inbound message from helper `%s'\n"),
359  h->binary_name);
360  if (NULL != h->exp_cb)
361  {
362  h->exp_cb (h->cb_cls);
364  return;
365  }
367  /* Restart the helper */
368  h->restart_task = GNUNET_SCHEDULER_add_delayed (
370  h->retry_back_off),
371  &restart_task,
372  h);
373  return;
374  }
375 }
static char buf[2048]
static struct GNUNET_SCHEDULER_Task * t
Main task.
#define GNUNET_MAX_MESSAGE_SIZE
Largest supported message (to be precise, one byte more than the largest possible message,...
ssize_t GNUNET_DISK_file_read(const struct GNUNET_DISK_FileHandle *h, void *result, size_t len)
Read the contents of a binary file into a buffer.
Definition: disk.c:622
void GNUNET_HELPER_stop(struct GNUNET_HELPER_Handle *h, int soft_kill)
Kills the helper, closes the pipe and frees the handle.
Definition: helper.c:538
#define GNUNET_ALIGN
gcc-ism to force alignment; we use this to align char-arrays that may then be cast to 'struct's.
@ GNUNET_NO
@ GNUNET_SYSERR
@ GNUNET_ERROR_TYPE_WARNING
@ GNUNET_ERROR_TYPE_DEBUG
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_read_file(struct GNUNET_TIME_Relative delay, const struct GNUNET_DISK_FileHandle *rfd, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay or when the specified file descriptor is ready f...
Definition: scheduler.c:1656
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_delayed(struct GNUNET_TIME_Relative delay, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay.
Definition: scheduler.c:1272
enum GNUNET_GenericReturnValue GNUNET_MST_from_buffer(struct GNUNET_MessageStreamTokenizer *mst, const char *buf, size_t size, int purge, int one_shot)
Add incoming data to the receive buffer and call the callback for all complete messages.
Definition: mst.c:101
#define GNUNET_TIME_UNIT_FOREVER_REL
Constant used to specify "forever".
#define GNUNET_TIME_UNIT_SECONDS
One second.
struct GNUNET_TIME_Relative GNUNET_TIME_relative_multiply(struct GNUNET_TIME_Relative rel, unsigned long long factor)
Multiply relative time by a given factor.
Definition: time.c:484
static void restart_task(void *cls)
Restart the helper process.
Definition: helper.c:448
static void helper_read(void *cls)
Read from the helper-process.
Definition: helper.c:294
static void stop_helper(struct GNUNET_HELPER_Handle *h, int soft_kill)
Stop the helper process, we're closing down or had an error.
Definition: helper.c:264
#define _(String)
GNU gettext support macro.
Definition: platform.h:178

References _, buf, GNUNET_ALIGN, GNUNET_DISK_file_read(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_HELPER_stop(), GNUNET_log, GNUNET_MAX_MESSAGE_SIZE, GNUNET_MST_from_buffer(), GNUNET_NO, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_add_read_file(), GNUNET_SYSERR, GNUNET_TIME_relative_multiply(), GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_TIME_UNIT_SECONDS, h, restart_task(), stop_helper(), and t.

Referenced by start_helper().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ start_helper()

static void start_helper ( struct GNUNET_HELPER_Handle h)
static

Start the helper process.

Parameters
hhandle to the helper process

Definition at line 384 of file helper.c.

385 {
386  h->helper_in =
388  h->helper_out =
390  if ((h->helper_in == NULL) || (h->helper_out == NULL))
391  {
392  /* out of file descriptors? try again later... */
394  "out of file descriptors? try again later\n");
396  h->restart_task = GNUNET_SCHEDULER_add_delayed (
398  h->retry_back_off),
399  &restart_task,
400  h);
401  return;
402  }
404  "Starting HELPER process `%s'\n",
405  h->binary_name);
406  h->fh_from_helper =
408  h->fh_to_helper =
410  h->helper_proc = GNUNET_OS_start_process_vap (h->with_control_pipe
414  h->helper_in,
415  h->helper_out,
416  NULL,
417  h->binary_name,
418  h->binary_argv);
419  if (NULL == h->helper_proc)
420  {
421  /* failed to start process? try again later... */
423  "failed to start process? try again later\n");
425  h->restart_task = GNUNET_SCHEDULER_add_delayed (
427  h->retry_back_off),
428  &restart_task,
429  h);
430  return;
431  }
434  if (NULL != h->mst)
436  h->fh_from_helper,
437  &helper_read,
438  h);
439 }
const struct GNUNET_DISK_FileHandle * GNUNET_DISK_pipe_handle(const struct GNUNET_DISK_PipeHandle *p, enum GNUNET_DISK_PipeEnd n)
Get the handle to a particular pipe end.
Definition: disk.c:1617
enum GNUNET_GenericReturnValue GNUNET_DISK_pipe_close_end(struct GNUNET_DISK_PipeHandle *p, enum GNUNET_DISK_PipeEnd end)
Closes one half of an interprocess channel.
Definition: disk.c:1534
struct GNUNET_DISK_PipeHandle * GNUNET_DISK_pipe(enum GNUNET_DISK_PipeFlags pf)
Creates an interprocess channel.
Definition: disk.c:1444
@ GNUNET_DISK_PF_BLOCKING_RW
Configure both pipe ends for blocking operations if set.
@ GNUNET_DISK_PIPE_END_WRITE
The writing-end of a pipe.
@ GNUNET_DISK_PIPE_END_READ
The reading-end of a pipe.
struct GNUNET_OS_Process * GNUNET_OS_start_process_vap(enum GNUNET_OS_InheritStdioFlags std_inheritance, struct GNUNET_DISK_PipeHandle *pipe_stdin, struct GNUNET_DISK_PipeHandle *pipe_stdout, struct GNUNET_DISK_PipeHandle *pipe_stderr, const char *filename, char *const argv[])
Start a process.
Definition: os_priority.c:567
@ GNUNET_OS_INHERIT_STD_ERR
When this flag is set, the child process will inherit stderr of the parent.
Definition: gnunet_os_lib.h:95
@ GNUNET_OS_USE_PIPE_CONTROL
Should a pipe be used to send signals to the child?

References GNUNET_DISK_PF_BLOCKING_RW, GNUNET_DISK_pipe(), GNUNET_DISK_pipe_close_end(), GNUNET_DISK_PIPE_END_READ, GNUNET_DISK_PIPE_END_WRITE, GNUNET_DISK_pipe_handle(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_NO, GNUNET_OS_INHERIT_STD_ERR, GNUNET_OS_start_process_vap(), GNUNET_OS_USE_PIPE_CONTROL, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_add_read_file(), GNUNET_TIME_relative_multiply(), GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_TIME_UNIT_SECONDS, h, helper_read(), restart_task(), and stop_helper().

Referenced by GNUNET_HELPER_start(), and restart_task().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ helper_write()

static void helper_write ( void *  cls)
static

Write to the helper-process.

Parameters
clshandle to the helper process

Definition at line 552 of file helper.c.

553 {
554  struct GNUNET_HELPER_Handle *h = cls;
556  const char *buf;
557  ssize_t t;
558 
559  h->write_task = NULL;
560  if (NULL == (sh = h->sh_head))
561  {
562  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Helper write had no work!\n");
563  return; /* how did this happen? */
564  }
565  buf = (const char *) sh->msg;
566  t = GNUNET_DISK_file_write (h->fh_to_helper,
567  &buf[sh->wpos],
568  ntohs (sh->msg->size) - sh->wpos);
569  if (-1 == t)
570  {
571  /* On write-error, restart the helper */
573  _ ("Error writing to `%s': %s\n"),
574  h->binary_name,
575  strerror (errno));
576  if (NULL != h->exp_cb)
577  {
578  h->exp_cb (h->cb_cls);
580  return;
581  }
583  "Stopping and restarting helper task!\n");
585  /* Restart the helper */
586  h->restart_task = GNUNET_SCHEDULER_add_delayed (
588  h->retry_back_off),
589  &restart_task,
590  h);
591  return;
592  }
594  "Transmitted %u bytes to %s\n",
595  (unsigned int) t,
596  h->binary_name);
597  sh->wpos += t;
598  if (sh->wpos == ntohs (sh->msg->size))
599  {
600  GNUNET_CONTAINER_DLL_remove (h->sh_head, h->sh_tail, sh);
601  if (NULL != sh->cont)
602  sh->cont (sh->cont_cls, GNUNET_YES);
603  GNUNET_free (sh);
604  }
605  if (NULL != h->sh_head)
606  h->write_task =
608  h->fh_to_helper,
609  &helper_write,
610  h);
611 }
static struct SolverHandle * sh
ssize_t GNUNET_DISK_file_write(const struct GNUNET_DISK_FileHandle *h, const void *buffer, size_t n)
Write a buffer to a file.
Definition: disk.c:686
#define GNUNET_CONTAINER_DLL_remove(head, tail, element)
Remove an element from a DLL.
@ GNUNET_YES
#define GNUNET_free(ptr)
Wrapper around free.
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_write_file(struct GNUNET_TIME_Relative delay, const struct GNUNET_DISK_FileHandle *wfd, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay or when the specified file descriptor is ready f...
Definition: scheduler.c:1689
static void helper_write(void *cls)
Write to the helper-process.
Definition: helper.c:552
Entry in the queue of messages we need to transmit to the helper.
Definition: helper.c:37

References _, buf, GNUNET_CONTAINER_DLL_remove, GNUNET_DISK_file_write(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_HELPER_stop(), GNUNET_log, GNUNET_NO, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_add_write_file(), GNUNET_TIME_relative_multiply(), GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_TIME_UNIT_SECONDS, GNUNET_YES, h, restart_task(), sh, stop_helper(), and t.

Referenced by GNUNET_HELPER_send().

Here is the call graph for this function:
Here is the caller graph for this function: