ext/kgio/kgio.h in kgio-2.10.0 vs ext/kgio/kgio.h in kgio-2.11.0

- old
+ new

@@ -27,13 +27,18 @@ void init_kgio_read(void); void init_kgio_write(void); void init_kgio_writev(void); void init_kgio_accept(void); void init_kgio_connect(void); +void init_kgio_autopush(void); void init_kgio_poll(void); void init_kgio_tryopen(void); +void kgio_autopush_accept(VALUE, VALUE); +void kgio_autopush_recv(VALUE); +void kgio_autopush_send(VALUE); + VALUE kgio_call_wait_writable(VALUE io); VALUE kgio_call_wait_readable(VALUE io); #if defined(HAVE_RB_THREAD_CALL_WITHOUT_GVL) && defined(HAVE_RUBY_THREAD_H) # define KGIO_WITHOUT_GVL(fn,data1,ubf,data2) \ rb_thread_call_without_gvl((fn),(data1),(ubf),(data2)) @@ -82,9 +87,16 @@ * notice. */ # if defined(__linux__) # define USE_MSG_DONTWAIT # endif + +#ifdef USE_MSG_DONTWAIT +/* we don't need these variants, we call kgio_autopush_send/recv directly */ +static inline void kgio_autopush_write(VALUE io) { } +#else +static inline void kgio_autopush_write(VALUE io) { kgio_autopush_send(io); } +#endif /* prefer rb_str_subseq because we don't use negative offsets */ #ifndef HAVE_RB_STR_SUBSEQ #define MY_STR_SUBSEQ(str,beg,len) rb_str_substr((str),(beg),(len)) #else