servers/vm/queryexit.c

   1
   2 #define _SYSTEM 1
   3
   4 #include <minix/callnr.h>
   5 #include <minix/com.h>
   6 #include <minix/config.h>
   7 #include <minix/const.h>
   8 #include <minix/ds.h>
   9 #include <minix/endpoint.h>
  10 #include <minix/keymap.h>
  11 #include <minix/minlib.h>
  12 #include <minix/type.h>
  13 #include <minix/ipc.h>
  14 #include <minix/sysutil.h>
  15 #include <minix/syslib.h>
  16 #include <minix/safecopies.h>
  17 #include <minix/bitmap.h>
  18 #include <minix/vm.h>
  19 #include <minix/ds.h>
  20
  21 #include <errno.h>
  22 #include <string.h>
  23 #include <env.h>
  24 #include <stdio.h>
  25
  26 #include "glo.h"
  27 #include "proto.h"
  28 #include "util.h"
  29
  30 struct query_exit_struct {
  31         int avail;
  32         endpoint_t ep;
  33 };
  34 static struct query_exit_struct array[NR_PROCS];
  35
  36 /*===========================================================================*
  37  *                              do_query_exit                                *
  38  *===========================================================================*/
  39 PUBLIC int do_query_exit(message *m)
  40 {
  41         int i, nr;
  42         endpoint_t ep;
  43
  44         for (i = 0; i < NR_PROCS; i++) {
  45                 if (!array[i].avail) {
  46                         array[i].avail = 1;
  47                         ep = array[i].ep;
  48                         array[i].ep = 0;
  49
  50                         break;
  51                 }
  52         }
  53
  54         nr = 0;
  55         for (i = 0; i < NR_PROCS; i++) {
  56                 if (!array[i].avail)
  57                         nr++;
  58         }
  59         m->VM_QUERY_RET_PT = ep;
  60         m->VM_QUERY_IS_MORE = (nr > 0);
  61
  62         return OK;
  63 }
  64
  65 /*===========================================================================*
  66  *                              do_notify_sig                                *
  67  *===========================================================================*/
  68 PUBLIC int do_notify_sig(message *m)
  69 {
  70         int i, avails = 0;
  71         endpoint_t ep = m->VM_NOTIFY_SIG_ENDPOINT;
  72         endpoint_t ipc_ep = m->VM_NOTIFY_SIG_IPC;
  73         int r;
  74
  75         for (i = 0; i < NR_PROCS; i++) {
  76                 /* its signal is already here */
  77                 if (!array[i].avail && array[i].ep == ep)
  78                         goto out;
  79                 if (array[i].avail)
  80                         avails++;
  81         }
  82         if (!avails) {
  83                 /* no slot for signals, impossible */
  84                 printf("VM: no slot for signals!\n");
  85                 return ENOMEM;
  86         }
  87
  88         for (i = 0; i < NR_PROCS; i++) {
  89                 if (array[i].avail) {
  90                         array[i].avail = 0;
  91                         array[i].ep = ep;
  92
  93                         break;
  94                 }
  95         }
  96
  97 out:
  98         /* only care when IPC server starts up,
  99          * and bypass the process to be signal is IPC itself.
 100          */
 101         if (ipc_ep != 0 && ep != ipc_ep) {
 102                 r = notify(ipc_ep);
 103                 if (r != OK)
 104                         printf("VM: notify IPC error!\n");
 105         }
 106         return OK;
 107 }
 108
 109 /*===========================================================================*
 110  *                              init_query_exit                              *
 111  *===========================================================================*/
 112 PUBLIC void init_query_exit(void)
 113 {
 114         int i;
 115
 116         for (i = 0; i < NR_PROCS; i++) {
 117                 array[i].avail = 1;
 118                 array[i].ep = 0;
 119         }
 120 }
 121