Browse Source

rely on state transition timeouts instead of those from sync_send_event

Will 15 years ago
parent
commit
912ba7529d
1 changed files with 9 additions and 9 deletions
  1. 9 9
      src/pgsql_connection.erl

+ 9 - 9
src/pgsql_connection.erl

@@ -41,34 +41,34 @@ stop(C) ->
     gen_fsm:send_all_state_event(C, stop).
     gen_fsm:send_all_state_event(C, stop).
 
 
 connect(C, Host, Username, Password, Opts) ->
 connect(C, Host, Username, Password, Opts) ->
-    gen_fsm:sync_send_event(C, {connect, Host, Username, Password, Opts}).
+    gen_fsm:sync_send_event(C, {connect, Host, Username, Password, Opts}, infinity).
 
 
 get_parameter(C, Name) ->
 get_parameter(C, Name) ->
     gen_fsm:sync_send_event(C, {get_parameter, to_binary(Name)}).
     gen_fsm:sync_send_event(C, {get_parameter, to_binary(Name)}).
 
 
 squery(C, Sql) ->
 squery(C, Sql) ->
-    gen_fsm:sync_send_event(C, {squery, Sql}).
+    gen_fsm:sync_send_event(C, {squery, Sql}, infinity).
 
 
 equery(C, Statement, Parameters) ->
 equery(C, Statement, Parameters) ->
-    gen_fsm:sync_send_event(C, {equery, Statement, Parameters}).
+    gen_fsm:sync_send_event(C, {equery, Statement, Parameters}, infinity).
 
 
 parse(C, Name, Sql, Types) ->
 parse(C, Name, Sql, Types) ->
-    gen_fsm:sync_send_event(C, {parse, Name, Sql, Types}).
+    gen_fsm:sync_send_event(C, {parse, Name, Sql, Types}, infinity).
 
 
 bind(C, Statement, PortalName, Parameters) ->
 bind(C, Statement, PortalName, Parameters) ->
-    gen_fsm:sync_send_event(C, {bind, Statement, PortalName, Parameters}).
+    gen_fsm:sync_send_event(C, {bind, Statement, PortalName, Parameters}, infinity).
 
 
 execute(C, Statement, PortalName, MaxRows) ->
 execute(C, Statement, PortalName, MaxRows) ->
-    gen_fsm:sync_send_event(C, {execute, Statement, PortalName, MaxRows}).
+    gen_fsm:sync_send_event(C, {execute, Statement, PortalName, MaxRows}, infinity).
 
 
 describe(C, Type, Name) ->
 describe(C, Type, Name) ->
-    gen_fsm:sync_send_event(C, {describe, Type, Name}).
+    gen_fsm:sync_send_event(C, {describe, Type, Name}, infinity).
 
 
 close(C, Type, Name) ->
 close(C, Type, Name) ->
-    gen_fsm:sync_send_event(C, {close, Type, Name}).
+    gen_fsm:sync_send_event(C, {close, Type, Name}, infinity).
 
 
 sync(C) ->
 sync(C) ->
-    gen_fsm:sync_send_event(C, sync).
+    gen_fsm:sync_send_event(C, sync, infinity).
 
 
 %% -- gen_fsm implementation --
 %% -- gen_fsm implementation --