Home
last modified time | relevance | path

Searched refs:Svc (Results 1 – 25 of 1050) sorted by relevance

12345678910>>...42

/dports/sysutils/vector/tower-c87fdd9c1e4c0728fdaa87d3fafe3e48da9b498a/tower/src/util/call_all/
H A Dordered.rs81 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 Dunordered.rs20 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 Dcommon.rs14 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 Dordered.rs80 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 Dunordered.rs12 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 Dcommon.rs8 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 Dordered.rs80 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 Dunordered.rs12 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 Dcommon.rs8 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 DServiceContainerTest.cs25 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 Ddiameter_callback.erl102 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 Ddiameter_callback.erl102 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 Ddiameter_callback.erl102 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 Ddiameter_callback.erl102 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 Ddiameter_callback.erl102 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 Ddiameter_callback.erl102 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 Ddiameter_callback.erl102 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 Dmemory_block.h53 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 Ddiameter_event_SUITE.erl121 {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 Ddiameter_event_SUITE.erl121 {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 Ddiameter_event_SUITE.erl121 {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 Ddiameter_event_SUITE.erl121 {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 Ddiameter_event_SUITE.erl121 {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 Ddiameter_event_SUITE.erl112 {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 Ddiameter_event_SUITE.erl121 {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 …]

12345678910>>...42