|
|
@ -164,8 +164,7 @@ static void session_read_cb(void* arg, // session |
|
|
|
// before notify_on_read is called.
|
|
|
|
// before notify_on_read is called.
|
|
|
|
grpc_fd_notify_on_read(se->em_fd, &se->session_read_closure); |
|
|
|
grpc_fd_notify_on_read(se->em_fd, &se->session_read_closure); |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
grpc_core::Crash(absl::StrFormat("Unhandled read error %s", |
|
|
|
LOG(FATAL) << "Unhandled read error " << grpc_core::StrError(errno); |
|
|
|
grpc_core::StrError(errno).c_str())); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
@ -330,8 +329,7 @@ static void client_session_write(void* arg, // client |
|
|
|
} |
|
|
|
} |
|
|
|
gpr_mu_unlock(g_mu); |
|
|
|
gpr_mu_unlock(g_mu); |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
grpc_core::Crash(absl::StrFormat("unknown errno %s", |
|
|
|
LOG(FATAL) << "unknown errno " << grpc_core::StrError(errno).c_str(); |
|
|
|
grpc_core::StrError(errno).c_str())); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -348,12 +346,10 @@ static void client_start(client* cl, int port) { |
|
|
|
pfd.events = POLLOUT; |
|
|
|
pfd.events = POLLOUT; |
|
|
|
pfd.revents = 0; |
|
|
|
pfd.revents = 0; |
|
|
|
if (poll(&pfd, 1, -1) == -1) { |
|
|
|
if (poll(&pfd, 1, -1) == -1) { |
|
|
|
LOG(ERROR) << "poll() failed during connect; errno=" << errno; |
|
|
|
LOG(FATAL) << "poll() failed during connect; errno=" << errno; |
|
|
|
abort(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
grpc_core::Crash( |
|
|
|
LOG(FATAL) << "Failed to connect to the server (errno=" << errno; |
|
|
|
absl::StrFormat("Failed to connect to the server (errno=%d)", errno)); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|