Searched refs:streamState (Results 1 – 5 of 5) sorted by relevance
175 void buildVertex(const STREAMOUT_STREAM& streamState, Value* pCurVertex, Value* pOutBuffer[4]) in buildVertex()177 for (uint32_t d = 0; d < streamState.numDecls; ++d) in buildVertex()179 const STREAMOUT_DECL& decl = streamState.decl[d]; in buildVertex()184 …void buildStream(const STREAMOUT_COMPILE_STATE& state, const STREAMOUT_STREAM& streamState, Value*… in buildStream()188 for (uint32_t d = 0; d < streamState.numDecls; ++d) in buildStream()190 const STREAMOUT_DECL& decl = streamState.decl[d]; in buildStream()237 buildVertex(streamState, pStreamData, pOutBuffer); in buildStream()289 const STREAMOUT_STREAM& streamState = state.stream; in Create() local290 buildStream(state, streamState, pSoCtx, returnBB, soFunc); in Create()
156 type streamState uint32 type159 streamActive streamState = iota197 state streamState222 func (s *Stream) swapState(st streamState) streamState {223 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))226 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {230 func (s *Stream) getState() streamState {231 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
79 type streamState int type94 stateIdle streamState = iota109 func (st streamState) String() string {
544 state streamState561 func (sc *serverConn) state(streamID uint32) (streamState, *stream) {1859 func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...