diff --git a/src/agVstCli/agMiscUtils.erl b/src/agVstCli/agMiscUtils.erl
index 2638c11..f6a0bc7 100644
--- a/src/agVstCli/agMiscUtils.erl
+++ b/src/agVstCli/agMiscUtils.erl
@@ -13,6 +13,7 @@
    , randElement/1
    , toBinary/1
    , agMethod/1
+   , syncSend/2
 ]).
 
 -spec parseUrl(binary()) -> dbOpts() | {error, invalidUrl}.
@@ -103,3 +104,32 @@ agMethod(4) -> <<"Head">>;
 agMethod(5) -> <<"Patch">>;
 agMethod(6) -> <<"Options">>.
 
+%% This is a generic "port_command" interface used by TCP, UDP, SCTP, depending
+%% on the driver it is mapped to, and the "Data". It actually sends out data,--
+%% NOT delegating this task to any back-end.  For SCTP, this function MUST NOT
+%% be called directly -- use "sendmsg" instead:
+%%
+syncSend(S, Data) ->
+   syncSend(S, Data, []).
+
+syncSend(S, Data, OptList) when is_port(S), is_list(OptList) ->
+   MRef = monitor(port, S),
+   MRefBin = term_to_binary(MRef, [local]),
+   MRefBinSize = byte_size(MRefBin),
+   MRefBinSize = MRefBinSize band 16#FFFF,
+   try
+      erlang:port_command(S, [<<MRefBinSize:16, MRefBin/binary>>, Data], OptList)
+   of
+      false -> % Port busy when nosuspend option was passed
+         {error, busy};
+      true ->
+         receive
+            {inet_reply, S, Status, MRef} ->
+               demonitor(MRef, [flush]),
+               Status;
+            {'DOWN', MRef, _, _, _Reason} ->
+               {error, closed}
+         end
+   catch error: _ ->
+      {error, einval}
+   end.