Searched refs:worker_cursor (Results 1 – 2 of 2) sorted by relevance
13 …for( int worker_cursor = 0; (worker_cursor < txconf->worker_count) && (retcode < 0 ); worker_curso… in dispatch_idle_worker() local14 if ( txconf->workers[worker_cursor].state == 'i' ) { in dispatch_idle_worker()15 retcode = worker_cursor; in dispatch_idle_worker()296 int worker_cursor = 0; in txlaunchworkers() local299 while ( worker_cursor < txconf->worker_count ) { in txlaunchworkers()304 txconf->workers[worker_cursor].sockfd = -66; // in txlaunchworkers()306 txconf->workers[worker_cursor].state = 'L'; in txlaunchworkers()307 txconf->workers[worker_cursor].id = worker_cursor; in txlaunchworkers()314 &(txconf->workers[worker_cursor].thread ), in txlaunchworkers()317 &(txconf->workers[worker_cursor]) in txlaunchworkers()[all …]
167 int worker_cursor=0; in rxlaunchworkers() local176 rxconf->workers[worker_cursor].id = worker_cursor; in rxlaunchworkers()177 rxconf->workers[worker_cursor].rxconf_parent = rxconf; in rxlaunchworkers()180 &rxconf->workers[worker_cursor].thread, in rxlaunchworkers()183 &(rxconf->workers[worker_cursor]) in rxlaunchworkers()185 whisper ( 18, "rxw:%02i threadlaunched\n", worker_cursor); in rxlaunchworkers()188 worker_cursor++; in rxlaunchworkers()189 } while ( worker_cursor < (kthreadmax ) ); in rxlaunchworkers()