/dports/sysutils/vector/tower-c87fdd9c1e4c0728fdaa87d3fafe3e48da9b498a/tower/src/util/call_all/ |
H A D | ordered.rs | 81 pub struct CallAll<Svc, S> 83 Svc: Service<S::Item>, 87 inner: common::CallAll<Svc, S, FuturesOrdered<Svc::Future>>, 90 impl<Svc, S> CallAll<Svc, S> 92 Svc: Service<S::Item>, 93 Svc::Error: Into<Error>, 100 pub fn new(service: Svc, stream: S) -> CallAll<Svc, S> { in new() argument 111 pub fn into_inner(self) -> Svc { in into_inner() argument 138 impl<Svc, S> Stream for CallAll<Svc, S> 140 Svc: Service<S::Item>, [all …]
|
H A D | unordered.rs | 20 pub struct CallAllUnordered<Svc, S> 22 Svc: Service<S::Item>, 26 inner: common::CallAll<Svc, S, FuturesUnordered<Svc::Future>>, 29 impl<Svc, S> CallAllUnordered<Svc, S> 31 Svc: Service<S::Item>, 32 Svc::Error: Into<Error>, 40 pub fn new(service: Svc, stream: S) -> CallAllUnordered<Svc, S> { in new() argument 51 pub fn into_inner(self) -> Svc { in into_inner() argument 67 impl<Svc, S> Stream for CallAllUnordered<Svc, S> 69 Svc: Service<S::Item>, [all …]
|
H A D | common.rs | 14 pub(crate) struct CallAll<Svc, S, Q> { 15 service: Option<Svc>, 31 impl<Svc, S, Q> CallAll<Svc, S, Q> 33 Svc: Service<S::Item>, 34 Svc::Error: Into<Error>, 36 Q: Drive<Svc::Future>, 38 pub(crate) fn new(service: Svc, stream: S, queue: Q) -> CallAll<Svc, S, Q> { in new() argument 67 impl<Svc, S, Q> Stream for CallAll<Svc, S, Q> 69 Svc: Service<S::Item>, 70 Svc::Error: Into<Error>, [all …]
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/tower-util-0.1.0/src/call_all/ |
H A D | ordered.rs | 80 pub struct CallAll<Svc, S> 82 Svc: Service<S::Item>, 85 inner: common::CallAll<Svc, S, FuturesOrdered<Svc::Future>>, 88 impl<Svc, S> CallAll<Svc, S> 90 Svc: Service<S::Item>, 91 Svc::Error: Into<Error>, 99 pub fn new(service: Svc, stream: S) -> CallAll<Svc, S> { in new() argument 122 impl<Svc, S> Stream for CallAll<Svc, S> 124 Svc: Service<S::Item>, 125 Svc::Error: Into<Error>, [all …]
|
H A D | unordered.rs | 12 pub struct CallAllUnordered<Svc, S> 14 Svc: Service<S::Item>, 17 inner: common::CallAll<Svc, S, FuturesUnordered<Svc::Future>>, 20 impl<Svc, S> CallAllUnordered<Svc, S> 22 Svc: Service<S::Item>, 23 Svc::Error: Into<Error>, 32 pub fn new(service: Svc, stream: S) -> CallAllUnordered<Svc, S> { in new() argument 44 impl<Svc, S> Stream for CallAllUnordered<Svc, S> 46 Svc: Service<S::Item>, 47 Svc::Error: Into<Error>, [all …]
|
H A D | common.rs | 8 service: Svc, 22 impl<Svc, S, Q> CallAll<Svc, S, Q> 24 Svc: Service<S::Item>, 25 Svc::Error: Into<Error>, 28 Q: Drive<Svc::Future>, 30 pub(crate) fn new(service: Svc, stream: S, queue: Q) -> CallAll<Svc, S, Q> { in new() argument 51 impl<Svc, S, Q> Stream for CallAll<Svc, S, Q> 53 Svc: Service<S::Item>, 54 Svc::Error: Into<Error>, 57 Q: Drive<Svc::Future>, [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/tower-util-0.1.0/src/call_all/ |
H A D | ordered.rs | 80 pub struct CallAll<Svc, S> 82 Svc: Service<S::Item>, 85 inner: common::CallAll<Svc, S, FuturesOrdered<Svc::Future>>, 88 impl<Svc, S> CallAll<Svc, S> 90 Svc: Service<S::Item>, 91 Svc::Error: Into<Error>, 99 pub fn new(service: Svc, stream: S) -> CallAll<Svc, S> { in new() argument 122 impl<Svc, S> Stream for CallAll<Svc, S> 124 Svc: Service<S::Item>, 125 Svc::Error: Into<Error>, [all …]
|
H A D | unordered.rs | 12 pub struct CallAllUnordered<Svc, S> 14 Svc: Service<S::Item>, 17 inner: common::CallAll<Svc, S, FuturesUnordered<Svc::Future>>, 20 impl<Svc, S> CallAllUnordered<Svc, S> 22 Svc: Service<S::Item>, 23 Svc::Error: Into<Error>, 32 pub fn new(service: Svc, stream: S) -> CallAllUnordered<Svc, S> { in new() argument 44 impl<Svc, S> Stream for CallAllUnordered<Svc, S> 46 Svc: Service<S::Item>, 47 Svc::Error: Into<Error>, [all …]
|
H A D | common.rs | 8 service: Svc, 22 impl<Svc, S, Q> CallAll<Svc, S, Q> 24 Svc: Service<S::Item>, 25 Svc::Error: Into<Error>, 28 Q: Drive<Svc::Future>, 30 pub(crate) fn new(service: Svc, stream: S, queue: Q) -> CallAll<Svc, S, Q> { in new() argument 51 impl<Svc, S, Q> Stream for CallAll<Svc, S, Q> 53 Svc: Service<S::Item>, 54 Svc::Error: Into<Error>, 57 Q: Drive<Svc::Future>, [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/Test/System.ComponentModel.Design/ |
H A D | ServiceContainerTest.cs | 25 class Svc class 154 Svc serviceInstance1 = new Svc (); in AddService1_ServiceType_Exists() 155 Svc serviceInstance2 = new Svc (); in AddService1_ServiceType_Exists() 442 sc.AddService (typeof (Svc), new Svc ()); in GeneralTest1() 443 Svc service1 = sc.GetService (typeof (Svc)) as Svc; in GeneralTest1() 454 sc.AddService (typeof (Svc), new Svc ()); in GeneralTest2() 455 Svc service1 = sc.GetService (typeof (Svc)) as Svc; in GeneralTest2() 460 sc.AddService (typeof (Svc), new Svc ()); in GeneralTest2() 496 Svc service1 = sc.GetService (typeof (Svc)) as Svc; in TestServiceCreator() 500 Svc service2 = sc.GetService (typeof (Svc)) as Svc; in TestServiceCreator() [all …]
|
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/diameter/src/base/ |
H A D | diameter_callback.erl | 102 peer_up(Svc, Peer, State, D) -> 104 [Svc, Peer, State], 115 peer_down(Svc, Peer, State, D) -> 117 [Svc, Peer, State], 132 [PeersL, PeersR, Svc, State], 145 [Pkt, Svc, Peer], 158 [Pkt, Svc, Peer], 169 handle_request(Pkt, Svc, Peer, D) -> 171 [Pkt, Svc, Peer], 186 [Pkt, Req, Svc, Peer], [all …]
|
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/diameter/src/base/ |
H A D | diameter_callback.erl | 102 peer_up(Svc, Peer, State, D) -> 104 [Svc, Peer, State], 115 peer_down(Svc, Peer, State, D) -> 117 [Svc, Peer, State], 132 [PeersL, PeersR, Svc, State], 145 [Pkt, Svc, Peer], 158 [Pkt, Svc, Peer], 169 handle_request(Pkt, Svc, Peer, D) -> 171 [Pkt, Svc, Peer], 186 [Pkt, Req, Svc, Peer], [all …]
|
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/diameter/src/base/ |
H A D | diameter_callback.erl | 102 peer_up(Svc, Peer, State, D) -> 104 [Svc, Peer, State], 115 peer_down(Svc, Peer, State, D) -> 117 [Svc, Peer, State], 132 [PeersL, PeersR, Svc, State], 145 [Pkt, Svc, Peer], 158 [Pkt, Svc, Peer], 169 handle_request(Pkt, Svc, Peer, D) -> 171 [Pkt, Svc, Peer], 186 [Pkt, Req, Svc, Peer], [all …]
|
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/diameter/src/base/ |
H A D | diameter_callback.erl | 102 peer_up(Svc, Peer, State, D) -> 104 [Svc, Peer, State], 115 peer_down(Svc, Peer, State, D) -> 117 [Svc, Peer, State], 132 [PeersL, PeersR, Svc, State], 145 [Pkt, Svc, Peer], 158 [Pkt, Svc, Peer], 169 handle_request(Pkt, Svc, Peer, D) -> 171 [Pkt, Svc, Peer], 186 [Pkt, Req, Svc, Peer], [all …]
|
/dports/lang/erlang/otp-OTP-24.1.7/lib/diameter/src/base/ |
H A D | diameter_callback.erl | 102 peer_up(Svc, Peer, State, D) -> 104 [Svc, Peer, State], 115 peer_down(Svc, Peer, State, D) -> 117 [Svc, Peer, State], 132 [PeersL, PeersR, Svc, State], 145 [Pkt, Svc, Peer], 158 [Pkt, Svc, Peer], 169 handle_request(Pkt, Svc, Peer, D) -> 171 [Pkt, Svc, Peer], 186 [Pkt, Req, Svc, Peer], [all …]
|
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/diameter/src/base/ |
H A D | diameter_callback.erl | 102 peer_up(Svc, Peer, State, D) -> 104 [Svc, Peer, State], 115 peer_down(Svc, Peer, State, D) -> 117 [Svc, Peer, State], 132 [PeersL, PeersR, Svc, State], 145 [Pkt, Svc, Peer], 158 [Pkt, Svc, Peer], 169 handle_request(Pkt, Svc, Peer, D) -> 171 [Pkt, Svc, Peer], 186 [Pkt, Req, Svc, Peer], [all …]
|
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/diameter/src/base/ |
H A D | diameter_callback.erl | 102 peer_up(Svc, Peer, State, D) -> 104 [Svc, Peer, State], 115 peer_down(Svc, Peer, State, D) -> 117 [Svc, Peer, State], 132 [PeersL, PeersR, Svc, State], 145 [Pkt, Svc, Peer], 158 [Pkt, Svc, Peer], 169 handle_request(Pkt, Svc, Peer, D) -> 171 [Pkt, Svc, Peer], 186 [Pkt, Req, Svc, Peer], [all …]
|
/dports/emulators/yuzu/yuzu-0b47f7a46/src/core/hle/kernel/memory/ |
H A D | memory_block.h | 53 Free = static_cast<u32>(Svc::MemoryState::Free), 54 Io = static_cast<u32>(Svc::MemoryState::Io) | FlagMapped, 86 Inaccessible = static_cast<u32>(Svc::MemoryState::Inaccessible), 94 Kernel = static_cast<u32>(Svc::MemoryState::Kernel) | FlagMapped, 135 UserMask = static_cast<u8>(Svc::MemoryPermission::Read | Svc::MemoryPermission::Write | 136 Svc::MemoryPermission::Execute), 146 Locked = static_cast<u8>(Svc::MemoryAttribute::Locked), 147 IpcLocked = static_cast<u8>(Svc::MemoryAttribute::IpcLocked), 149 Uncached = static_cast<u8>(Svc::MemoryAttribute::Uncached), 170 constexpr Svc::MemoryInfo GetSvcMemoryInfo() const { in GetSvcMemoryInfo() [all …]
|
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/diameter/test/ |
H A D | diameter_event_SUITE.erl | 121 {Svc, Ref, T} = connect(Config, [{strict_mbit, false}, 124 start = event(Svc), 126 = {event(Svc), T}, 128 {watchdog, Ref, _, {initial, okay}, _} = event(Svc), 133 {{down, Ref, {TPid, Caps}, T}, _} = {event(Svc), T}, 134 {watchdog, Ref, _, {okay, down}, _} = event(Svc), 135 {reconnect, Ref, _} = event(Svc, 10000, 20000). 146 start = event(Svc), 149 = {event(Svc), T}, 151 {reconnect, Ref, _} = event(Svc, 4000, 10000). [all …]
|
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/diameter/test/ |
H A D | diameter_event_SUITE.erl | 121 {Svc, Ref, T} = connect(Config, [{strict_mbit, false}, 124 start = event(Svc), 126 = {event(Svc), T}, 128 {watchdog, Ref, _, {initial, okay}, _} = event(Svc), 133 {{down, Ref, {TPid, Caps}, T}, _} = {event(Svc), T}, 134 {watchdog, Ref, _, {okay, down}, _} = event(Svc), 135 {reconnect, Ref, _} = event(Svc, 10000, 20000). 146 start = event(Svc), 149 = {event(Svc), T}, 151 {reconnect, Ref, _} = event(Svc, 4000, 10000). [all …]
|
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/diameter/test/ |
H A D | diameter_event_SUITE.erl | 121 {Svc, Ref, T} = connect(Config, [{strict_mbit, false}, 124 start = event(Svc), 126 = {event(Svc), T}, 128 {watchdog, Ref, _, {initial, okay}, _} = event(Svc), 133 {{down, Ref, {TPid, Caps}, T}, _} = {event(Svc), T}, 134 {watchdog, Ref, _, {okay, down}, _} = event(Svc), 135 {reconnect, Ref, _} = event(Svc, 10000, 20000). 146 start = event(Svc), 149 = {event(Svc), T}, 151 {reconnect, Ref, _} = event(Svc, 4000, 10000). [all …]
|
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/diameter/test/ |
H A D | diameter_event_SUITE.erl | 121 {Svc, Ref, T} = connect(Config, [{strict_mbit, false}, 124 start = event(Svc), 126 = {event(Svc), T}, 128 {watchdog, Ref, _, {initial, okay}, _} = event(Svc), 133 {{down, Ref, {TPid, Caps}, T}, _} = {event(Svc), T}, 134 {watchdog, Ref, _, {okay, down}, _} = event(Svc), 135 {reconnect, Ref, _} = event(Svc, 10000, 20000). 146 start = event(Svc), 149 = {event(Svc), T}, 151 {reconnect, Ref, _} = event(Svc, 4000, 10000). [all …]
|
/dports/lang/erlang/otp-OTP-24.1.7/lib/diameter/test/ |
H A D | diameter_event_SUITE.erl | 121 {Svc, Ref, T} = connect(Config, [{strict_mbit, false}, 124 start = event(Svc), 126 = {event(Svc), T}, 128 {watchdog, Ref, _, {initial, okay}, _} = event(Svc), 133 {{down, Ref, {TPid, Caps}, T}, _} = {event(Svc), T}, 134 {watchdog, Ref, _, {okay, down}, _} = event(Svc), 135 {reconnect, Ref, _} = event(Svc, 10000, 20000). 146 start = event(Svc), 149 = {event(Svc), T}, 151 {reconnect, Ref, _} = event(Svc, 4000, 10000). [all …]
|
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/diameter/test/ |
H A D | diameter_event_SUITE.erl | 112 {Svc, Ref} = connect(Config, [{connect_timer, 5000}, 114 start = event(Svc), 117 {watchdog, Ref, _, {initial, okay}, _} = event(Svc), 122 {down, Ref, {TPid, Caps}, Cfg} = event(Svc), 123 {watchdog, Ref, _, {okay, down}, _} = event(Svc), 124 {reconnect, Ref, _} = event(Svc, 10000, 20000). 135 start = event(Svc), 137 = event(Svc), 139 {reconnect, Ref, _} = event(Svc, 4000, 10000). 146 start = event(Svc), [all …]
|
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/diameter/test/ |
H A D | diameter_event_SUITE.erl | 121 {Svc, Ref, T} = connect(Config, [{strict_mbit, false}, 124 start = event(Svc), 126 = {event(Svc), T}, 128 {watchdog, Ref, _, {initial, okay}, _} = event(Svc), 133 {{down, Ref, {TPid, Caps}, T}, _} = {event(Svc), T}, 134 {watchdog, Ref, _, {okay, down}, _} = event(Svc), 135 {reconnect, Ref, _} = event(Svc, 10000, 20000). 146 start = event(Svc), 149 = {event(Svc), T}, 151 {reconnect, Ref, _} = event(Svc, 4000, 10000). [all …]
|