diff --git a/src/net/kqueue_event.cc b/src/net/kqueue_event.cc index f64b6da0..6178a542 100644 --- a/src/net/kqueue_event.cc +++ b/src/net/kqueue_event.cc @@ -195,20 +195,14 @@ void KqueueEvent::DoRead(const struct kevent &event, const std::shared_ptr &conn) { - auto ret = conn->net_event_->OnWritable(); - if (ret == NE_ERROR) { - DoError(event, "DoWrite error,errno: " + std::to_string(errno)); - return; - } - if (ret == 0) { # ifdef HAVE_64BIT - auto conn_id = reinterpret_cast(event.udata); + auto conn_id = reinterpret_cast(event.udata); # else - auto _conn_id = reinterpret_cast(event.udata); - uint64_t conn_id = *_conn_id; - delete event.udata; + auto _conn_id = reinterpret_cast(event.udata); + uint64_t conn_id = *_conn_id; + delete event.udata; # endif - auto ret = conn->net_event_->OnWritable(conn_id, conn->fd_, this); + auto ret = conn->net_event_->OnWritable(conn_id, conn->fd_, this); if (ret == NE_ERROR) { DoError(event, "DoWrite error,errno: " + std::to_string(errno)); return;