ngcbSched.h

Go to the documentation of this file.

#ifndef ngcbSched_h
#define ngcbSched_h
 
 
 
#ifndef _REENTRANT
#define _REENTRANT    
#endif
 
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <string.h>
#include <errno.h>
#include <sys/time.h>
#include <pthread.h> 
 
#include <ngc/core/ngcb.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
/*
 * CPU profiles
 */
#ifndef NGC_CCV
#define NGC_CCV 11             
#endif
#define ngcbCPU_PROFILE_DMA 1  
#define ngcbCPU_PROFILE_UDP 2  
 
/*
 * CPU affinity flags
 */
#define ngcbCPU_ANY     -1   
#define ngcbCPU_SHARED  -2   
#define ngcbCPU_HIGH    -3   
#define ngcbCPU_EXACT   0x1  
#define ngcbCPU_EXCLUDE 0x2  

typedef pthread_t ngcb_thread_t;

typedef struct timespec ngcb_abstime_t;

#define ngcbGetAbsTime(t) clock_gettime(CLOCK_REALTIME, t)

#define ngcbSEM_FAST 0  

#define ngcbSEM_CHECKED 1  

typedef struct {
  pthread_mutex_t mutex_v;  
  pthread_cond_t lck;       
  size_t val;                  
} ngcb_sema_t;

typedef struct {
  pthread_mutex_t mutex_v;  
  pthread_cond_t lckr;      
  pthread_cond_t lckw;      
  unsigned int val;         
  unsigned char wr;            
} ngcb_lock_t;
 
/*
 * Priority control
 */
#define ngcbPRI_TS  1  
#define ngcbPRI_IA  2  
#define ngcbPRI_RT  3  
#define ngcbTQ_DEF  0  
#define ngcbTQ_NC  -1  
#define ngcbTQ_INF -2  

extern int ngcbPrio;

int ngcbSetPrio(int priority, int schedClass, int quantum);

int ngcbGetPrio(int *priority, int *schedClass, int *quantum);

void ngcbClockInit(void);

void ngcbClockGet(ngcb_time_hr *t);

void ngcbClockGetAbs(ngcb_time_hr *t);

double ngcbTimeStamp();

uint64_t ngcbTimeStamp64();

int _ngcbClockWait(int fd, int waitTime);

#define ngcbClockWait(fd, waitTime) ngcbMicroSleep(fd, waitTime)
 
/*
 * Threads
 */

int ngcbThrCreate(void *(*startFunc)(void *), void *arg, size_t stack, 
          ngcb_thread_t *thread);

void ngcbThrExit(void *status);

int ngcbThrCancel(ngcb_thread_t thread);

int ngcbThrKill(ngcb_thread_t thread, int sig);

int ngcbThrJoin(ngcb_thread_t thread);

ngcb_thread_t ngcbThrId(void);

int ngcbThrEqual(ngcb_thread_t t1, ngcb_thread_t t2);

extern int ngcbCpuProfile;

int ngcbCpuNumCores(void);

int ngcbCpuRT(void);

int ngcbCpu2Thread(ngcb_thread_t thread, int cpu, int flag);

int ngcbCpuAssign(int cpu, int flag);

void ngcbCpuShow(const char *name);

int ngcbCpuDisableLatencyStates(char *erms);
  
void ngcbCpuResetLatencyStates(int fd);
 
/*
 * Semaphores
 */

int ngcbSemInit(ngcb_sema_t *sp, unsigned int count, int type, void *arg);

int ngcbSemDestroy(ngcb_sema_t *sp);

int ngcbSemLock(ngcb_sema_t *sp);

int ngcbSemUnlock(ngcb_sema_t *sp);

int ngcbSemTryLock(ngcb_sema_t *sp);

int ngcbSemPost(ngcb_sema_t *sp);

int ngcbSemSet(ngcb_sema_t *sp, unsigned int cnt);

int ngcbSemWait(ngcb_sema_t *sp);

size_t ngcbSemWaitCnt(ngcb_sema_t *sp, size_t cnt);

int ngcbSemWaitAbsTime(ngcb_sema_t *sp, ngcb_abstime_t *absTime);

int ngcbSemTryWait(ngcb_sema_t *sp);

size_t ngcbSemCnt(ngcb_sema_t *sp);
 
 
/*
 * Readers/writer locks 
 */

int ngcbRwLockInit(ngcb_lock_t *rwlp, int type, void *arg);

int ngcbRwLockDestroy(ngcb_lock_t *rwlp);

int ngcbRwRdLock(ngcb_lock_t *rwlp);

int ngcbRwTryRdLock(ngcb_lock_t *rwlp);

int ngcbRwWrLock(ngcb_lock_t *rwlp);

int ngcbRwTryWrLock(ngcb_lock_t *rwlp);

int ngcbRwUnlock(ngcb_lock_t *rwlp);
 
 
/*
 * Synchronous multi-threading 
 */

int ngcbProcCreate(void (*calcProcess)(void *), int n, char *erms);

int ngcbProcCreate2(void (*calcProcess)(void *), int n, size_t stack,
            char *erms);

int ngcbProcWaitStart(int procId);

int ngcbProcWaitTrigger(int procId);

int ngcbProcAck(int procId);

int ngcbProcStart(int setId);

int ngcbProcTrigger(int setId) ;

int ngcbProcWaitAck(int setId);

int ngcbProcSync(int procId);

void ngcbProcJoin(int setId);

void ngcbProcFree(int setId);

#define ngcbPROC_MAX_SET 8   

#define ngcbPROC_MAX_PROC 1024  

#define ngcbProcId(x) (int)((unsigned long)x & 0xffffffff) 

#define ngcbProcNum(x) (int)(x & 0x0000ffff)
 
#ifdef __cplusplus
}
#endif
 
#endif