Selaa lähdekoodia

ft: 文件名与目录修改

master
SisMaker 3 vuotta sitten
vanhempi
commit
8a6e7204c3
20 muutettua tiedostoa jossa 41 lisäystä ja 42 poistoa
  1. +1
    -1
      LICENSE
  2. +2
    -2
      include/eNet.hrl
  3. +10
    -1
      rebar.config
  4. +9
    -9
      src/eNet.app.src
  5. +5
    -5
      src/eNet.erl
  6. +0
    -10
      src/eNet_sup.erl
  7. +0
    -0
      src/misc/erlang套接字编程和性能优化.md
  8. +1
    -1
      src/misc/ntAccess.erl
  9. +1
    -1
      src/misc/ntCidr.erl
  10. +1
    -1
      src/misc/ntNetCom.erl
  11. +1
    -1
      src/misc/ntTokenBucket.erl
  12. +0
    -0
      src/ssl/doToSsl.md
  13. +0
    -0
      src/tcp/echo_client.erl
  14. +0
    -0
      src/tcp/echo_server.erl
  15. +1
    -1
      src/tcp/ntTcpAcceptor.erl
  16. +1
    -1
      src/tcp/ntTcpAcceptorSup.erl
  17. +4
    -4
      src/tcp/ntTcpListener.erl
  18. +1
    -1
      src/tcp/ntTcpMgrSup.erl
  19. +3
    -3
      src/udp/nlUdpExm.erl
  20. +0
    -0
      src/udp/nlUdpIns.erl

+ 1
- 1
LICENSE Näytä tiedosto

@ -1,6 +1,6 @@
MIT License
Copyright (c) 2019 AICells
Copyright (c) 2021 AICells
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal

+ 2
- 2
include/eNet.hrl Näytä tiedosto

@ -4,8 +4,8 @@
-define(miSockReady, miSockReady).
-define(WARN(Tag, Format, Data), nlNetCom:warnMsg(Tag, Format, Data)).
-define(getListValue(Key, List, Default), nlNetCom:getListValue(Key, List, Default)).
-define(WARN(Tag, Format, Data), ntNetCom:warnMsg(Tag, Format, Data)).
-define(getListValue(Key, List, Default), ntNetCom:getListValue(Key, List, Default)).
-define(SSL_CLOSE_TIMEOUT, 5000).
-define(SSL_HANDSHAKE_TIMEOUT, 15000).

+ 10
- 1
rebar.config Näytä tiedosto

@ -1,5 +1,14 @@
{erl_opts, [{i, "include"}, warn_unused_vars, warn_shadow_vars, warn_unused_import, warn_obsolete_guard, debug_info]}.
{erl_opts, [
debug_info
, {i, "include"}
, warn_unused_vars
, warn_shadow_vars
, warn_unused_import
, warn_obsolete_guard
]}.
{deps, [
{eGbh, ".*", {git, "http://sismaker.tpddns.cn:53000/SisMaker/eGbh.git", {branch, "master"}}},
{eSync, ".*", {git, "http://sismaker.tpddns.cn:53000/SisMaker/eSync.git", {branch, "master"}}}
]}.

+ 9
- 9
src/eNet.app.src Näytä tiedosto

@ -1,12 +1,12 @@
{application, eNet,
[{description, "An OTP application"},
{vsn, "0.1.0"},
{registered, []},
{mod, {eNet_app, []}},
{applications,
[kernel, stdlib]},
{env,[]},
{modules, []},
{licenses, ["Apache 2.0"]},
{links, []}
{vsn, "0.1.0"},
{registered, []},
{mod, {eNet_app, []}},
{applications, [kernel, stdlib]},
{env, []},
{modules, []},
{licenses, ["MIT"]},
{links, []}
]}.

+ 5
- 5
src/eNet.erl Näytä tiedosto

@ -41,16 +41,16 @@ addTcpLr(ListenName, AddrPort, ConMod, ListenOpt) ->
_ ->
ignore
end,
FixAddrPort = nlNetCom:fixAddr(AddrPort),
FixAddrPort = ntNetCom:fixAddr(AddrPort),
TcpListenSpec = #{
id => ListenName,
start => {nlTcpListener, start_link, [ListenName, FixAddrPort, ConMod, ListenOpt]},
start => {ntTcpListener, start_link, [ListenName, FixAddrPort, ConMod, ListenOpt]},
restart => transient,
shutdown => 5000,
type => worker,
modules => [nlTcpListener]
},
nlTcpMgrSup:startChild(TcpListenSpec).
ntTcpMgrSup:startChild(TcpListenSpec).
%% stop a TCP listener
-spec stopTcpLr(listenName()) -> ignore | {ok, pid()} | {error, term()}.
@ -59,6 +59,6 @@ stopTcpLr(ListenName) ->
undefined ->
ignore;
_ ->
nlTcpMgrSup:terminateChild(ListenName),
nlTcpMgrSup:deleteChild(ListenName)
ntTcpMgrSup:terminateChild(ListenName),
ntTcpMgrSup:deleteChild(ListenName)
end.

+ 0
- 10
src/eNet_sup.erl Näytä tiedosto

@ -11,16 +11,6 @@
start_link() ->
supervisor:start_link({local, ?MODULE}, ?MODULE, []).
%% sup_flags() = #{strategy => strategy(), % optional
%% intensity => non_neg_integer(), % optional
%% period => pos_integer()} % optional
%% child_spec() = #{id => child_id(), % mandatory
%% start => mfargs(), % mandatory
%% restart => restart(), % optional
%% shutdown => shutdown(), % optional
%% type => worker(), % optional
%% modules => modules()} % optional
init([]) ->
SupFlag = #{strategy => one_for_one, intensity => 1000, period => 3600},
{ok, {SupFlag, []}}.

src/comMod/erlang套接字编程和性能优化.md → src/misc/erlang套接字编程和性能优化.md Näytä tiedosto


src/comMod/nlAccess.erl → src/misc/ntAccess.erl Näytä tiedosto

@ -14,7 +14,7 @@
%% limitations under the License.
%%--------------------------------------------------------------------
-module(nlAccess).
-module(ntAccess).
-type(rule() :: {allow, all} | {allow, string()}
| {deny, all} | {deny, string()}).

src/comMod/nlCidr.erl → src/misc/ntCidr.erl Näytä tiedosto

@ -1,4 +1,4 @@
-module(nlCidr).
-module(ntCidr).
-export([
parse/1

src/comMod/nlNetCom.erl → src/misc/ntNetCom.erl Näytä tiedosto

@ -1,4 +1,4 @@
-module(nlNetCom).
-module(ntNetCom).
-compile([export_all]).

src/comMod/nlTokenBucket.erl → src/misc/ntTokenBucket.erl Näytä tiedosto

@ -13,7 +13,7 @@
%%
%%
%%
-module(nlTokenBucket).
-module(ntTokenBucket).
-include("eNet.hrl").
-export([

src/sslMod/doToSsl.md → src/ssl/doToSsl.md Näytä tiedosto


src/tcpMod/echo_client.erl → src/tcp/echo_client.erl Näytä tiedosto


src/tcpMod/echo_server.erl → src/tcp/echo_server.erl Näytä tiedosto


src/tcpMod/nlTcpAcceptor.erl → src/tcp/ntTcpAcceptor.erl Näytä tiedosto

@ -1,4 +1,4 @@
-module(nlTcpAcceptor).
-module(ntTcpAcceptor).
-include("eNet.hrl").
-compile(inline).
-compile({inline_size, 128}).

src/tcpMod/nlTcpAcceptorSup.erl → src/tcp/ntTcpAcceptorSup.erl Näytä tiedosto

@ -1,4 +1,4 @@
-module(nlTcpAcceptorSup).
-module(ntTcpAcceptorSup).
-behaviour(supervisor).

src/tcpMod/nlTcpListener.erl → src/tcp/ntTcpListener.erl Näytä tiedosto

@ -1,4 +1,4 @@
-module(nlTcpListener).
-module(ntTcpListener).
-include("eNet.hrl").
%%
@ -93,9 +93,9 @@ loop(Parent, State) ->
init({ListenOn, ConMod, ListenOpt}) ->
process_flag(trap_exit, true),
Port = nlNetCom:getPort(ListenOn),
Port = ntNetCom:getPort(ListenOn),
SockOpts = ?getListValue(tcpOpts, ListenOpt, []),
LastSockOpts = nlNetCom:mergeOpts(?DEFAULT_TCP_OPTIONS, SockOpts),
LastSockOpts = ntNetCom:mergeOpts(?DEFAULT_TCP_OPTIONS, SockOpts),
%% Don't active the socket...
case gen_tcp:listen(Port, [{active, false} | lists:keydelete(active, 1, LastSockOpts)]) of
{ok, LSock} ->
@ -130,7 +130,7 @@ terminate(_Reason, #state{lSock = LSock, listenAddr = Addr, listenPort = Port})
startAcceptor(0, _LSock, _ConMod) ->
ok;
startAcceptor(N, LSock, ConMod) ->
nlTcpAcceptorSup:startChild([LSock, ConMod, []]),
ntTcpAcceptorSup:startChild([LSock, ConMod, []]),
startAcceptor(N - 1, LSock, ConMod).
-spec getOpts(pid()) -> [listenOpt()].

src/tcpMod/nlTcpMgrSup.erl → src/tcp/ntTcpMgrSup.erl Näytä tiedosto

@ -1,4 +1,4 @@
-module(nlTcpMgrSup).
-module(ntTcpMgrSup).
-include("eNet.hrl").
-behaviour(supervisor).

src/udpMod/nlUdpExm.erl → src/udp/nlUdpExm.erl Näytä tiedosto

@ -50,7 +50,7 @@ safeRegister(Name) ->
end.
moduleInit(Parent, Args) ->
case nlTcpAcceptor:init(Args) of
case ntTcpAcceptor:init(Args) of
{ok, State} ->
proc_lib:init_ack(Parent, {ok, self()}),
loop(Parent, State);
@ -66,7 +66,7 @@ loop(Parent, State) ->
{'EXIT', Parent, Reason} ->
terminate(Reason, State);
Msg ->
case nlTcpAcceptor:handleMsg(Msg, State) of
case ntTcpAcceptor:handleMsg(Msg, State) of
{ok, NewState} ->
loop(Parent, NewState);
{stop, Reason} ->
@ -75,7 +75,7 @@ loop(Parent, State) ->
end.
terminate(Reason, State) ->
nlTcpAcceptor:terminate(Reason, State),
ntTcpAcceptor:terminate(Reason, State),
exit(Reason).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%% genExm end %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%

src/udpMod/nlUdpIns.erl → src/udp/nlUdpIns.erl Näytä tiedosto


Ladataan…
Peruuta
Tallenna