def err_sender_thread
        Thread.start {
          log_info { "start err sender thread" }
          loop do
            if @r_io_err.closed?