Merge remote-tracking branch 'origin/master'

include/agVstCli.hrl

@@ -26,7 +26,7 @@
 -define(AgHeaderSize, 24).
 
 %% 默认选项定义
--define(AgDefBaseUrl, <<"http://sismaker.tpddns.cn:8529">>).
+-define(AgDefBaseUrl, <<"http://127.0.0.1:8529">>).
 -define(AgDefDbName, <<"_system">>).
 -define(AgDefUser, <<"root">>).
 -define(AgDefPassWord, <<"156736">>).

src/agApi/agDbMgr.erl

@@ -42,7 +42,7 @@ curDbInfo(PoolNameOrSocket) ->
 % 返回码
 % 200：如果数据库列表编译成功，则返回。
 % 400：如果请求无效，则返回。
-visitDbList(PoolNameOrSocket) ->
+visitDbs(PoolNameOrSocket) ->
    agVstCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_api/database/user">>).
 
 % 检索所有现有数据库的列表
@@ -54,7 +54,7 @@ visitDbList(PoolNameOrSocket) ->
 % 200：如果数据库列表编译成功，则返回。
 % 400：如果请求无效，则返回。
 % 403：如果请求未在_system数据库中执行，则返回。
-dbList(PoolNameOrSocket) ->
+allDbs(PoolNameOrSocket) ->
    agVstCli:callAgency(PoolNameOrSocket, ?AgGet, <<"/_api/database">>, ?AgDefQuery, ?AgDefHeader, ?AgDefBody, true).
 
 % 创建一个新的数据库

src/agTest.erl

@@ -7,7 +7,7 @@
 start() ->
    eSync:run(),
    application:ensure_all_started(eArango),
-   eArango:openPool(tt, [{poolSize, 1}], []).
+   eArango:openPool(tt, [{poolSize, 16}], []).
 
 stop() ->
    eArango:closePool(tt).
@@ -17,7 +17,7 @@ isDebug() ->
 
 tt(C, N) ->
    application:ensure_all_started(eArango),
-   eArango:openPool(tt, [{poolSize, 1}], []),
+   eArango:openPool(tt, [{poolSize, 16}], []),
    StartTime = erlang:system_time(millisecond),
    io:format("IMY**********************  started~n"),
    [spawn(?MODULE, test, [N, StartTime]) || _Idx <- lists:seq(1, C)].

src/agVstCli/agVstCli.erl

@@ -183,7 +183,7 @@ initMsgId() ->
    case persistent_term:get(agMessageId, undefined) of
       undefined ->
          Ref = atomics:new(1, [{signed, false}]),
-         InitId = rand:uniform(10000),
+         InitId = rand:uniform(100000),
          atomics:put(Ref, 1, InitId),
          persistent_term:put(agMessageId, Ref);
       _ ->
@@ -192,13 +192,5 @@ initMsgId() ->
 
 getMsgId() ->
    Ref = persistent_term:get(agMessageId, undefined),
-   MessageId = atomics:add_get(Ref, 1, 1),
-   if
-      MessageId >= ?agMaxMessageId ->
-         InitId = rand:uniform(10000),
-         atomics:put(Ref, 1, InitId),
-         InitId;
-      true ->
-         MessageId
-   end.
+   atomics:add_get(Ref, 1, 1).