|
@@ -141,6 +141,11 @@ send(#state{mod = Mod, sock = Sock}, Data) ->
|
|
|
send(#state{mod = Mod, sock = Sock}, Type, Data) ->
|
|
|
Mod:send(Sock, pgsql_wire:encode(Type, Data)).
|
|
|
|
|
|
+reply(#state{queue = Q} = State, Message) ->
|
|
|
+ {{value, Pid}, Q2} = queue:out(Q),
|
|
|
+ Pid ! Message,
|
|
|
+ State#state{queue = Q2}.
|
|
|
+
|
|
|
%% -- backend message handling --
|
|
|
|
|
|
%% AuthenticationOk
|