Lines Matching refs:event_buffer
43 event_buffer: VecDeque<u8>, field
52 event_buffer: Default::default(), in new()
82 while !self.event_buffer.is_empty() { in flush_buffered_events()
83 let written = self.event_socket.write(&self.event_buffer.as_slices().0)?; in flush_buffered_events()
87 self.event_buffer.drain(..written); in flush_buffered_events()
93 self.event_buffer.is_empty() in is_buffered_events_empty()
104 if self.event_buffer.len() > (EVENT_BUFFER_LEN_MAX - EVENT_SIZE * (it.len() + 1)) { in send_report()
110 self.event_buffer.extend(bytes.iter()); in send_report()
113 self.event_buffer in send_report()
133 if self.event_buffer.len() <= (EVENT_BUFFER_LEN_MAX - EVENT_SIZE) { in send_event_encoded()
134 self.event_buffer.extend(bytes[written..].iter()); in send_event_encoded()