src/bindings/ruby/rb_msg_task.c

   1 #include "rb_msg_task.h"
   2
   3
   4 // Free Method
   5 static void task_free(m_task_t tk) {
   6   MSG_task_destroy(tk);
   7 }
   8
   9 // New Method
  10 static VALUE task_new(VALUE class, VALUE name,VALUE comp_size,VALUE comm_size)
  11 {
  12
  13   //char * t_name = RSTRING(name)->ptr;
  14   m_task_t task = MSG_task_create(RSTRING(name)->ptr,NUM2INT(comp_size),NUM2INT(comm_size),NULL);
  15   // Wrap m_task_t to a Ruby Value
  16   return Data_Wrap_Struct(class, 0, task_free, task);
  17
  18 }
  19
  20 //Get Computation Size
  21 static VALUE task_comp(VALUE class,VALUE task)
  22 {
  23   double size;
  24   m_task_t tk;
  25   // Wrap Ruby Value to m_task_t struct
  26   Data_Get_Struct(task, m_task_t, tk);
  27   size = MSG_task_get_compute_duration(tk);
  28   return rb_float_new(size);
  29 }
  30
  31
  32 //Get Name
  33
  34 static VALUE task_name(VALUE class,VALUE task)
  35 {
  36
  37   // Wrap Ruby Value to m_task_t struct
  38
  39   m_task_t tk;
  40   Data_Get_Struct(task, m_task_t, tk);
  41   return rb_str_new2(MSG_task_get_name(tk));
  42
  43 }
  44
  45
  46
  47
  48 // Execute Task
  49
  50 static VALUE task_execute(VALUE class,VALUE task)
  51 {
  52
  53   // Wrap Ruby Value to m_task_t struct
  54   m_task_t tk;
  55   Data_Get_Struct(task, m_task_t, tk);
  56   return INT2NUM(MSG_task_execute(tk));
  57
  58
  59 }
  60
  61 // Sending Task
  62
  63 static VALUE task_send(VALUE class,VALUE task,VALUE mailbox)
  64 {
  65
  66     // Wrap Ruby Value to m_task_t struct
  67   m_task_t tk;
  68   Data_Get_Struct(task, m_task_t, tk);
  69   return INT2NUM(MSG_task_send(tk,RSTRING(mailbox)->ptr));
  70
  71
  72 }
  73
  74 // Recieving Task
  75
  76 /**
  77 *It Return a Task
  78 */
  79
  80 static VALUE task_receive(VALUE class,VALUE mailbox)
  81 {
  82   m_task_t tk;
  83   MSG_task_receive(tk,RSTRING(mailbox)->ptr);
  84   return Data_Wrap_Struct(class, 0, task_free, tk);
  85 }
  86
  87 // Recieve Task 2
  88 // Not Appreciated
  89 static VALUE task_receive2(VALUE class,VALUE task,VALUE mailbox)
  90 {
  91   m_task_t tk;
  92   Data_Get_Struct(task, m_task_t, tk);
  93   return INT2NUM(MSG_task_receive(tk,RSTRING(mailbox)->ptr));
  94
  95 }
  96
  97
  98 // It Return a Native Process ( m_process_t )
  99 static VALUE task_sender(VALUE class,VALUE task)
 100 {
 101   m_task_t tk;
 102   Data_Get_Struct(task,m_task_t,tk);
 103   return MSG_task_get_sender(tk);
 104
 105 }
 106
 107 // it return a Host
 108 static VALUE task_source(VALUE class,VALUE task)
 109 {
 110   m_task_t tk;
 111   Data_Get_Struct(task,m_task_t,tk);
 112
 113   m_host_t host = MSG_task_get_source(tk);
 114   if(!host->data)
 115   {
 116     rb_raise(rb_eRuntimeError,"MSG_task_get_source() failed");
 117     return Qnil;
 118   }
 119   return host;
 120
 121 }
 122
 123 // Return Boolean
 124 static VALUE task_listen(VALUE class,VALUE task,VALUE alias)
 125 {
 126  m_task_t tk;
 127  const char *p_alias;
 128  int rv;
 129
 130  Data_Get_Struct(task,m_task_t,tk);
 131  p_alias = RSTRING(alias)->ptr;
 132
 133  rv = MSG_task_listen(p_alias);
 134
 135  if(rv) return Qtrue;
 136
 137  return Qfalse;
 138
 139 }
 140
 141 // return Boolean
 142 static VALUE task_listen_host(VALUE class,VALUE task,VALUE alias,VALUE host)
 143 {
 144
 145  m_task_t tk;
 146  m_host_t ht;
 147  const char *p_alias;
 148  int rv;
 149
 150  Data_Get_Struct(task,m_task_t,tk);
 151  Data_Get_Struct(host,m_host_t,ht);
 152  p_alias = RSTRING(alias)->ptr;
 153
 154  rv = MSG_task_listen_from_host(p_alias,ht);
 155
 156  if (rv) return Qtrue;
 157
 158  return Qfalse;
 159
 160
 161
 162 }