Home
last modified time | relevance | path

Searched refs:MRef (Results 1 – 25 of 760) sorted by relevance

12345678910>>...31

/dports/devel/erlang-sbroker/sbroker-1.0.0/test/
H A Dsregulator_rate_statem.erl198 {Pid, MRef}.
323 await(MRef, Regulator);
335 await(MRef, Regulator) ->
341 {MRef, {drop, _}} ->
362 {MRef, From, down} ->
369 {MRef, Other} ->
387 {MRef, From, done} ->
396 {MRef, From, down} ->
406 drop(MRef, Regulator) ->
418 {MRef, From, down} ->
[all …]
/dports/lang/erlang-runtime23/corba-5.0.2/lib/orber/src/
H A Dorber_iiop_outproxy.erl72 {MRef, Reply} ->
93 cancel(Pid, RequestId, MRef) ->
147 [{_, Pid, TRef, MRef}] ->
149 Pid ! {MRef, ER},
171 MRef}),
234 [{ReqId, Pid, _, MRef}] ->
276 [{_, Pid, TRef, MRef}] ->
288 [{_, Pid, TRef, MRef}] ->
302 [{_, Pid, TRef, MRef}] ->
314 [{_, Pid, _, MRef}] ->
[all …]
/dports/lang/erlang-runtime24/corba-5.0.2/lib/orber/src/
H A Dorber_iiop_outproxy.erl72 {MRef, Reply} ->
93 cancel(Pid, RequestId, MRef) ->
147 [{_, Pid, TRef, MRef}] ->
149 Pid ! {MRef, ER},
171 MRef}),
234 [{ReqId, Pid, _, MRef}] ->
276 [{_, Pid, TRef, MRef}] ->
288 [{_, Pid, TRef, MRef}] ->
302 [{_, Pid, TRef, MRef}] ->
314 [{_, Pid, _, MRef}] ->
[all …]
/dports/lang/erlang-runtime22/corba-4.5.2/lib/orber/src/
H A Dorber_iiop_outproxy.erl72 {MRef, Reply} ->
93 cancel(Pid, RequestId, MRef) ->
147 [{_, Pid, TRef, MRef}] ->
149 Pid ! {MRef, ER},
171 MRef}),
234 [{ReqId, Pid, _, MRef}] ->
276 [{_, Pid, TRef, MRef}] ->
288 [{_, Pid, TRef, MRef}] ->
302 [{_, Pid, TRef, MRef}] ->
314 [{_, Pid, _, MRef}] ->
[all …]
/dports/lang/erlang/corba-5.0.2/lib/orber/src/
H A Dorber_iiop_outproxy.erl72 {MRef, Reply} ->
93 cancel(Pid, RequestId, MRef) ->
147 [{_, Pid, TRef, MRef}] ->
149 Pid ! {MRef, ER},
171 MRef}),
234 [{ReqId, Pid, _, MRef}] ->
276 [{_, Pid, TRef, MRef}] ->
288 [{_, Pid, TRef, MRef}] ->
302 [{_, Pid, TRef, MRef}] ->
314 [{_, Pid, _, MRef}] ->
[all …]
/dports/lang/erlang-runtime21/corba-4.5.2/lib/orber/src/
H A Dorber_iiop_outproxy.erl72 {MRef, Reply} ->
93 cancel(Pid, RequestId, MRef) ->
147 [{_, Pid, TRef, MRef}] ->
149 Pid ! {MRef, ER},
171 MRef}),
234 [{ReqId, Pid, _, MRef}] ->
276 [{_, Pid, TRef, MRef}] ->
288 [{_, Pid, TRef, MRef}] ->
302 [{_, Pid, TRef, MRef}] ->
314 [{_, Pid, _, MRef}] ->
[all …]
/dports/misc/hs-hascard/hascard-0.3.0.1/_cabal_deps/stateref-0.3/src/Data/MRef/Instances/
H A DSTM.hs12 module Data.MRef.Instances.STM
22 import Data.MRef.Types
29 instance NewMRef (MRef STM a) IO a where
31 newMReference = fmap MRef . newTMVarIO
34 newMReference = fmap MRef . newTVarIO . Just
38 instance TakeMRef (MRef STM a) IO a where
40 instance PutMRef (MRef STM a) IO a where
47 newMRef x = fmap MRef (newTMVar x)
48 newEmptyMRef = fmap MRef newEmptyTMVar
74 newMRef x = fmap MRef (newTVar (Just x))
[all …]
/dports/misc/hs-hascard/hascard-0.3.0.1/_cabal_deps/stateref-0.3/src/Data/
H A DMRef.hs1 module Data.MRef
2 ( module Data.MRef
3 , module Data.MRef.Types
4 , module Data.MRef.Instances
7 import Data.MRef.Types
8 import Data.MRef.Instances
11 takeMRef :: MRef m a -> m a
15 putMRef :: MRef m a -> a -> m ()
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/eetcd/src/
H A Deetcd_watch.erl127 MRef = erlang:monitor(process, Gun),
129 case eetcd_stream:await(Gun, StreamRef, Timeout, MRef) of
145 monitor_ref => MRef,
154 erlang:demonitor(MRef, [flush]),
158 erlang:demonitor(MRef, [flush]),
161 erlang:demonitor(MRef, [flush]),
199 erlang:demonitor(MRef, [flush]),
204 erlang:demonitor(MRef, [flush]),
207 watch_stream(#{http2_pid := Pid, monitor_ref := MRef},
209 erlang:demonitor(MRef, [flush]),
[all …]
H A Deetcd_election.erl111 MRef = erlang:monitor(process, Gun),
116 monitor_ref => MRef,
130 #{monitor_ref := MRef} = CCtx,
131 erlang:demonitor(MRef, [flush]),
237 MRef = erlang:monitor(process, Gun),
258 erlang:demonitor(MRef, [flush]),
264 monitor_ref => MRef,
270 erlang:demonitor(MRef, [flush]),
296 erlang:demonitor(MRef, [flush]),
301 erlang:demonitor(MRef, [flush]),
[all …]
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/diameter/test/
H A Ddiameter_gen_sctp_SUITE.erl175 accept_loop(Sock, MRef).
207 accept_loop(Sock, MRef) ->
231 assoc(MRef, _Id, OS)
232 when is_reference(MRef) ->
238 recv_loop(Sock, Id, Pid, MRef) ->
249 MRef,
253 recv(Sock, Id, Pid, MRef, T);
264 recv_loop(Sock, Id, Pid, MRef);
267 recv_loop(Sock, Id, Pid, MRef);
269 recv(_, _, _, MRef, {'DOWN', MRef, process, _, Reason}) ->
[all …]
H A Ddiameter_gen_tcp_SUITE.erl77 {Pid, MRef} = spawn_monitor(fun() -> connect(PortNr, LPid) end),
82 {'DOWN', MRef, process, _, _} = T ->
99 {_, MRef} = spawn_monitor(fun() -> exit(gen_tcp:send(Sock, Bin)) end),
100 down(MRef).
123 [RC || {_, MRef} <- Monitors, RC <- [down(MRef)], ok /= element(1, RC)].
143 down(MRef) ->
144 receive {'DOWN', MRef, process, _, Reason} -> Reason end.
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/diameter/test/
H A Ddiameter_gen_sctp_SUITE.erl175 accept_loop(Sock, MRef).
207 accept_loop(Sock, MRef) ->
231 assoc(MRef, _Id, OS)
232 when is_reference(MRef) ->
238 recv_loop(Sock, Id, Pid, MRef) ->
249 MRef,
253 recv(Sock, Id, Pid, MRef, T);
264 recv_loop(Sock, Id, Pid, MRef);
267 recv_loop(Sock, Id, Pid, MRef);
269 recv(_, _, _, MRef, {'DOWN', MRef, process, _, Reason}) ->
[all …]
H A Ddiameter_gen_tcp_SUITE.erl77 {Pid, MRef} = spawn_monitor(fun() -> connect(PortNr, LPid) end),
82 {'DOWN', MRef, process, _, _} = T ->
99 {_, MRef} = spawn_monitor(fun() -> exit(gen_tcp:send(Sock, Bin)) end),
100 down(MRef).
123 [RC || {_, MRef} <- Monitors, RC <- [down(MRef)], ok /= element(1, RC)].
143 down(MRef) ->
144 receive {'DOWN', MRef, process, _, Reason} -> Reason end.
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/diameter/test/
H A Ddiameter_gen_sctp_SUITE.erl175 accept_loop(Sock, MRef).
207 accept_loop(Sock, MRef) ->
231 assoc(MRef, _Id, OS)
232 when is_reference(MRef) ->
238 recv_loop(Sock, Id, Pid, MRef) ->
249 MRef,
253 recv(Sock, Id, Pid, MRef, T);
264 recv_loop(Sock, Id, Pid, MRef);
267 recv_loop(Sock, Id, Pid, MRef);
269 recv(_, _, _, MRef, {'DOWN', MRef, process, _, Reason}) ->
[all …]
H A Ddiameter_gen_tcp_SUITE.erl77 {Pid, MRef} = spawn_monitor(fun() -> connect(PortNr, LPid) end),
82 {'DOWN', MRef, process, _, _} = T ->
99 {_, MRef} = spawn_monitor(fun() -> exit(gen_tcp:send(Sock, Bin)) end),
100 down(MRef).
123 [RC || {_, MRef} <- Monitors, RC <- [down(MRef)], ok /= element(1, RC)].
143 down(MRef) ->
144 receive {'DOWN', MRef, process, _, Reason} -> Reason end.
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/diameter/test/
H A Ddiameter_gen_sctp_SUITE.erl175 accept_loop(Sock, MRef).
207 accept_loop(Sock, MRef) ->
231 assoc(MRef, _Id, OS)
232 when is_reference(MRef) ->
238 recv_loop(Sock, Id, Pid, MRef) ->
249 MRef,
253 recv(Sock, Id, Pid, MRef, T);
264 recv_loop(Sock, Id, Pid, MRef);
267 recv_loop(Sock, Id, Pid, MRef);
269 recv(_, _, _, MRef, {'DOWN', MRef, process, _, Reason}) ->
[all …]
H A Ddiameter_gen_tcp_SUITE.erl77 {Pid, MRef} = spawn_monitor(fun() -> connect(PortNr, LPid) end),
82 {'DOWN', MRef, process, _, _} = T ->
99 {_, MRef} = spawn_monitor(fun() -> exit(gen_tcp:send(Sock, Bin)) end),
100 down(MRef).
123 [RC || {_, MRef} <- Monitors, RC <- [down(MRef)], ok /= element(1, RC)].
143 down(MRef) ->
144 receive {'DOWN', MRef, process, _, Reason} -> Reason end.
/dports/lang/erlang/otp-OTP-24.1.7/lib/diameter/test/
H A Ddiameter_gen_sctp_SUITE.erl175 accept_loop(Sock, MRef).
207 accept_loop(Sock, MRef) ->
231 assoc(MRef, _Id, OS)
232 when is_reference(MRef) ->
238 recv_loop(Sock, Id, Pid, MRef) ->
249 MRef,
253 recv(Sock, Id, Pid, MRef, T);
264 recv_loop(Sock, Id, Pid, MRef);
267 recv_loop(Sock, Id, Pid, MRef);
269 recv(_, _, _, MRef, {'DOWN', MRef, process, _, Reason}) ->
[all …]
H A Ddiameter_gen_tcp_SUITE.erl77 {Pid, MRef} = spawn_monitor(fun() -> connect(PortNr, LPid) end),
82 {'DOWN', MRef, process, _, _} = T ->
99 {_, MRef} = spawn_monitor(fun() -> exit(gen_tcp:send(Sock, Bin)) end),
100 down(MRef).
123 [RC || {_, MRef} <- Monitors, RC <- [down(MRef)], ok /= element(1, RC)].
143 down(MRef) ->
144 receive {'DOWN', MRef, process, _, Reason} -> Reason end.
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/diameter/test/
H A Ddiameter_gen_sctp_SUITE.erl175 accept_loop(Sock, MRef).
207 accept_loop(Sock, MRef) ->
231 assoc(MRef, _Id, OS)
232 when is_reference(MRef) ->
238 recv_loop(Sock, Id, Pid, MRef) ->
249 MRef,
253 recv(Sock, Id, Pid, MRef, T);
264 recv_loop(Sock, Id, Pid, MRef);
267 recv_loop(Sock, Id, Pid, MRef);
269 recv(_, _, _, MRef, {'DOWN', MRef, process, _, Reason}) ->
[all …]
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/diameter/test/
H A Ddiameter_gen_sctp_SUITE.erl175 accept_loop(Sock, MRef).
207 accept_loop(Sock, MRef) ->
231 assoc(MRef, _Id, OS)
232 when is_reference(MRef) ->
238 recv_loop(Sock, Id, Pid, MRef) ->
249 MRef,
253 recv(Sock, Id, Pid, MRef, T);
264 recv_loop(Sock, Id, Pid, MRef);
267 recv_loop(Sock, Id, Pid, MRef);
269 recv(_, _, _, MRef, {'DOWN', MRef, process, _, Reason}) ->
[all …]
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/compiler/test/receive_SUITE_data/ref_opt/
H A Dno_5.erl12 MRef = erlang:monitor(process, Pid),
17 MRef -> gurka
19 MRef ->
29 MRef = erlang:monitor(process, Pid),
34 MRef -> gurka
36 MRef ->
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/compiler/test/receive_SUITE_data/ref_opt/
H A Dno_5.erl12 MRef = erlang:monitor(process, Pid),
17 MRef -> gurka
19 MRef ->
29 MRef = erlang:monitor(process, Pid),
34 MRef -> gurka
36 MRef ->
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/mochiweb/examples/websocket/
H A Dwebsocket.erl111 {'DOWN', MRef, process, Pid, _Reason} ->
112 broadcast_down(Pid, MRef, Pids);
120 MRef = erlang:monitor(process, Pid),
122 Pid, "connected", dict:store(Pid, {Channel, MRef}, Pids)).
124 broadcast_down(Pid, MRef, Pids) ->
126 {ok, {_, MRef}} ->
136 fun (K, {Reply, MRef}, Acc) ->
140 dict:store(K, {Reply, MRef}, Acc)

12345678910>>...31