diff --git a/include/agVstCli.hrl b/include/agVstCli.hrl index ad52efa..fbe4935 100644 --- a/include/agVstCli.hrl +++ b/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">>). diff --git a/src/agApi/agDbMgr.erl b/src/agApi/agDbMgr.erl index 47866f2..b09d142 100644 --- a/src/agApi/agDbMgr.erl +++ b/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). % 创建一个新的数据库 diff --git a/src/agTest.erl b/src/agTest.erl index 0779d0b..27aad67 100644 --- a/src/agTest.erl +++ b/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)]. diff --git a/src/agVstCli/agVstCli.erl b/src/agVstCli/agVstCli.erl index 07cf375..cbf31fd 100644 --- a/src/agVstCli/agVstCli.erl +++ b/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).