xrootd
Functions | Variables
XrdFfsQueue.cc File Reference
#include "XrdFfs/XrdFfsQueue.hh"
Include dependency graph for XrdFfsQueue.cc:

Functions

void XrdFfsQueue_enqueue (struct XrdFfsQueueTasks *task)
struct XrdFfsQueueTasksXrdFfsQueue_dequeue ()
struct XrdFfsQueueTasksXrdFfsQueue_create_task (void *(*func)(void *), void **args, short initstat)
void XrdFfsQueue_free_task (struct XrdFfsQueueTasks *task)
void XrdFfsQueue_wait_task (struct XrdFfsQueueTasks *task)
unsigned int XrdFfsQueue_count_tasks ()
void * XrdFfsQueue_worker (void *x)
int XrdFfsQueue_create_workers (int n)
int XrdFfsQueue_remove_workers (int n)
int XrdFfsQueue_count_workers ()

Variables

struct XrdFfsQueueTasksXrdFfsQueueTaskque_head = NULL
struct XrdFfsQueueTasksXrdFfsQueueTaskque_tail = NULL
unsigned int XrdFfsQueueNext_task_id = 0
pthread_mutex_t XrdFfsQueueTaskque_mutex = PTHREAD_MUTEX_INITIALIZER
pthread_cond_t XrdFfsQueueTaskque_cond = PTHREAD_COND_INITIALIZER
pthread_mutex_t XrdFfsQueueWorker_mutex
unsigned short XrdFfsQueueNworkers = 0
unsigned int XrdFfsQueueWorker_id = 0

Function Documentation

unsigned int XrdFfsQueue_count_tasks ( )

References XrdFfsQueueTasks::id.

int XrdFfsQueue_count_workers ( )

References XrdFfsQueueNworkers.

Referenced by XrdFfsMisc_xrd_init().

struct XrdFfsQueueTasks* XrdFfsQueue_create_task ( void *(*)(void *)  func,
void **  args,
short  initstat 
) [read]
int XrdFfsQueue_create_workers ( int  n)
struct XrdFfsQueueTasks* XrdFfsQueue_dequeue ( ) [read]
void XrdFfsQueue_enqueue ( struct XrdFfsQueueTasks task)
void XrdFfsQueue_free_task ( struct XrdFfsQueueTasks task)
int XrdFfsQueue_remove_workers ( int  n)
void XrdFfsQueue_wait_task ( struct XrdFfsQueueTasks task)
void* XrdFfsQueue_worker ( void *  x)

Variable Documentation

unsigned int XrdFfsQueueNext_task_id = 0
unsigned short XrdFfsQueueNworkers = 0
pthread_cond_t XrdFfsQueueTaskque_cond = PTHREAD_COND_INITIALIZER

Referenced by XrdFfsQueue_dequeue().

pthread_mutex_t XrdFfsQueueTaskque_mutex = PTHREAD_MUTEX_INITIALIZER

Referenced by XrdFfsQueue_enqueue().

unsigned int XrdFfsQueueWorker_id = 0
pthread_mutex_t XrdFfsQueueWorker_mutex