Library mcertikos.proc.PCVIntroCSource

#define num_chan 16337

extern void init_sync_chan (unsigned int index);
extern void tdqueue_init (unsigned int mbi_adr);

void fifobbq_pool_init (unsigned int mbi_adr){
    unsigned int i;

    tdqueue_init(mbi_adr);

    i = 0;
    while (i < num_chan){
        init_sync_chan(i);
        i++;
    }   
}

    #define MAX_BUFFSIZE 1024

    unsigned int
    ipc_send_body(unsigned int chid, unsigned int sender_kpa, unsigned int scount)
    {
        //unsigned int myid = get_curid();
        //unsigned int sender_kpa = get_kernel_pa(myid, vaddr);

        //set_sync_chan_to(chid, myid);
        if (scount < MAX_BUFFSIZE) {
          //set_sync_chan_paddr(chid, sender_kpa);
          set_sync_chan_count(chid, scount);
          page_copy(chid, scount, vaddr);
          return scount;
        } else {
          //set_sync_chan_paddr(chid, sender_kpa);
          set_sync_chan_count(chid, MAX_BUFFSIZE);
          page_copy(chid, MAX_BUFFSIZE, sender_kpa);
          return MAX_BUFFSIZE;
        }
    }

    #define NUM_PROC 1204

    unsigned int
    ipc_receive_body(unsigned int chid, unsigned int vaddr, unsigned int rcount)
    {
      //unsigned int myid = get_curid();
      unsigned int sender_count = get_sync_chan_count(chid);
      unsigned int arecvcount = (sender_count < rcount) ? sender_count : rcount;
      //unsigned int rbuffpa = get_kernel_pa(myid, vaddr);

      page_copy_back(chid, arecvcount, vaddr);

      //set_sync_chan_to(chid, NUM_PROC);
      //set_sync_chan_paddr(chid, 0);
      set_sync_chan_count(chid, 0);

      return arecvcount;
    }

    #define num_cv 255
    #define num_proc 1024

    void
    idq_push(unsigned int chid, unsigned int qid, unsigned int tid)
    {
      unsigned int h;
      unsigned int t;

      h = fifobbq_get_head(chid, qid);
      if (h == num_proc)
      {
        fifobbq_set_head(chid, qid, tid);
        fifobbq_set_tail(chid, qid, tid);
      }
      else
      {
        t = fifobbq_get_tail(chid, qid);
        fifobbq_set_head(chid, qid, h);
        fifobbq_set_tail(chid, qid, tid);
        idq_set_next(t, tid);
        idq_set_prev(tid, t);
        idq_set_next(tid, num_proc);
      }
    }

    #define num_cv 255
    #define num_proc 1024

    unsigned int
    idq_pull(unsigned int chid, unsigned int qid)
    {
      unsigned int h;
      unsigned int t;
      unsigned int n;

      h = fifobbq_get_head(chid, qid);
      t = fifobbq_get_tail(chid, qid);
      if (h == t)
      {
        fifobbq_set_head(chid, qid, num_proc);
        fifobbq_set_tail(chid, qid, num_proc);
      }
      else
      {
        n = idq_get_next(h);
        fifobbq_set_head(chid, qid, n);
        fifobbq_set_tail(chid, qid, t);
      }
      return h;
    }

    unsigned int
    idq_peek(unsigned int chid, unsigned int qid)
    {
      unsigned int h;

      h = fifobbq_get_head(chid, qid);
      return h;
    }