Home
last modified time | relevance | path

Searched refs:kRequestWriteCompleted (Results 1 – 2 of 2) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_state.cc25 case UntypedStreamingRPCState::Tag::TagType::kRequestWriteCompleted: in ToString()
43 case TagType::kRequestWriteCompleted: in OnCompleted()
78 case Exchange::State::kRequestWriteCompleted: in ToString()
124 if (e.state() == Exchange::State::kRequestWriteCompleted) { in GetReadyForResponseReading()
177 Exchange::State::kRequestWriteCompleted); in GetPossibleTransitions()
178 s->emplace(Exchange::State::kRequestWriteCompleted, in GetPossibleTransitions()
184 s->emplace(Exchange::State::kRequestWriteCompleted, in GetPossibleTransitions()
185 Exchange::State::kRequestWriteCompleted); in GetPossibleTransitions()
189 Exchange::State::kRequestWriteCompleted); in GetPossibleTransitions()
Dgrpc_state.h250 kRequestWriteCompleted, enumerator
281 kRequestWriteCompleted, enumerator
302 state_ = State::kRequestWriteCompleted; in MarkRequestWriteCompleted()
305 DCHECK(state_ == State::kRequestWriteCompleted); in MarkResponseReadIssued()
631 Tag request_write_completed_tag_{this, Tag::TagType::kRequestWriteCompleted};