| /dports/net/evans/evans-0.9.1/vendor/github.com/improbable-eng/grpc-web/integration_test/ts/src/ |
| H A D | cancellation.spec.ts | 67 const streamIdentifier = `rpc-${Math.random()}`; constant
72 ping.setStreamIdentifier(streamIdentifier);
90 continueStream(testHostUrl, streamIdentifier, (status) => {
94 checkStreamClosedRequest.setStreamIdentifier(streamIdentifier);
138 continueStream(testHostUrl, streamIdentifier, (status) => {
|
| H A D | util.ts | 67 export function continueStream(host: string, streamIdentifier: string, cb: (status: grpc.Code) => v…
69 req.setStreamIdentifier(streamIdentifier);
|
| /dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/sctp/ |
| H A D | association.go | 497 delete(a.streams, s.streamIdentifier)
1057 s := a.getOrCreateStream(d.streamIdentifier)
1148 if _, ok := a.streams[streamIdentifier]; ok {
1152 s := a.createStream(streamIdentifier, false)
1171 streamIdentifier: streamIdentifier,
1182 a.streams[streamIdentifier] = s
1184 a.name, streamIdentifier)
1191 a.streams[streamIdentifier] = s
1199 if s, ok := a.streams[streamIdentifier]; ok {
1546 ssn, ok := streamMap[c.streamIdentifier]
[all …]
|
| H A D | stream.go | 25 streamIdentifier uint16 member
46 return s.streamIdentifier
222 streamIdentifier: s.streamIdentifier,
278 return s.streamIdentifier, isOpen
|
| H A D | chunk_payload_data.go | 54 streamIdentifier uint16 member
126 p.streamIdentifier = binary.BigEndian.Uint16(p.raw[4:])
138 binary.BigEndian.PutUint16(payRaw[4:], p.streamIdentifier)
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/sctp/ |
| H A D | association.go | 482 delete(a.streams, s.streamIdentifier)
1020 s := a.getOrCreateStream(d.streamIdentifier)
1111 if _, ok := a.streams[streamIdentifier]; ok {
1115 s := a.createStream(streamIdentifier, false)
1134 streamIdentifier: streamIdentifier,
1145 a.streams[streamIdentifier] = s
1147 a.name, streamIdentifier)
1154 a.streams[streamIdentifier] = s
1162 if s, ok := a.streams[streamIdentifier]; ok {
1503 ssn, ok := streamMap[c.streamIdentifier]
[all …]
|
| H A D | chunk_payload_data.go | 54 streamIdentifier uint16 member
123 p.streamIdentifier = binary.BigEndian.Uint16(p.raw[4:])
135 binary.BigEndian.PutUint16(payRaw[4:], p.streamIdentifier)
|
| H A D | stream.go | 25 streamIdentifier uint16 member
46 return s.streamIdentifier
187 streamIdentifier: s.streamIdentifier,
238 return s.streamIdentifier, isOpen
|
| /dports/finance/hs-hledger-web/hledger-web-1.19/_cabal_deps/http2-2.0.5/Network/HTTP2/ |
| H A D | Decode.hs | 59 let !sid = streamIdentifier w32
208 sid = streamIdentifier (N.word32 bs0)
221 sid = streamIdentifier (N.word32 bs0)
264 streamIdentifier :: Word32 -> StreamId
265 streamIdentifier w32 = clearExclusive $ fromIntegral w32 function
271 let !streamdId = streamIdentifier w32
|
| /dports/devel/hs-hoogle/hoogle-5.0.18.2/_cabal_deps/http2-2.0.4/Network/HTTP2/ |
| H A D | Decode.hs | 59 let !sid = streamIdentifier w32
208 sid = streamIdentifier (N.word32 bs0)
221 sid = streamIdentifier (N.word32 bs0)
264 streamIdentifier :: Word32 -> StreamId
265 streamIdentifier w32 = clearExclusive $ fromIntegral w32 function
271 let !streamdId = streamIdentifier w32
|
| /dports/www/hs-wai-app-static/wai-app-static-3.1.7.2/_cabal_deps/http2-2.0.6/Network/HTTP2/ |
| H A D | Decode.hs | 59 let !sid = streamIdentifier w32
208 sid = streamIdentifier (N.word32 bs0)
221 sid = streamIdentifier (N.word32 bs0)
264 streamIdentifier :: Word32 -> StreamId
265 streamIdentifier w32 = clearExclusive $ fromIntegral w32 function
271 let !streamdId = streamIdentifier w32
|
| /dports/www/hs-postgrest/postgrest-8.0.0/_cabal_deps/http2-3.0.2/Network/HTTP2/Frame/ |
| H A D | Decode.hs | 59 let sid = streamIdentifier w32
210 sid = streamIdentifier (N.word32 bs0)
223 sid = streamIdentifier (N.word32 bs0)
266 streamIdentifier :: Word32 -> StreamId
267 streamIdentifier w32 = clearExclusive $ fromIntegral w32 function
273 let streamdId = streamIdentifier w32
|
| /dports/www/hs-yesod-bin/yesod-bin-1.6.1/_cabal_deps/http2-2.0.6/Network/HTTP2/ |
| H A D | Decode.hs | 59 let !sid = streamIdentifier w32
208 sid = streamIdentifier (N.word32 bs0)
221 sid = streamIdentifier (N.word32 bs0)
264 streamIdentifier :: Word32 -> StreamId
265 streamIdentifier w32 = clearExclusive $ fromIntegral w32 function
271 let !streamdId = streamIdentifier w32
|
| /dports/devel/hs-git-annex/git-annex-8.20210903/_cabal_deps/http2-2.0.4/Network/HTTP2/ |
| H A D | Decode.hs | 59 let !sid = streamIdentifier w32
208 sid = streamIdentifier (N.word32 bs0)
221 sid = streamIdentifier (N.word32 bs0)
264 streamIdentifier :: Word32 -> StreamId
265 streamIdentifier w32 = clearExclusive $ fromIntegral w32 function
271 let !streamdId = streamIdentifier w32
|
| /dports/lang/purescript/purescript-0.14.5/_cabal_deps/http2-3.0.2/Network/HTTP2/Frame/ |
| H A D | Decode.hs | 59 let sid = streamIdentifier w32
210 sid = streamIdentifier (N.word32 bs0)
223 sid = streamIdentifier (N.word32 bs0)
266 streamIdentifier :: Word32 -> StreamId
267 streamIdentifier w32 = clearExclusive $ fromIntegral w32 function
273 let streamdId = streamIdentifier w32
|
| /dports/net/evans/evans-0.9.1/vendor/github.com/improbable-eng/grpc-web/integration_test/ts/_proto/improbable/grpcweb/test/ |
| H A D | test_pb.d.ts | 51 streamIdentifier: string,
131 streamIdentifier: string,
151 streamIdentifier: string,
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.debug/org.eclipse.debug.ui/ui/org/eclipse/debug/internal/ui/views/console/ |
| H A D | ProcessConsole.java | 462 public IOConsoleOutputStream getStream(String streamIdentifier) { in getStream() argument
463 if (streamIdentifier == null) { in getStream()
467 if (streamIdentifier.equals(listener.fStreamId)) { in getStream()
648 public void connect(IStreamMonitor streamMonitor, String streamIdentifier) { in connect() argument
649 connect(streamMonitor, streamIdentifier, false); in connect()
660 …private void connect(IStreamMonitor streamMonitor, String streamIdentifier, boolean activateOnWrit… in connect() argument
665 Color color = fColorProvider.getColor(streamIdentifier); in connect()
670 StreamListener listener = new StreamListener(streamIdentifier, streamMonitor, stream); in connect()
725 …public StreamListener(String streamIdentifier, IStreamMonitor monitor, IOConsoleOutputStream strea… in StreamListener() argument
726 this.fStreamId = streamIdentifier; in StreamListener()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 156 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
158 streamHandler.getStream(streamIdentifier).close(); in closeStream()
162 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
164 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/jdk.management.jfr/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 156 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
158 streamHandler.getStream(streamIdentifier).close(); in closeStream()
162 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
164 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 156 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
158 streamHandler.getStream(streamIdentifier).close(); in closeStream()
162 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
164 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/jdk.management.jfr/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 158 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
160 streamHandler.getStream(streamIdentifier).close(); in closeStream()
164 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
166 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/jdk.management.jfr/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 158 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
160 streamHandler.getStream(streamIdentifier).close(); in closeStream()
164 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
166 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/jdk.management.jfr/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 158 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
160 streamHandler.getStream(streamIdentifier).close(); in closeStream()
164 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
166 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/jdk.management.jfr/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 168 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
170 streamHandler.getStream(streamIdentifier).close(); in closeStream()
174 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
176 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/jdk.management.jfr/share/classes/jdk/management/jfr/ |
| H A D | FlightRecorderMXBeanImpl.java | 171 public void closeStream(long streamIdentifier) throws IOException { in closeStream() argument
173 streamHandler.getStream(streamIdentifier).close(); in closeStream()
177 public byte[] readStream(long streamIdentifier) throws IOException { in readStream() argument
179 return streamHandler.getStream(streamIdentifier).read(); in readStream()
|