|
|
|
@ -246,28 +246,28 @@ class CallSpineInterface { |
|
|
|
|
|
|
|
|
|
class CallSpine final : public CallSpineInterface { |
|
|
|
|
public: |
|
|
|
|
Pipe<ClientMetadataHandle>& client_initial_metadata() { |
|
|
|
|
Pipe<ClientMetadataHandle>& client_initial_metadata() override { |
|
|
|
|
return client_initial_metadata_; |
|
|
|
|
} |
|
|
|
|
Pipe<ServerMetadataHandle>& server_initial_metadata() { |
|
|
|
|
Pipe<ServerMetadataHandle>& server_initial_metadata() override { |
|
|
|
|
return server_initial_metadata_; |
|
|
|
|
} |
|
|
|
|
Pipe<MessageHandle>& client_to_server_messages() { |
|
|
|
|
Pipe<MessageHandle>& client_to_server_messages() override { |
|
|
|
|
return client_to_server_messages_; |
|
|
|
|
} |
|
|
|
|
Pipe<MessageHandle>& server_to_client_messages() { |
|
|
|
|
Pipe<MessageHandle>& server_to_client_messages() override { |
|
|
|
|
return server_to_client_messages_; |
|
|
|
|
} |
|
|
|
|
Pipe<ServerMetadataHandle>& server_trailing_metadata() { |
|
|
|
|
Pipe<ServerMetadataHandle>& server_trailing_metadata() override { |
|
|
|
|
return server_trailing_metadata_; |
|
|
|
|
} |
|
|
|
|
absl::nullopt_t Cancel(ServerMetadataHandle metadata) { |
|
|
|
|
absl::nullopt_t Cancel(ServerMetadataHandle metadata) override { |
|
|
|
|
GPR_DEBUG_ASSERT(Activity::current() == &party()); |
|
|
|
|
if (cancel_latch_.is_set()) return absl::nullopt; |
|
|
|
|
cancel_latch_.Set(std::move(metadata)); |
|
|
|
|
return absl::nullopt; |
|
|
|
|
} |
|
|
|
|
Party& party() { Crash("unimplemented"); } |
|
|
|
|
Party& party() override { Crash("unimplemented"); } |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
// Initial metadata from client to server
|
|
|
|
|