| 395 | } |
| 396 | |
| 397 | Status ServerNegotiation::ValidateConnectionHeader(faststring* recv_buf) { |
| 398 | TRACE("Waiting for connection header"); |
| 399 | size_t num_read; |
| 400 | const size_t conn_header_len = kMagicNumberLength + kHeaderFlagsLength; |
| 401 | recv_buf->resize(conn_header_len); |
| 402 | RETURN_NOT_OK(socket_->BlockingRecv(recv_buf->data(), conn_header_len, &num_read, deadline_)); |
| 403 | DCHECK_EQ(conn_header_len, num_read); |
| 404 | |
| 405 | RETURN_NOT_OK(serialization::ValidateConnHeader(*recv_buf)); |
| 406 | TRACE("Connection header received"); |
| 407 | return Status::OK(); |
| 408 | } |
| 409 | |
| 410 | // calls sasl_server_init() and sasl_server_new() |
| 411 | Status ServerNegotiation::InitSaslServer() { |
nothing calls this directly
no test coverage detected