Library mcertikos.proc.PIPCIntroCSource

***********************************************************************
*                                                                     *
*            The CertiKOS Certified Kit Operating System              *
*                                                                     *
*                   The FLINT Group, Yale University                  *
*                                                                     *
*  Copyright The FLINT Group, Yale University.  All rights reserved.  *
*  This file is distributed under the terms of the Yale University    *
*  Non-Commercial License Agreement.                                  *
*                                                                     *
*********************************************************************** 

      #define num_chan 64
      
      extern void sched_init(unsigned int);
      extern void init_sync_chan(unsigned int);
      
      void proc_init(unsigned int mbi_adr)
      {
          unsigned int i;
          sched_init(mbi_adr);
          i = 0;
          while(i < num_chan)
          {
              init_sync_chan(i);
              i++;
          }
      }

#define MAX_BUFFSIZE 1024
#define NUM_CHAN     64

extern unsigned int get_curid(void);
extern unsigned int get_state(unsigned int pidx);

extern void set_sync_chan_paddr(unsigned int chanid, unsigned int paddr);
extern void set_sync_chan_to(unsigned int chanid, unsigned int to);
extern void set_sync_chan_count(unsigned int chanid, unsigned int count);

extern unsigned int get_sync_chan_to(unsigned int chanid);

extern unsigned int get_kernel_pa(unsigned int pid, unsigned int vaddr);

unsigned int
syncsendto_chan_pre(unsigned int pid, unsigned int vaddr, unsigned int scount)
{
  unsigned int myid = get_curid();
  unsigned int target_state = get_state(pid);

  if (target_state == 3) return MAX_BUFFSIZE+2;

  if (0 <= pid && pid < NUM_CHAN) {
    unsigned int sender_kpa = get_kernel_pa(myid, vaddr);

    if (scount < MAX_BUFFSIZE) {
      set_sync_chan_paddr(myid, sender_kpa);
      set_sync_chan_count(myid, scount);
    } else {
      set_sync_chan_paddr(myid, sender_kpa);
      set_sync_chan_count(myid, MAX_BUFFSIZE);
    }

    if (get_sync_chan_to(myid) == NUM_CHAN) {
      set_sync_chan_to(myid, pid);
    } else {
      // Should Crash
    }

    return 0;
  } else {
    return MAX_BUFFSIZE+1;
  }
}

#define NUM_CHAN 64
#define MAX_BUFFSIZE 1024

extern unsigned int get_curid(void);
extern unsigned int get_sync_chan_to(unsigned int chanid);
extern unsigned int get_sync_chan_count(unsigned int chanid);
extern void set_sync_chan_to(unsigned int chanid, unsigned int to);

unsigned int
syncsendto_chan_post(void)
{
  unsigned int myid = get_curid();
  unsigned int to = get_sync_chan_to(myid);

  if (to == NUM_CHAN) {
    return get_sync_chan_count(myid);
  } else {
    set_sync_chan_to(myid, NUM_CHAN);
    return MAX_BUFFSIZE+3;
  }
}

#define NUM_CHAN 64
#define TCB_STATE_DEAD 3
#define MAX_BUFFSIZE 1024

extern unsigned int get_curid(void);
extern unsigned int get_state(unsigned int pid);

extern unsigned int get_sync_chan_to(unsigned int chanid);
extern unsigned int get_sync_chan_count(unsigned int chanid);
extern unsigned int get_sync_chan_paddr(unsigned int chanid);

extern unsigned int get_kernel_pa(unsigned int pid, unsigned int vaddr);

extern void set_sync_chan_to(unsigned int chanid, unsigned int to);
extern void set_sync_chan_count(unsigned int chanid, unsigned int count);
extern void set_sync_chan_paddr(unsigned int chanid, unsigned int paddr);

extern void flatmem_copy(unsigned int len, unsigned int to, unsigned int from);
extern void thread_wakeup(unsigned int pid);

unsigned int
syncreceive_chan(unsigned int pid, unsigned int vaddr, unsigned int rcount)
{
  unsigned int myid = get_curid();
  unsigned int sender_state = get_state(pid);

  if (sender_state == TCB_STATE_DEAD) {

    return MAX_BUFFSIZE+2;

  } else {

    unsigned int sender_to = get_sync_chan_to(pid);

    if (sender_to == myid) {
      unsigned int sender_count = get_sync_chan_count(pid);
      unsigned int sbuffpa = get_sync_chan_paddr(pid);

      unsigned int arecvcount = (sender_count < rcount) ? sender_count : rcount;

      unsigned int rbuffva = vaddr;

      unsigned int rbuffpa = get_kernel_pa(myid, rbuffva);

      flatmem_copy(arecvcount, rbuffpa, sbuffpa);

      set_sync_chan_to(pid, NUM_CHAN);
      set_sync_chan_paddr(pid, 0);
      set_sync_chan_count(pid, arecvcount);

      thread_wakeup(pid);

      return arecvcount;

    } else {
      return MAX_BUFFSIZE+3;
    }
  }
}