Class: NanoMsg::Socket

Inherits:

Object

• Object
• NanoMsg::Socket

Defined in:

lib/nanomsg.rb,
ext/init.c

Direct Known Subclasses

BusSocket, PairSocket, PubSocket, PullSocket, PushSocket, RepSocket, ReqSocket, RespondSocket, SubSocket, SurveySocket

Instance Method Summary

• #bind(bind) ⇒ Object
• #close ⇒ Object
• #connect(connect) ⇒ Object
• #recv ⇒ Object
• #send(buffer) ⇒ Object
• #setsockopt(level, option, val) ⇒ Object

Instance Method Details

#bind(bind) ⇒ Object

# File 'ext/init.c', line 104

static VALUE
sock_bind(VALUE socket, VALUE bind)
{
  int sock = sock_get(socket);
  int endpoint; 

  endpoint = nn_bind(sock, StringValueCStr(bind));
  if (endpoint < 0) 
    RAISE_SOCK_ERROR; 

  // TODO do something with the endpoint, returning it in a class for example. 
  return Qnil; 
}

#close ⇒ Object

# File 'ext/init.c', line 223

static VALUE
sock_close(VALUE socket)
{
  struct ioop io; 

  io.sock = sock_get(socket);

  // I've no idea on how to abort a close (which may block for NN_LINGER 
  // seconds), so we'll be uninterruptible. 
  rb_thread_blocking_region(sock_close_no_gvl, &io, RUBY_UBF_IO, 0);

  if (io.return_code < 0)
    sock_raise_error(io.nn_errno);

  return Qnil;
}

#connect(connect) ⇒ Object

# File 'ext/init.c', line 118

static VALUE
sock_connect(VALUE socket, VALUE connect)
{
  int sock = sock_get(socket);
  int endpoint; 

  endpoint = nn_connect(sock, StringValueCStr(connect));
  if (endpoint < 0) 
    RAISE_SOCK_ERROR; 

  // TODO do something with the endpoint, returning it in a class for example. 
  return Qnil; 
}

#recv ⇒ Object

# File 'ext/init.c', line 192

static VALUE
sock_recv(VALUE socket)
{
  VALUE result; 
  struct ioop io; 

  io.sock = sock_get(socket);

  rb_thread_blocking_region(sock_recv_blocking, &io, RUBY_UBF_IO, 0);

  if (io.return_code < 0)
    sock_raise_error(io.nn_errno);

  result = rb_str_new(io.buffer, io.return_code);
  nn_freemsg(io.buffer); io.buffer = (char*) 0;

  return result;
}

#send(buffer) ⇒ Object

# File 'ext/init.c', line 162

static VALUE
sock_send(VALUE socket, VALUE buffer)
{
  struct ioop io; 

  io.sock = sock_get(socket);
  io.buffer = StringValuePtr(buffer);
  io.len = RSTRING_LEN(buffer);

  rb_thread_blocking_region(sock_send_blocking, &io, RUBY_UBF_IO, 0);

  if (io.return_code < 0)
    sock_raise_error(io.nn_errno);

  return INT2NUM(io.return_code);
}

#setsockopt(level, option, val) ⇒ Object

# File 'ext/init.c', line 240

static VALUE
sock_setsockopt(VALUE self, VALUE level, VALUE option, VALUE val)
{
  int sock = sock_get(self);
  int level_arg = FIX2INT(level); 
  int option_arg = FIX2INT(option);
  int err; 
  int i; 
  void* v; 
  size_t vlen = 0;

  switch (TYPE(val)) {
    case T_FIXNUM:
      i = FIX2INT(val);
      goto numval;
    case T_FALSE:
      i = 0;
      goto numval;
    case T_TRUE:
      i = 1;
    numval: 
      v = (void*)&i; vlen = sizeof(i);
      break;
    
    default:
      StringValue(val);
      v = RSTRING_PTR(val);
      vlen = RSTRING_LEN(val);
      break;
  }

  err = nn_setsockopt(sock, level_arg, option_arg, v, vlen);
  if (err < 0)
    RAISE_SOCK_ERROR; 

  return self; 
}