Programming Languages Research Group: Git - IRC.git/blob

   1 #include "queue.h"
   2
   3 primarypfq_t pqueue; //Global queue
   4
   5 void queueInit(void) {
   6         /* Intitialize primary queue */
   7         pqueue.front = pqueue.rear = NULL;
   8         pthread_mutex_init(&pqueue.qlock, NULL);
   9         pthread_cond_init(&pqueue.qcond, NULL);
  10 }
  11
  12 /* Delete the node pointed to by the front ptr of the queue */
  13 void delqnode() {
  14         prefetchqelem_t *delnode;
  15         if((pqueue.front == NULL) && (pqueue.rear == NULL)) {
  16                 printf("The queue is empty: UNDERFLOW %s, %d\n", __FILE__, __LINE__);
  17                 return;
  18         } else if ((pqueue.front == pqueue.rear) && pqueue.front != NULL && pqueue.rear != NULL) {
  19                 printf("TEST1\n");
  20                 free(pqueue.front);
  21                 pqueue.front = pqueue.rear = NULL;
  22         } else {
  23                 delnode = pqueue.front;
  24                 pqueue.front = pqueue.front->next;
  25                 printf("TEST2\n");
  26                 free(delnode);
  27         }
  28 }
  29
  30 void queueDelete(void) {
  31         /* Remove each element */
  32         while(pqueue.front != NULL)
  33                 delqnode();
  34         pqueue.front = pqueue.rear = NULL;
  35 }
  36
  37 /* Inserts to the rear of primary prefetch queue */
  38 void enqueue(prefetchqelem_t *qnode) {
  39         if(pqueue.front == NULL && pqueue.rear == NULL) {
  40                 pqueue.front = pqueue.rear = qnode;
  41         } else {
  42                 qnode->next = NULL;
  43                 pqueue.rear->next = qnode;
  44                 pqueue.rear = qnode;
  45         }
  46 }
  47
  48 /* Return the node pointed to by the front ptr of the queue */
  49 prefetchqelem_t *dequeue(void) {
  50         prefetchqelem_t *retnode;
  51         if (pqueue.front == NULL) {
  52                 printf("Queue empty: Underflow %s, %d\n", __FILE__, __LINE__);
  53                 return NULL;
  54         }
  55         retnode = pqueue.front;
  56         pqueue.front = pqueue.front->next;
  57
  58         return retnode;
  59 }
  60
  61 void queueDisplay() {
  62         int offset = sizeof(prefetchqelem_t);
  63         int *ptr;
  64         int ntuples;
  65         char *ptr1;
  66         prefetchqelem_t *tmp = pqueue.front;
  67         while(tmp != NULL) {
  68                 ptr1 = (char *) tmp;
  69                 ptr = (int *)(ptr1 + offset);
  70                 ntuples = *ptr;
  71                 printf("Number of tuples = %d\n", ntuples);
  72                 tmp = tmp->next;
  73         }
  74 }
  75
  76 void predealloc(prefetchqelem_t *node) {
  77         free(node);
  78         node->next = NULL;
  79 }
  80
  81
  82 #if 0
  83 main() {
  84         unsigned int oids[] = {11, 13};
  85         short endoffsets[] = {2, 5};
  86         short arrayfields[] = {2, 2, 1, 5, 6};
  87         queueInit();
  88         queueDisplay();
  89         prefetch(2, oids, endoffsets, arrayfields);
  90         queueDisplay();
  91         unsigned int oids1[] = {21, 23, 25, 27};
  92         short endoffsets1[] = {1, 2, 3, 4};
  93         short arrayfields1[] = {3, 2, 1, 3};
  94         prefetch(4, oids1, endoffsets1, arrayfields1);
  95         queueDisplay();
  96         delqnode();
  97         queueDisplay();
  98         delqnode();
  99         queueDisplay();
 100         delqnode();
 101         queueDisplay();
 102         delqnode();
 103
 104 }
 105
 106 #endif
 107
 108