/dports/devel/erlang-sbroker/sbroker-1.0.0/test/ |
H A D | sregulator_rate_statem.erl | 198 {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 D | orber_iiop_outproxy.erl | 72 {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 D | orber_iiop_outproxy.erl | 72 {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 D | orber_iiop_outproxy.erl | 72 {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 D | orber_iiop_outproxy.erl | 72 {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 D | orber_iiop_outproxy.erl | 72 {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 D | STM.hs | 12 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 D | MRef.hs | 1 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 D | eetcd_watch.erl | 127 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 D | eetcd_election.erl | 111 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 D | diameter_gen_sctp_SUITE.erl | 175 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 D | diameter_gen_tcp_SUITE.erl | 77 {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 D | diameter_gen_sctp_SUITE.erl | 175 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 D | diameter_gen_tcp_SUITE.erl | 77 {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 D | diameter_gen_sctp_SUITE.erl | 175 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 D | diameter_gen_tcp_SUITE.erl | 77 {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 D | diameter_gen_sctp_SUITE.erl | 175 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 D | diameter_gen_tcp_SUITE.erl | 77 {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 D | diameter_gen_sctp_SUITE.erl | 175 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 D | diameter_gen_tcp_SUITE.erl | 77 {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 D | diameter_gen_sctp_SUITE.erl | 175 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 D | diameter_gen_sctp_SUITE.erl | 175 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 D | no_5.erl | 12 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 D | no_5.erl | 12 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 D | websocket.erl | 111 {'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)
|