gistfile1.rbx

static void schedule_query(VALUE obj, VALUE timeout)
{
    MYSQL* m = GetHandler(obj);
    fd_set read;

    timeout = ( NIL_P(timeout) ? m->net.read_timeout : INT2NUM(timeout) );

    struct timeval tv = { tv_sec: timeout, tv_usec: 0 };

    FD_ZERO(&read);
    FD_SET(m->net.fd, &read);

    if (rb_thread_select(m->net.fd + 1, &read, NULL, NULL, &tv) < 0) {
      rb_raise(eMysql, "query: timeout");
    }
}