提交 6d929898 编写于 作者: X xionglei6

init: fix reviewbot

Signed-off-by: Nxionglei6 <xionglei6@huawei.com>
上级 a0bef945
......@@ -241,7 +241,7 @@ int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg)
LibuvStreamTask *worker = (LibuvStreamTask *)stream;
req->buf = uv_buf_init((char *)msg, msg->msgSize);
int ret = uv_write(&req->writer, (uv_stream_t *)&worker->stream.pipe, &req->buf, 1, OnWriteResponse);
PARAM_CHECK(ret >= 0, LibuvFreeMsg(stream, msg);
PARAM_CHECK(ret >= 0, LibuvFreeMsg(stream, msg); free(req);
return -1, "Failed to uv_write2 ret %s", uv_strerror(ret));
#endif
return 0;
......
......@@ -245,7 +245,9 @@ void WatcherManager::RunLoop()
bool retry = false;
while (!stop_) {
int fd = GetServerFd(retry);
ssize_t recvLen = recv(fd, buffer.data(), RECV_BUFFER_MAX, 0);
if (fd >= 0) {
ssize_t recvLen = recv(fd, buffer.data(), RECV_BUFFER_MAX, 0);
}
if (stop_) {
break;
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册