Class: FDPass::Server

Inherits:
Object
  • Object
show all
Defined in:
ext/fdpass_server.c

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'ext/fdpass_server.c', line 47

static VALUE rd_fdpass_server_close(VALUE self) {
  struct fdpass_socket *p;

  Data_Get_Struct(self, struct fdpass_socket, p);

  if (!p->closed) {
    close(p->sock);
    unlink_socket(p);
    p->sock = -1;
    p->closed = 1;
    p->path = Qnil;
  }

  return Qnil;
}

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


63
64
65
66
67
 
# File 'ext/fdpass_server.c', line 63

static VALUE rd_fdpass_server_is_closed(VALUE self) {
  struct fdpass_socket *p;
  Data_Get_Struct(self, struct fdpass_socket, p);
  return p->closed ? Qtrue : Qfalse;
}

#recv ⇒ Object 



102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
 
# File 'ext/fdpass_server.c', line 102

static VALUE rb_fdpass_server_recv(VALUE self) {
  struct fdpass_socket *p;
  struct msghdr msg = { 0 };
  struct cmsghdr *cmsg;
  char cmsgbuf[CMSG_SPACE(sizeof(int))];
  int *cmsg_data;
  struct iovec iov;
  char iov_data[1];
  VALUE fd;

  Data_Get_Struct(self, struct fdpass_socket, p);
  Check_Socket(p);

  iov.iov_base = iov_data;
  iov.iov_len = sizeof(iov_data);

  msg.msg_name = NULL;
  msg.msg_namelen = 0;
  msg.msg_iov = &iov;
  msg.msg_iovlen = 1;
  msg.msg_control = cmsgbuf;
  msg.msg_controllen = sizeof(cmsgbuf);

  if (recvmsg(p->sock, &msg, MSG_WAITALL) < 0) { 
    rb_raise(rb_eFDPassError, "%s", strerror(errno));
  }

  cmsg = CMSG_FIRSTHDR(&msg);
  cmsg_data = (int *) CMSG_DATA(cmsg);

  fd = INT2NUM(*cmsg_data);
  return rb_class_new_instance(1, &fd, rb_cFDPassFD);
}