Oct 01 04:48:53.968 DEBUG proxy: client: sleep to give server chance to come up
Oct 01 04:48:53.968 DEBUG proxy: server: binding
Oct 01 04:48:53.968 DEBUG proxy: server: successfully binding. waiting for incoming
Oct 01 04:48:54.168 DEBUG proxy: client: trying to connect
Oct 01 04:48:54.177 DEBUG proxy: client: got connection. waiting
Oct 01 04:48:54.177 DEBUG proxy: client: loop 0 sending test message
Oct 01 04:48:54.178 DEBUG proxy: server: new incoming connection
Oct 01 04:48:54.178 DEBUG proxy: server: loop 0, received from client: 8 bytes
Oct 01 04:48:54.178 DEBUG proxy: sever: send back reply: message0reply
Oct 01 04:48:54.178 DEBUG proxy: client: loop 0, received reply back
Oct 01 04:48:54.178 DEBUG proxy: client: loop 1 sending test message
git clone https://github.com/infinyon/flv-tls-proxy
cd flv-tls-proxy
RUST_LOG=proxy=debug cargo test test_proxy
TRACE tokio_util::codec::framed_read: frame decoded from buffer
Oct 01 04:52:52.420 DEBUG proxy: client: loop 0, received reply back
Oct 01 04:52:52.420 DEBUG proxy: client: loop 1 sending test message
Oct 01 04:52:52.420 TRACE tokio_util::codec::framed_write: flushing framed transport
Oct 01 04:52:52.420 TRACE tokio_util::codec::framed_write: writing; remaining=8
Oct 01 04:52:52.420 TRACE async_io::driver: main_loop: sleeping for 1000 us
Oct 01 04:52:52.420 TRACE polling::epoll: interest: epoll_fd=3, fd=8, ev=Event { key: 2, readable: true, writable: false }
Oct 01 04:52:52.420 TRACE polling::epoll: new events: epoll_fd=3, res=1
Oct 01 04:52:52.420 TRACE tokio_util::codec::framed_write: framed transport flushed
Oct 01 04:52:52.420 TRACE polling::epoll: interest: epoll_fd=3, fd=4, ev=Event { key: 18446744073709551615, readable: true, writable: false }
Oct 01 04:52:52.420 TRACE tokio_util::codec::framed_read: attempting to decode a frame
Oct 01 04:52:52.420 TRACE async_io::reactor: react: 1 ready wakers
Oct 01 04:52:52.420 TRACE async_io::driver: block_on: stops hogging the reactor
Oct 01 04:52:52.420 TRACE polling: Poller::notify()
Oct 01 04:52:52.420 TRACE polling::epoll: notify: epoll_fd=3, event_fd=4
Oct 01 04:52:52.420 TRACE async_io::driver: main_loop: notified
Oct 01 04:52:52.420 TRACE async_io::driver: block_on: waiting on I/O
Oct 01 04:52:52.420 TRACE async_io::driver: main_loop: sleeping for 50 us
Oct 01 04:52:52.420 TRACE async_io::reactor: process_timers: 0 ready wakers
Oct 01 04:52:52.420 TRACE polling::epoll: interest: epoll_fd=3, fd=7, ev=Event { key: 1, readable: true, writable: false }
Oct 01 04:52:52.420 TRACE polling: Poller::wait(_, None)
Oct 01 04:52:52.420 TRACE async_io::driver: block_on: sleep until notification
Oct 01 04:52:52.420 TRACE polling::epoll: interest: epoll_fd=3, fd=9, ev=Event { key: 3, readable: true, writable: false }
Oct 01 04:52:52.420 TRACE polling::epoll: wait: epoll_fd=3, timeout=None
Oct 01 04:52:52.421 TRACE async_io::driver: main_loop: sleeping for 75 us
Oct 01 04:52:52.421 TRACE polling::epoll: interest: epoll_fd=3, fd=5, ev=Event { key: 18446744073709551615, readable: true, writable: false }
Oct 01 04:52:52.421 TRACE async_io::driver: block_on: sleep until notification
Oct 01 04:52:52.421 TRACE polling::epoll: new events: epoll_fd=3, res=1
Oct 01 04:52:52.421 TRACE polling::epoll: interest: epoll_fd=3, fd=4, ev=Event { key: 18446744073709551615, readable: true, writable: false }
Oct 01 04:52:52.421 TRACE async_io::reactor: process_timers: 0 ready wakers
Oct 01 04:52:52.421 TRACE async_io::driver: main_loop: sleeping for 100 us
Oct 01 04:52:52.421 TRACE async_io::reactor: react: 0 ready wakers
Oct 01 04:52:52.421 TRACE async_io::driver: block_on: stops hogging the reactor
Oct 01 04:52:52.421 TRACE async_io::driver: main_loop: notified
Oct 01 04:52:52.421 TRACE async_io::driver: main_loop: waiting on I/O
Oct 01 04:52:52.421 TRACE async_io::reactor: process_timers: 0 ready wakers
Oct 01 04:52:52.421 TRACE polling: Poller::wait(_, None)
Oct 01 04:52:52.421 TRACE polling::epoll: wait: epoll_fd=3, timeout=None
Oct 01 04:52:52.421 TRACE polling::epoll: interest: epoll_fd=3, fd=5, ev=Event { key: 18446744073709551615, readable: true, writable: false }