Robust/src/Runtime/DSTM/interface/threadnotify.h

   1 #ifndef _THREADNOTIFY_H_
   2 #define _THREADNOTIFY_H_
   3
   4 #include <stdio.h>
   5 #include <stdlib.h>
   6 #include <pthread.h>
   7
   8 #define N_LOADFACTOR 0.5
   9 #define N_HASH_SIZE 20
  10
  11 //Structure to notify object of which other objects/threads are waiting on it
  12 typedef struct threadlist {
  13   unsigned int threadid;
  14   unsigned int mid;
  15   struct threadlist *next;
  16 } threadlist_t;
  17
  18 //Structure for objects involved in wait-notify call
  19 typedef struct notifydata {
  20   unsigned int numoid;          /* Number of oids on which we are waiting for updated notification */
  21   unsigned int threadid;        /* The threadid that is waiting for  update notification response*/
  22   unsigned int *oidarry;        /* Pointer to array of oids that this threadid is waiting on*/
  23   unsigned short *versionarry;      /* Pointer to array of versions of the oids that we are waiting on */
  24   pthread_cond_t threadcond;       /* Cond variable associated with each threadid that needs to be signaled*/
  25   pthread_mutex_t threadnotify;
  26 } notifydata_t;
  27
  28 typedef struct notifylistnode {
  29   unsigned int threadid;
  30   notifydata_t *ndata;
  31   struct notifylistnode *next;
  32 } notifylistnode_t;
  33
  34 typedef struct notifyhashtable {
  35   notifylistnode_t *table;       //Points to beginning of hash table
  36   unsigned int size;
  37   unsigned int numelements;
  38   float loadfactor;
  39   pthread_mutex_t locktable;       //Lock for the hashtable
  40 } notifyhashtable_t;
  41
  42 threadlist_t *insNode(threadlist_t *head, unsigned int threadid, unsigned int mid); //Inserts nodes for one object that
  43 //needs to send notification to threads waiting on it
  44 void display(threadlist_t *head); // Displays linked list of nodes for one object
  45 unsigned int notifyhashCreate(unsigned int size, float loadfactor); //returns 1 if hashtable creation is not successful
  46 unsigned int notifyhashFunction(unsigned int tid); //returns index in the hash table
  47 unsigned int notifyhashInsert(unsigned int tid, notifydata_t *ndata); //returns 1 if insert not successful
  48 notifydata_t *notifyhashSearch(unsigned int tid); //returns pointer to notify data, NULL if not found
  49 unsigned int notifyhashRemove(unsigned int tid); //returns 1 if not successful
  50 unsigned int notifyhashResize(unsigned int newsize);
  51
  52 #endif