超时时间修改

README.md

@@ -30,7 +30,7 @@
     Make a connection first
         {ok, Socket} = agHttpCli:connect([]).           %% Use default Settings
         %% Then you can then call various apis using Socket as the first argument
-        agMgrDb:curDbInfo(S).
+        agMgrDb:curDbInfo(Socket).
     
     Connection pooling mode
        application:ensure_all_started(erlArango).        %% start app

src/agHttpCli/agHttpCli.erl

@@ -66,7 +66,7 @@ castAgency(PoolNameOrSocket, Method, Path, Headers, Body, Pid, IsSystem, Timeout
       case Timeout of
          infinity -> infinity;
          _ ->
-            erlang:system_time(millisecond) + Timeout
+            erlang:monotonic_time(millisecond) + Timeout
       end,
    case erlang:is_atom(PoolNameOrSocket) of
       true ->

src/agHttpCli/agSslAgencyIns.erl

@@ -183,7 +183,7 @@ overAllWork(SrvState, #cliState{requestsIns = RequestsIns, requestsOuts = Reques
 overDealQueueRequest(#miRequest{method = Method, path = Path, headers = Headers, body = Body, requestId = RequestId, fromPid = FromPid, overTime = OverTime, isSystem = IsSystem},
    #srvState{serverName = ServerName, host = Host, userPassWord = UserPassWord, dbName = DbName, socket = Socket} = SrvState,
    #cliState{requestsIns = RequestsIns, requestsOuts = RequestsOuts, backlogNum = BacklogNum} = CliState) ->
-   case erlang:system_time(millisecond) > OverTime of
+   case erlang:monotonic_time(millisecond) > OverTime of
       true ->
          %% 超时了
          agAgencyUtils:agencyReply(FromPid, RequestId, undefined, {error, timeout}),
@@ -359,7 +359,7 @@ dealConnect(ServerName, HostName, Port, SocketOptions) ->
 dealQueueRequest(#miRequest{method = Method, path = Path, headers = Headers, body = Body, requestId = RequestId, fromPid = FromPid, overTime = OverTime, isSystem = IsSystem},
    #srvState{serverName = ServerName, host = Host, userPassWord = UserPassWord, dbName = DbName, socket = Socket} = SrvState,
    #cliState{requestsIns = RequestsIns, requestsOuts = RequestsOuts, backlogNum = BacklogNum} = CliState) ->
-   case erlang:system_time(millisecond) > OverTime of
+   case erlang:monotonic_time(millisecond) > OverTime of
       true ->
          %% 超时了
          agAgencyUtils:agencyReply(FromPid, RequestId, undefined, {error, timeout}),

src/agHttpCli/agTcpAgencyIns.erl

@@ -182,7 +182,7 @@ overAllWork(SrvState, #cliState{requestsIns = RequestsIns, requestsOuts = Reques
 overDealQueueRequest(#miRequest{method = Method, path = Path, headers = Headers, body = Body, requestId = RequestId, fromPid = FromPid, overTime = OverTime, isSystem = IsSystem},
    #srvState{serverName = ServerName, host = Host, userPassWord = UserPassWord, dbName = DbName, socket = Socket} = SrvState,
    #cliState{requestsIns = RequestsIns, requestsOuts = RequestsOuts, backlogNum = BacklogNum} = CliState) ->
-   case erlang:system_time(millisecond) > OverTime of
+   case erlang:monotonic_time(millisecond) > OverTime of
       true ->
          %% 超时了
          agAgencyUtils:agencyReply(FromPid, RequestId, undefined, {error, timeout}),
@@ -358,7 +358,7 @@ dealConnect(ServerName, HostName, Port, SocketOptions) ->
 dealQueueRequest(#miRequest{method = Method, path = Path, headers = Headers, body = Body, requestId = RequestId, fromPid = FromPid, overTime = OverTime, isSystem = IsSystem},
    #srvState{serverName = ServerName, host = Host, userPassWord = UserPassWord, dbName = DbName, socket = Socket} = SrvState,
    #cliState{requestsIns = RequestsIns, requestsOuts = RequestsOuts, backlogNum = BacklogNum} = CliState) ->
-   case erlang:system_time(millisecond) > OverTime of
+   case erlang:monotonic_time(millisecond) > OverTime of
       true ->
          %% 超时了
          agAgencyUtils:agencyReply(FromPid, RequestId, undefined, {error, timeout}),