Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Make ruby in consideration with cmake.
[simgrid.git] / src / bindings / ruby / smx_context_ruby.c
1 /* $Id$ */
2
3 /* context_Ruby - implementation of context switching with lua coroutines */
4
5 /* Copyright (c) 2004-2008 the SimGrid team. All right reserved */
6
7 /* This program is free software; you can redistribute it and/or modify it
8  * under the terms of the license (GNU LGPL) which comes with this package. */
9 #include <ruby.h>
10 #include "private.h"
11 #include "xbt/function_types.h"
12 #include "context_sysv_config.h"
13
14 typedef struct s_smx_ctx_ruby
15 {
16   SMX_CTX_BASE_T;
17   VALUE process;   // The Process Ruby Instance 
18   //...
19 }s_smx_ctx_ruby_t,*smx_ctx_ruby_t;
20   
21 static smx_context_t
22 smx_ctx_ruby_create_context(xbt_main_func_t code,int argc,char** argv,
23                             void_f_pvoid_t cleanup_func,void *cleanup_arg);
24
25
26 static int smx_ctx_ruby_factory_finalize(smx_context_factory_t *factory);
27
28 static void smx_ctx_ruby_free(smx_context_t context);
29
30 static void smx_ctx_ruby_start(smx_context_t context);
31
32 static void smx_ctx_ruby_stop(smx_context_t context);
33
34 static void smx_ctx_ruby_suspend(smx_context_t context);
35
36 static void 
37   smx_ctx_ruby_resume(smx_context_t old_context,smx_context_t new_context);
38
39 static void smx_ctx_ruby_wrapper(void); //??!!
40
41
42
43 void SIMIX_ctx_ruby_factory_init(smx_context_factory_t *factory)
44 {
45   
46  *factory = xbt_new0(s_smx_context_factory_t,1);
47  
48  (*factory)->create_context = smx_ctx_ruby_create_context;
49  (*factory)->finalize = smx_ctx_ruby_factory_finalize;
50  (*factory)->free = smx_ctx_ruby_free;
51  (*factory)->start = smx_ctx_ruby_start;
52  (*factory)->stop = smx_ctx_ruby_stop;
53  (*factory)->suspend = smx_ctx_ruby_suspend;
54  (*factory)->resume = smx_ctx_ruby_resume;
55  (*factory)->name = "smx_ruby_context_factory";
56  
57   ruby_init();
58   ruby_init_loadpath();
59   
60 }
61   
62 static int smx_ctx_ruby_factory_finalize(smx_context_factory_t *factory)
63 {
64   
65  free(*factory);
66  *factory = NULL;
67  return 0;
68  
69 }
70
71 static smx_context_t 
72   smx_ctx_ruby_create_context(xbt_main_func_t code,int argc,char** argv,
73                               void_f_pvoid_t cleanup_func,void* cleanup_arg)
74 {
75   
76   smx_ctx_ruby_t context = xbt_new0(s_smx_ruby_t,1);
77   
78   /*if the user provided a function for the process , then use it 
79   Otherwise it's the context for maestro */
80   if( code )
81   {
82    context->cleanup_func = cleanup_func;
83    context->cleanup_arg = cleanup_arg;
84    context->process = rb_funcall3(rb_const_get(rb_cObject, rb_intern("RbProcess")),  rb_intern("new"), 0, 0);
85    //context->process = rb_thread_main(); // Or VALUE rb_thread_create          (       VALUE(*(ANYARGS), void *)                ) 
86    
87    
88   }
89   return (smx_context_t) context;
90   
91 }
92   
93 static void smx_ctx_ruby_free(smx_context_t context)
94 {
95   
96   if (context)
97   {
98    smx_ctx_ruby_t ctx_ruby = (smx_ctx_ruby_t) context;
99    
100    if (ctx_ruby->process)
101      VALUE process = ctx_ruby->process;
102     
103      ctx_ruby->process = Qnil;
104      
105      // if the Ruby Process is Alive , Join it  
106      
107     if ( process_isAlive(process) )
108       process_join(process);
109     
110   }
111   
112   free(context);
113   context = NULL;
114     
115     
116   }
117   
118   
119 }
120
121
122 static void smx_ctx_ruby_start(smx_context_t context)
123 {
124   
125   
126   
127 }
128
129
130 static void smx_ctx_ruby_stop(smx_context_t context)
131 {
132   
133   VALUE process = Qnil;
134   smx_ctx_ruby_t ctx_ruby;
135   
136   if ( context->cleanup_func)
137     (*(context->cleanup_func)) (context->cleanup_arg);
138   
139   ctx_ruby = (smx_ctx_ruby_t) context;
140   
141   // Well , Let's Do The Same as JNI Stoppin' Process
142   if ( simix_gloabl->current_process->iwannadie )
143   {
144    if( ctx_ruby->process )
145    {
146     //if the Ruby Process still Alive ,let's Schedule it
147     if ( process_isAlive( ctx_ruby->process ) )
148     {
149      
150      current = (smx_ctx_ruby_t)simix_gloabl->current_process->context:
151      process_schedule(current->process); 
152       
153      process = ctx_ruby->process;
154      
155      // interupt/kill The Ruby Process
156      process_kill(process);
157       
158     }
159    }    
160   }else {
161    
162     process = ctx_ruby->process;
163     ctx_ruby->process = Qnil;
164     
165   }
166
167   
168 }
169
170 static void smx_ctx_ruby_suspend(smx_context_t context)
171 {
172
173 if ( context )
174 {
175 smx_ctx_ruby_t ctx_ruby = (smx_ctx_ruby_t) context;
176   if (ctx_ruby->process)
177     process_unschedule( ctx_ruby->process ) ;
178 }
179   
180   else
181     rb_raise(rb_eRuntimeError,"smx_ctx_ruby_suspend failed");
182   
183 }
184
185 static void smx_ctx_ruby_resume(smx_context_t old_context,smx_context_t new_context)
186 {
187   
188  smx_ctx_ruby_t ctx_ruby = (smx_ctx_ruby_t) new_context;
189  
190  process_schedule( ctx_ruby->process );
191   
192   
193 }