MCPcopy Create free account
hub / github.com/apache/impala / CheckInBlockingMode

Function CheckInBlockingMode

be/src/kudu/rpc/blocking_ops.cc:45–54  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

43const char kHTTPHeader[] = "HTTP";
44
45Status CheckInBlockingMode(const Socket* sock) {
46 bool is_nonblocking;
47 RETURN_NOT_OK(sock->IsNonBlocking(&is_nonblocking));
48 if (is_nonblocking) {
49 static const char* const kErrMsg = "socket is not in blocking mode";
50 LOG(DFATAL) << kErrMsg;
51 return Status::IllegalState(kErrMsg);
52 }
53 return Status::OK();
54}
55
56Status SendFramedMessageBlocking(Socket* sock, const MessageLite& header, const MessageLite& msg,
57 const MonoTime& deadline) {

Callers 4

NegotiateMethod · 0.85
NegotiateMethod · 0.85

Calls 3

IllegalStateFunction · 0.85
OKFunction · 0.85
IsNonBlockingMethod · 0.80

Tested by

no test coverage detected