Changeset 751 for trunk/server/source3/lib/pthreadpool/tests.c
- Timestamp:
- Nov 29, 2012, 1:59:04 PM (13 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/server/source3/lib/pthreadpool/tests.c
r745 r751 69 69 70 70 for (i=0; i<num_jobs; i++) { 71 ret = pthreadpool_finished_job(p); 72 if ((ret < 0) || (ret >= num_jobs)) { 73 fprintf(stderr, "invalid job number %d\n", ret); 74 return -1; 75 } 76 finished[ret] += 1; 71 int jobid = -1; 72 ret = pthreadpool_finished_job(p, &jobid); 73 if ((ret != 0) || (jobid >= num_jobs)) { 74 fprintf(stderr, "invalid job number %d\n", jobid); 75 return -1; 76 } 77 finished[jobid] += 1; 77 78 } 78 79 … … 276 277 277 278 for (j=0; j<num_pools; j++) { 279 int jobid = -1; 278 280 279 281 if ((pfds[j].revents & (POLLIN|POLLHUP)) == 0) { … … 281 283 } 282 284 283 ret = pthreadpool_finished_job(pools[j] );284 if ((ret < 0) || (ret>= num_jobs * num_threads)) {285 ret = pthreadpool_finished_job(pools[j], &jobid); 286 if ((ret != 0) || (jobid >= num_jobs * num_threads)) { 285 287 fprintf(stderr, "invalid job number %d\n", 286 ret);288 jobid); 287 289 return -1; 288 290 } 289 finished[ ret] += 1;291 finished[jobid] += 1; 290 292 received += 1; 291 293 }
Note:
See TracChangeset
for help on using the changeset viewer.