Home
last modified time | relevance | path

Searched refs:DispatchError (Results 1 – 25 of 180) sorted by relevance

12345678

/dports/www/firefox/firefox-99.0/third_party/rust/glean/src/dispatcher/
H A Dmod.rs67 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 Dglobal.rs8 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 Dmod.rs67 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 Dglobal.rs8 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 Dmod.rs67 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 Dglobal.rs8 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 Ddispatch_test.cc59 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 Ddispatch_test.cc59 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 Ddispatch_test.cc59 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 Ddispatch_test.cc59 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 Ddispatch_test.cc59 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 Dtest-server-code.rs8 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 Dtest-client-code.rs8 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 Ddispatcher.rs74 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 Dservice.rs26 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 DGonkSensorsRegistryInterface.cpp174 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 DGonkSensorsPollInterface.cpp380 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 DOnlineSpeechRecognitionService.cpp144 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 DOnlineSpeechRecognitionService.cpp140 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 DOnlineSpeechRecognitionService.cpp144 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 DOnlineSpeechRecognitionService.cpp144 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 Ddispatcher.rs17 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 Dservice.rs22 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 Ddispatcher.rs24 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 DnsFakeSynthServices.cpp166 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()

12345678