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
• #getsockopt(level, option) ⇒ Object
• #recv ⇒ Object
• #send(buffer) ⇒ Object
• #setsockopt(level, option, val) ⇒ Object

Instance Method Details

#bind(bind) ⇒ Object

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

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 238

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. 
  WITHOUT_GVL(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 133

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; 
}

#getsockopt(level, option) ⇒ Object

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

static VALUE 
sock_getsockopt(VALUE self, VALUE level, VALUE option)
{
  int sock = sock_get(self);
  int level_arg = FIX2INT(level); 
  int option_arg = FIX2INT(option);
  int err; 
 
  int out; 
  size_t sz; 

  if (level_arg == NN_SOL_SOCKET) {
    // This list of supported options is not complete yet. However, having
    // a few supported sockets here is more useful than none at all. WIP. 
    // Yes, pr please ;) 
    switch (option_arg) {
      case NN_SNDFD: 
      case NN_RCVFD: 
        // Return will be int, which is a system fd. 
        sz = sizeof(out);
        err = nn_getsockopt(sock, level_arg, option_arg, &out, &sz);
        if (err < 0)
          RAISE_SOCK_ERROR;

        return INT2NUM(out);
      default: 
        // Unsupported option, returning nil. 
        return Qnil;
    }  
  }
  else {
    // And yet more code here. 
    return Qnil; 
  }
}

#recv ⇒ Object

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

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

  io.sock = sock_get(socket);

  WITHOUT_GVL(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 177

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);

  WITHOUT_GVL(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 255

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; 
}