sys/src/sysmailbx.c

Go to the documentation of this file.

// _Id: sysmailbx.c,v 1.11 2007-04-28 07:23:52 roart Exp $
// _Locker:  $

// Author. Roar Thronæs.

#include<linux/vmalloc.h>
#include<linux/linkage.h>

#include <system_data_cells.h>
#include <descrip.h>
#include <starlet.h>
#include <misc.h>
#include <ssdef.h>
#include <ipldef.h>
#include <ipl.h>
#include <ccbdef.h>
#include <cmbdef.h>
#include <lnmdef.h>
#include <ucbdef.h>
#include <queue.h>
#include <exe_routines.h>
#include <ioc_routines.h>
#include <misc_routines.h>
#include <sch_routines.h>

long clone_init_ucb() {
  extern struct _mb_ucb * mbucb0;
  //  struct _ucb * mb_ar_ucb0 = &mb$ucb;
  struct _ucb * u;
  ioc_std_clone_ucb(mbucb0,&u);
  struct _mb_ucb * m = u;
  qhead_init(&m->ucb_l_mb_readqfl);
  qhead_init(&m->ucb_l_mb_writerwaitqfl);
  qhead_init(&m->ucb_l_mb_readerwaitqfl);
  qhead_init(&m->ucb_l_mb_nowriterwaitqfl);
  qhead_init(&m->ucb_l_mb_noreaderwaitqfl);
  return u;
}

long find_mb_log(void * lognam) {
  _DESCRIPTOR(mytabnam,"LNM$SYSTEM_TABLE");
  struct item_list_3 i[6];
  char c[64];
  int retlen, retlenu;
  long back = LNMX_C_BACKPTR;
  long u;
  int status;
  i[0].item_code=LNM__STRING;
  i[0].buflen=4;
  i[0].bufaddr=&u;
  i[0].retlenaddr=&retlen;
  i[1].item_code=LNM__INDEX;
  i[1].buflen=4;
  i[1].bufaddr=&back;
  i[1].retlenaddr=&retlenu;
  i[2].item_code=0;
  status=exe_trnlnm(0,&mytabnam,lognam,0,i);
  if (status&1)
    return u;
  else 
    return 0;
}

int create_mb_log(void * lognam, long bufquo, struct _ucb * u) {
  _DESCRIPTOR(mytabnam,"LNM$SYSTEM_TABLE");
  struct item_list_3 i[6];
  int status;
  if (lognam) {
    char c[64];
    int retlen, retlenu;
    int index=0;
    long back = LNMX_C_BACKPTR;

    u->ucb_w_bufquo=bufquo;
    u->ucb_w_iniquo=bufquo;

    sprintf(c,"MBA%d",u->ucb_w_unit);

    i[0].item_code=LNM__STRING;
    i[0].buflen=4;
    i[0].bufaddr=u;
    i[0].retlenaddr=&retlen;
    i[1].item_code=LNM__INDEX;
    i[1].buflen=4;
    i[1].bufaddr=&back;
    i[1].retlenaddr=&retlenu;
    i[2].item_code=LNM__LNMB_ADDR;
    i[2].buflen=4;
    i[2].bufaddr=&((struct _mb_ucb *)u)->ucb_l_logadr;
    i[2].retlenaddr=&retlenu;
    i[3].item_code=LNM__STRING;
    i[3].buflen=strlen(c);
    i[3].bufaddr=c;
    i[3].retlenaddr=&retlenu;
    i[4].item_code=LNM__INDEX;
    i[4].buflen=4;
    i[4].bufaddr=&index;
    i[4].retlenaddr=&retlenu;
    i[5].item_code=0;
    status=exe_crelnm(0,&mytabnam,lognam,0,i);
  }
}

asmlinkage int exe_crembx  (char prmflg, unsigned short int *chan, unsigned int maxmsg, unsigned int bufquo, unsigned int promsk, unsigned int acmode, void *lognam, long flags,...) {
  int status;
  struct _ccb * c;
  struct _ucb * u;
  _DESCRIPTOR(mytabnam,"LNM$SYSTEM_TABLE");
  _DESCRIPTOR(mypartab,"LNM$SYSTEM_DIRECTORY");
  struct item_list_3 i[6];
  /* verify writable chan arg */
  /* ma780 stuff will not be relevant for some time */
  setipl(IPL__ASTDEL);
  /* no priv check yet */
  /* lock i/o database mutex */
  //  printk("here assign\n");
  /* lock i/o db */
  sch_iolockw(); // moved up because of global db
  status=ioc_ffchan(chan);
  if (status!=SS__NORMAL) return status;
  // check priv for prmflg
  /* lock i/o db */
  // sch_iolockw();
  // printk("here assign %x\n", chan);
  // ucb ccb stuff 
  c=&ctl_gl_ccbbase[*chan];
  c->ccb_b_amod=1; /* wherever this gets set */
  if (lognam==0) {
    /* assume nonexist and must create */
    if (bufquo==0) bufquo=DEFMBXBUFQUO;
    if (maxmsg==0) maxmsg=DEFMBXMXMSG;
    u=clone_init_ucb();
    u->ucb_w_bufquo=bufquo;
    u->ucb_w_iniquo=bufquo;
    u->ucb_w_msgmax=maxmsg;
    u->ucb_w_devbufsiz=maxmsg;
    ((struct _mb_ucb *)u)->ucb_l_logadr=0;

  } else {
    u=find_mb_log(lognam);

    if (u==0) {
      u=clone_init_ucb();
      u->ucb_w_bufquo=bufquo;
      u->ucb_w_iniquo=bufquo;
      u->ucb_w_msgmax=maxmsg;
      u->ucb_w_devbufsiz=maxmsg;
      u->ucb_l_pid=0;
      u->ucb_l_devdepend=0;
      u->ucb_l_devsts=0;//?
      if (prmflg) {
        u->ucb_l_devsts|=UCB$M_PRMMBX;
      } else {
        u->ucb_l_devsts|=UCB$M_DELMBX;
      }
    }
    c->ccb_l_ucb=u;
    create_mb_log(lognam,bufquo,u);
    goto out;
  }

  c->ccb_l_ucb=u;
  // amod here instead
  if (flags&CMB_M_READONLY)
    c->ccb_l_sts|=CCB$M_NOWRITEACC;
  if (flags&CMB_M_WRITEONLY)
    c->ccb_l_sts|=CCB$M_NOREADACC;

  mb_chanunwait(u,c);

  /* incr ref count */

 out:
  // unlock mutex
  sch_iounlockw();

  setipl(0);
  return SS__NORMAL;
}

int exe_delmbx  (unsigned short int chan)
{
}

asmlinkage int exe_crembx_wrap(struct struct_crembx * s) {
  return exe_crembx(s->prmflg, s->chan, s->maxmsg, s->bufquo, s->promsk, s->acmode, s->lognam, s->flags);
}

---