diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2012-02-16 10:03:45 +0900 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2012-02-16 10:03:45 +0900 |
commit | 0e167c86051614f9d9d9fab255aae8272b1b056b (patch) | |
tree | 4b1184b3937804a4cdfaad5552085c94e3fa813e /src/stream_engine.cpp | |
parent | ff12aabf4b2ec48339235ad67175575d2b00adc0 (diff) |
File descriptor passed to in_event and out_event
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/stream_engine.cpp')
-rw-r--r-- | src/stream_engine.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/stream_engine.cpp b/src/stream_engine.cpp index 0ae96d2..fb49152 100644 --- a/src/stream_engine.cpp +++ b/src/stream_engine.cpp @@ -124,7 +124,7 @@ void xs::stream_engine_t::plug (io_thread_t *io_thread_, set_pollout (handle); // Flush all the data that may have been already received downstream. - in_event (); + in_event (s); } void xs::stream_engine_t::unplug () @@ -151,7 +151,7 @@ void xs::stream_engine_t::terminate () delete this; } -void xs::stream_engine_t::in_event () +void xs::stream_engine_t::in_event (fd_t fd_) { bool disconnection = false; @@ -206,7 +206,7 @@ void xs::stream_engine_t::in_event () error (); } -void xs::stream_engine_t::out_event () +void xs::stream_engine_t::out_event (fd_t fd_) { bool more_data = true; @@ -260,7 +260,7 @@ void xs::stream_engine_t::activate_out () // was sent by the user the socket is probably available for writing. // Thus we try to write the data to socket avoiding polling for POLLOUT. // Consequently, the latency should be better in request/reply scenarios. - out_event (); + out_event (s); } void xs::stream_engine_t::activate_in () @@ -268,7 +268,7 @@ void xs::stream_engine_t::activate_in () set_pollin (handle); // Speculative read. - in_event (); + in_event (s); } void xs::stream_engine_t::error () |