diff --git a/src/agVstCli/agTcpAgency.erl b/src/agVstCli/agTcpAgency.erl
index 56369ae..37020fe 100644
--- a/src/agVstCli/agTcpAgency.erl
+++ b/src/agVstCli/agTcpAgency.erl
@@ -103,7 +103,7 @@ handleMsg(#agReq{method = Method, path = Path, queryPars = QueryPars, headers =
                %erlang:put(MessageId, {FromPid, undefined, 0, <<>>}),
                %Ret = agVstProto:response(?AgUndef, 0, 0, 0, 0, <<>>, BBBB),
                %?AgErr(ServerName, "the request is response ret:~p~n", [Ret]),
-               case gen_tcp:send(Socket, Request) of
+               case ntCom:syncSend(Socket, Request) of
                   ok ->
                      TimerRef = case OverTime of
                         infinity ->
@@ -159,9 +159,9 @@ handleMsg(?AgMDoDBConn,
       #dbOpts{port = Port, hostname = HostName, dbName = DbName, user = User, password = Password, vstSize = VstSize} ->
          case gen_tcp:connect(HostName, Port, ?AgDefSocketOpts, ?AgDefConnTimeout) of
             {ok, Socket} ->
-               gen_tcp:send(Socket, ?AgUpgradeInfo),
+               ntCom:syncSend(Socket, ?AgUpgradeInfo),
                AuthInfo = agVstProto:authInfo(User, Password),
-               gen_tcp:send(Socket, AuthInfo),
+               ntCom:syncSend(Socket, AuthInfo),
                case agVstCli:receiveTcpData(#recvState{}, Socket) of
                   {200, _BodyMap, _HeaderMap} ->
                      {ok, SrvState#srvState{dbName = DbName, reConnState = agAgencyUtils:resetReConnState(ReConnState), socket = Socket, vstSize = VstSize}, CliState};
diff --git a/src/agVstCli/agVstCli.erl b/src/agVstCli/agVstCli.erl
index cbf31fd..5b23b13 100644
--- a/src/agVstCli/agVstCli.erl
+++ b/src/agVstCli/agVstCli.erl
@@ -91,7 +91,7 @@ castAgency(PoolNameOrSocket, Method, Path, QueryPars, Headers, Body, Pid, IsSyst
                Request = agVstProto:request(IsSystem, MessageId, Method, DbName, Path, QueryPars, Headers, Body, VstSize),
                case Protocol of
                   tcp ->
-                     case gen_tcp:send(PoolNameOrSocket, Request) of
+                     case ntCom:syncSend(PoolNameOrSocket, Request) of
                         ok ->
                            receiveTcpData(#recvState{messageId = MessageId}, PoolNameOrSocket);
                         _Err ->
diff --git a/src/eArango.erl b/src/eArango.erl
index ac00fc3..907e076 100644
--- a/src/eArango.erl
+++ b/src/eArango.erl
@@ -58,9 +58,9 @@ connDb(DbCfgs) ->
       tcp ->
          case gen_tcp:connect(HostName, Port, ?AgDefSocketOpts, ?AgDefConnTimeout) of
             {ok, Socket} ->
-               gen_tcp:send(Socket, ?AgUpgradeInfo),
+               ntCom:syncSend(Socket, ?AgUpgradeInfo),
                AuthInfo = agVstProto:authInfo(User, Password),
-               gen_tcp:send(Socket, AuthInfo),
+               ntCom:syncSend(Socket, AuthInfo),
                case agVstCli:receiveTcpData(#recvState{}, Socket) of
                   {200, _BodyMap, _HeaderMap} ->
                      setCurDbInfo(Socket, DbName, VstSize, Protocol),