wip

src/ejabberd_sm_sql.erl

@@ -52,14 +52,18 @@ init() ->
 	      case ejabberd_sql:sql_query(
 		     Host, ?SQL("delete from sm where node=%(Node)s")) of
 		  {updated, _} ->
+              ?DEBUG("Successfully cleaned 'sm' table on host: ~p", [Host]),
 		      ok;
 		  Err ->
+          ?DEBUG("Error tatata", []),
 		      ?ERROR_MSG("Failed to clean 'sm' table: ~p", [Err]),
 		      {error, db_failure}
 	      end;
 	 (_, Err) ->
+         ?DEBUG("Another case...", []),
 	      Err
-      end, ok, ejabberd_sm:get_vh_by_backend(?MODULE)).
+      end, ok, ejabberd_sm:get_vh_by_backend(?MODULE)),
+      ?DEBUG("Bullshit done...", []).
 
 schemas() ->
     [#sql_schema{

src/ejabberd_sql.erl

@@ -144,10 +144,12 @@ sql_call(Host, Msg) ->
     Timeout = query_timeout(Host),
     case get(?STATE_KEY) of
 	undefined ->
+        ?DEBUG("No existing state", []),
 	    sync_send_event(Host,
 			    {sql_cmd, Msg, current_time() + Timeout},
 			    Timeout);
 	_State ->
+        ?DEBUG("Existing state", [_State]),
 	    nested_op(Msg)
     end.
 
@@ -167,14 +169,18 @@ keep_alive(Host, Proc) ->
 sync_send_event(Host, Msg, Timeout) when is_binary(Host) ->
     case ejabberd_sql_sup:start(Host) of
 	ok ->
+        ?DEBUG("Loaded sql sup", []),
 	    Proc = get_worker(Host),
 	    sync_send_event(Proc, Msg, Timeout);
 	{error, _} = Err ->
+        ?DEBUG("Error while starting sql sup", []),
 	    Err
     end;
 sync_send_event(Proc, Msg, Timeout) ->
+    ?DEBUG("sync_send_event 180", []),
     try p1_fsm:sync_send_event(Proc, Msg, Timeout)
     catch _:{Reason, {p1_fsm, _, _}} ->
+        ?DEBUG("sync_send_event 180 error", []),
 	    {error, Reason}
     end.
 

src/ejabberd_sql_schema.erl

@@ -36,6 +36,7 @@
 start(Host) ->
     case should_update_schema(Host) of
         true ->
+            ?DEBUG("Should update schema", []),
             case table_exists(Host, <<"schema_version">>) of
                 true ->
                     ok;
@@ -52,6 +53,7 @@ start(Host) ->
                     end
             end;
         false ->
+            ?DEBUG("Should not update schema", []),
             ok
     end.