/mandos/trunk : revision 24.1.51

21

* Contact the authors at <mandos@fukt.bsnet.se>.

22

*/

23

24

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

25

asprintf() */

24

#define _GNU_SOURCE /* TEMP_FAILURE_RETRY() */

25

26

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

27

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

28

EXIT_SUCCESS, realloc() */

51

close() */

52

#include <fcntl.h> /* fcntl(), F_GETFD, F_SETFD,

53

FD_CLOEXEC */

54

#include <string.h> /* strsep, strlen(), asprintf() */

54

#include <string.h> /* strsep, strlen(), strcpy(),

55

strcat() */

55

56

#include <errno.h> /* errno */

56

57

#include <argp.h> /* struct argp_option, struct

57

58

argp_state, struct argp,

58

59

argp_parse(), ARGP_ERR_UNKNOWN,

59

ARGP_KEY_END, ARGP_KEY_ARG,

60

error_t */

60

ARGP_KEY_END, ARGP_KEY_ARG, error_t */

61

#include <signal.h> /* struct sigaction, sigemptyset(),

62

sigaddset(), sigaction(),

63

sigprocmask(), SIG_BLOCK, SIGCHLD,

65

#include <errno.h> /* errno, EBADF */

66

67

#define BUFFER_SIZE 256

68

69

#define PDIR "/lib/mandos/plugins.d"

70

#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"

71

72

const char *argp_program_version = "plugin-runner 1.0";

68

#define CONFFILE "/conf/conf.d/mandos/client.conf"

69

70

const char *argp_program_version = "mandos-client 1.0";

73

71

const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";

74

72

75

73

struct process;

81

79

size_t buffer_size;

82

80

size_t buffer_length;

83

81

bool eof;

84

volatile bool completed;

85

volatile int status;

82

bool completed;

83

int status;

86

84

struct process *next;

87

85

} process;

88

86

90

88

char *name; /* can be NULL or any plugin name */

91

89

char **argv;

92

90

int argc;

93

char **environ;

94

int envc;

95

91

bool disabled;

96

92

struct plugin *next;

97

93

} plugin;

106

102

/* Create a new plugin */

107

103

plugin *new_plugin = malloc(sizeof(plugin));

108

104

if (new_plugin == NULL){

109

return NULL;

110

}

111

char *copy_name = NULL;

112

if(name != NULL){

113

copy_name = strdup(name);

114

if(copy_name == NULL){

115

return NULL;

116

}

117

}

118

119

*new_plugin = (plugin) { .name = copy_name,

120

.argc = 1,

121

.envc = 0,

122

.disabled = false,

123

.next = *plugin_list };

124

105

perror("malloc");

106

exit(EXIT_FAILURE);

107

}

108

new_plugin->name = name;

125

109

new_plugin->argv = malloc(sizeof(char *) * 2);

126

110

if (new_plugin->argv == NULL){

127

free(copy_name);

128

free(new_plugin);

129

return NULL;

111

perror("malloc");

112

exit(EXIT_FAILURE);

130

113

}

131

new_plugin->argv[0] = copy_name;

114

new_plugin->argv[0] = name;

132

115

new_plugin->argv[1] = NULL;

133

134

new_plugin->environ = malloc(sizeof(char *));

135

if(new_plugin->environ == NULL){

136

free(copy_name);

137

free(new_plugin->argv);

138

free(new_plugin);

139

return NULL;

140

}

141

new_plugin->environ[0] = NULL;

116

new_plugin->argc = 1;

117

new_plugin->disabled = false;

118

new_plugin->next = *plugin_list;

142

119

/* Append the new plugin to the list */

143

120

*plugin_list = new_plugin;

144

121

return new_plugin;

145

122

}

146

123

147

/* Helper function for add_argument and add_environment */

148

static bool add_to_char_array(const char *new, char ***array,

149

int *len){

150

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

151

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

152

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

153

/* Malloc check */

154

if(*array == NULL){

155

return false;

156

}

157

/* Make a copy of the new string */

158

char *copy = strdup(new);

159

if(copy == NULL){

160

return false;

161

}

162

/* Insert the copy */

163

(*array)[*len] = copy;

164

(*len)++;

165

/* Add a new terminating NULL pointer to the last element */

166

(*array)[*len] = NULL;

167

return true;

168

}

169

170

/* Add to a plugin's argument vector */

171

static bool add_argument(plugin *p, const char *arg){

172

if(p == NULL){

173

return false;

174

}

175

return add_to_char_array(arg, &(p->argv), &(p->argc));

176

}

177

178

/* Add to a plugin's environment */

179

static bool add_environment(plugin *p, const char *def){

180

if(p == NULL){

181

return false;

182

}

183

return add_to_char_array(def, &(p->environ), &(p->envc));

184

}

185

124

static void addargument(plugin *p, char *arg){

125

p->argv[p->argc] = arg;

126

p->argv = realloc(p->argv, sizeof(char *) * (size_t)(p->argc + 2));

127

if (p->argv == NULL){

128

perror("malloc");

129

exit(EXIT_FAILURE);

130

}

131

p->argc++;

132

p->argv[p->argc] = NULL;

133

}

186

134

187

135

/*

188

136

* Based on the example in the GNU LibC manual chapter 13.13 "File

202

150

203

151

process *process_list = NULL;

204

152

205

/* Mark processes as completed when they exit, and save their exit

153

/* Mark a process as completed when it exits, and save its exit

206

154

status. */

207

155

void handle_sigchld(__attribute__((unused)) int sig){

208

while(true){

209

process *proc = process_list;

210

int status;

211

pid_t pid = waitpid(-1, &status, WNOHANG);

212

if(pid == 0){

213

/* Only still running child processes */

214

break;

215

}

216

if(pid == -1){

217

if (errno != ECHILD){

218

perror("waitpid");

219

}

220

/* No child processes */

221

break;

222

}

223

224

/* A child exited, find it in process_list */

225

while(proc != NULL and proc->pid != pid){

226

proc = proc->next;

227

}

228

if(proc == NULL){

229

/* Process not found in process list */

230

continue;

231

}

232

proc->status = status;

233

proc->completed = true;

234

}

156

process *proc = process_list;

157

int status;

158

pid_t pid = wait(&status);

159

if(pid == -1){

160

perror("wait");

161

return;

162

}

163

while(proc != NULL and proc->pid != pid){

164

proc = proc->next;

165

}

166

if(proc == NULL){

167

/* Process not found in process list */

168

return;

169

}

170

proc->status = status;

171

proc->completed = true;

235

172

}

236

173

237

174

bool print_out_password(const char *buffer, size_t length){

249

186

return true;

250

187

}

251

188

252

static void free_plugin_list(plugin *plugin_list){

253

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

254

next = plugin_list->next;

255

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

256

free(*arg);

257

}

258

free(plugin_list->argv);

259

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

260

free(*env);

261

}

262

free(plugin_list->environ);

263

free(plugin_list);

264

}

189

char ** addcustomargument(char **argv, int *argc, char *arg){

190

191

if (argv == NULL){

192

*argc = 1;

193

argv = malloc(sizeof(char*) * 2);

194

if(argv == NULL){

195

return NULL;

196

}

197

argv[0] = NULL; /* Will be set to argv[0] in main before parsing */

198

argv[1] = NULL;

199

}

200

*argc += 1;

201

argv = realloc(argv, sizeof(char *)

202

* ((unsigned int) *argc + 1));

203

if(argv == NULL){

204

return NULL;

205

}

206

argv[*argc-1] = arg;

207

argv[*argc] = NULL;

208

return argv;

265

209

}

266

210

267

211

int main(int argc, char *argv[]){

268

char *plugindir = NULL;

269

char *argfile = NULL;

212

const char *plugindir = "/conf/conf.d/mandos/plugins.d";

213

const char *conffile = CONFFILE;

270

214

FILE *conffp;

271

215

size_t d_name_len;

272

216

DIR *dir = NULL;

287

231

/* Establish a signal handler */

288

232

sigemptyset(&sigchld_action.sa_mask);

289

233

ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);

290

if(ret == -1){

234

if(ret < 0){

291

235

perror("sigaddset");

292

exitstatus = EXIT_FAILURE;

293

goto fallback;

236

exit(EXIT_FAILURE);

294

237

}

295

238

ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);

296

if(ret == -1){

239

if(ret < 0){

297

240

perror("sigaction");

298

exitstatus = EXIT_FAILURE;

299

goto fallback;

241

exit(EXIT_FAILURE);

300

242

}

301

243

302

244

/* The options we understand. */

304

246

{ .name = "global-options", .key = 'g',

305

247

.arg = "OPTION[,OPTION[,...]]",

306

248

.doc = "Options passed to all plugins" },

307

{ .name = "global-envs", .key = 'e',

308

.arg = "VAR=value",

309

.doc = "Environment variable passed to all plugins" },

310

249

{ .name = "options-for", .key = 'o',

311

250

.arg = "PLUGIN:OPTION[,OPTION[,...]]",

312

251

.doc = "Options passed only to specified plugin" },

313

{ .name = "envs-for", .key = 'f',

314

.arg = "PLUGIN:ENV=value",

315

.doc = "Environment variable passed to specified plugin" },

316

252

{ .name = "disable", .key = 'd',

317

253

.arg = "PLUGIN",

318

254

.doc = "Disable a specific plugin", .group = 1 },

319

255

{ .name = "plugin-dir", .key = 128,

320

256

.arg = "DIRECTORY",

321

257

.doc = "Specify a different plugin directory", .group = 2 },

322

{ .name = "config-file", .key = 129,

323

.arg = "FILE",

324

.doc = "Specify a different configuration file", .group = 2 },

325

{ .name = "userid", .key = 130,

326

.arg = "ID", .flags = 0,

327

.doc = "User ID the plugins will run as", .group = 3 },

328

{ .name = "groupid", .key = 131,

329

.arg = "ID", .flags = 0,

330

.doc = "Group ID the plugins will run as", .group = 3 },

331

{ .name = "debug", .key = 132,

332

.doc = "Debug mode", .group = 4 },

258

{ .name = "userid", .key = 129,

259

.arg = "ID", .flags = 0,

260

.doc = "User ID the plugins will run as", .group = 2 },

261

{ .name = "groupid", .key = 130,

262

.arg = "ID", .flags = 0,

263

.doc = "Group ID the plugins will run as", .group = 2 },

264

{ .name = "debug", .key = 131,

265

.doc = "Debug mode", .group = 3 },

333

266

{ .name = NULL }

334

267

};

335

268

345

278

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

346

279

continue;

347

280

}

348

if(not add_argument(getplugin(NULL, plugins), p)){

349

perror("add_argument");

350

return ARGP_ERR_UNKNOWN;

351

}

352

}

353

}

354

break;

355

case 'e':

356

if(arg == NULL){

357

break;

358

}

359

{

360

char *envdef = strdup(arg);

361

if(envdef == NULL){

362

break;

363

}

364

if(not add_environment(getplugin(NULL, plugins), envdef)){

365

perror("add_environment");

281

addargument(getplugin(NULL, plugins), p);

366

282

}

367

283

}

368

284

break;

369

285

case 'o':

370

286

if (arg != NULL){

371

char *p_name = strsep(&arg, ":");

372

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

287

char *name = strsep(&arg, ":");

288

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

373

289

break;

374

290

}

375

291

char *opt = strsep(&arg, ":");

382

298

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

383

299

continue;

384

300

}

385

if(not add_argument(getplugin(p_name, plugins), p)){

386

perror("add_argument");

387

return ARGP_ERR_UNKNOWN;

388

}

301

addargument(getplugin(name, plugins), p);

389

302

}

390

303

}

391

304

}

392

305

break;

393

case 'f':

394

if(arg == NULL){

395

break;

396

}

397

{

398

char *envdef = strchr(arg, ':');

399

if(envdef == NULL){

400

break;

401

}

402

char *p_name = strndup(arg, (size_t) (envdef-arg));

403

if(p_name == NULL){

404

break;

405

}

406

envdef++;

407

if(not add_environment(getplugin(p_name, plugins), envdef)){

408

perror("add_environment");

409

}

410

}

411

break;

412

306

case 'd':

413

307

if (arg != NULL){

414

plugin *p = getplugin(arg, plugins);

415

if(p == NULL){

416

return ARGP_ERR_UNKNOWN;

417

}

418

p->disabled = true;

308

getplugin(arg, plugins)->disabled = true;

419

309

}

420

310

break;

421

311

case 128:

422

plugindir = strdup(arg);

423

if(plugindir == NULL){

424

perror("strdup");

425

}

312

plugindir = arg;

426

313

break;

427

314

case 129:

428

argfile = strdup(arg);

429

if(argfile == NULL){

430

perror("strdup");

431

}

432

break;

315

uid = (uid_t)strtol(arg, NULL, 10);

316

break;

433

317

case 130:

434

uid = (uid_t)strtol(arg, NULL, 10);

318

gid = (gid_t)strtol(arg, NULL, 10);

435

319

break;

436

320

case 131:

437

gid = (gid_t)strtol(arg, NULL, 10);

438

break;

439

case 132:

440

321

debug = true;

441

322

break;

442

323

case ARGP_KEY_ARG:

443

fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);

324

fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);

444

325

break;

445

326

case ARGP_KEY_END:

446

327

break;

460

341

if (ret == ARGP_ERR_UNKNOWN){

461

342

fprintf(stderr, "Unknown error while parsing arguments\n");

462

343

exitstatus = EXIT_FAILURE;

463

goto fallback;

344

goto end;

464

345

}

465

346

466

if (argfile == NULL){

467

conffp = fopen(AFILE, "r");

468

} else {

469

conffp = fopen(argfile, "r");

470

}

471

347

conffp = fopen(conffile, "r");

472

348

if(conffp != NULL){

473

349

char *org_line = NULL;

474

char *p, *arg, *new_arg, *line;

475

350

size_t size = 0;

476

351

ssize_t sret;

352

char *p, *arg, *new_arg, *line;

477

353

const char whitespace_delims[] = " \r\t\f\v\n";

478

354

const char comment_delim[] = "#";

479

355

480

custom_argc = 1;

481

custom_argv = malloc(sizeof(char*) * 2);

482

if(custom_argv == NULL){

483

perror("malloc");

484

exitstatus = EXIT_FAILURE;

485

goto fallback;

486

}

487

custom_argv[0] = argv[0];

488

custom_argv[1] = NULL;

489

490

356

while(true){

491

357

sret = getline(&org_line, &size, conffp);

492

358

if(sret == -1){

500

366

continue;

501

367

}

502

368

new_arg = strdup(p);

503

if(new_arg == NULL){

504

perror("strdup");

505

exitstatus = EXIT_FAILURE;

506

free(org_line);

507

goto fallback;

508

}

509

510

custom_argc += 1;

511

custom_argv = realloc(custom_argv, sizeof(char *)

512

* ((unsigned int) custom_argc + 1));

513

if(custom_argv == NULL){

514

perror("realloc");

515

exitstatus = EXIT_FAILURE;

516

free(org_line);

517

goto fallback;

518

}

519

custom_argv[custom_argc-1] = new_arg;

520

custom_argv[custom_argc] = NULL;

369

custom_argv = addcustomargument(custom_argv, &custom_argc, new_arg);

370

if (custom_argv == NULL){

371

perror("addcustomargument");

372

exitstatus = EXIT_FAILURE;

373

goto end;

374

}

521

375

}

522

376

}

523

377

free(org_line);

524

378

} else{

525

/* Check for harmful errors and go to fallback. Other errors might

526

not affect opening plugins */

379

/* check for harmfull errors */

527

380

if (errno == EMFILE or errno == ENFILE or errno == ENOMEM){

528

381

perror("fopen");

529

382

exitstatus = EXIT_FAILURE;

530

goto fallback;

383

goto end;

531

384

}

532

385

}

533

386

534

387

if(custom_argv != NULL){

388

custom_argv[0] = argv[0];

535

389

ret = argp_parse (&argp, custom_argc, custom_argv, 0, 0, &plugin_list);

536

390

if (ret == ARGP_ERR_UNKNOWN){

537

391

fprintf(stderr, "Unknown error while parsing arguments\n");

538

392

exitstatus = EXIT_FAILURE;

539

goto fallback;

393

goto end;

540

394

}

541

395

}

542

396

547

401

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

548

402

fprintf(stderr, "\tArg: %s\n", *a);

549

403

}

550

fprintf(stderr, "...and %u environment variables\n", p->envc);

551

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

552

fprintf(stderr, "\t%s\n", *a);

553

}

554

404

}

555

405

}

556

406

563

413

if (ret == -1){

564

414

perror("setgid");

565

415

}

566

567

if (plugindir == NULL){

568

dir = opendir(PDIR);

569

} else {

570

dir = opendir(plugindir);

571

}

572

416

417

dir = opendir(plugindir);

573

418

if(dir == NULL){

574

419

perror("Could not open plugin dir");

575

420

exitstatus = EXIT_FAILURE;

576

goto fallback;

421

goto end;

577

422

}

578

423

579

424

/* Set the FD_CLOEXEC flag on the directory, if possible */

584

429

if(ret < 0){

585

430

perror("set_cloexec_flag");

586

431

exitstatus = EXIT_FAILURE;

587

goto fallback;

432

goto end;

588

433

}

589

434

}

590

435

}

599

444

if (errno == EBADF){

600

445

perror("readdir");

601

446

exitstatus = EXIT_FAILURE;

602

goto fallback;

447

goto end;

603

448

}

604

449

break;

605

450

}

650

495

continue;

651

496

}

652

497

}

653

654

char *filename;

655

ret = asprintf(&filename, "%s/%s", plugindir, dirst->d_name);

656

if(ret < 0){

657

perror("asprintf");

498

499

char *filename = malloc(d_name_len + strlen(plugindir) + 2);

500

if (filename == NULL){

501

perror("malloc");

658

502

continue;

659

503

}

504

strcpy(filename, plugindir); /* Spurious warning */

505

strcat(filename, "/"); /* Spurious warning */

506

strcat(filename, dirst->d_name); /* Spurious warning */

660

507

661

508

ret = stat(filename, &st);

662

509

if (ret == -1){

673

520

free(filename);

674

521

continue;

675

522

}

676

plugin *p = getplugin(dirst->d_name, &plugin_list);

677

if(p == NULL){

678

perror("getplugin");

679

free(filename);

680

continue;

681

}

682

if(p->disabled){

523

if(getplugin(dirst->d_name, &plugin_list)->disabled){

683

524

if(debug){

684

525

fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",

685

526

dirst->d_name);

687

528

free(filename);

688

529

continue;

689

530

}

531

plugin *p = getplugin(dirst->d_name, &plugin_list);

690

532

{

691

533

/* Add global arguments to argument list for this plugin */

692

534

plugin *g = getplugin(NULL, &plugin_list);

693

if(g != NULL){

694

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

695

if(not add_argument(p, *a)){

696

perror("add_argument");

697

}

698

}

699

/* Add global environment variables */

700

for(char **e = g->environ; *e != NULL; e++){

701

if(not add_environment(p, *e)){

702

perror("add_environment");

703

}

704

}

705

}

706

}

707

/* If this plugin has any environment variables, we will call

708

using execve and need to duplicate the environment from this

709

process, too. */

710

if(p->environ[0] != NULL){

711

for(char **e = environ; *e != NULL; e++){

712

char *copy = strdup(*e);

713

if(copy == NULL){

714

perror("strdup");

715

continue;

716

}

717

if(not add_environment(p, copy)){

718

perror("add_environment");

719

}

720

}

721

}

722

723

int pipefd[2];

535

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

536

addargument(p, *a);

537

}

538

}

539

int pipefd[2];

724

540

ret = pipe(pipefd);

725

541

if (ret == -1){

726

542

perror("pipe");

727

543

exitstatus = EXIT_FAILURE;

728

goto fallback;

544

goto end;

729

545

}

730

546

ret = set_cloexec_flag(pipefd[0]);

731

547

if(ret < 0){

732

548

perror("set_cloexec_flag");

733

549

exitstatus = EXIT_FAILURE;

734

goto fallback;

550

goto end;

735

551

}

736

552

ret = set_cloexec_flag(pipefd[1]);

737

553

if(ret < 0){

738

554

perror("set_cloexec_flag");

739

555

exitstatus = EXIT_FAILURE;

740

goto fallback;

556

goto end;

741

557

}

742

558

/* Block SIGCHLD until process is safely in process list */

743

559

ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);

744

560

if(ret < 0){

745

561

perror("sigprocmask");

746

562

exitstatus = EXIT_FAILURE;

747

goto fallback;

563

goto end;

748

564

}

749

565

// Starting a new process to be watched

750

566

pid_t pid = fork();

751

567

if(pid == -1){

752

568

perror("fork");

753

569

exitstatus = EXIT_FAILURE;

754

goto fallback;

570

goto end;

755

571

}

756

572

if(pid == 0){

757

573

/* this is the child process */

777

593

above and must now close it manually here. */

778

594

closedir(dir);

779

595

}

780

if(p->environ[0] == NULL){

781

if(execv(filename, p->argv) < 0){

782

perror("execv");

783

_exit(EXIT_FAILURE);

784

}

785

} else {

786

if(execve(filename, p->argv, p->environ) < 0){

787

perror("execve");

788

_exit(EXIT_FAILURE);

789

}

596

if(execv(filename, p->argv) < 0){

597

perror("execv");

598

_exit(EXIT_FAILURE);

790

599

}

791

600

/* no return */

792

601

}

801

610

perror("sigprocmask");

802

611

}

803

612

exitstatus = EXIT_FAILURE;

804

goto fallback;

613

goto end;

805

614

}

806

615

807

616

*new_process = (struct process){ .pid = pid,

815

624

if(ret < 0){

816

625

perror("sigprocmask");

817

626

exitstatus = EXIT_FAILURE;

818

goto fallback;

627

goto end;

819

628

}

820

629

821

630

FD_SET(new_process->fd, &rfds_all);

825

634

}

826

635

827

636

}

828

829

free_plugin_list(plugin_list);

830

plugin_list = NULL;

637

638

/* Free the plugin list */

639

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

640

next = plugin_list->next;

641

free(plugin_list->argv);

642

free(plugin_list);

643

}

831

644

832

645

closedir(dir);

833

646

dir = NULL;

843

656

if (select_ret == -1){

844

657

perror("select");

845

658

exitstatus = EXIT_FAILURE;

846

goto fallback;

659

goto end;

847

660

}

848

661

/* OK, now either a process completed, or something can be read

849

662

from one of them */

871

684

/* Remove the plugin */

872

685

FD_CLR(proc->fd, &rfds_all);

873

686

/* Block signal while modifying process_list */

874

ret = sigprocmask(SIG_BLOCK, &sigchld_action.sa_mask, NULL);

687

ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);

875

688

if(ret < 0){

876

689

perror("sigprocmask");

877

690

exitstatus = EXIT_FAILURE;

878

goto fallback;

691

goto end;

879

692

}

880

693

/* Delete this process entry from the list */

881

694

if(process_list == proc){

905

718

}

906

719

/* This process exited nicely, so print its buffer */

907

720

908

bool bret = print_out_password(proc->buffer,

909

proc->buffer_length);

721

bool bret = print_out_password(proc->buffer, proc->buffer_length);

910

722

if(not bret){

911

723

perror("print_out_password");

912

724

exitstatus = EXIT_FAILURE;

913

725

}

914

goto fallback;

726

goto end;

915

727

}

916

728

/* This process has not completed. Does it have any output? */

917

729

if(proc->eof or not FD_ISSET(proc->fd, &rfds)){

925

737

if (proc->buffer == NULL){

926

738

perror("malloc");

927

739

exitstatus = EXIT_FAILURE;

928

goto fallback;

740

goto end;

929

741

}

930

742

proc->buffer_size += BUFFER_SIZE;

931

743

}

946

758

}

947

759

948

760

949

fallback:

761

end:

950

762

951

763

if(process_list == NULL or exitstatus != EXIT_SUCCESS){

952

/* Fallback if all plugins failed, none are found or an error

953

occured */

764

/* Fallback if all plugins failed, none are found or an error occured */

954

765

bool bret;

955

766

fprintf(stderr, "Going to fallback mode using getpass(3)\n");

956

767

char *passwordbuffer = getpass("Password: ");

958

769

if(not bret){

959

770

perror("print_out_password");

960

771

exitstatus = EXIT_FAILURE;

772

goto end;

961

773

}

962

774

}

963

775

964

776

/* Restore old signal handler */

965

ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);

966

if(ret == -1){

967

perror("sigaction");

968

exitstatus = EXIT_FAILURE;

969

}

970

971

if(custom_argv != NULL){

972

for(char **arg = custom_argv+1; *arg != NULL; arg++){

973

free(*arg);

974

}

975

free(custom_argv);

976

}

977

free_plugin_list(plugin_list);

777

sigaction(SIGCHLD, &old_sigchld_action, NULL);

778

779

free(custom_argv);

780

781

/* Free the plugin list */

782

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

783

next = plugin_list->next;

784

free(plugin_list->argv);

785

free(plugin_list);

786

}

978

787

979

788

if(dir != NULL){

980

789

closedir(dir);

1000

809

if(errno != ECHILD){

1001

810

perror("wait");

1002

811

}

1003

1004

free(plugindir);

1005

free(argfile);

1006

812

1007

813

return exitstatus;

1008

814

}