WKFThreads.C File Reference

When rendering in the CAVE we use a special synchronization mode so that shared memory mutexes and condition variables will work correctly when accessed from multiple processes. Inter-process synchronization involves the kernel to a greater degree, so these barriers are substantially more costly to use than the ones designed for use within a single-process.

Definition at line 1389 of file WKFThreads.C.

References barrier_struct::lock, barrier_struct::n_clients, barrier_struct::n_waiting, NULL, barrier_struct::phase, barrier_struct::sum, and barrier_struct::wait_cv.

int wkf_thread_create ( wkf_thread_t * ,

void *fctn(void *) ,

void *

)

create a new child thread

Definition at line 655 of file WKFThreads.C.

References NULL, wkf_thread_t, and WKFTHREAD_START_ROUTINE.

int wkf_thread_join ( wkf_thread_t ,

void **

)

join (wait for completion of, and merge with) a thread

Definition at line 698 of file WKFThreads.C.

References NULL, and wkf_thread_t.

int wkf_thread_numphysprocessors ( void )

If compiling on Linux, enable the GNU CPU affinity functions in both libc and the libpthreads

Definition at line 120 of file WKFThreads.C.

References NULL.

Referenced by affinitize_threads, vmd_cuda_affinitize_threads, and wkf_thread_numprocessors.

int wkf_thread_numprocessors ( void )

number of processors available, subject to user override

Definition at line 208 of file WKFThreads.C.

References NULL, and wkf_thread_numphysprocessors.

Referenced by Orbital::calculate_mo, cc_threaded, find_next_cluster, find_within, measure_gofr, measure_rmsdmat_qcp, measure_rmsdmat_qcp_ooc, measure_sasalist, vmd_bondsearch_thr, vmd_cuda_vol_cpotential, vmd_gaussdensity_threaded, vmdinfo_tcl, VMDApp::VMDinit, vol_cpotential_cpu, volin_threaded, and volin_threaded_prob.

void*(*)(void *) wkf_thread_run_barrier ( )

Wait until all threads reach barrier, and return the function pointer passed in by the master thread.

Definition at line 1500 of file WKFThreads.C.

References wkf_run_barrier_struct::fctn, wkf_run_barrier_struct::lock, wkf_run_barrier_struct::n_clients, wkf_run_barrier_struct::n_waiting, NULL, wkf_run_barrier_struct::parms, wkf_run_barrier_struct::phase, wkf_run_barrier_struct::rslt, wkf_run_barrier_struct::rsltparms, wkf_run_barrier_struct::wait_cv, wkf_cond_broadcast, wkf_cond_wait, wkf_mutex_lock, and wkf_mutex_unlock.

Referenced by wkf_threadpool_destroy, wkf_threadpool_launch, and wkf_threadpool_wait.

void wkf_thread_run_barrier_destroy ( wkf_run_barrier_t * barrier )

destroy thread pool barrier

Definition at line 1488 of file WKFThreads.C.

References wkf_run_barrier_struct::lock, wkf_run_barrier_struct::wait_cv, wkf_cond_destroy, and wkf_mutex_destroy.

int wkf_thread_run_barrier_init ( wkf_run_barrier_t * barrier,

int n_clients

)

initialize thread pool barrier

Definition at line 1472 of file WKFThreads.C.

References wkf_run_barrier_struct::fctn, wkf_run_barrier_struct::lock, wkf_run_barrier_struct::n_clients, wkf_run_barrier_struct::n_waiting, NULL, wkf_run_barrier_struct::phase, wkf_run_barrier_struct::wait_cv, wkf_cond_init, and wkf_mutex_init.

int wkf_thread_run_barrier_poll ( wkf_run_barrier_t * barrier )

non-blocking poll to see if peers are already at the barrier

Definition at line 1546 of file WKFThreads.C.

References wkf_run_barrier_struct::lock, wkf_run_barrier_struct::n_clients, wkf_run_barrier_struct::n_waiting, wkf_mutex_lock, and wkf_mutex_unlock.

int wkf_thread_set_self_cpuaffinity ( int cpu )

set the CPU affinity of the current thread (if allowed by host system)

Definition at line 582 of file WKFThreads.C.

int wkf_thread_setconcurrency ( int )

set the concurrency level and scheduling scope for threads

Definition at line 628 of file WKFThreads.C.

int wkf_threadlaunch ( int numprocs,

void * clientdata,

void *fctn(void *) ,

wkf_tasktile_t * tile

)

launch up to numprocs threads using shared iterator as a load balancer

Definition at line 2095 of file WKFThreads.C.

References wkf_threadlaunch_struct::clientdata, wkf_threadlaunch_struct::iter, NULL, wkf_threadlaunch_struct::threadcount, wkf_threadlaunch_struct::threadid, wkf_shared_iterator_destroy, wkf_shared_iterator_getfatalerror, wkf_shared_iterator_init, wkf_shared_iterator_set, wkf_thread_create, wkf_thread_join, and wkf_thread_t.

int wkf_threadlaunch_getdata ( void * voidparms,

void ** clientdata

)

worker thread can call this to get its client data pointer

Definition at line 2185 of file WKFThreads.C.

References wkf_threadlaunch_struct::clientdata, and NULL.

int wkf_threadlaunch_getid ( void * voidparms,

int * threadid,

int * threadcount

)

worker thread can call this to get its ID and number of peers

Definition at line 2172 of file WKFThreads.C.

References NULL, wkf_threadlaunch_struct::threadcount, and wkf_threadlaunch_struct::threadid.

int wkf_threadlaunch_next_tile ( void * voidparms,

int reqsize,

wkf_tasktile_t * tile

)

iterate the shared iterator over the requested half-open interval

Definition at line 2195 of file WKFThreads.C.

References wkf_threadlaunch_struct::iter, and wkf_shared_iterator_next_tile.

int wkf_threadlaunch_setfatalerror ( void * voidparms )

worker thread calls this to indicate that an unrecoverable error occured

Definition at line 2203 of file WKFThreads.C.

References wkf_threadlaunch_struct::iter, and wkf_shared_iterator_setfatalerror.

wkf_threadpool_t* wkf_threadpool_create ( int workercount,

int * devlist

)

int wkf_threadpool_destroy ( wkf_threadpool_t * thrpool )

join all worker threads and free resources

Definition at line 1927 of file WKFThreads.C.

References wkf_threadpool_struct::devlist, wkf_threadpool_struct::errorstack, wkf_threadpool_struct::iter, NULL, wkf_threadpool_struct::runbar, wkf_threadpool_struct::threads, wkf_shared_iterator_destroy, wkf_thread_join, wkf_thread_run_barrier, wkf_thread_run_barrier_destroy, wkf_tilestack_destroy, wkf_threadpool_struct::workercount, and wkf_threadpool_struct::workerdata.

int wkf_threadpool_get_workercount ( wkf_threadpool_t * thrpool )

return the number of worker threads currently in the pool

Definition at line 1961 of file WKFThreads.C.

References wkf_threadpool_struct::workercount.

int wkf_threadpool_getfatalerror ( void * thrparms )

master thread calls this to query for fatal errors

Definition at line 2087 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::iter, and wkf_shared_iterator_getfatalerror.

int wkf_threadpool_launch ( wkf_threadpool_t * thrpool,

void *fctn(void *) ,

void * parms,

int blocking

)

launch threads onto a new function, with associated parms

Definition at line 1892 of file WKFThreads.C.

References NULL, wkf_threadpool_workerdata_struct::parms, wkf_threadpool_struct::runbar, wkf_thread_run_barrier, and wkf_threadpool_struct::workerdata.

int wkf_threadpool_next_tile ( void * voidparms,

int reqsize,

wkf_tasktile_t * tile

)

iterate the shared iterator over the requested half-open interval

Definition at line 2052 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::errorstack, wkf_threadpool_workerdata_struct::iter, WKF_SCHED_CONTINUE, WKF_SCHED_DONE, wkf_shared_iterator_next_tile, WKF_TILESTACK_EMPTY, and wkf_tilestack_pop.

int wkf_threadpool_poll ( wkf_threadpool_t * thrpool )

Definition at line 1918 of file WKFThreads.C.

References wkf_threadpool_struct::runbar, and wkf_thread_run_barrier_poll.

int wkf_threadpool_sched_dynamic ( wkf_threadpool_t * thrpool,

wkf_tasktile_t * tile

)

Set shared iterator state to half-open interval defined by tile

Definition at line 2044 of file WKFThreads.C.

References wkf_threadpool_struct::iter, NULL, and wkf_shared_iterator_set.

int wkf_threadpool_setfatalerror ( void * thrparms )

worker thread calls this to indicate that an unrecoverable error occured

Definition at line 2079 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::iter, and wkf_shared_iterator_setfatalerror.

int wkf_threadpool_tile_failed ( void * voidparms,

wkf_tasktile_t * tile

)

worker thread calls this when a failure occurs on a tile it has already taken from the scheduler

Definition at line 2072 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::errorstack, and wkf_tilestack_push.

int wkf_threadpool_wait ( wkf_threadpool_t * thrpool )

wait for all worker threads to complete their work

Definition at line 1910 of file WKFThreads.C.

References NULL, wkf_threadpool_struct::runbar, and wkf_thread_run_barrier.

int wkf_threadpool_worker_devscaletile ( void * voiddata,

int * tilesize

)

worker thread calls this to scale max tile size by worker speed as determined by the SM/core count and clock rate

Definition at line 2018 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::devspeed, and NULL.

int wkf_threadpool_worker_getdata ( void * voiddata,

void ** clientdata

)

worker thread can call this to get its client data pointer

Definition at line 2034 of file WKFThreads.C.

References NULL, and wkf_threadpool_workerdata_struct::parms.

int wkf_threadpool_worker_getdevid ( void * voiddata,

int * devid

)

worker thread can call this to get its CPU/GPU device ID

Definition at line 1980 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::devid, and NULL.

int wkf_threadpool_worker_getdevspeed ( void * voiddata,

float * speed

)

worker thread calls this to get relative speed of this device as determined by the SM/core count and clock rate

Definition at line 2006 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::devspeed, and NULL.

int wkf_threadpool_worker_getid ( void * voiddata,

int * threadid,

int * threadcount

)

worker thread can call this to get its ID and number of peers

Definition at line 1967 of file WKFThreads.C.

References NULL, wkf_threadpool_workerdata_struct::threadcount, and wkf_threadpool_workerdata_struct::threadid.

int wkf_threadpool_worker_setdevspeed ( void * voiddata,

float speed

)

worker thread calls this to set relative speed of this device as determined by the SM/core count and clock rate Note: this should only be called once, during the worker's device initialization process

Definition at line 1995 of file WKFThreads.C.

References wkf_threadpool_workerdata_struct::devspeed.

int wkf_tilestack_compact ( wkf_tilestack_t * )

shrink memory buffers associated with task tile stack if possible

Definition at line 1594 of file WKFThreads.C.

References wkf_tilestack_t::mtx, NULL, wkf_tilestack_t::s, wkf_tilestack_t::size, wkf_tilestack_t::top, wkf_mutex_lock, and wkf_mutex_unlock.

void wkf_tilestack_destroy ( wkf_tilestack_t * )

destroy task tile stack

Definition at line 1585 of file WKFThreads.C.

References wkf_tilestack_t::mtx, NULL, wkf_tilestack_t::s, and wkf_mutex_destroy.

int wkf_tilestack_empty ( wkf_tilestack_t * )

query if the task tile stack is empty or not