To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/trunk
« back to all changes in this revision
Viewing changes to plugin-runner.c
- browse files at revision 80
- compare with another revision
- download diff
- download tarball
- view history from revision 80
- Committer: Teddy Hogeborn
- Date: 2008-08-16 20:32:58 UTC
- mfrom: (24.1.55 mandos)
- Revision ID: teddy@fukt.bsnet.se-20080816203258-eq4by31vdgxkhs9g
* mandos-keygen.xml: New man page for mandos-keygen(8).
- files added:
- mandos-keygen.xml
- files modified:
- TODO
added
removed
plugin-runner.c
105
105
if (new_plugin == NULL){
106
106
return NULL;
107
107
}
108
*new_plugin = (plugin) { .name = name,
108
char *copy_name = strdup(name);
109
if(copy_name == NULL){
110
return NULL;
111
}
112
113
*new_plugin = (plugin) { .name = copy_name,
109
114
.argc = 1,
110
115
.envc = 0,
111
116
.disabled = false,
116
121
free(new_plugin);
117
122
return NULL;
118
123
}
119
new_plugin->argv[0] = name;
124
new_plugin->argv[0] = copy_name;
120
125
new_plugin->argv[1] = NULL;
121
126
122
127
new_plugin->environ = malloc(sizeof(char *));
246
251
return argv;
247
252
}
248
253
254
static void free_plugin_list(plugin *plugin_list){
255
for(plugin *next = plugin_list; plugin_list != NULL; plugin_list = next){
256
next = plugin_list->next;
257
free(plugin_list->name);
258
for(char **arg = plugin_list->argv; *arg != NULL; arg++){
259
free(*arg);
260
}
261
free(plugin_list->argv);
262
for(char **env = plugin_list->environ; *env != NULL; env++){
263
free(*env);
264
}
265
free(plugin_list->environ);
266
free(plugin_list);
267
}
268
}
269
249
270
int main(int argc, char *argv[]){
250
271
const char *plugindir = "/lib/mandos/plugins.d";
251
272
const char *argfile = ARGFILE;
269
290
/* Establish a signal handler */
270
291
sigemptyset(&sigchld_action.sa_mask);
271
292
ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);
272
if(ret < 0){
293
if(ret == -1){
273
294
perror("sigaddset");
274
exit(EXIT_FAILURE);
295
exitstatus = EXIT_FAILURE;
296
goto fallback;
275
297
}
276
298
ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);
277
if(ret < 0){
299
if(ret == -1){
278
300
perror("sigaction");
279
exit(EXIT_FAILURE);
301
exitstatus = EXIT_FAILURE;
302
goto fallback;
280
303
}
281
304
282
305
/* The options we understand. */
428
451
if (ret == ARGP_ERR_UNKNOWN){
429
452
fprintf(stderr, "Unknown error while parsing arguments\n");
430
453
exitstatus = EXIT_FAILURE;
431
goto end;
454
goto fallback;
432
455
}
433
456
434
457
conffp = fopen(argfile, "r");
435
458
if(conffp != NULL){
436
459
char *org_line = NULL;
460
char *p, *arg, *new_arg, *line;
437
461
size_t size = 0;
438
462
ssize_t sret;
439
char *p, *arg, *new_arg, *line;
440
463
const char whitespace_delims[] = " \r\t\f\v\n";
441
464
const char comment_delim[] = "#";
442
465
457
480
if (custom_argv == NULL){
458
481
perror("add_to_argv");
459
482
exitstatus = EXIT_FAILURE;
460
goto end;
483
goto fallback;
461
484
}
462
485
}
463
486
}
468
491
if (errno == EMFILE or errno == ENFILE or errno == ENOMEM){
469
492
perror("fopen");
470
493
exitstatus = EXIT_FAILURE;
471
goto end;
494
goto fallback;
472
495
}
473
496
}
474
497
478
501
if (ret == ARGP_ERR_UNKNOWN){
479
502
fprintf(stderr, "Unknown error while parsing arguments\n");
480
503
exitstatus = EXIT_FAILURE;
481
goto end;
504
goto fallback;
482
505
}
483
506
}
484
507
510
533
if(dir == NULL){
511
534
perror("Could not open plugin dir");
512
535
exitstatus = EXIT_FAILURE;
513
goto end;
536
goto fallback;
514
537
}
515
538
516
539
/* Set the FD_CLOEXEC flag on the directory, if possible */
521
544
if(ret < 0){
522
545
perror("set_cloexec_flag");
523
546
exitstatus = EXIT_FAILURE;
524
goto end;
547
goto fallback;
525
548
}
526
549
}
527
550
}
536
559
if (errno == EBADF){
537
560
perror("readdir");
538
561
exitstatus = EXIT_FAILURE;
539
goto end;
562
goto fallback;
540
563
}
541
564
break;
542
565
}
662
685
if (ret == -1){
663
686
perror("pipe");
664
687
exitstatus = EXIT_FAILURE;
665
goto end;
688
goto fallback;
666
689
}
667
690
ret = set_cloexec_flag(pipefd[0]);
668
691
if(ret < 0){
669
692
perror("set_cloexec_flag");
670
693
exitstatus = EXIT_FAILURE;
671
goto end;
694
goto fallback;
672
695
}
673
696
ret = set_cloexec_flag(pipefd[1]);
674
697
if(ret < 0){
675
698
perror("set_cloexec_flag");
676
699
exitstatus = EXIT_FAILURE;
677
goto end;
700
goto fallback;
678
701
}
679
702
/* Block SIGCHLD until process is safely in process list */
680
703
ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);
681
704
if(ret < 0){
682
705
perror("sigprocmask");
683
706
exitstatus = EXIT_FAILURE;
684
goto end;
707
goto fallback;
685
708
}
686
709
// Starting a new process to be watched
687
710
pid_t pid = fork();
688
711
if(pid == -1){
689
712
perror("fork");
690
713
exitstatus = EXIT_FAILURE;
691
goto end;
714
goto fallback;
692
715
}
693
716
if(pid == 0){
694
717
/* this is the child process */
738
761
perror("sigprocmask");
739
762
}
740
763
exitstatus = EXIT_FAILURE;
741
goto end;
764
goto fallback;
742
765
}
743
766
744
767
*new_process = (struct process){ .pid = pid,
752
775
if(ret < 0){
753
776
perror("sigprocmask");
754
777
exitstatus = EXIT_FAILURE;
755
goto end;
778
goto fallback;
756
779
}
757
780
758
781
FD_SET(new_process->fd, &rfds_all);
763
786
764
787
}
765
788
766
/* Free the plugin list */
767
for(plugin *next; plugin_list != NULL; plugin_list = next){
768
next = plugin_list->next;
769
free(plugin_list->argv);
770
if(plugin_list->environ[0] != NULL){
771
for(char **e = plugin_list->environ; *e != NULL; e++){
772
free(*e);
773
}
774
}
775
free(plugin_list);
776
}
789
free_plugin_list(plugin_list);
777
790
778
791
closedir(dir);
779
792
dir = NULL;
789
802
if (select_ret == -1){
790
803
perror("select");
791
804
exitstatus = EXIT_FAILURE;
792
goto end;
805
goto fallback;
793
806
}
794
807
/* OK, now either a process completed, or something can be read
795
808
from one of them */
821
834
if(ret < 0){
822
835
perror("sigprocmask");
823
836
exitstatus = EXIT_FAILURE;
824
goto end;
837
goto fallback;
825
838
}
826
839
/* Delete this process entry from the list */
827
840
if(process_list == proc){
856
869
perror("print_out_password");
857
870
exitstatus = EXIT_FAILURE;
858
871
}
859
goto end;
872
goto fallback;
860
873
}
861
874
/* This process has not completed. Does it have any output? */
862
875
if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
870
883
if (proc->buffer == NULL){
871
884
perror("malloc");
872
885
exitstatus = EXIT_FAILURE;
873
goto end;
886
goto fallback;
874
887
}
875
888
proc->buffer_size += BUFFER_SIZE;
876
889
}
891
904
}
892
905
893
906
894
end:
907
fallback:
895
908
896
909
if(process_list == NULL or exitstatus != EXIT_SUCCESS){
897
910
/* Fallback if all plugins failed, none are found or an error occured */
902
915
if(not bret){
903
916
perror("print_out_password");
904
917
exitstatus = EXIT_FAILURE;
905
goto end;
906
918
}
907
919
}
908
920
909
921
/* Restore old signal handler */
910
sigaction(SIGCHLD, &old_sigchld_action, NULL);
911
912
free(custom_argv);
913
914
/* Free the plugin list */
915
for(plugin *next; plugin_list != NULL; plugin_list = next){
916
next = plugin_list->next;
917
free(plugin_list->argv);
918
if(plugin_list->environ[0] != NULL){
919
for(char **e = plugin_list->environ; *e != NULL; e++){
920
free(*e);
921
}
922
ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
923
if(ret == -1){
924
perror("sigaction");
925
exitstatus = EXIT_FAILURE;
926
}
927
928
if(custom_argv != NULL){
929
for(char **arg = custom_argv; *arg != NULL; arg++){
930
free(*arg);
922
931
}
923
free(plugin_list->environ);
924
free(plugin_list);
932
free(custom_argv);
925
933
}
934
free_plugin_list(plugin_list);
926
935
927
936
if(dir != NULL){
928
937
closedir(dir);
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0