Home
last modified time | relevance | path

Searched refs:streamState (Results 176 – 200 of 1236) sorted by relevance

12345678910>>...50

/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
278 state streamState
303 func (s *Stream) swapState(st streamState) streamState {
304 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
307 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
311 func (s *Stream) getState() streamState {
312 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/google.golang.org/grpc/grpc-go-1.34.0/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
278 state streamState
303 func (s *Stream) swapState(st streamState) streamState {
304 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
307 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
311 func (s *Stream) getState() streamState {
312 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/net/traefik/traefik-2.6.1/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
279 state streamState
304 func (s *Stream) swapState(st streamState) streamState {
305 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
308 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
312 func (s *Stream) getState() streamState {
313 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/devel/gitlab-runner/vault-sdk-v0.1.13/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go210 type streamState uint32 type
213 streamActive streamState = iota
256 state streamState
281 func (s *Stream) swapState(st streamState) streamState {
282 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
285 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
289 func (s *Stream) getState() streamState {
290 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/net/storj/storj-1.45.3/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go224 type streamState uint32 type
227 streamActive streamState = iota
275 state streamState
300 func (s *Stream) swapState(st streamState) streamState {
301 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
304 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
308 func (s *Stream) getState() streamState {
309 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go224 type streamState uint32 type
227 streamActive streamState = iota
275 state streamState
300 func (s *Stream) swapState(st streamState) streamState {
301 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
304 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
308 func (s *Stream) getState() streamState {
309 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
279 state streamState
304 func (s *Stream) swapState(st streamState) streamState {
305 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
308 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
312 func (s *Stream) getState() streamState {
313 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/istio/vault-sdk-v0.1.12/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go210 type streamState uint32 type
213 streamActive streamState = iota
256 state streamState
281 func (s *Stream) swapState(st streamState) streamState {
282 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
285 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
289 func (s *Stream) getState() streamState {
290 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/istio/istio-1.6.7/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go224 type streamState uint32 type
227 streamActive streamState = iota
275 state streamState
300 func (s *Stream) swapState(st streamState) streamState {
301 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
304 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
308 func (s *Stream) getState() streamState {
309 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go228 type streamState uint32 type
231 streamActive streamState = iota
280 state streamState
305 func (s *Stream) swapState(st streamState) streamState {
306 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
309 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
313 func (s *Stream) getState() streamState {
314 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/devel/mutagen/mutagen-0.11.8/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go224 type streamState uint32 type
227 streamActive streamState = iota
275 state streamState
300 func (s *Stream) swapState(st streamState) streamState {
301 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
304 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
308 func (s *Stream) getState() streamState {
309 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
279 state streamState
304 func (s *Stream) swapState(st streamState) streamState {
305 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
308 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
312 func (s *Stream) getState() streamState {
313 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/www/grafana8/grafana-8.3.6/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go228 type streamState uint32 type
231 streamActive streamState = iota
280 state streamState
305 func (s *Stream) swapState(st streamState) streamState {
306 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
309 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
313 func (s *Stream) getState() streamState {
314 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/ftp/sftpgo/sftpgo-2.2.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go228 type streamState uint32 type
231 streamActive streamState = iota
280 state streamState
305 func (s *Stream) swapState(st streamState) streamState {
306 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
309 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
313 func (s *Stream) getState() streamState {
314 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/databases/litestream/litestream-0.3.6/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32
230 streamActive streamState = iota
279 state streamState
304 func (s *Stream) swapState(st streamState) streamState {
305 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
308 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
312 func (s *Stream) getState() streamState {
313 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/security/vault/vault-1.8.2/vendor/github.com/Microsoft/hcsshim/test/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go223 type streamState uint32 type
226 streamActive streamState = iota
269 state streamState
294 func (s *Stream) swapState(st streamState) streamState {
295 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
298 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
302 func (s *Stream) getState() streamState {
303 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go224 type streamState uint32 type
227 streamActive streamState = iota
275 state streamState
300 func (s *Stream) swapState(st streamState) streamState {
301 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
304 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
308 func (s *Stream) getState() streamState {
309 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/terraform-docs/terraform-docs-0.16.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
279 state streamState
304 func (s *Stream) swapState(st streamState) streamState {
305 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
308 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
312 func (s *Stream) getState() streamState {
313 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/terraform/terraform-1.0.11/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go224 type streamState uint32 type
227 streamActive streamState = iota
275 state streamState
300 func (s *Stream) swapState(st streamState) streamState {
301 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
304 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
308 func (s *Stream) getState() streamState {
309 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/terraform-provider-gridscale/terraform-provider-gridscale-1.6.2/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go223 type streamState uint32 type
226 streamActive streamState = iota
269 state streamState
294 func (s *Stream) swapState(st streamState) streamState {
295 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
298 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
302 func (s *Stream) getState() streamState {
303 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/net/grpcurl/grpcurl-1.8.5/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
279 state streamState
304 func (s *Stream) swapState(st streamState) streamState {
305 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
308 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
312 func (s *Stream) getState() streamState {
313 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/sysutils/restic/restic-0.12.1/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go227 type streamState uint32 type
230 streamActive streamState = iota
279 state streamState
304 func (s *Stream) swapState(st streamState) streamState {
305 return streamState(atomic.SwapUint32((*uint32)(&s.state), uint32(st)))
308 func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
312 func (s *Stream) getState() streamState {
313 return streamState(atomic.LoadUint32((*uint32)(&s.state)))
/dports/devel/hyperscan/hyperscan-5.4.0/src/nfa/
H A Dlbr_common_impl.h50 lbrCompressState(l, offset, lstate, q->streamState); in JOIN()
94 return lbrInAccept(l, lstate, q->streamState, offset, report); in JOIN()
195 lbrTop(l, lstate, q->streamState, sp); in JOIN()
264 if (lbrFindMatch(l, sp, ep, lstate, q->streamState, &mloc)) { in JOIN()
274 char rv = lbrMatchLoop(l, sp, ep, lstate, q->streamState, q->cb, in JOIN()
314 lbrTop(l, lstate, q->streamState, q_cur_offset(q)); in JOIN()
330 return lbrIsAlive(l, lstate, q->streamState, sp); in JOIN()
430 lbrTop(l, lstate, q->streamState, q_cur_offset(q)); in JOIN()
451 if (lbrInAccept(l, lstate, q->streamState, sp, report)) { in JOIN()
455 return lbrIsActive(l, lstate, q->streamState, sp); in JOIN()
/dports/multimedia/libva-intel-media-driver/media-driver-intel-media-22.1.1/media_softlet/linux/common/os/
H A Dmos_gpucontext_specific_next.h72 MOS_STREAM_HANDLE streamState,
122 MOS_STREAM_HANDLE streamState,
150 MOS_STREAM_HANDLE streamState,
257 MOS_STREAM_HANDLE streamState);
/dports/multimedia/navidrome/navidrome-0.40.0/vendor/gopkg.in/djherbis/stream.v1/
H A Dsync.go16 type streamState int type
19 openState streamState = iota
27 state streamState
131 func (b *broadcaster) setState(s streamState) {

12345678910>>...50