sys/src/sysforcex.c

Go to the documentation of this file.

// _Id: sysforcex.c,v 1.11 2009-05-16 16:59:44 roart Exp $
// _Locker:  $

// Author. Roar Thronæs.
/**
   \file sysforcex.c
   \brief system service forced exit
   \author Roar Thronæs
*/

#include<linux/linkage.h>
#include<linux/sched.h>
#include<linux/vmalloc.h>
#include<acbdef.h>
#include<pridef.h>
#include<ipldef.h>
#include<ipl.h>
#include<internals.h>
#include<system_data_cells.h>
#include<cwpsdef.h>
#include<cdrpdef.h>
#include<rddef.h>
#include<ssdef.h>
#include <linux/slab.h>
#include <exe_routines.h>
#include <misc_routines.h>
#include <sch_routines.h>
#include <scs_routines.h>

asmlinkage int exe_exit(unsigned int code);

/**
   \brief system service force exit - see 5.2 13.3.3
*/

asmlinkage int exe_forcex(unsigned int *pidadr, void *prcnam, unsigned int code){
  struct _pcb *p;
  struct _acb *a;
  struct _pcb * retpcb;
  unsigned long ipid, epid;
  int sts;
#if 0
  if (pidadr && ((*pidadr)&0x80000000)) 
    return cwps_forcex(pidadr,prcnam,code);
#endif
  /** invoke nampid translation */
  sts=exe_nampid(current,pidadr,prcnam,&retpcb,&ipid,&epid);
  p=retpcb;
  /** if remote invoke cwps force - NOTE cluster out of order */
  if (sts==SS__REMOTE_PROC)
    return cwps_forcex(pidadr,prcnam,code);
  /** unlock spin */
  vmsunlock(&SPIN_SCHED,0);
  /** if not found return */
  if (!p) return 0;
  /** set forcepen flag in pcb */
  p->pcb_l_sts|=PCB$M_FORCPEN;
  a=kmalloc(sizeof(struct _acb),GFP_KERNEL);
  memset(a,0,sizeof(struct _acb));
  a->acb_l_pid=p->pcb$l_pid;
  a->acb_l_ast=&exe$exit;
  a->acb_l_astprm=code;
  /** queue a user mode (TODO check mode) to process, running exe_exit */
  return sch_qast(p->pcb$l_pid,PRI$_RESAVL,a);
  
  /*no cwps*/
}

forcex_msg(){}
forcex_dg(){}
forcex_err(){}

int cwps_forcex(unsigned int *pidadr, void *prcnam, unsigned int code){
  struct _cdrp * c=vmalloc(sizeof(struct _cdrp));
  struct _scs_rd *r;
  struct _cdt * cdt;
  struct _cwpssrv * cwpssrv=vmalloc(sizeof(struct _cwpssrv)+100);
  struct _cwpsfex * cwpsfex=((unsigned long)cwpssrv)+sizeof(struct _cwpssrv);
  cwpssrv->cwpssrv_b_subtype=CWPSSRV$K_FORCEX;
  if (pidadr) cwpssrv->cwpssrv_l_sought_epid=*pidadr&0x7fffffff;
  cwpsfex->cwpsfex_l_code=code;
  memset(c,0,sizeof(struct _cdrp));
  c->cdrp_l_rwcptr=0;
  c->cdrp_l_rspid=scs_std$alloc_rspid(0,0,c,0);
  scs_std_find_rdte( c->cdrp$l_rspid, &r);
  r->rd_l_cdrp=c;
  //printk("cluster forcex temporary broke?\n");
  cdt=find_a_cdt(forcex_msg);
  if (cdt==0) {
    printk("no forcex_msg\n");
    return 0;
  }

  c->cdrp_l_cdt=cdt;
  c->cdrp_w_cdrpsize=sizeof(struct _cwpssrv);
  c->cdrp_l_msg_buf=cwpssrv;
  c->cdrp_l_xct_len=100+sizeof(struct _cwpssrv);
  scs_std_senddg(0,100+sizeof(struct _cwpssrv),c);
  vfree(c);
  vfree(cwpssrv);
  return 0;
}

---