@@ -51,12 +51,14 @@ put_commands(int argc, char** argv)
51
51
ADLB_Fail (-1 );
52
52
}
53
53
54
- printf ("command file is %s\n" , argv [1 ]);
54
+ printf ("command file is '%s'\n" , argv [1 ]);
55
+ fflush (stdout );
55
56
56
57
FILE * fp = fopen (argv [1 ], "r" );
57
58
if (fp == NULL )
58
59
{
59
60
printf ("could not open command file\n" );
61
+ fflush (stdout );
60
62
ADLB_Fail (-1 );
61
63
}
62
64
@@ -70,10 +72,11 @@ put_commands(int argc, char** argv)
70
72
/* put command into adlb here */
71
73
int rc = ADLB_Put (cmdbuffer , strlen (cmdbuffer )+ 1 , ADLB_RANK_ANY ,
72
74
-1 , CMDLINE , ADLB_DEFAULT_PUT_OPTS );
73
- printf ("put cmd, rc = %d\n" , rc );
75
+ // printf("put cmd, rc = %d\n", rc);
74
76
}
75
77
}
76
78
printf ("\nall commands submitted\n" );
79
+ fflush (stdout );
77
80
fclose (fp );
78
81
}
79
82
@@ -106,12 +109,12 @@ worker_loop(void)
106
109
107
110
if (rc == ADLB_SHUTDOWN )
108
111
{
109
- printf ("All jobs done\n" );
110
112
break ;
111
113
}
112
114
113
115
chomp (payload );
114
116
printf ("executing command line '%s'\n" , (char * ) payload );
117
+ fflush (stdout );
115
118
rc = system (payload );
116
119
if (payload != buffer )
117
120
free (payload );
@@ -132,9 +135,6 @@ main(int argc, char *argv[])
132
135
int num_types = 1 ;
133
136
int type_vect [2 ] = { CMDLINE };
134
137
135
-
136
- printf ("batcher...\n" );
137
-
138
138
rc = MPI_Init ( & argc , & argv );
139
139
assert (rc == MPI_SUCCESS );
140
140
@@ -156,7 +156,9 @@ main(int argc, char *argv[])
156
156
if (am_server )
157
157
{
158
158
// server rank
159
+ printf ("batcher server...\n" );
159
160
ADLB_Server (3000000 );
161
+ printf ("batcher server done.\n" );
160
162
}
161
163
else
162
164
{
@@ -172,7 +174,7 @@ main(int argc, char *argv[])
172
174
if (worker_rank == 0 )
173
175
{
174
176
double end_time = MPI_Wtime ();
175
- printf ("TOOK : %.3f\n" , end_time - start_time );
177
+ printf ("worker time : %.3f\n" , end_time - start_time );
176
178
}
177
179
}
178
180
0 commit comments