/dports/www/firefox/firefox-99.0/third_party/rust/glean/src/dispatcher/ |
H A D | mod.rs | 67 pub enum DispatchError { enum 89 impl From<TrySendError<Command>> for DispatchError { implementation 93 _ => DispatchError::SendError, in from() 98 impl<T> From<SendError<T>> for DispatchError { implementation 100 DispatchError::SendError in from() 141 .map_err(DispatchError::from) in send() 177 fn kill(&mut self) -> Result<(), DispatchError> { in kill() argument 181 return Err(DispatchError::AlreadyFlushed); in kill() 193 return Err(DispatchError::AlreadyFlushed); in flush_init() 205 .map_err(|_| DispatchError::SendError)?; in flush_init() [all …]
|
H A D | global.rs | 8 use super::{DispatchError, DispatchGuard, Dispatcher}; 39 Err(DispatchError::QueueFull) => { in launch() 50 pub fn block_on_queue() -> Result<(), DispatchError> { in block_on_queue() 63 pub fn flush_init() -> Result<usize, DispatchError> { in flush_init() 67 fn join_dispatcher_thread() -> Result<(), DispatchError> { in join_dispatcher_thread() 74 return worker.join().map_err(|_| DispatchError::WorkerPanic); in join_dispatcher_thread() 85 pub fn kill() -> Result<(), DispatchError> { in kill() 94 pub fn shutdown() -> Result<(), DispatchError> { in shutdown()
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/glean/src/dispatcher/ |
H A D | mod.rs | 67 pub enum DispatchError { enum 89 impl From<TrySendError<Command>> for DispatchError { implementation 93 _ => DispatchError::SendError, in from() 98 impl<T> From<SendError<T>> for DispatchError { implementation 100 DispatchError::SendError in from() 141 .map_err(DispatchError::from) in send() 179 fn kill(&mut self) -> Result<(), DispatchError> { in kill() argument 183 return Err(DispatchError::AlreadyFlushed); in kill() 195 return Err(DispatchError::AlreadyFlushed); in flush_init() 207 .map_err(|_| DispatchError::SendError)?; in flush_init() [all …]
|
H A D | global.rs | 8 use super::{DispatchError, DispatchGuard, Dispatcher}; 39 Err(DispatchError::QueueFull) => { in launch() 63 pub fn flush_init() -> Result<usize, DispatchError> { in flush_init() 67 fn join_dispatcher_thread() -> Result<(), DispatchError> { in join_dispatcher_thread() 74 return worker.join().map_err(|_| DispatchError::WorkerPanic); in join_dispatcher_thread() 85 pub fn kill() -> Result<(), DispatchError> { in kill() 94 pub fn shutdown() -> Result<(), DispatchError> { in shutdown()
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/rust/glean/src/dispatcher/ |
H A D | mod.rs | 67 pub enum DispatchError { enum 89 impl From<TrySendError<Command>> for DispatchError { implementation 93 _ => DispatchError::SendError, in from() 98 impl<T> From<SendError<T>> for DispatchError { implementation 100 DispatchError::SendError in from() 141 .map_err(DispatchError::from) in send() 179 fn kill(&mut self) -> Result<(), DispatchError> { in kill() argument 183 return Err(DispatchError::AlreadyFlushed); in kill() 195 return Err(DispatchError::AlreadyFlushed); in flush_init() 207 .map_err(|_| DispatchError::SendError)?; in flush_init() [all …]
|
H A D | global.rs | 8 use super::{DispatchError, DispatchGuard, Dispatcher}; 39 Err(DispatchError::QueueFull) => { in launch() 63 pub fn flush_init() -> Result<usize, DispatchError> { in flush_init() 67 fn join_dispatcher_thread() -> Result<(), DispatchError> { in join_dispatcher_thread() 74 return worker.join().map_err(|_| DispatchError::WorkerPanic); in join_dispatcher_thread() 85 pub fn kill() -> Result<(), DispatchError> { in kill() 94 pub fn shutdown() -> Result<(), DispatchError> { in shutdown()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/v8/third_party/inspector_protocol/crdtp/ |
H A D | dispatch_test.cc | 59 EXPECT_EQ(DispatchCode::INVALID_REQUEST, empty.DispatchError().Code()); in TEST() 60 EXPECT_EQ("Message must be an object", empty.DispatchError().Message()); in TEST() 72 dispatchable.DispatchError().Message()); in TEST() 85 dispatchable.DispatchError().Message()); in TEST() 97 dispatchable.DispatchError().Message()); in TEST() 111 dispatchable.DispatchError().Message()); in TEST() 129 dispatchable.DispatchError().Message()); in TEST() 146 dispatchable.DispatchError().Message()); in TEST() 161 dispatchable.DispatchError().Message()); in TEST() 175 EXPECT_THAT(dispatchable.DispatchError().Message(), in TEST() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/inspector_protocol/crdtp/ |
H A D | dispatch_test.cc | 59 EXPECT_EQ(DispatchCode::INVALID_REQUEST, empty.DispatchError().Code()); in TEST() 60 EXPECT_EQ("Message must be an object", empty.DispatchError().Message()); in TEST() 72 dispatchable.DispatchError().Message()); in TEST() 85 dispatchable.DispatchError().Message()); in TEST() 97 dispatchable.DispatchError().Message()); in TEST() 111 dispatchable.DispatchError().Message()); in TEST() 129 dispatchable.DispatchError().Message()); in TEST() 146 dispatchable.DispatchError().Message()); in TEST() 161 dispatchable.DispatchError().Message()); in TEST() 175 EXPECT_THAT(dispatchable.DispatchError().Message(), in TEST() [all …]
|
/dports/lang/v8/v8-9.6.180.12/third_party/inspector_protocol/crdtp/ |
H A D | dispatch_test.cc | 59 EXPECT_EQ(DispatchCode::INVALID_REQUEST, empty.DispatchError().Code()); in TEST() 60 EXPECT_EQ("Message must be an object", empty.DispatchError().Message()); in TEST() 72 dispatchable.DispatchError().Message()); in TEST() 85 dispatchable.DispatchError().Message()); in TEST() 97 dispatchable.DispatchError().Message()); in TEST() 111 dispatchable.DispatchError().Message()); in TEST() 129 dispatchable.DispatchError().Message()); in TEST() 146 dispatchable.DispatchError().Message()); in TEST() 161 dispatchable.DispatchError().Message()); in TEST() 175 EXPECT_THAT(dispatchable.DispatchError().Message(), in TEST() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/inspector_protocol/crdtp/ |
H A D | dispatch_test.cc | 59 EXPECT_EQ(DispatchCode::INVALID_REQUEST, empty.DispatchError().Code()); in TEST() 60 EXPECT_EQ("Message must be an object", empty.DispatchError().Message()); in TEST() 72 dispatchable.DispatchError().Message()); in TEST() 85 dispatchable.DispatchError().Message()); in TEST() 97 dispatchable.DispatchError().Message()); in TEST() 111 dispatchable.DispatchError().Message()); in TEST() 129 dispatchable.DispatchError().Message()); in TEST() 146 dispatchable.DispatchError().Message()); in TEST() 161 dispatchable.DispatchError().Message()); in TEST() 175 EXPECT_THAT(dispatchable.DispatchError().Message(), in TEST() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/v8/third_party/inspector_protocol/crdtp/ |
H A D | dispatch_test.cc | 59 EXPECT_EQ(DispatchCode::INVALID_REQUEST, empty.DispatchError().Code()); in TEST() 60 EXPECT_EQ("Message must be an object", empty.DispatchError().Message()); in TEST() 72 dispatchable.DispatchError().Message()); in TEST() 85 dispatchable.DispatchError().Message()); in TEST() 97 dispatchable.DispatchError().Message()); in TEST() 111 dispatchable.DispatchError().Message()); in TEST() 129 dispatchable.DispatchError().Message()); in TEST() 146 dispatchable.DispatchError().Message()); in TEST() 161 dispatchable.DispatchError().Message()); in TEST() 175 EXPECT_THAT(dispatchable.DispatchError().Message(), in TEST() [all …]
|
/dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/wayland-scanner-0.30.0-alpha5/tests/scanner_assets/ |
H A D | test-server-code.rs | 8 Dispatch, DispatchError, DisplayHandle, New, Resource, ResourceData, 71 ) -> Result<(Self, Self::Request), DispatchError> { in parse_request() argument 110 Dispatch, DispatchError, DisplayHandle, New, Resource, ResourceData, 231 ) -> Result<(Self, Self::Request), DispatchError> { in parse_request() argument 317 return Err(DispatchError::BadMessage { in parse_request() 458 Dispatch, DispatchError, DisplayHandle, New, Resource, ResourceData, 518 ) -> Result<(Self, Self::Request), DispatchError> { in parse_request() argument 553 Dispatch, DispatchError, DisplayHandle, New, Resource, ResourceData, 613 ) -> Result<(Self, Self::Request), DispatchError> { in parse_request() argument 648 Dispatch, DispatchError, DisplayHandle, New, Resource, ResourceData, [all …]
|
H A D | test-client-code.rs | 8 ConnectionHandle, Dispatch, DispatchError, Proxy, QueueHandle, QueueProxyData, 122 ) -> Result<(Self, Self::Event), DispatchError> { in parse_event() argument 222 ConnectionHandle, Dispatch, DispatchError, Proxy, QueueHandle, QueueProxyData, 306 ) -> Result<(Self, Self::Event), DispatchError> { in parse_event() argument 445 ) -> Result<(Self, Self::Event), DispatchError> { in parse_event() argument 589 ) -> Result<(Self, Self::Event), DispatchError> { in parse_event() argument 623 return Err(DispatchError::BadMessage { in parse_event() 646 return Err(DispatchError::BadMessage { in parse_event() 884 ) -> Result<(Self, Self::Event), DispatchError> { in parse_event() argument 977 ) -> Result<(Self, Self::Event), DispatchError> { in parse_event() argument [all …]
|
/dports/www/miniserve/miniserve-0.18.0/cargo-crates/actix-http-3.0.0-beta.9/src/h2/ |
H A D | dispatcher.rs | 74 type Output = Result<(), crate::error::DispatchError>; 115 DispatchError::SendResponse(err) => { in poll() 118 DispatchError::SendData(err) => warn!("{:?}", err), in poll() 119 DispatchError::ResponseBody(err) => { in poll() 131 enum DispatchError { enum 141 ) -> Result<(), DispatchError> in handle_response() 156 .map_err(DispatchError::SendResponse)?; in handle_response() 166 let mut chunk = res.map_err(|err| DispatchError::ResponseBody(err.into()))?; in handle_response() 177 let cap = res.map_err(DispatchError::SendData)?; in handle_response() 184 .map_err(DispatchError::SendData)?; in handle_response() [all …]
|
H A D | service.rs | 26 error::DispatchError, 89 Error = DispatchError, in tcp() 95 ready(Ok::<_, DispatchError>((io, peer_addr))) in tcp() 129 Error = TlsError<SslError, DispatchError>, in openssl() argument 175 Error = TlsError<io::Error, DispatchError>, in rustls() argument 212 type Error = DispatchError; 274 type Error = DispatchError; 281 DispatchError::Service(e) in poll_ready() 338 type Output = Result<(), DispatchError>;
|
/dports/www/firefox-legacy/firefox-52.8.0esr/hal/gonk/ |
H A D | GonkSensorsRegistryInterface.cpp | 174 DispatchError(aRes, rv); in RegisterModule() 186 DispatchError(aRes, rv); in UnregisterModule() 191 GonkSensorsRegistryInterface::DispatchError( in DispatchError() function in mozilla::hal::GonkSensorsRegistryInterface 201 GonkSensorsRegistryInterface::DispatchError( in DispatchError() function in mozilla::hal::GonkSensorsRegistryInterface 209 DispatchError(aRes, error); in DispatchError()
|
H A D | GonkSensorsPollInterface.cpp | 380 DispatchError(aRes, rv); in EnableSensor() 392 DispatchError(aRes, rv); in DisableSensor() 404 DispatchError(aRes, rv); in SetPeriod() 409 GonkSensorsPollInterface::DispatchError( in DispatchError() function in mozilla::hal::GonkSensorsPollInterface 419 GonkSensorsPollInterface::DispatchError( in DispatchError() function in mozilla::hal::GonkSensorsPollInterface 427 DispatchError(aRes, error); in DispatchError()
|
/dports/www/firefox-esr/firefox-91.8.0/dom/media/webspeech/recognition/ |
H A D | OnlineSpeechRecognitionService.cpp | 144 mRecognition->DispatchError( in OnStopRequest() 236 mRecognition->DispatchError( in EncoderError() 309 mRecognition->DispatchError( in DoSTT() 322 mRecognition->DispatchError( in DoSTT() 330 mRecognition->DispatchError( in DoSTT() 338 mRecognition->DispatchError( in DoSTT() 383 mRecognition->DispatchError( in DoSTT() 397 mRecognition->DispatchError( in DoSTT() 411 mRecognition->DispatchError( in DoSTT()
|
/dports/lang/spidermonkey78/firefox-78.9.0/dom/media/webspeech/recognition/ |
H A D | OnlineSpeechRecognitionService.cpp | 140 mRecognition->DispatchError( in OnStopRequest() 238 mRecognition->DispatchError( in EncoderError() 311 mRecognition->DispatchError( in DoSTT() 326 mRecognition->DispatchError( in DoSTT() 334 mRecognition->DispatchError( in DoSTT() 342 mRecognition->DispatchError( in DoSTT() 391 mRecognition->DispatchError( in DoSTT() 406 mRecognition->DispatchError( in DoSTT() 422 mRecognition->DispatchError( in DoSTT()
|
/dports/www/firefox/firefox-99.0/dom/media/webspeech/recognition/ |
H A D | OnlineSpeechRecognitionService.cpp | 144 mRecognition->DispatchError( in OnStopRequest() 236 mRecognition->DispatchError( in EncoderError() 309 mRecognition->DispatchError( in DoSTT() 322 mRecognition->DispatchError( in DoSTT() 330 mRecognition->DispatchError( in DoSTT() 338 mRecognition->DispatchError( in DoSTT() 383 mRecognition->DispatchError( in DoSTT() 397 mRecognition->DispatchError( in DoSTT() 411 mRecognition->DispatchError( in DoSTT()
|
/dports/mail/thunderbird/thunderbird-91.8.0/dom/media/webspeech/recognition/ |
H A D | OnlineSpeechRecognitionService.cpp | 144 mRecognition->DispatchError( in OnStopRequest() 236 mRecognition->DispatchError( in EncoderError() 309 mRecognition->DispatchError( in DoSTT() 322 mRecognition->DispatchError( in DoSTT() 330 mRecognition->DispatchError( in DoSTT() 338 mRecognition->DispatchError( in DoSTT() 383 mRecognition->DispatchError( in DoSTT() 397 mRecognition->DispatchError( in DoSTT() 411 mRecognition->DispatchError( in DoSTT()
|
/dports/net/proby/proby-1.0.2/cargo-crates/actix-http-1.0.1/src/h1/ |
H A D | dispatcher.rs | 17 use crate::error::{DispatchError, Error}; 89 error: Option<DispatchError>, 305 return Err(DispatchError::Io(io::Error::new( in poll_flush() 334 ) -> Result<State<S, B, X>, DispatchError> { in send_response() argument 341 DispatchError::Io(err) in send_response() 359 ) -> Result<PollResponse, DispatchError> { in poll_response() argument 463 ) -> Result<State<S, B, X>, DispatchError> { in handle_request() argument 504 ) -> Result<bool, DispatchError> { in poll_request() argument 579 self.error = Some(DispatchError::Io(e)); in poll_request() 710 type Output = Result<(), DispatchError>; [all …]
|
/dports/net/proby/proby-1.0.2/cargo-crates/actix-http-1.0.1/src/h2/ |
H A D | service.rs | 22 use crate::error::{DispatchError, Error}; 83 Error = DispatchError, in tcp() 90 ok::<_, DispatchError>((io, peer_addr)) in tcp() 122 Error = SslError<HandshakeError<TcpStream>, DispatchError>, in openssl() argument 164 Error = SslError<io::Error, DispatchError>, in rustls() argument 198 type Error = DispatchError; 289 type Error = DispatchError; 296 DispatchError::Service(e) in poll_ready() 355 type Output = Result<(), DispatchError>;
|
/dports/www/miniserve/miniserve-0.18.0/cargo-crates/actix-http-3.0.0-beta.9/src/h1/ |
H A D | dispatcher.rs | 24 error::{DispatchError, ParseError, PayloadError}, 110 error: Option<DispatchError>, 304 ) -> Result<BodySize, DispatchError> { in send_response_inner() argument 313 DispatchError::Io(err) in send_response_inner() 325 ) -> Result<(), DispatchError> { in send_response() argument 339 ) -> Result<(), DispatchError> { in send_error_response() argument 516 ) -> Result<(), DispatchError> { in handle_request() argument 586 ) -> Result<bool, DispatchError> { in poll_request() argument 728 ) -> Result<(), DispatchError> { in poll_keepalive() argument 809 ) -> Result<bool, DispatchError> { in read_available() argument [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/dom/media/webspeech/synth/test/ |
H A D | nsFakeSynthServices.cpp | 166 class DispatchError final : public Runnable { in NS_IMPL_ISUPPORTS() class 168 DispatchError(nsISpeechTask* aTask, const nsAString& aText) in NS_IMPL_ISUPPORTS() function in mozilla::dom::NS_IMPL_ISUPPORTS::DispatchError 172 mTask->DispatchError(mText.Length() / 2, mText.Length()); in NS_IMPL_ISUPPORTS() 203 runnable = new DispatchError(aTask, aText); in NS_IMPL_ISUPPORTS()
|