Skip to content
Permalink
Browse files
fix module rename process supervisor ref
  • Loading branch information
DLive committed May 3, 2019
1 parent 834dc65 commit 2e9b709c198fa9dd7eac6b38bc58b847dbaf4ca1
Showing 6 changed files with 11 additions and 30 deletions.

This file was deleted.

@@ -24,7 +24,7 @@
-export([gen_id/0,get_index/2]).

-define(SERVER, ?MODULE).
-define(INDEX_ETS_TABLE,de_id_count_table).
-define(INDEX_ETS_TABLE,dubbo_id_count_table).
-define(MAX_NUM,9223372036854775807).
-record(state, {}).

@@ -31,7 +31,7 @@ start_link() ->
init([]) ->
ZK = {dubbo_zookeeper,{dubbo_zookeeper, start_link, []},transient,5000,worker,[dubbo_zookeeper]},
%% NettySer = {dubbo_netty_client,{dubbo_netty_client, start_link, []},transient,5000,worker,[dubbo_netty_client]},
Id_count = {de_id_count,{de_id_count, start_link, []},transient,5000,worker,[de_id_count]},
Id_count = {dubbo_id_generator,{dubbo_id_generator, start_link, []},transient,5000,worker,[dubbo_id_generator]},
ProviderPoolSup = {dubbo_provider_worker_sup,{dubbo_provider_worker_sup, start_link, []},transient,5000,supervisor,[dubbo_provider_worker_sup]},
ConsumerPoolSup = {dubbo_consumer_pool_sup,{dubbo_consumer_pool_sup, start_link, []},transient,5000,supervisor,[dubbo_consumer_pool_sup]},
ConsumerPool = {dubbo_consumer_pool,{dubbo_consumer_pool, start_link, []},transient,5000,worker,[dubbo_consumer_pool]},
@@ -17,19 +17,19 @@
init()->
case ets:info(?FOREIGN_NATIVE_TABLE) of
undefined ->
io:format("init decoding foreign_native_table table pid ~p~n",[self()]),
ets:new(?FOREIGN_NATIVE_TABLE,[public,named_table]); %% public
?FOREIGN_NATIVE_TABLE = ets:new(?FOREIGN_NATIVE_TABLE,[public,named_table]),
logger:info("init decoding foreign_native_table table",[]);
_ ->
ets:delete(?FOREIGN_NATIVE_TABLE),
ets:new(?FOREIGN_NATIVE_TABLE,[public,named_table])
?FOREIGN_NATIVE_TABLE = ets:new(?FOREIGN_NATIVE_TABLE,[public,named_table])
end,
case ets:info(?NATIVE_FOREIGN_TABLE) of
undefined ->
io:format("init decoding foreign_native_table table pid ~p~n",[self()]),
ets:new(?NATIVE_FOREIGN_TABLE,[public,named_table]); %% public
io:format("init decoding native_foreign_table table pid ~p~n",[self()]),
?NATIVE_FOREIGN_TABLE = ets:new(?NATIVE_FOREIGN_TABLE,[public,named_table]); %% public
_ ->
ets:delete(?NATIVE_FOREIGN_TABLE),
ets:new(?NATIVE_FOREIGN_TABLE,[public,named_table])
?NATIVE_FOREIGN_TABLE = ets:new(?NATIVE_FOREIGN_TABLE,[public,named_table])
end,
ok.

@@ -30,7 +30,8 @@ suite() ->
%% Reason = term()
%%--------------------------------------------------------------------
init_per_suite(Config) ->
application:ensure_all_started(dubboerl),
Start = application:ensure_all_started(dubboerl),
io:format(user,"test case start info ~p~n",[Start]),
Config.

%%--------------------------------------------------------------------
@@ -35,6 +35,6 @@ register_type_list()->
List = dubbo_service_type_list:get_list(),
lists:map(
fun({NativeType,ForeignType,Fields}) ->
de_type_transfer:pre_process_typedef(NativeType,ForeignType,Fields)
dubbo_type_transfer:pre_process_typedef(NativeType,ForeignType,Fields)
end,List),
ok.

0 comments on commit 2e9b709

Please sign in to comment.