Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
[Messaging]
[simgrid.git] / src / gras / Virtu / sg_process.c
1 /* $Id$ */
2
3 /* process_sg - GRAS process handling on simulator                          */
4
5 /* Authors: Martin Quinson                                                  */
6 /* Copyright (C) 2003,2004 da GRAS posse.                                   */
7
8 /* This program is free software; you can redistribute it and/or modify it
9    under the terms of the license (GNU LGPL) which comes with this package. */
10
11 #include "Virtu/virtu_sg.h"
12
13 GRAS_LOG_NEW_DEFAULT_SUBCATEGORY(process,GRAS);
14
15 gras_error_t
16 gras_process_init() {
17   gras_error_t errcode;
18   gras_hostdata_t *hd=(gras_hostdata_t *)MSG_host_get_data(MSG_host_self());
19   gras_procdata_t *pd;
20   int i;
21   
22   if (!(pd=(gras_procdata_t *)malloc(sizeof(gras_procdata_t)))) 
23     RAISE_MALLOC;
24
25   if (MSG_process_set_data(MSG_process_self(),(void*)pd) != MSG_OK) {
26     return unknown_error;
27   }
28   TRY(gras_procdata_init());
29
30   if (!hd) {
31     if (!(hd=(gras_hostdata_t *)malloc(sizeof(gras_hostdata_t)))) 
32       RAISE_MALLOC;
33
34     hd->portLen = 0;
35     hd->port=NULL;
36     hd->port2chan=NULL;
37     for (i=0; i<GRAS_MAX_CHANNEL; i++) {
38       hd->proc[i]=0;
39     }
40
41     if (MSG_host_set_data(MSG_host_self(),(void*)hd) != MSG_OK) {
42       return unknown_error;
43     }
44   }
45   
46   /* take a free channel for this process */
47   for (i=0; i<GRAS_MAX_CHANNEL && hd->proc[i]; i++);
48   if (i == GRAS_MAX_CHANNEL) 
49     RAISE2(system_error,
50            "GRAS: Can't add a new process on %s, because all channel are already in use. Please increase MAX CHANNEL (which is %d for now) and recompile GRAS\n.",
51             MSG_host_get_name(MSG_host_self()),GRAS_MAX_CHANNEL);
52
53   pd->chan = i;
54   hd->proc[ i ] = MSG_process_self_PID();
55
56   /* take a free RAW channel for this process */
57   for (i=0; i<GRAS_MAX_CHANNEL && hd->proc[i]; i++);
58   if (i == GRAS_MAX_CHANNEL) {
59     RAISE2(system_error,
60            "GRAS: Can't add a new process on %s, because all channel are already in use. Please increase MAX CHANNEL (which is %d for now) and recompile GRAS\n.",
61             MSG_host_get_name(MSG_host_self()),GRAS_MAX_CHANNEL);
62   }
63   pd->rawChan = i;
64   hd->proc[ i ] = MSG_process_self_PID();
65
66   VERB2("Creating process '%s' (%d)",
67            MSG_process_get_name(MSG_process_self()),
68            MSG_process_self_PID());
69   return no_error;
70 }
71
72 gras_error_t
73 gras_process_exit() {
74   gras_hostdata_t *hd=(gras_hostdata_t *)MSG_host_get_data(MSG_host_self());
75   gras_procdata_t *pd=(gras_procdata_t *)MSG_process_get_data(MSG_process_self());
76   int myPID=MSG_process_self_PID();
77   int i;
78
79   gras_assert0(hd && pd,"Run gras_process_init!!\n");
80
81   INFO2("GRAS: Finalizing process '%s' (%d)",
82         MSG_process_get_name(MSG_process_self()),MSG_process_self_PID());
83
84   if (gras_dynar_length(pd->msg_queue))
85     WARN1("process %d terminated, but some queued messages where not handled",MSG_process_self_PID());
86
87   for (i=0; i< GRAS_MAX_CHANNEL; i++)
88     if (myPID == hd->proc[i])
89       hd->proc[i] = 0;
90
91   for (i=0; i<hd->portLen; i++) {
92     if (hd->port2chan[ i ] == pd->chan) {
93       memmove(&(hd->port[i]),      &(hd->port[i+1]),      (hd->portLen -i -1) * sizeof(int));
94       memmove(&(hd->port2chan[i]), &(hd->port2chan[i+1]), (hd->portLen -i -1) * sizeof(int));
95       hd->portLen--;
96       i--; /* counter the effect of the i++ at the end of the iteration */
97     }
98   }
99
100   return no_error;
101 }
102
103 /* **************************************************************************
104  * Process data
105  * **************************************************************************/
106
107 gras_procdata_t *gras_procdata_get(void) {
108   gras_procdata_t *pd=(gras_procdata_t *)MSG_process_get_data(MSG_process_self());
109
110   gras_assert0(pd,"Run gras_process_init!");
111
112   return pd;
113 }
114