syn_test_event_handler.erl 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. %% ==========================================================================================================
  2. %% Syn - A global Process Registry and Process Group manager.
  3. %%
  4. %% The MIT License (MIT)
  5. %%
  6. %% Copyright (c) 2015-2021 Roberto Ostinelli <roberto@ostinelli.net> and Neato Robotics, Inc.
  7. %%
  8. %% Permission is hereby granted, free of charge, to any person obtaining a copy
  9. %% of this software and associated documentation files (the "Software"), to deal
  10. %% in the Software without restriction, including without limitation the rights
  11. %% to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  12. %% copies of the Software, and to permit persons to whom the Software is
  13. %% furnished to do so, subject to the following conditions:
  14. %%
  15. %% The above copyright notice and this permission notice shall be included in
  16. %% all copies or substantial portions of the Software.
  17. %%
  18. %% THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  19. %% IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  20. %% FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  21. %% AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  22. %% LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  23. %% OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  24. %% THE SOFTWARE.
  25. %% ==========================================================================================================
  26. -module(syn_test_event_handler).
  27. -behaviour(syn_event_handler).
  28. -export([on_process_registered/4]).
  29. -export([on_process_unregistered/4]).
  30. on_process_registered(Scope, Name, Pid, {recipient, RecipientPid, AdditionalMeta}) ->
  31. RecipientPid ! {on_process_registered, node(), Scope, Name, Pid, AdditionalMeta}.
  32. on_process_unregistered(Scope, Name, Pid, {recipient, RecipientPid, AdditionalMeta}) ->
  33. RecipientPid ! {on_process_unregistered, node(), Scope, Name, Pid, AdditionalMeta}.
  34. %%-export([resolve_registry_conflict/4]).
  35. %%
  36. %%-spec resolve_registry_conflict(
  37. %% Scope ::atom(),
  38. %% Name :: any(),
  39. %% {LocalPid :: pid(), LocalMeta :: any()},
  40. %% {RemotePid :: pid(), RemoteMeta :: any()}
  41. %%) -> PidToKeep :: pid().
  42. %%resolve_registry_conflict(_Scope, _Name, {Pid1, _Meta1, _Time1}, {_Pid2, _Meta2, _Time2}) ->
  43. %% Pid1.