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 void task_send(VALUE class,VALUE task,VALUE mailbox)
  64 {
  65
  66     // Wrap Ruby Value to m_task_t struct
  67
  68   m_task_t tk;
  69   Data_Get_Struct(task, m_task_t, tk);
  70   int res = MSG_task_send(tk,RSTRING(mailbox)->ptr);
  71
  72   if(res != MSG_OK)
  73    rb_raise(rb_eRuntimeError,"MSG_task_send failed");
  74
  75   return;
  76 }
  77
  78 // Recieving Task
  79
  80 /**
  81 *It Return a Task
  82 */
  83
  84 static VALUE task_receive(VALUE class,VALUE mailbox)
  85 {
  86   m_task_t tk;
  87   MSG_task_receive(tk,RSTRING(mailbox)->ptr);
  88   return Data_Wrap_Struct(class, 0, task_free, tk);
  89 }
  90
  91 // Recieve Task 2
  92 // Not Appreciated
  93 static VALUE task_receive2(VALUE class,VALUE task,VALUE mailbox)
  94 {
  95   m_task_t tk;
  96   Data_Get_Struct(task, m_task_t, tk);
  97   return INT2NUM(MSG_task_receive(tk,RSTRING(mailbox)->ptr));
  98
  99 }
 100
 101
 102 // It Return a Native Process ( m_process_t )
 103 static VALUE task_sender(VALUE class,VALUE task)
 104 {
 105   m_task_t tk;
 106   Data_Get_Struct(task,m_task_t,tk);
 107   return MSG_task_get_sender(tk);
 108
 109 }
 110
 111 // it return a Host
 112 static VALUE task_source(VALUE class,VALUE task)
 113 {
 114   m_task_t tk;
 115   Data_Get_Struct(task,m_task_t,tk);
 116
 117   m_host_t host = MSG_task_get_source(tk);
 118   if(!host->data)
 119   {
 120     rb_raise(rb_eRuntimeError,"MSG_task_get_source() failed");
 121     return Qnil;
 122   }
 123   return host;
 124
 125 }
 126
 127 // Return Boolean
 128 static VALUE task_listen(VALUE class,VALUE task,VALUE alias)
 129 {
 130  m_task_t tk;
 131  const char *p_alias;
 132  int rv;
 133
 134  Data_Get_Struct(task,m_task_t,tk);
 135  p_alias = RSTRING(alias)->ptr;
 136
 137  rv = MSG_task_listen(p_alias);
 138
 139  if(rv) return Qtrue;
 140
 141  return Qfalse;
 142
 143 }
 144
 145 // return Boolean
 146 static VALUE task_listen_host(VALUE class,VALUE task,VALUE alias,VALUE host)
 147 {
 148
 149  m_task_t tk;
 150  m_host_t ht;
 151  const char *p_alias;
 152  int rv;
 153
 154  Data_Get_Struct(task,m_task_t,tk);
 155  Data_Get_Struct(host,m_host_t,ht);
 156  p_alias = RSTRING(alias)->ptr;
 157
 158  rv = MSG_task_listen_from_host(p_alias,ht);
 159
 160  if (rv) return Qtrue;
 161
 162  return Qfalse;
 163
 164
 165
 166 }