Ignore:
Timestamp:
Nov 29, 2012, 1:59:04 PM (13 years ago)
Author:
Silvan Scherrer
Message:

Samba Server: updated trunk to 3.6.9

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/server/source3/lib/pthreadpool/tests.c

    r745 r751  
    6969
    7070        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;
    7778        }
    7879
     
    276277
    277278                for (j=0; j<num_pools; j++) {
     279                        int jobid = -1;
    278280
    279281                        if ((pfds[j].revents & (POLLIN|POLLHUP)) == 0) {
     
    281283                        }
    282284
    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)) {
    285287                                fprintf(stderr, "invalid job number %d\n",
    286                                         ret);
     288                                        jobid);
    287289                                return -1;
    288290                        }
    289                         finished[ret] += 1;
     291                        finished[jobid] += 1;
    290292                        received += 1;
    291293                }
Note: See TracChangeset for help on using the changeset viewer.