| /dports/net/jgroups/jgroups-2.12.0/tests/other/org/jgroups/tests/ |
| H A D | MessageListStreamableTest.java | 87 msg.putHeader(UDP_ID, new TpHeader("MyGroup")); in addHeaders()
88 msg.putHeader(PING_ID, new PingHeader(PingHeader.GET_MBRS_REQ, "demo-cluster")); in addHeaders()
89 msg.putHeader(FD_SOCK_ID, new FD_SOCK.FdHeader()); in addHeaders()
90 msg.putHeader(VERIFY_SUSPECT_ID, new VERIFY_SUSPECT.VerifyHeader()); in addHeaders()
91 msg.putHeader(STABLE_ID, new org.jgroups.protocols.pbcast.STABLE.StableHeader()); in addHeaders()
92 msg.putHeader(NAKACK_ID, new org.jgroups.protocols.pbcast.NakAckHeader()); in addHeaders()
93 msg.putHeader(UNICAST_ID, new UNICAST.UnicastHeader()); in addHeaders()
94 msg.putHeader(FRAG_ID, new FragHeader()); in addHeaders()
95 msg.putHeader(GMS_ID, new org.jgroups.protocols.pbcast.GMS.GmsHeader()); in addHeaders()
|
| /dports/benchmarks/polygraph/polygraph-4.13.0/src/client/ |
| H A D | SingleRangeCfg.cc | 67 const bool putHeader = hp.putHeader(hfpRange); in makeRangeSet() local
71 if (putHeader) in makeRangeSet()
89 if (putHeader) in makeRangeSet()
100 if (putHeader) in makeRangeSet()
104 if (putHeader) in makeRangeSet()
|
| H A D | MultiRangeCfg.cc | 66 const bool putHeader = hp.putHeader(hfpRange); in makeRangeSet() local
90 if (putHeader) { in makeRangeSet()
102 if (putHeader) in makeRangeSet()
|
| /dports/net/jgroups/jgroups-2.12.0/tests/junit-functional/org/jgroups/tests/ |
| H A D | HeadersTest.java | 51 old.putHeader((short)300, new MyHeader()); in testContructor2()
104 hdrs.putHeader(NAKACK_ID, h1); in createHeaders()
105 hdrs.putHeader(FRAG_ID, h2); in createHeaders()
106 hdrs.putHeader(UDP_ID, h3); in createHeaders()
114 hdrs.putHeader(NAKACK_ID, new MyHeader()); in testPutHeader()
119 hdrs.putHeader((short)400, new MyHeader()); in testPutHeader()
152 hdrs.putHeader((short)400, new MyHeader()); in testResize()
158 hdrs.putHeader((short)i, new MyHeader()); in testResize()
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 106 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
130 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
146 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
157 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
179 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
198 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
210 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
224 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
235 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
266 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 106 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
130 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
146 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
157 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
179 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
198 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
210 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
224 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
235 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
266 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 106 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
130 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
146 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
157 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
179 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
198 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
210 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
224 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
235 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
266 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 106 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
130 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
146 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
157 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
179 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
198 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
210 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
224 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
235 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
266 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 96 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
120 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
136 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
147 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
169 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
188 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
200 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
214 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
225 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
256 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 96 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
120 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
136 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
147 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
169 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
188 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
200 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
214 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
225 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
256 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 106 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
130 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
146 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
157 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
179 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
198 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
210 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
224 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
235 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
266 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.net.http/share/classes/jdk/internal/net/http/frame/ |
| H A D | FramesEncoder.java | 106 putHeader(buf, length, DataFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeDataFrameStart()
130 putHeader(buf, length, HeadersFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeHeadersFrameStart()
146 putHeader(buf, length, PriorityFrame.TYPE, NO_FLAGS, frame.streamid()); in encodePriorityFrame()
157 putHeader(buf, length, ResetFrame.TYPE, NO_FLAGS, frame.streamid()); in encodeResetFrame()
179 putHeader(buf, length, PushPromiseFrame.TYPE, frame.getFlags(), frame.streamid()); in encodePushPromiseFrame()
198 putHeader(buf, length, PingFrame.TYPE, frame.getFlags(), ZERO_STREAM); in encodePingFrame()
210 putHeader(buf, length, GoAwayFrame.TYPE, NO_FLAGS, ZERO_STREAM); in encodeGoAwayFrame()
224 putHeader(buf, length, WindowUpdateFrame.TYPE, NO_FLAGS, frame.streamid); in encodeWindowUpdateFrame()
235 putHeader(buf, length, ContinuationFrame.TYPE, frame.getFlags(), frame.streamid()); in encodeContinuationFrame()
266 putHeader(buf, length, SettingsFrame.TYPE, frame.getFlags(), ZERO_STREAM); in putSettingsFrame()
[all …]
|
| /dports/benchmarks/polygraph/polygraph-4.13.0/src/server/ |
| H A D | HttpSrvXact.cc | 548 if (hp.putHeader(hfpLocation)) in make302Found()
603 if (hp.putHeader(hfpContRange)) in make416RequestedRangeNotSatisfiable()
631 if (hp.putHeader(hfpDate)) in putStdFields()
637 hp.putHeader(hfConnAliveOrg); in putStdFields()
648 hp.putHeader(hfpExpires)) in putStdFields()
655 if (hp.putHeader(hfpXTarget)) in putXFields()
659 hp.putHeader(hfpXXact)) { in putXFields()
669 if (hp.putHeader(hfpXAbort)) { in putXFields()
687 hp.putHeader(hfCcCachable); in put2xxContentHead()
689 hp.putHeader(hfCcUncachable); in put2xxContentHead()
[all …]
|
| /dports/net/jgroups/jgroups-2.12.0/tests/stress/org/jgroups/tests/ |
| H A D | MessageStressTest.java | 27 msg.putHeader(NAKACK_ID, NakAckHeader.createMessageHeader((long)i)); in start()
28 msg.putHeader(UNICAST_ID, UNICAST.UnicastHeader.createAckHeader(i)); in start()
29 msg.putHeader(UDP_ID, new TpHeader("demo")); in start()
|
| /dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/blocks/mux/ |
| H A D | MuxRequestCorrelator.java | 31 msg.putHeader(MUX_ID, header); in sendRequest()
37 msg.putHeader(MUX_ID, header); in sendUnicastRequest()
43 rsp.putHeader(MUX_ID, header); in prepareResponse()
|
| /dports/benchmarks/polygraph/polygraph-4.13.0/src/csm/ |
| H A D | BodyIter.cc | 123 if (hp.putHeader(hfpContLength)) { in putHeaders()
133 hp.putHeader(hfpContType)) in putHeaders()
136 hp.putHeader(hfGzipContentEncoding); in putHeaders()
|
| /dports/devel/stack/stack-2.7.3/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/lang/purescript/purescript-0.14.5/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/net-im/matterhorn/matterhorn-50200.13.0/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/finance/hs-hledger-web/hledger-web-1.19/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/devel/hs-hoogle/hoogle-5.0.18.2/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/devel/hs-hpack/hpack-0.34.4/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/devel/hs-spago/spago-0.20.3/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/lang/elm/compiler-0.19.1/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|
| /dports/www/hs-postgrest/postgrest-8.0.0/_cabal_deps/asn1-encoding-0.9.6/Data/ASN1/ |
| H A D | Serialize.hs | 8 module Data.ASN1.Serialize (getHeader, putHeader) where
71 putHeader :: ASN1Header -> B.ByteString
72 putHeader (ASN1Header cl tag pc len) = B.concat function
|