Searched refs:fill_incoming_buffers (Results 1 – 10 of 10) sorted by relevance
137 let ret = socket.fill_incoming_buffers().and_then(|_| socket.fill_incoming_buffers());161 let ret = socket.fill_incoming_buffers().and_then(|_| socket.fill_incoming_buffers());185 let ret = socket.fill_incoming_buffers().and_then(|_| socket.fill_incoming_buffers());
218 pub fn fill_incoming_buffers(&mut self) -> IoResult<()> { in fill_incoming_buffers() method413 server.fill_incoming_buffers().unwrap(); in write_read_cycle()449 server.fill_incoming_buffers().unwrap(); in write_read_cycle_fd()508 server.fill_incoming_buffers().unwrap(); in write_read_cycle_multiple()548 server.fill_incoming_buffers().unwrap(); in parse_with_string_len_multiple_of_4()
195 pub fn fill_incoming_buffers(&mut self) -> NixResult<()> { in fill_incoming_buffers() method341 match self.fill_incoming_buffers() { in read_messages()
206 pub fn fill_incoming_buffers(&mut self) -> NixResult<()> { in fill_incoming_buffers() method352 match self.fill_incoming_buffers() { in read_messages()
199 pub fn fill_incoming_buffers(&mut self) -> NixResult<()> { in fill_incoming_buffers() method345 match self.fill_incoming_buffers() { in read_messages()
201 pub fn fill_incoming_buffers(&mut self) -> NixResult<()> { in fill_incoming_buffers() method347 match self.fill_incoming_buffers() { in read_messages()
336 if let Err(e) = self.socket.fill_incoming_buffers() { in next_request()
227 if let Err(e) = self.handle.socket.fill_incoming_buffers() { in dispatch_events()