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