sys/src/sys_affinity.c

Go to the documentation of this file.

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

// Author. Roar Thronæs.
/**
   \file sys_affinity.c
   \brief system service affinities
   \author Roar Thronæs
*/

#include <linux/config.h>
#include <linux/linkage.h>
#include <far_pointers.h>
#include <linux/sched.h>
#include <ssdef.h>
#include <cpbdef.h>
#include <ipldef.h>
#include <statedef.h>
#include <internals.h>
#include <prvdef.h>
#include <sch_routines.h>
#include <exe_routines.h>
#include <capdef.h>
#include <starlet.h>

/**
   \brief system service for explicit affinity mask - see 7.0 2.5.2
   \details lots of flags and checks unimplemented
*/

// lots of flags and checks unimplemented
asmlinkage int exe_process_affinity (unsigned int *pidadr, void *prcnam, struct _generic_64 *select_mask, struct _generic_64 *modify_mask, struct _generic_64 *prev_mask, struct _generic_64 *flags,...) {
  struct _pcb * retpcb;
  unsigned long ipid, epid;
  int sts;
  sts=exe_nampid(current,pidadr,prcnam,&retpcb,&ipid,&epid);
  if ((sts & 1) == 0)
    return sts;
  struct _pcb * pcb;
  pcb = retpcb;
  int aff;
  int priv = ctl_gl_pcb->pcb$l_priv;
  // check right?
  if (pcb != ctl_gl_pcb && (select_mask || modify_mask) && (priv & PRV$M_ALTPRI) == 0)
    return SS__NOPRIV;
  if ((select_mask || modify_mask)) {
    int prev = pcb->pcb_l_affinity;
    int mask;
    mask = *(int*)select_mask & ~(*(int*)modify_mask);
    sch_clear_affinity(pcb, mask, flags, 0 /*prev_mask*/);
    mask = *(int*)select_mask & (*(int*)modify_mask);
    /** call set_affinity */
    sch_set_affinity(pcb, mask, flags, 0 /*prev_mask*/);
    if (prev_mask)
      *(int*)prev_mask = prev;
  } else {
    if (prev_mask)
      *(int*)prev_mask = pcb->pcb_l_affinity;
  }
  vmsunlock(&SPIN_SCHED,IPL__ASTDEL);
  return SS__NORMAL;
}

/**
   \brief system service for implicit affinity mask - see 7.0 2.5.4
   \details lots of flags and checks unimplemented
*/

asmlinkage int exe_set_implicit_affinity (unsigned int *pidadr, void *prcnam, struct _generic_64 *state, int cpu_id, struct _generic_64 *prev_mask) {
  int flag = 0;
  if (state)
    flag = *(int*)state;
  struct _pcb * retpcb;
  unsigned long ipid, epid;
  int sts;
  sts=exe_nampid(current,pidadr,prcnam,&retpcb,&ipid,&epid); 
  if ((sts & 1) == 0)
    return sts;
  struct _pcb * pcb;
  pcb = retpcb;
  int priv = ctl_gl_pcb->pcb$l_priv;
  if (flag && (priv & PRV_M_ALTPRI) == 0)
    return SS__NOPRIV;
  if ((priv & PRV_M_ALTPRI) == 0)
    return SS__NOPRIV;
  if (flag & CAP_M_IMPLICIT_DEFAULT_ONLY) {
    if (prev_mask)
      *(int*)prev_mask = sch_gl_default_process_cap;
    sch_gl_default_process_cap = state;
  }
  /** maybe do acquire affinity */
  if (flag & CAP_M_IMPLICIT_AFFINITY_SET) {
    if (prev_mask)
      *(int*)prev_mask = pcb->pcb_l_capability;
    sch_acquire_affinity(pcb, 0, cpu_id);
  }
  /** maybe do release affinity */
  if (flag & CAP_M_IMPLICIT_AFFINITY_CLEAR) {
    if (prev_mask)
      *(int*)prev_mask = pcb->pcb_l_capability;
    sch_release_affinity(pcb);
  }
  vmsunlock(&SPIN_SCHED,IPL__ASTDEL);
  return SS__NORMAL;
}

asmlinkage int exe_process_affinity_wrap (struct struct_args * s) {
  return exe_process_affinity (s->s1, s->s2, s->s3, s->s4, s->s5, s->s6);
}

---