processes.h File Reference

processes.c header. More...

#include "../misc/ipc.h"
#include <sys/types.h>

Include dependency graph for processes.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros
#define	FORKFAILED   -1
#define	NOINIT   -2
#define	PROCSFULL   -3
#define	NOCHILD   -4

Typedefs
typedef void(*	process_func_t) (void *)

Functions
void	procs_terminate_childs (void)
	This function terminates all processes spawned with create_process. Calls terminate_child for each process active. In case init_procs was not called this function does nothing. More...
int	terminate_process (pid_t pid)
	Terminates a given process. If termination does not work, the process will get killed. Terminate process can be called with the (-1 * pid) to send the signal to the process group. More...
pid_t	create_ipc_process (ipc_process_func func, void *args)
	initializes a communication channels and calls a function with a new process More...
const struct ipc_contexts *	procs_get_ipc_contexts (void)
	returns ipc_contexts. More...
int	procs_cleanup_children (void)
	iterates through ipcc and verify if a child is stopped or killed to free the file handler. More...

Detailed Description

processes.c header.

Definition in file processes.h.

Macro Definition Documentation

FORKFAILED

#define FORKFAILED   -1

Definition at line 20 of file processes.h.

NOCHILD

#define NOCHILD   -4

Definition at line 23 of file processes.h.

NOINIT

#define NOINIT   -2

Definition at line 21 of file processes.h.

PROCSFULL

#define PROCSFULL   -3

Definition at line 22 of file processes.h.

Typedef Documentation

process_func_t

typedef void(* process_func_t) (void *)

Definition at line 25 of file processes.h.

Function Documentation

create_ipc_process()

pid_t create_ipc_process	(	ipc_process_func	func,
		void *	args
	)

initializes a communication channels and calls a function with a new process

Parameters

func	Function to call
args	arguments

Returns

pid of spawned process on success or one of the following errors: FORKFAILED

Definition at line 195 of file processes.c.

{
  struct ipc_context *pctx = NULL;
  struct ipc_exec_context ec = {0};
  pid_t child_pid;
  // previously init call, we want to store the contexts without making
  // assumptions about signal handlung
  if (ipcc == NULL)
    ipcc = ipc_contexts_init (10);
 
  ec.pre_func = (ipc_process_func) &pre_fn_call;
  ec.post_func = (ipc_process_func) &post_fn_call;
  ec.func = (ipc_process_func) func;
  ec.func_arg = args;
  // check for exited processes and clean file descriptor
  // we do it twice, before forking and when forking fails with EMFILE or EAGAIN
retry:
  g_debug ("%s: closed %d fd.", __func__, procs_cleanup_children ());
  if ((pctx = ipc_exec_as_process (IPC_PIPE, ec)) == NULL)
    {
      if (errno == EMFILE || errno == EAGAIN)
        {
          g_debug (
            "%s: could not fork: %s (%d) retrying after trying to close fd.",
            __func__, strerror (errno), errno);
          goto retry;
        }
      g_warning ("%s: could not fork: %s (%d)", __func__, strerror (errno),
                 errno);
      return FORKFAILED;
    }
  reuse_or_add_context (pctx);
  child_pid = pctx->pid;
  // ipcc works uses copies of pctx therefore we free it
  free (pctx);
  return child_pid;
}

References FORKFAILED, free(), ipc_exec_context::func, ipc_exec_context::func_arg, ipc_contexts_init(), ipc_exec_as_process(), IPC_PIPE, ipcc, ipc_context::pid, post_fn_call(), ipc_exec_context::post_func, pre_fn_call(), ipc_exec_context::pre_func, procs_cleanup_children(), and reuse_or_add_context().

Referenced by attack_network(), and nasl_plugin_launch().

Here is the call graph for this function:

Here is the caller graph for this function:

procs_cleanup_children()

int procs_cleanup_children

(

void

)

iterates through ipcc and verify if a child is stopped or killed to free the file handler.

Returns

the amount of freed file handler or -1 on ipcc not initialized

Definition at line 47 of file processes.c.

{
  int freed = 0, i, status;
  pid_t pid;
  if (ipcc == NULL)
    return -1;
  g_debug ("%s: checking %d ipc.", __func__, ipcc->len);
  for (i = 0; i < ipcc->len; i++)
    {
      if (ipcc->ctxs[i].closed)
        {
          continue;
        }
      pid = waitpid (ipcc->ctxs[i].pid, &status, WNOHANG);
      if ((pid < 0)
          || ((pid == ipcc->ctxs[i].pid)
              && (WIFEXITED (status) || WIFSTOPPED (status)
                  || WIFSIGNALED (status))))
        {
          freed++;
          ipc_close (&ipcc->ctxs[i]);
        }
    }
  return freed;
}

References ipc_context::closed, ipc_contexts::ctxs, ipc_close(), ipcc, ipc_contexts::len, ipc_context::pid, and pid.

Referenced by create_ipc_process(), and pluginlaunch_wait_for_free_process().

Here is the call graph for this function:

Here is the caller graph for this function:

procs_get_ipc_contexts()

const struct ipc_contexts* procs_get_ipc_contexts

(

void

)

returns ipc_contexts.

Returns

the globally hold array of all ipc_context; do not manipulate them.

Definition at line 239 of file processes.c.

{
  return ipcc;
}

References ipcc.

Referenced by launch_plugin().

Here is the caller graph for this function:

procs_terminate_childs()

void procs_terminate_childs

(

void

)

This function terminates all processes spawned with create_process. Calls terminate_child for each process active. In case init_procs was not called this function does nothing.

Definition at line 113 of file processes.c.

{
  if (ipcc == NULL)
    return;
 
  for (int i = 0; i < ipcc->len; i++)
    {
      if (!ipcc->ctxs[i].closed)
        terminate_process (ipcc->ctxs[i].pid);
    }
}

References ipc_context::closed, ipc_contexts::ctxs, ipcc, ipc_contexts::len, ipc_context::pid, and terminate_process().

Referenced by handle_termination_signal().

Here is the call graph for this function:

Here is the caller graph for this function:

terminate_process()

int terminate_process

(

pid_t

pid

)

Terminates a given process. If termination does not work, the process will get killed. Terminate process can be called with the (-1 * pid) to send the signal to the process group.

Parameters

pid	id of the child process

Returns

int 0 on success, NOCHILD if child does not exist, NOINIT if not initialized

Definition at line 96 of file processes.c.

{
  kill (pid, SIGTERM);
  usleep (10000);
  if (waitpid (pid, NULL, WNOHANG))
    kill (pid, SIGKILL);
 
  return 0;
}

References pid.

Referenced by pluginlaunch_stop(), procs_terminate_childs(), and update_running_processes().

Here is the caller graph for this function: