Home
last modified time | relevance | path

Searched refs:CloseType (Results 1 – 25 of 40) sorted by relevance

12

/dports/www/firefox/firefox-99.0/third_party/rust/neqo-http3/src/features/extended_connect/
H A Dmod.rs15 use crate::{CloseType, Http3StreamInfo, Http3StreamType};
27 impl From<CloseType> for SessionCloseReason {
28 fn from(close_type: CloseType) -> SessionCloseReason { in from()
30 CloseType::ResetApp(e) | CloseType::ResetRemote(e) | CloseType::LocalError(e) => { in from()
33 CloseType::Done => SessionCloseReason::Clean { in from()
H A Dwebtransport_streams.rs9 CloseType, Http3StreamInfo, Http3StreamType, ReceiveOutput, RecvStream, RecvStreamEvents, Res,
62 fn reset(&mut self, close_type: CloseType) -> Res<()> { in reset()
63 if !matches!(close_type, CloseType::ResetApp(_)) { in reset()
127 fn set_done(&mut self, close_type: CloseType) { in set_done() argument
151 self.set_done(CloseType::Done); in send()
188 fn handle_stop_sending(&mut self, close_type: CloseType) { in handle_stop_sending() argument
198 self.set_done(CloseType::Done); in close()
H A Dwebtransport_session.rs14 CloseType, Error, HFrame, Http3StreamInfo, Http3StreamType, HttpRecvStream,
206 fn close(&mut self, close_type: CloseType) { in close() argument
212 if let CloseType::ResetApp(_) = close_type { in close()
406 fn reset(&mut self, close_type: CloseType) -> Res<()> { in reset()
469 fn handle_stop_sending(&mut self, close_type: CloseType) { in handle_stop_sending() argument
/dports/www/firefox/firefox-99.0/third_party/rust/neqo-http3/src/
H A Dclient_events.rs13 CloseType, Http3StreamInfo, HttpRecvStreamEvents, RecvStreamEvents, SendStreamEvents,
118 fn recv_closed(&self, stream_info: Http3StreamInfo, close_type: CloseType) { in recv_closed() argument
121 CloseType::ResetApp(_) => { in recv_closed()
125 CloseType::Done => return, in recv_closed()
126 CloseType::ResetRemote(e) => { in recv_closed()
130 CloseType::LocalError(e) => { in recv_closed()
170 fn send_closed(&self, stream_info: Http3StreamInfo, close_type: CloseType) { in send_closed() argument
173 if let CloseType::ResetRemote(error) = close_type { in send_closed()
H A Dserver_connection_events.rs10 CloseType, Http3StreamInfo, HttpRecvStreamEvents, Priority, RecvStreamEvents, SendStreamEvents,
66 fn send_closed(&self, stream_info: Http3StreamInfo, close_type: CloseType) { in send_closed() argument
67 if close_type != CloseType::Done { in send_closed()
86 fn recv_closed(&self, stream_info: Http3StreamInfo, close_type: CloseType) { in recv_closed() argument
87 if close_type != CloseType::Done { in recv_closed()
H A Dpush_controller.rs9 use crate::{CloseType, Error, Http3StreamInfo, HttpRecvStreamEvents, RecvStreamEvents, Res};
373 pub fn push_stream_reset(&mut self, push_id: u64, close_type: CloseType) { in push_stream_reset() argument
384 if let CloseType::LocalError(app_error) = close_type { in push_stream_reset()
479 fn recv_closed(&self, _stream_info: Http3StreamInfo, close_type: CloseType) { in recv_closed() argument
481 CloseType::ResetApp(_) => {} in recv_closed()
482 CloseType::ResetRemote(_) | CloseType::LocalError(_) => self in recv_closed()
486 CloseType::Done => self.push_handler.borrow_mut().close(self.push_id), in recv_closed()
H A Dlib.rs336 fn reset(&mut self, close_type: CloseType) -> Res<()>; in reset()
412 fn recv_closed(&self, _stream_info: Http3StreamInfo, _close_type: CloseType) {} in recv_closed() argument
452 fn handle_stop_sending(&mut self, close_type: CloseType); in handle_stop_sending() argument
476 fn send_closed(&self, _stream_info: Http3StreamInfo, _close_type: CloseType) {} in send_closed() argument
487 pub enum CloseType { enum
494 impl CloseType { impl
H A Dqpack_decoder_receiver.rs7 use crate::{CloseType, Error, Http3StreamType, ReceiveOutput, RecvStream, Res, Stream};
32 fn reset(&mut self, _close_type: CloseType) -> Res<()> { in reset()
H A Dqpack_encoder_receiver.rs7 use crate::{CloseType, Error, Http3StreamType, ReceiveOutput, RecvStream, Res, Stream};
32 fn reset(&mut self, _close_type: CloseType) -> Res<()> { in reset()
H A Dcontrol_stream_remote.rs8 use crate::{CloseType, Error, Http3StreamType, ReceiveOutput, RecvStream, Res, Stream};
58 fn reset(&mut self, _close_type: CloseType) -> Res<()> { in reset()
H A Dconnection.rs26 client_events::Http3ClientEvents, CloseType, Http3Parameters, Http3StreamType,
327 self.close_recv(stream_id, CloseType::ResetRemote(app_error), conn) in handle_stream_reset()
347 self.close_send(stream_id, CloseType::ResetRemote(app_error), conn); in handle_stream_stop_sending()
556 self.close_recv(stream_id, CloseType::LocalError(e.code()), conn)?; in handle_stream_manipulation_output()
728 self.close_send(stream_id, CloseType::ResetApp(error), conn); in stream_reset_send()
749 self.close_recv(stream_id, CloseType::ResetApp(error), conn)?; in stream_stop_sending()
1246 fn close_send(&mut self, stream_id: StreamId, close_type: CloseType, conn: &mut Connection) { in close_send() argument
1255 close_type: CloseType, in close_recv() argument
1280 mem::drop(s.reset(CloseType::ResetRemote(Error::HttpRequestCancelled.code()))); in remove_extended_connect()
1287 s.handle_stop_sending(CloseType::ResetRemote(Error::HttpRequestCancelled.code())); in remove_extended_connect()
H A Dsend_message.rs10 qlog, BufferedStream, CloseType, Error, Http3StreamInfo, Http3StreamType, HttpSendStream, Res,
281 .send_closed(self.get_stream_info(), CloseType::Done); in close()
285 fn handle_stop_sending(&mut self, close_type: CloseType) { in handle_stop_sending() argument
/dports/net/v2ray/v2ray-core-4.36.2/vendor/github.com/lucas-clemente/quic-go/quictrace/pb/
H A Dquic-trace.pb.go121 type CloseType int32 type
143 func (x CloseType) Enum() *CloseType {
144 p := new(CloseType)
149 func (x CloseType) String() string {
157 func (CloseType) Type() protoreflect.EnumType {
166 func (x *CloseType) UnmarshalJSON(b []byte) error {
171 *x = CloseType(num)
176 func (CloseType) EnumDescriptor() ([]byte, []int) {
758 func (x *CloseInfo) GetCloseType() CloseType {
759 if x != nil && x.CloseType != nil {
[all …]
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/lucas-clemente/quic-go/quictrace/pb/
H A Dquic-trace.pb.go121 type CloseType int32 type
143 func (x CloseType) Enum() *CloseType {
144 p := new(CloseType)
149 func (x CloseType) String() string {
157 func (CloseType) Type() protoreflect.EnumType {
166 func (x *CloseType) UnmarshalJSON(b []byte) error {
171 *x = CloseType(num)
176 func (CloseType) EnumDescriptor() ([]byte, []int) {
758 func (x *CloseInfo) GetCloseType() CloseType {
759 if x != nil && x.CloseType != nil {
[all …]
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/lucas-clemente/quic-go/quictrace/pb/
H A Dquic-trace.pb.go121 type CloseType int32 type
143 func (x CloseType) Enum() *CloseType {
144 p := new(CloseType)
149 func (x CloseType) String() string {
157 func (CloseType) Type() protoreflect.EnumType {
166 func (x *CloseType) UnmarshalJSON(b []byte) error {
171 *x = CloseType(num)
176 func (CloseType) EnumDescriptor() ([]byte, []int) {
758 func (x *CloseInfo) GetCloseType() CloseType {
759 if x != nil && x.CloseType != nil {
[all …]
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/quictrace/pb/
H A Dquic-trace.pb.go97 type CloseType int32 type
117 func (x CloseType) Enum() *CloseType {
118 p := new(CloseType)
123 func (x CloseType) String() string {
127 func (x *CloseType) UnmarshalJSON(data []byte) error {
132 *x = CloseType(value)
136 func (CloseType) EnumDescriptor() ([]byte, []int) {
576 …CloseType *CloseType `protobuf:"varint,3,opt,name=close_type,json=closeType,enum=pb.… member
622 func (m *CloseInfo) GetCloseType() CloseType {
623 if m != nil && m.CloseType != nil {
[all …]
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/quic-go/quictrace/pb/
H A Dquic-trace.pb.go97 type CloseType int32 type
117 func (x CloseType) Enum() *CloseType {
118 p := new(CloseType)
123 func (x CloseType) String() string {
127 func (x *CloseType) UnmarshalJSON(data []byte) error {
132 *x = CloseType(value)
136 func (CloseType) EnumDescriptor() ([]byte, []int) {
576 …CloseType *CloseType `protobuf:"varint,3,opt,name=close_type,json=closeType,enum=pb.… member
622 func (m *CloseInfo) GetCloseType() CloseType {
623 if m != nil && m.CloseType != nil {
[all …]
/dports/devel/folly/folly-2021.12.27.00/folly/experimental/channels/test/
H A DChannelTest.cpp269 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::NoException); in TEST_P()
281 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::Exception); in TEST_P()
294 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::Cancelled); in TEST_P()
310 AnyOf(Eq(CloseType::NoException), Eq(CloseType::Cancelled))); in TEST_P()
325 AnyOf(Eq(CloseType::NoException), Eq(CloseType::Cancelled))); in TEST_P()
H A DChannelTestUtil.h166 enum class CloseType { NoException, Exception, Cancelled }; enum
196 closedType_.setValue(CloseType::Cancelled); in onNext()
199 closedType_.setValue(CloseType::Exception); in onNext()
201 closedType_.setValue(CloseType::NoException); in onNext()
207 folly::SemiFuture<CloseType> waitForClose() { in waitForClose()
214 folly::Promise<CloseType> closedType_;
H A DMergeTest.cpp233 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::NoException); in TEST_F()
260 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::Exception); in TEST_F()
280 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::Cancelled); in TEST_F()
305 AnyOf(Eq(CloseType::NoException), Eq(CloseType::Cancelled))); in TEST_F()
330 AnyOf(Eq(CloseType::NoException), Eq(CloseType::Cancelled))); in TEST_F()
H A DFanoutChannelTest.cpp336 EXPECT_EQ(consumers_.at(0)->waitForClose().get(), CloseType::Cancelled); in TEST_F()
341 EXPECT_EQ(consumers_.at(1)->waitForClose().get(), CloseType::NoException); in TEST_F()
342 EXPECT_EQ(consumers_.at(2)->waitForClose().get(), CloseType::NoException); in TEST_F()
364 EXPECT_EQ(consumers_.at(0)->waitForClose().get(), CloseType::Cancelled); in TEST_F()
369 EXPECT_EQ(consumers_.at(1)->waitForClose().get(), CloseType::NoException); in TEST_F()
370 EXPECT_EQ(consumers_.at(2)->waitForClose().get(), CloseType::NoException); in TEST_F()
H A DMergeChannelTest.cpp536 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::NoException); in TEST_F()
562 EXPECT_EQ(consumer_->waitForClose().get(), CloseType::Cancelled); in TEST_F()
591 AnyOf(Eq(CloseType::NoException), Eq(CloseType::Cancelled))); in TEST_F()
620 AnyOf(Eq(CloseType::NoException), Eq(CloseType::Cancelled))); in TEST_F()
/dports/www/chromium-legacy/chromium-88.0.4324.182/styleguide/c++/
H A Dblink-c++.md247 enum class CloseType {
252 bool ShouldClose(CloseType) {
253 if (type == CloseType::kForReload) {
256 DCHECK_EQ(type, CloseType::kNotForReload);
263 if (frame_->Loader().ShouldClose(FrameLoader::CloseType::kNotForReload)) {
/dports/cad/abc/abc-a4518e6f833885c905964f1233d11e5b941ec24c/src/opt/dau/
H A DdauArray.c143 char CloseType[7] = {0, 0, 0, ')', ']', '>', '}'}; in Dau_DsdPrint() local
168 pTypes[d] = CloseType[p->Type]; in Dau_DsdPrint()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/styleguide/c++/
H A Dblink-c++.md260 enum class CloseType {
265 bool ShouldClose(CloseType) {
266 if (type == CloseType::kForReload) {
269 DCHECK_EQ(type, CloseType::kNotForReload);
276 if (frame_->Loader().ShouldClose(FrameLoader::CloseType::kNotForReload)) {

12