n2o_syn to n4u_syn

ebin/n4u.app

@@ -2,7 +2,7 @@
   {description, "N4U WebSocket Application Server"},
   {vsn, "4.4.20"},
   {applications, [kernel, stdlib, asn1, public_key, ssl, crypto, ranch, cowboy, fs, active, sh, gproc, nitro]},
-  {modules, [n2o, n4u_app, n4u_sup, n4u_async, n2o_xhr, n4u_cx, n2o_cowboy, n2o_multipart, n2o_static, n2o_stream, n4u_document, n2o_proto, n2o_relay, n4u_error, n4u_io, n4u_log, n4u_mq, n2o_pickle, n2o_query, n2o_secret, n2o_session, n2o_syn, n4u_client, n2o_file, n4u_heart, n4u_http, n4u_nitrogen, n2o_text, wf, wf_convert, wf_utils]},
+  {modules, [n2o, n4u_app, n4u_sup, n4u_async, n2o_xhr, n4u_cx, n2o_cowboy, n2o_multipart, n2o_static, n2o_stream, n4u_document, n2o_proto, n2o_relay, n4u_error, n4u_io, n4u_log, n4u_mq, n2o_pickle, n2o_query, n2o_secret, n2o_session, n4u_syn, n4u_client, n2o_file, n4u_heart, n4u_http, n4u_nitrogen, n2o_text, wf, wf_convert, wf_utils]},
   {registered, [n4u_sup]},
   {mod, {n4u_app, []}},
   {env, []}

src/handlers/n2o_syn.erl

@@ -1,16 +0,0 @@
--module(n2o_syn).
--include_lib("n4u/include/n4u.hrl").
--export([send/2, reg/1, reg/2, unreg/1]).
-
-send(Pool, Message) -> syn:publish(term_to_binary(Pool),Message).
-reg(Pool) -> reg(Pool,undefined).
-reg(Pool, _Value) ->
-    case get({pool,Pool}) of
-         undefined -> syn:join(term_to_binary(Pool),self()),
-                      put({pool,Pool},Pool);
-         _Defined -> skip end.
-unreg(Pool) ->
-    case get({pool,Pool}) of
-         undefined -> skip;
-         _Defined -> syn:leave(term_to_binary(Pool), self()), 
-                     erase({pool,Pool}) end.

src/handlers/n4u_syn.erl

@@ -0,0 +1,27 @@
+-module(n4u_syn).
+
+-export([send/2, reg/1, reg/2, unreg/1]).
+
+
+send(Pool, Message) -> syn:publish(erlang:term_to_binary(Pool), Message).
+
+
+reg(Pool) -> reg(Pool, undefined).
+
+reg(Pool, _Value) ->
+  case erlang:get({pool, Pool}) of
+    undefined ->
+      syn:join(erlang:term_to_binary(Pool), erlang:self()),
+      erlang:put({pool, Pool}, Pool);
+    _Defined -> skip
+  end.
+
+
+unreg(Pool) ->
+  case erlang:get({pool, Pool}) of
+    undefined -> skip;
+    _Defined ->
+      syn:leave(erlang:term_to_binary(Pool), erlang:self()), 
+      erlang:erase({pool, Pool})
+  end.
+

src/n4u_sup.erl

@@ -21,7 +21,7 @@ init([]) ->
   [ ets:new(T, ets_tables_opts()) || T <- ets_tables() ],
   
   case application:get_env(n4u, mq, "") of
-    n2o_syn -> syn:init();
+    n4u_syn -> syn:init();
     _ -> ok
   end,