| 366 | } |
| 367 | |
| 368 | Status ServerNegotiation::SendNegotiatePB(const NegotiatePB& msg) { |
| 369 | ResponseHeader header; |
| 370 | header.set_call_id(kNegotiateCallId); |
| 371 | |
| 372 | DCHECK(socket_); |
| 373 | DCHECK(msg.IsInitialized()) << "message must be initialized"; |
| 374 | DCHECK(msg.has_step()) << "message must have a step"; |
| 375 | |
| 376 | TRACE("Sending $0 NegotiatePB response", NegotiatePB::NegotiateStep_Name(msg.step())); |
| 377 | return SendFramedMessageBlocking(socket_.get(), header, msg, deadline_); |
| 378 | } |
| 379 | |
| 380 | Status ServerNegotiation::SendError(ErrorStatusPB::RpcErrorCodePB code, const Status& err) { |
| 381 | DCHECK(!err.ok()); |
nothing calls this directly
no test coverage detected