28 VALUE rb_cSOCKSSocket;
49 if (
fstat(fd, &sbuf) < 0)
52 if (!S_ISSOCK(sbuf.st_mode))
125 arg.
alen = (socklen_t)
sizeof(arg.
buf);
128 klass =
RBASIC(str)->klass;
142 RBASIC(str)->klass = klass;
152 if (arg.
alen !=
sizeof(
struct sockaddr_in)) {
168 rb_bug(
"rsock_s_recvfrom called with bad value");
178 socklen_t alen = (socklen_t)
sizeof buf;
187 if (flg ==
Qnil) flags = 0;
194 flags |= MSG_DONTWAIT;
207 slen = recvfrom(fd,
RSTRING_PTR(str), buflen, flags, (
struct sockaddr*)&buf, &alen);
212 #if defined(EWOULDBLOCK) && EWOULDBLOCK != EAGAIN
228 if (alen && alen !=
sizeof(buf))
237 rb_bug(
"rsock_s_recvfrom_nonblock called with bad value");
247 fd = socket(domain, type, proto);
251 fd = socket(domain, type, proto);
263 socklen_t sockerrlen;
275 sockerrlen = (socklen_t)
sizeof(sockerr);
276 ret = getsockopt(fd, SOL_SOCKET, SO_ERROR, (
void *)&sockerr, &sockerrlen);
303 #define WAIT_IN_PROGRESS 10
306 #define WAIT_IN_PROGRESS 10
310 #define WAIT_IN_PROGRESS 0
312 #ifndef WAIT_IN_PROGRESS
314 #define WAIT_IN_PROGRESS 1
330 #if defined(SOCKS) && !defined(SOCKS5)
332 socks_connect_blocking(
void *data)
345 #if WAIT_IN_PROGRESS > 0
346 int wait_in_progress = -1;
348 socklen_t sockerrlen;
354 #if defined(SOCKS) && !defined(SOCKS5)
355 if (socks) func = socks_connect_blocking;
362 #if defined(ERESTART)
371 #if WAIT_IN_PROGRESS > 0
372 sockerrlen = (socklen_t)
sizeof(sockerr);
373 status = getsockopt(fd, SOL_SOCKET, SO_ERROR, (
void *)&sockerr, &sockerrlen);
384 #if WAIT_IN_PROGRESS > 0
394 #if WAIT_IN_PROGRESS > 0
396 if (wait_in_progress-- > 0) {
402 sockerrlen = (socklen_t)
sizeof(sockerr);
403 status = getsockopt(fd, SOL_SOCKET, SO_ERROR, (
void *)&sockerr, &sockerrlen);
404 if (!status && !sockerr) {
405 struct timeval tv = {0, 100000};
434 flags =
fcntl(fd, F_GETFL);
451 socklen_t len0 = len ? *len : 0;
455 fd2 = accept(fptr->
fd, (
struct sockaddr*)sockaddr, len);
459 #if defined(EWOULDBLOCK) && EWOULDBLOCK != EAGAIN
470 if (len && len0 < *len) *len = len0;
488 if (arg->
len) len0 = *arg->
len;
490 if (arg->
len && len0 < *arg->
len) *arg->
len = len0;
524 if (!klass)
return INT2NUM(fd2);
532 socklen_t sslen = (socklen_t)
sizeof(ss);
535 if (getsockname(sockfd, (
struct sockaddr*)&ss, &sslen) < 0)
#define RSTRING_LEN(string)
struct sockaddr * sockaddr
void rb_bug(const char *fmt,...)
VALUE rsock_sendto_blocking(void *data)
void rb_update_max_fd(int fd)
void rb_io_set_nonblock(rb_io_t *fptr)
void rb_io_synchronized(rb_io_t *)
VALUE rsock_ipaddr(struct sockaddr *sockaddr, int norevlookup)
VALUE rsock_init_sock(VALUE sock, int fd)
void rsock_init_unixsocket(void)
static VALUE INT2NUM(int v)
#define RSTRING_PTR(string)
void rsock_init_tcpserver(void)
void rb_raise(VALUE exc, const char *fmt,...)
VALUE rsock_s_accept(VALUE klass, int fd, struct sockaddr *sockaddr, socklen_t *len)
#define FMODE_NOREVLOOKUP
void rsock_init_socket_constants(void)
static void make_fd_nonblock(int fd)
int rsock_getfamily(int sockfd)
#define GetOpenFile(obj, fp)
void rsock_init_addrinfo(void)
VALUE rsock_io_socket_addrinfo(VALUE io, struct sockaddr *addr, socklen_t len)
int rb_w32_is_socket(int)
RUBY_EXTERN VALUE rb_mWaitReadable
void rsock_init_tcpsocket(void)
VALUE rb_obj_taint(VALUE)
void rsock_init_sockssocket(void)
VALUE rsock_send_blocking(void *data)
int rsock_socket(int domain, int type, int proto)
VALUE rb_define_class(const char *name, VALUE super)
Defines a top-level class.
void rsock_init_ancdata(void)
static int wait_connectable(int fd)
VALUE rb_obj_alloc(VALUE)
void rsock_init_socket_init()
char * gai_strerror(int ecode)
SSL_METHOD *(* func)(void)
VALUE rsock_s_recvfrom(VALUE sock, int argc, VALUE *argv, enum sock_recv_type from)
int rb_scan_args(int argc, const VALUE *argv, const char *fmt,...)
VALUE rb_assoc_new(VALUE car, VALUE cdr)
void rb_thread_wait_fd(int)
void rsock_init_udpsocket(void)
int rsock_do_not_reverse_lookup
int rb_wait_for_single_fd(int fd, int events, struct timeval *tv)
register unsigned int len
VALUE rb_blocking_function_t(void *)
void rb_sys_fail(const char *mesg)
const struct sockaddr * sockaddr
void rb_thread_wait_for(struct timeval)
int rb_io_read_pending(rb_io_t *)
struct sockaddr_storage buf
void rb_mod_sys_fail(VALUE mod, const char *mesg)
void rsock_raise_socket_error(const char *reason, int error)
VALUE rb_io_ascii8bit_binmode(VALUE)
int rsock_connect(int fd, const struct sockaddr *sockaddr, int len, int socks)
#define rb_str_set_len(str, length)
static VALUE connect_blocking(void *data)
VALUE rsock_s_accept_nonblock(VALUE klass, rb_io_t *fptr, struct sockaddr *sockaddr, socklen_t *len)
static VALUE accept_blocking(void *data)
void rsock_init_ipsocket(void)
void rsock_init_unixserver(void)
RUBY_EXTERN VALUE rb_eIOError
#define MakeOpenFile(obj, fp)
static VALUE recvfrom_blocking(void *data)
void rsock_init_sockopt(void)
VALUE rb_tainted_str_new(const char *, long)
VALUE rsock_s_recvfrom_nonblock(VALUE sock, int argc, VALUE *argv, enum sock_recv_type from)
int rb_io_wait_readable(int)
void rb_io_check_closed(rb_io_t *)
#define BLOCKING_REGION_FD(func, arg)