2 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
4 * Copyright 1999-2011 The OpenLDAP Foundation.
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted only as authorized by the OpenLDAP
11 * A copy of this license is available in file LICENSE in the
12 * top-level directory of the distribution or, alternatively, at
13 * <http://www.OpenLDAP.org/license.html>.
16 * This work was initially developed by Kurt Spanier for inclusion
17 * in OpenLDAP Software.
24 #include "ac/stdlib.h"
27 #include "ac/dirent.h"
29 #include "ac/socket.h"
30 #include "ac/string.h"
31 #include "ac/unistd.h"
35 #include "ldap_defaults.h"
41 #include "slapd-common.h"
43 #define SEARCHCMD "slapd-search"
44 #define READCMD "slapd-read"
45 #define ADDCMD "slapd-addel"
46 #define MODRDNCMD "slapd-modrdn"
47 #define MODIFYCMD "slapd-modify"
48 #define BINDCMD "slapd-bind"
52 #define OUTERLOOPS "1"
55 #define TSEARCHFILE "do_search.0"
56 #define TREADFILE "do_read.0"
57 #define TADDFILE "do_add."
58 #define TMODRDNFILE "do_modrdn.0"
59 #define TMODIFYFILE "do_modify.0"
60 #define TBINDFILE "do_bind.0"
62 static char *get_file_name( char *dirname, char *filename );
63 static int get_search_filters( char *filename, char *filters[], char *attrs[], char *bases[], LDAPURLDesc *luds[] );
64 static int get_read_entries( char *filename, char *entries[], char *filters[] );
65 static void fork_child( char *prog, char **args );
66 static void wait4kids( int nkidval );
68 static int maxkids = 20;
72 static HANDLE *children;
73 static char argbuf[BUFSIZ];
74 #define ArgDup(x) strdup(strcat(strcat(strcpy(argbuf,"\""),x),"\""))
76 #define ArgDup(x) strdup(x)
80 usage( char *name, char opt )
83 fprintf( stderr, "%s: unable to handle option \'%c\'\n\n",
89 "-H <uri> | ([-h <host>] -p <port>) "
95 "[-l {<loops>|<type>=<loops>[,...]}] "
105 exit( EXIT_FAILURE );
109 main( int argc, char **argv )
113 char *host = "localhost";
115 char *manager = NULL;
117 char *dirname = NULL;
118 char *progdir = NULL;
120 char *outerloops = OUTERLOOPS;
121 char *retries = RETRIES;
133 char *sreqs[MAXREQS];
134 char *sattrs[MAXREQS];
135 char *sbase[MAXREQS];
136 LDAPURLDesc *slud[MAXREQS];
138 char *sargs[MAXARGS];
141 char scmd[MAXPATHLEN];
143 char swampopt[sizeof("-SSS")];
144 /* static so that its address can be used in initializer below. */
145 static char sloops[LDAP_PVT_INTTYPE_CHARS(unsigned long)];
148 char *rreqs[MAXREQS];
150 char *rargs[MAXARGS];
151 char *rflts[MAXREQS];
154 char rcmd[MAXPATHLEN];
155 static char rloops[LDAP_PVT_INTTYPE_CHARS(unsigned long)];
157 char *afiles[MAXREQS];
159 char *aargs[MAXARGS];
161 char acmd[MAXPATHLEN];
162 static char aloops[LDAP_PVT_INTTYPE_CHARS(unsigned long)];
165 char *nreqs[MAXREQS];
167 char *nargs[MAXARGS];
169 char ncmd[MAXPATHLEN];
170 static char nloops[LDAP_PVT_INTTYPE_CHARS(unsigned long)];
173 char *mreqs[MAXREQS];
176 char *margs[MAXARGS];
178 char mcmd[MAXPATHLEN];
179 static char mloops[LDAP_PVT_INTTYPE_CHARS(unsigned long)];
182 char *breqs[MAXREQS];
183 char *bcreds[MAXREQS];
184 char *battrs[MAXREQS];
186 char *bargs[MAXARGS];
188 char bcmd[MAXPATHLEN];
189 static char bloops[LDAP_PVT_INTTYPE_CHARS(unsigned long)];
190 char **bargs_extra = NULL;
192 char *friendlyOpt = NULL;
194 char *pw_file = NULL;
196 /* extra action to do after bind... */
197 typedef struct extra_t {
199 struct extra_t *next;
202 extra_t *extra = NULL;
205 tester_init( "slapd-tester", TESTER_TESTER );
214 while ( ( i = getopt( argc, argv, "AB:CD:d:FH:h:Ii:j:L:l:NP:p:r:St:Ww:y:" ) ) != EOF )
223 **b = ldap_str2charray( optarg, "," );
226 for ( epp = &extra; *epp; epp = &(*epp)->next )
229 for ( p = b; p[0]; p++ ) {
230 *epp = calloc( 1, sizeof( extra_t ) );
231 (*epp)->action = p[0];
243 case 'D': /* slapd manager */
244 manager = ArgDup( optarg );
247 case 'd': /* data directory */
248 dirname = strdup( optarg );
255 case 'H': /* slapd uri */
256 uri = strdup( optarg );
259 case 'h': /* slapd host */
260 host = strdup( optarg );
271 case 'j': /* the number of parallel clients */
272 if ( lutil_atoi( &maxkids, optarg ) != 0 ) {
273 usage( argv[0], 'j' );
277 case 'l': /* the number of loops per client */
278 if ( !isdigit( (unsigned char) optarg[0] ) ) {
280 **l = ldap_str2charray( optarg, "," );
282 for ( p = l; p[0]; p++) {
287 { BER_BVC( "add=" ), aloops },
288 { BER_BVC( "bind=" ), bloops },
289 { BER_BVC( "modify=" ), mloops },
290 { BER_BVC( "modrdn=" ), nloops },
291 { BER_BVC( "read=" ), rloops },
292 { BER_BVC( "search=" ), sloops },
297 for ( c = 0; types[c].type.bv_val; c++ ) {
298 if ( strncasecmp( p[0], types[c].type.bv_val, types[c].type.bv_len ) == 0 ) {
303 if ( types[c].type.bv_val == NULL ) {
304 usage( argv[0], 'l' );
307 if ( lutil_atoi( &n, &p[0][types[c].type.bv_len] ) != 0 ) {
308 usage( argv[0], 'l' );
311 snprintf( types[c].buf, sizeof( aloops ), "%d", n );
314 ldap_charray_free( l );
316 } else if ( lutil_atoi( &loops, optarg ) != 0 ) {
317 usage( argv[0], 'l' );
321 case 'L': /* the number of outerloops per client */
322 outerloops = strdup( optarg );
329 case 'P': /* prog directory */
330 progdir = strdup( optarg );
333 case 'p': /* the servers port number */
334 port = strdup( optarg );
337 case 'r': /* the number of retries in case of error */
338 retries = strdup( optarg );
345 case 't': /* the delay in seconds between each retry */
346 delay = strdup( optarg );
349 case 'w': /* the managers passwd */
350 passwd = ArgDup( optarg );
351 memset( optarg, '*', strlen( optarg ) );
363 usage( argv[0], '\0' );
368 if (( dirname == NULL ) || ( port == NULL && uri == NULL ) ||
369 ( manager == NULL ) || ( passwd == NULL ) || ( progdir == NULL ))
371 usage( argv[0], '\0' );
375 children = malloc( maxkids * sizeof(HANDLE) );
377 /* get the file list */
378 if ( ( datadir = opendir( dirname )) == NULL ) {
379 fprintf( stderr, "%s: couldn't open data directory \"%s\".\n",
381 exit( EXIT_FAILURE );
384 /* look for search, read, modrdn, and add/delete files */
385 for ( file = readdir( datadir ); file; file = readdir( datadir )) {
387 if ( !strcasecmp( file->d_name, TSEARCHFILE )) {
388 sfile = get_file_name( dirname, file->d_name );
390 } else if ( !strcasecmp( file->d_name, TREADFILE )) {
391 rfile = get_file_name( dirname, file->d_name );
393 } else if ( !strcasecmp( file->d_name, TMODRDNFILE )) {
394 nfile = get_file_name( dirname, file->d_name );
396 } else if ( !strcasecmp( file->d_name, TMODIFYFILE )) {
397 mfile = get_file_name( dirname, file->d_name );
399 } else if ( !strncasecmp( file->d_name, TADDFILE, strlen( TADDFILE ))
400 && ( anum < MAXREQS )) {
401 afiles[anum++] = get_file_name( dirname, file->d_name );
403 } else if ( !strcasecmp( file->d_name, TBINDFILE )) {
404 bfile = get_file_name( dirname, file->d_name );
412 passwd = getpassphrase( _("Enter LDAP Password: ") );
414 } else if ( pw_file ) {
417 if ( lutil_get_filed_password( pw_file, &pw ) ) {
418 exit( EXIT_FAILURE );
424 if ( !sfile && !rfile && !nfile && !mfile && !bfile && !anum ) {
425 fprintf( stderr, "no data files found.\n" );
426 exit( EXIT_FAILURE );
429 /* look for search requests */
431 snum = get_search_filters( sfile, sreqs, sattrs, sbase, slud );
434 "unable to parse file \"%s\" line %d\n",
435 sfile, -2*(snum + 1));
436 exit( EXIT_FAILURE );
440 /* look for read requests */
442 rnum = get_read_entries( rfile, rreqs, rflts );
445 "unable to parse file \"%s\" line %d\n",
446 rfile, -2*(rnum + 1) );
447 exit( EXIT_FAILURE );
451 /* look for modrdn requests */
453 nnum = get_read_entries( nfile, nreqs, NULL );
456 "unable to parse file \"%s\" line %d\n",
457 nfile, -2*(nnum + 1) );
458 exit( EXIT_FAILURE );
462 /* look for modify requests */
464 mnum = get_search_filters( mfile, mreqs, NULL, mdn, NULL );
467 "unable to parse file \"%s\" line %d\n",
468 mfile, -2*(mnum + 1) );
469 exit( EXIT_FAILURE );
473 /* look for bind requests */
475 bnum = get_search_filters( bfile, bcreds, battrs, breqs, NULL );
478 "unable to parse file \"%s\" line %d\n",
479 bfile, -2*(bnum + 1) );
480 exit( EXIT_FAILURE );
484 /* setup friendly option */
485 switch ( friendly ) {
494 /* NOTE: right now we don't need it more than twice */
500 /* setup swamp option */
503 if ( swamp > 3 ) swamp = 3;
504 swampopt[swamp + 1] = '\0';
505 for ( ; swamp-- > 0; ) swampopt[swamp + 1] = 'S';
508 /* setup loop options */
509 if ( sloops[0] == '\0' ) snprintf( sloops, sizeof( sloops ), "%d", 10 * loops );
510 if ( rloops[0] == '\0' ) snprintf( rloops, sizeof( rloops ), "%d", 20 * loops );
511 if ( aloops[0] == '\0' ) snprintf( aloops, sizeof( aloops ), "%d", loops );
512 if ( nloops[0] == '\0' ) snprintf( nloops, sizeof( nloops ), "%d", loops );
513 if ( mloops[0] == '\0' ) snprintf( mloops, sizeof( mloops ), "%d", loops );
514 if ( bloops[0] == '\0' ) snprintf( bloops, sizeof( bloops ), "%d", 20 * loops );
517 * generate the search clients
521 snprintf( scmd, sizeof scmd, "%s" LDAP_DIRSEP SEARCHCMD,
523 sargs[sanum++] = scmd;
525 sargs[sanum++] = "-H";
526 sargs[sanum++] = uri;
528 sargs[sanum++] = "-h";
529 sargs[sanum++] = host;
530 sargs[sanum++] = "-p";
531 sargs[sanum++] = port;
533 sargs[sanum++] = "-D";
534 sargs[sanum++] = manager;
535 sargs[sanum++] = "-w";
536 sargs[sanum++] = passwd;
537 sargs[sanum++] = "-l";
538 sargs[sanum++] = sloops;
539 sargs[sanum++] = "-L";
540 sargs[sanum++] = outerloops;
541 sargs[sanum++] = "-r";
542 sargs[sanum++] = retries;
543 sargs[sanum++] = "-t";
544 sargs[sanum++] = delay;
546 sargs[sanum++] = friendlyOpt;
549 sargs[sanum++] = "-C";
552 sargs[sanum++] = "-A";
555 sargs[sanum++] = "-N";
558 sargs[sanum++] = "-i";
559 sargs[sanum++] = ignore;
562 sargs[sanum++] = swampopt;
564 sargs[sanum++] = "-b";
565 sargs[sanum++] = NULL; /* will hold the search base */
566 sargs[sanum++] = "-s";
567 sargs[sanum++] = NULL; /* will hold the search scope */
568 sargs[sanum++] = "-f";
569 sargs[sanum++] = NULL; /* will hold the search request */
571 sargs[sanum++] = NULL;
572 sargs[sanum++] = NULL; /* might hold the "attr" request */
578 * generate the read clients
582 snprintf( rcmd, sizeof rcmd, "%s" LDAP_DIRSEP READCMD,
584 rargs[ranum++] = rcmd;
586 rargs[ranum++] = "-H";
587 rargs[ranum++] = uri;
589 rargs[ranum++] = "-h";
590 rargs[ranum++] = host;
591 rargs[ranum++] = "-p";
592 rargs[ranum++] = port;
594 rargs[ranum++] = "-D";
595 rargs[ranum++] = manager;
596 rargs[ranum++] = "-w";
597 rargs[ranum++] = passwd;
598 rargs[ranum++] = "-l";
599 rargs[ranum++] = rloops;
600 rargs[ranum++] = "-L";
601 rargs[ranum++] = outerloops;
602 rargs[ranum++] = "-r";
603 rargs[ranum++] = retries;
604 rargs[ranum++] = "-t";
605 rargs[ranum++] = delay;
607 rargs[ranum++] = friendlyOpt;
610 rargs[ranum++] = "-C";
613 rargs[ranum++] = "-A";
616 rargs[ranum++] = "-i";
617 rargs[ranum++] = ignore;
620 rargs[ranum++] = swampopt;
622 rargs[ranum++] = "-e";
623 rargs[ranum++] = NULL; /* will hold the read entry */
625 rargs[ranum++] = NULL;
626 rargs[ranum++] = NULL; /* might hold the filter arg */
632 * generate the modrdn clients
636 snprintf( ncmd, sizeof ncmd, "%s" LDAP_DIRSEP MODRDNCMD,
638 nargs[nanum++] = ncmd;
640 nargs[nanum++] = "-H";
641 nargs[nanum++] = uri;
643 nargs[nanum++] = "-h";
644 nargs[nanum++] = host;
645 nargs[nanum++] = "-p";
646 nargs[nanum++] = port;
648 nargs[nanum++] = "-D";
649 nargs[nanum++] = manager;
650 nargs[nanum++] = "-w";
651 nargs[nanum++] = passwd;
652 nargs[nanum++] = "-l";
653 nargs[nanum++] = nloops;
654 nargs[nanum++] = "-L";
655 nargs[nanum++] = outerloops;
656 nargs[nanum++] = "-r";
657 nargs[nanum++] = retries;
658 nargs[nanum++] = "-t";
659 nargs[nanum++] = delay;
661 nargs[nanum++] = friendlyOpt;
664 nargs[nanum++] = "-C";
667 nargs[nanum++] = "-i";
668 nargs[nanum++] = ignore;
670 nargs[nanum++] = "-e";
671 nargs[nanum++] = NULL; /* will hold the modrdn entry */
675 * generate the modify clients
679 snprintf( mcmd, sizeof mcmd, "%s" LDAP_DIRSEP MODIFYCMD,
681 margs[manum++] = mcmd;
683 margs[manum++] = "-H";
684 margs[manum++] = uri;
686 margs[manum++] = "-h";
687 margs[manum++] = host;
688 margs[manum++] = "-p";
689 margs[manum++] = port;
691 margs[manum++] = "-D";
692 margs[manum++] = manager;
693 margs[manum++] = "-w";
694 margs[manum++] = passwd;
695 margs[manum++] = "-l";
696 margs[manum++] = mloops;
697 margs[manum++] = "-L";
698 margs[manum++] = outerloops;
699 margs[manum++] = "-r";
700 margs[manum++] = retries;
701 margs[manum++] = "-t";
702 margs[manum++] = delay;
704 margs[manum++] = friendlyOpt;
707 margs[manum++] = "-C";
710 margs[manum++] = "-i";
711 margs[manum++] = ignore;
713 margs[manum++] = "-e";
714 margs[manum++] = NULL; /* will hold the modify entry */
715 margs[manum++] = "-a";;
716 margs[manum++] = NULL; /* will hold the ava */
720 * generate the add/delete clients
724 snprintf( acmd, sizeof acmd, "%s" LDAP_DIRSEP ADDCMD,
726 aargs[aanum++] = acmd;
728 aargs[aanum++] = "-H";
729 aargs[aanum++] = uri;
731 aargs[aanum++] = "-h";
732 aargs[aanum++] = host;
733 aargs[aanum++] = "-p";
734 aargs[aanum++] = port;
736 aargs[aanum++] = "-D";
737 aargs[aanum++] = manager;
738 aargs[aanum++] = "-w";
739 aargs[aanum++] = passwd;
740 aargs[aanum++] = "-l";
741 aargs[aanum++] = aloops;
742 aargs[aanum++] = "-L";
743 aargs[aanum++] = outerloops;
744 aargs[aanum++] = "-r";
745 aargs[aanum++] = retries;
746 aargs[aanum++] = "-t";
747 aargs[aanum++] = delay;
749 aargs[aanum++] = friendlyOpt;
752 aargs[aanum++] = "-C";
755 aargs[aanum++] = "-i";
756 aargs[aanum++] = ignore;
758 aargs[aanum++] = "-f";
759 aargs[aanum++] = NULL; /* will hold the add data file */
763 * generate the bind clients
767 snprintf( bcmd, sizeof bcmd, "%s" LDAP_DIRSEP BINDCMD,
769 bargs[banum++] = bcmd;
771 bargs[banum++] = "-I"; /* init on each bind */
774 bargs[banum++] = "-H";
775 bargs[banum++] = uri;
777 bargs[banum++] = "-h";
778 bargs[banum++] = host;
779 bargs[banum++] = "-p";
780 bargs[banum++] = port;
782 bargs[banum++] = "-l";
783 bargs[banum++] = bloops;
784 bargs[banum++] = "-L";
785 bargs[banum++] = outerloops;
787 bargs[banum++] = "-r";
788 bargs[banum++] = retries;
789 bargs[banum++] = "-t";
790 bargs[banum++] = delay;
793 bargs[banum++] = friendlyOpt;
796 bargs[banum++] = "-C";
799 bargs[banum++] = "-i";
800 bargs[banum++] = ignore;
803 bargs[banum++] = "-B";
804 bargs_extra = &bargs[banum++];
806 bargs[banum++] = "-D";
807 bargs[banum++] = NULL;
808 bargs[banum++] = "-w";
809 bargs[banum++] = NULL;
812 #define DOREQ(n,j) ((n) && ((maxkids > (n)) ? ((j) < maxkids ) : ((j) < (n))))
814 for ( j = 0; j < MAXREQS; j++ ) {
816 if ( DOREQ( snum, j ) ) {
818 int x = sanum - sextra_args;
821 if ( sbase[jj] != NULL ) {
822 sargs[sanum - 7] = sbase[jj];
825 sargs[sanum - 7] = slud[jj]->lud_dn;
829 if ( slud[jj] != NULL ) {
830 sargs[sanum - 5] = (char *)ldap_pvt_scope2str( slud[jj]->lud_scope );
833 sargs[sanum - 5] = "sub";
837 if ( sreqs[jj] != NULL ) {
838 sargs[sanum - 3] = sreqs[jj];
840 } else if ( slud[jj]->lud_filter != NULL ) {
841 sargs[sanum - 3] = slud[jj]->lud_filter;
844 sargs[sanum - 3] = "(objectClass=*)";
851 if ( sattrs[jj] != NULL ) {
853 sargs[x++] = sattrs[jj];
857 if ( slud[jj] != NULL && slud[jj]->lud_attrs != NULL ) {
860 for ( i = 0; slud[jj]->lud_attrs[ i ] != NULL && x + i < MAXARGS - 1; i++ ) {
861 sargs[x + i] = slud[jj]->lud_attrs[ i ];
866 fork_child( scmd, sargs );
870 if ( DOREQ( rnum, j ) ) {
872 int x = ranum - rextra_args;
874 rargs[ranum - 3] = rreqs[jj];
875 if ( rflts[jj] != NULL ) {
877 rargs[x++] = rflts[jj];
880 fork_child( rcmd, rargs );
885 nargs[nanum - 1] = nreqs[j];
886 fork_child( ncmd, nargs );
891 margs[manum - 3] = mdn[j];
892 margs[manum - 1] = mreqs[j];
893 fork_child( mcmd, margs );
898 aargs[aanum - 1] = afiles[j];
899 fork_child( acmd, aargs );
903 if ( DOREQ( bnum, j ) ) {
907 int n = ((double)nextra)*rand()/(RAND_MAX + 1.0);
910 for ( e = extra; n-- > 0; e = e->next )
912 *bargs_extra = e->action;
915 if ( battrs[jj] != NULL ) {
916 bargs[banum - 3] = manager ? manager : "";
917 bargs[banum - 1] = passwd ? passwd : "";
919 bargs[banum + 0] = "-b";
920 bargs[banum + 1] = breqs[jj];
921 bargs[banum + 2] = "-f";
922 bargs[banum + 3] = bcreds[jj];
923 bargs[banum + 4] = "-a";
924 bargs[banum + 5] = battrs[jj];
925 bargs[banum + 6] = NULL;
928 bargs[banum - 3] = breqs[jj];
929 bargs[banum - 1] = bcreds[jj];
933 fork_child( bcmd, bargs );
940 exit( EXIT_SUCCESS );
944 get_file_name( char *dirname, char *filename )
946 char buf[MAXPATHLEN];
948 snprintf( buf, sizeof buf, "%s" LDAP_DIRSEP "%s",
950 return( strdup( buf ));
955 get_search_filters( char *filename, char *filters[], char *attrs[], char *bases[], LDAPURLDesc *luds[] )
960 if ( (fp = fopen( filename, "r" )) != NULL ) {
963 while (( filter < MAXREQS ) && ( fgets( line, BUFSIZ, fp ))) {
967 if (( nl = strchr( line, '\r' )) || ( nl = strchr( line, '\n' )))
970 if ( luds ) luds[filter] = NULL;
972 if ( luds && strncmp( line, "ldap:///", STRLENOF( "ldap:///" ) ) == 0 ) {
976 bases[filter] = NULL;
977 if ( ldap_url_parse( line, &lud ) != LDAP_URL_SUCCESS ) {
978 filter = -filter - 1;
982 if ( lud->lud_dn == NULL || lud->lud_exts != NULL ) {
983 filter = -filter - 1;
984 ldap_free_urldesc( lud );
991 bases[filter] = ArgDup( line );
993 if ( fgets( line, BUFSIZ, fp ) == NULL )
995 if (( nl = strchr( line, '\r' )) || ( nl = strchr( line, '\n' )))
998 filters[filter] = ArgDup( line );
1000 if ( filters[filter][0] == '+') {
1001 char *sep = strchr( filters[filter], ':' );
1003 attrs[ filter ] = &filters[ filter ][ 1 ];
1004 if ( sep != NULL ) {
1006 /* NOTE: don't free this! */
1007 filters[ filter ] = &sep[ 1 ];
1011 attrs[ filter ] = NULL;
1025 get_read_entries( char *filename, char *entries[], char *filters[] )
1030 if ( (fp = fopen( filename, "r" )) != NULL ) {
1033 while (( entry < MAXREQS ) && ( fgets( line, BUFSIZ, fp ))) {
1036 if (( nl = strchr( line, '\r' )) || ( nl = strchr( line, '\n' )))
1038 if ( filters != NULL && line[0] == '+' ) {
1041 if ( ldap_url_parse( &line[1], &lud ) != LDAP_URL_SUCCESS ) {
1046 if ( lud->lud_dn == NULL || lud->lud_dn[ 0 ] == '\0' ) {
1047 ldap_free_urldesc( lud );
1052 entries[entry] = ArgDup( lud->lud_dn );
1054 if ( lud->lud_filter ) {
1055 filters[entry] = ArgDup( lud->lud_filter );
1058 filters[entry] = ArgDup( "(objectClass=*)" );
1060 ldap_free_urldesc( lud );
1063 if ( filters != NULL )
1064 filters[entry] = NULL;
1066 entries[entry] = ArgDup( line );
1078 #ifndef HAVE_WINSOCK
1080 fork_child( char *prog, char **args )
1082 /* note: obscures global pid var; intended */
1085 wait4kids( maxkids );
1087 switch ( pid = fork() ) {
1090 /* The __LIBASCII execvp only handles ASCII "prog",
1091 * we still need to translate the arg vec ourselves.
1093 { char *arg2[MAXREQS];
1096 for (i=0; args[i]; i++) {
1097 arg2[i] = ArgDup(args[i]);
1103 execvp( prog, args );
1104 tester_perror( "execvp", NULL );
1106 for (i=0; args[i]; i++);
1107 fprintf(stderr,"%d args\n", i);
1108 for (i=0; args[i]; i++)
1109 fprintf(stderr,"%d %s\n", i, args[i]);
1112 exit( EXIT_FAILURE );
1115 case -1: /* trouble */
1116 tester_perror( "fork", NULL );
1119 default: /* parent */
1126 wait4kids( int nkidval )
1130 while ( nkids >= nkidval ) {
1131 pid_t pid = wait( &status );
1133 if ( WIFSTOPPED(status) ) {
1135 "stopping: child PID=%ld stopped with signal %d\n",
1136 (long) pid, (int) WSTOPSIG(status) );
1138 } else if ( WIFSIGNALED(status) ) {
1140 "stopping: child PID=%ld terminated with signal %d%s\n",
1141 (long) pid, (int) WTERMSIG(status),
1143 WCOREDUMP(status) ? ", core dumped" : ""
1148 exit( WEXITSTATUS(status) );
1150 } else if ( WEXITSTATUS(status) != 0 ) {
1152 "stopping: child PID=%ld exited with status %d\n",
1153 (long) pid, (int) WEXITSTATUS(status) );
1154 exit( WEXITSTATUS(status) );
1164 wait4kids( int nkidval )
1168 while ( nkids >= nkidval ) {
1169 rc = WaitForMultipleObjects( nkids, children, FALSE, INFINITE );
1170 for ( i=rc - WAIT_OBJECT_0; i<nkids-1; i++)
1171 children[i] = children[i+1];
1177 fork_child( char *prog, char **args )
1181 wait4kids( maxkids );
1183 rc = _spawnvp( _P_NOWAIT, prog, args );
1186 tester_perror( "_spawnvp", NULL );
1188 children[nkids++] = (HANDLE)rc;