Module: NanoMsg

Defined in:

lib/nanomsg.rb,
lib/nanomsg/pair_socket.rb,
ext/init.c

Defined Under Namespace

Classes: BusSocket, PairSocket, PubSocket, PullSocket, PushSocket, RepSocket, ReqSocket, RespondSocket, Socket, SocketError, SubSocket, SurveySocket

Class Method Summary

• .run_device(a, b) ⇒ Object
• .run_loopback(a) ⇒ Object
• .terminate ⇒ Object

Class Method Details

.run_device(a, b) ⇒ Object

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

static VALUE
nanomsg_run_device(VALUE self, VALUE a, VALUE b)
{
  struct device_op dop; 

  dop.sa = sock_get(a);
  dop.sb = sock_get(b);

  rb_thread_blocking_region(nanomsg_run_device_no_gvl, &dop, RUBY_UBF_IO, 0);
  if (dop.err < 0)
    RAISE_SOCK_ERROR;

  return Qnil; 
}

.run_loopback(a) ⇒ Object

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

static VALUE
nanomsg_run_loopback(VALUE self, VALUE a)
{
  struct device_op dop; 

  dop.sa = sock_get(a);
  dop.sb = -1;          // invalid socket, see documentation

  rb_thread_blocking_region(nanomsg_run_device_no_gvl, &dop, RUBY_UBF_IO, 0);
  if (dop.err < 0)
    RAISE_SOCK_ERROR;

  return Qnil; 
}

.terminate ⇒ Object

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

static VALUE
nanomsg_terminate(VALUE self)
{
  nn_term(); 

  return Qnil; 
}