/mandos/trunk

« back to all changes in this revision

Viewing changes to plugin-runner.c

• browse files at revision 1225
• compare with another revision
• download diff
• download tarball
• view history from revision 1225

• reverse the comparison (1225 to 884)
• stop comparing with revision 884

Show diffs side-by-side

added

removed

plugin-runner.c

2

2

/*

3

3

 * Mandos plugin runner - Run Mandos plugins

4

4

 *

5

 

 * Copyright © 2008-2016 Teddy Hogeborn

6

 

 * Copyright © 2008-2016 Björn Påhlsson

7

 

 * 

8

 

 * This program is free software: you can redistribute it and/or

9

 

 * modify it under the terms of the GNU General Public License as

10

 

 * published by the Free Software Foundation, either version 3 of the

11

 

 * License, or (at your option) any later version.

12

 

 * 

13

 

 * This program is distributed in the hope that it will be useful, but

 

5

 * Copyright © 2008-2020 Teddy Hogeborn

 

6

 * Copyright © 2008-2020 Björn Påhlsson

 

7

 * 

 

8

 * This file is part of Mandos.

 

9

 * 

 

10

 * Mandos is free software: you can redistribute it and/or modify it

 

11

 * under the terms of the GNU General Public License as published by

 

12

 * the Free Software Foundation, either version 3 of the License, or

 

13

 * (at your option) any later version.

 

14

 * 

 

15

 * Mandos is distributed in the hope that it will be useful, but

14

16

 * WITHOUT ANY WARRANTY; without even the implied warranty of

15

17

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

16

18

 * General Public License for more details.

17

19

 * 

18

20

 * You should have received a copy of the GNU General Public License

19

 

 * along with this program.  If not, see

20

 

 * <http://www.gnu.org/licenses/>.

 

21

 * along with Mandos.  If not, see <http://www.gnu.org/licenses/>.

21

22

 * 

22

23

 * Contact the authors at <mandos@recompile.se>.

23

24

 */

25

26

#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), getline(),

26

27

                                   O_CLOEXEC, pipe2() */

27

28

#include <stddef.h>             /* size_t, NULL */

28

 

#include <stdlib.h>             /* malloc(), exit(), EXIT_SUCCESS,

29

 

                                   realloc() */

 

29

#include <stdlib.h>             /* malloc(), reallocarray(), realloc(),

 

30

                                   EXIT_SUCCESS, exit() */

30

31

#include <stdbool.h>            /* bool, true, false */

31

32

#include <stdio.h>              /* fileno(), fprintf(),

32

33

                                   stderr, STDOUT_FILENO, fclose() */

178

179

  /* Resize the pointed-to array to hold one more pointer */

179

180

  char **new_array = NULL;

180

181

  do {

181

 

    new_array = realloc(*array, sizeof(char *)

182

 

                        * (size_t) ((*len) + 2));

 

182

#if defined(__GLIBC_PREREQ) and __GLIBC_PREREQ(2, 26)

 

183

    new_array = reallocarray(*array, (size_t)((*len) + 2),

 

184

                             sizeof(char *));

 

185

#else

 

186

    if(((size_t)((*len) + 2)) > (SIZE_MAX / sizeof(char *))){

 

187

      /* overflow */

 

188

      new_array = NULL;

 

189

      errno = ENOMEM;

 

190

    } else {

 

191

      new_array = realloc(*array, (size_t)((*len) + 2)

 

192

                          * sizeof(char *));

 

193

    }

 

194

#endif

183

195

  } while(new_array == NULL and errno == EINTR);

184

196

  /* Malloc check */

185

197

  if(new_array == NULL){

312

324

__attribute__((nonnull))

313

325

static void free_plugin(plugin *plugin_node){

314

326

  

315

 

  for(char **arg = plugin_node->argv; *arg != NULL; arg++){

 

327

  for(char **arg = (plugin_node->argv)+1; *arg != NULL; arg++){

316

328

    free(*arg);

317

329

  }

 

330

  free(plugin_node->name);

318

331

  free(plugin_node->argv);

319

332

  for(char **env = plugin_node->environ; *env != NULL; env++){

320

333

    free(*env);

563

576

    case '?':                   /* --help */

564

577

      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */

565

578

      argp_state_help(state, state->out_stream, ARGP_HELP_STD_HELP);

 

579

      __builtin_unreachable();

566

580

    case -3:                    /* --usage */

567

581

      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */

568

582

      argp_state_help(state, state->out_stream,

569

583

                      ARGP_HELP_USAGE | ARGP_HELP_EXIT_OK);

 

584

      __builtin_unreachable();

570

585

    case 'V':                   /* --version */

571

586

      fprintf(state->out_stream, "%s\n", argp_program_version);

572

587

      exit(EXIT_SUCCESS);

582

597

      if(arg[0] == '\0'){

583

598

        break;

584

599

      }

 

600

#if __GNUC__ >= 7

 

601

      __attribute__((fallthrough));

 

602

#else

 

603

          /* FALLTHROUGH */

 

604

#endif

585

605

    default:

586

606

      return ARGP_ERR_UNKNOWN;

587

607

    }

699

719

        

700

720

        custom_argc += 1;

701

721

        {

702

 

          char **new_argv = realloc(custom_argv, sizeof(char *)

703

 

                                    * ((size_t)custom_argc + 1));

 

722

#if defined(__GLIBC_PREREQ) and __GLIBC_PREREQ(2, 26)

 

723

          char **new_argv = reallocarray(custom_argv, (size_t)custom_argc + 1,

 

724

                                         sizeof(char *));

 

725

#else

 

726

          char **new_argv = NULL;

 

727

          if(((size_t)custom_argc + 1) > (SIZE_MAX / sizeof(char *))){

 

728

            /* overflow */

 

729

            errno = ENOMEM;

 

730

          } else {

 

731

            new_argv = realloc(custom_argv, ((size_t)custom_argc + 1)

 

732

                               * sizeof(char *));

 

733

          }

 

734

#endif

704

735

          if(new_argv == NULL){

705

 

            error(0, errno, "realloc");

 

736

            error(0, errno, "reallocarray");

706

737

            exitstatus = EX_OSERR;

707

738

            free(new_arg);

708

739

            free(org_line);

792

823

  }

793

824

  

794

825

  if(debug){

795

 

    for(plugin *p = plugin_list; p != NULL; p=p->next){

 

826

    for(plugin *p = plugin_list; p != NULL; p = p->next){

796

827

      fprintf(stderr, "Plugin: %s has %d arguments\n",

797

828

              p->name ? p->name : "Global", p->argc - 1);

798

829

      for(char **a = p->argv; *a != NULL; a++){

1091

1122

    

1092

1123

    new_plugin->pid = pid;

1093

1124

    new_plugin->fd = pipefd[0];

1094

 

    

 

1125

 

 

1126

    if(debug){

 

1127

      fprintf(stderr, "Plugin %s started (PID %" PRIdMAX ")\n",

 

1128

              new_plugin->name, (intmax_t) (new_plugin->pid));

 

1129

    }

 

1130

 

1095

1131

    /* Unblock SIGCHLD so signal handler can be run if this process

1096

1132

       has already completed */

1097

1133

    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,

• Older »

Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0