diff options
Diffstat (limited to 'src/mod_bosh_sql.erl')
-rw-r--r-- | src/mod_bosh_sql.erl | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/mod_bosh_sql.erl b/src/mod_bosh_sql.erl index 012a61da..c32714c8 100644 --- a/src/mod_bosh_sql.erl +++ b/src/mod_bosh_sql.erl @@ -31,7 +31,6 @@ %% API -export([init/0, open_session/2, close_session/1, find_session/1]). --include("ejabberd.hrl"). -include("logger.hrl"). -include("ejabberd_sql_pt.hrl"). @@ -42,7 +41,7 @@ init() -> Node = erlang:atom_to_binary(node(), latin1), ?DEBUG("Cleaning SQL 'bosh' table...", []), case ejabberd_sql:sql_query( - ?MYNAME, ?SQL("delete from bosh where node=%(Node)s")) of + ejabberd_config:get_myname(), ?SQL("delete from bosh where node=%(Node)s")) of {updated, _} -> ok; Err -> @@ -53,7 +52,7 @@ init() -> open_session(SID, Pid) -> PidS = misc:encode_pid(Pid), Node = erlang:atom_to_binary(node(Pid), latin1), - case ?SQL_UPSERT(?MYNAME, "bosh", + case ?SQL_UPSERT(ejabberd_config:get_myname(), "bosh", ["!sid=%(SID)s", "node=%(Node)s", "pid=%(PidS)s"]) of @@ -65,7 +64,7 @@ open_session(SID, Pid) -> close_session(SID) -> case ejabberd_sql:sql_query( - ?MYNAME, ?SQL("delete from bosh where sid=%(SID)s")) of + ejabberd_config:get_myname(), ?SQL("delete from bosh where sid=%(SID)s")) of {updated, _} -> ok; _Err -> @@ -74,7 +73,7 @@ close_session(SID) -> find_session(SID) -> case ejabberd_sql:sql_query( - ?MYNAME, + ejabberd_config:get_myname(), ?SQL("select @(pid)s, @(node)s from bosh where sid=%(SID)s")) of {selected, [{Pid, Node}]} -> try {ok, misc:decode_pid(Pid, Node)} |