提交 f22c441f 编写于 作者: D Dmitry Kozlov

Revert "implemented session count limiting"

This reverts commit e3fc927e.
上级 d1c33d02
......@@ -40,7 +40,6 @@ thread-count=4
#single-session=replace
#sid-case=upper
#sid-source=seq
#max-sessions=1000
[ppp]
verbose=1
......
......@@ -1190,12 +1190,6 @@ static struct ipoe_session *ipoe_session_create_dhcpv4(struct ipoe_serv *serv, s
int dlen = 0;
uint8_t *ptr = NULL;
if (ap_shutdown)
return NULL;
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions)
return NULL;
ses = ipoe_session_alloc(serv->ifname);
if (!ses)
return NULL;
......@@ -1796,9 +1790,6 @@ static struct ipoe_session *ipoe_session_create_up(struct ipoe_serv *serv, struc
if (ap_shutdown)
return NULL;
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions)
return NULL;
if (l4_redirect_list_check(saddr))
return NULL;
......
......@@ -2731,9 +2731,6 @@ static int l2tp_recv_SCCRQ(const struct l2tp_serv_t *serv,
return 0;
}
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions)
return 0;
if (triton_module_loaded("connlimit")
&& connlimit_check(cl_key_from_ipv4(pack->addr.sin_addr.s_addr))) {
log_warn("l2tp: connection limits reached,"
......@@ -3260,9 +3257,6 @@ static int l2tp_recv_ICRQ(struct l2tp_conn_t *conn,
return 0;
}
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions)
return 0;
if (triton_module_loaded("connlimit")
&& connlimit_check(cl_key_from_ipv4(conn->peer_addr.sin_addr.s_addr))) {
log_tunnel(log_warn, conn, "connection limits reached,"
......@@ -3563,9 +3557,6 @@ static int l2tp_recv_OCRQ(struct l2tp_conn_t *conn,
return 0;
}
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions)
return 0;
if (triton_module_loaded("connlimit")
&& connlimit_check(cl_key_from_ipv4(conn->peer_addr.sin_addr.s_addr))) {
log_tunnel(log_warn, conn, "connection limits reached,"
......
......@@ -949,9 +949,6 @@ static void pppoe_recv_PADI(struct pppoe_serv_t *serv, uint8_t *pack, int size)
if (ap_shutdown || pado_delay == -1)
return;
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions)
return;
if (check_padi_limit(serv, ethhdr->h_source)) {
__sync_add_and_fetch(&stat_PADI_drop, 1);
if (conf_verbose) {
......@@ -1071,9 +1068,6 @@ static void pppoe_recv_PADR(struct pppoe_serv_t *serv, uint8_t *pack, int size)
if (ap_shutdown)
return;
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions)
return;
if (!memcmp(ethhdr->h_dest, bc_addr, ETH_ALEN)) {
if (conf_verbose)
log_warn("pppoe: discard PADR (destination address is broadcast)\n");
......
......@@ -644,14 +644,9 @@ static int pptp_connect(struct triton_md_handler_t *h)
continue;
}
if (conf_max_sessions && ap_session_stat.active + ap_session_stat.starting > conf_max_sessions) {
close(sock);
continue;
}
if (triton_module_loaded("connlimit") && connlimit_check(cl_key_from_ipv4(addr.sin_addr.s_addr))) {
close(sock);
continue;
return 0;
}
log_info2("pptp: new connection from %s\n", inet_ntoa(addr.sin_addr));
......
......@@ -129,7 +129,6 @@ extern int sock_fd; // internet socket for ioctls
extern int sock6_fd; // internet socket for ioctls
extern int urandom_fd;
extern struct ap_session_stat ap_session_stat;
extern int conf_max_sessions;
extern __thread const struct ap_net *net;
extern const struct ap_net def_net;
......
......@@ -34,7 +34,6 @@ static int conf_single_session = -1;
static int conf_sid_source;
static int conf_seq_save_timeout = 10;
static const char *conf_seq_file;
int conf_max_sessions;
pthread_rwlock_t __export ses_lock = PTHREAD_RWLOCK_INITIALIZER;
__export LIST_HEAD(ses_list);
......@@ -76,10 +75,6 @@ void __export ap_session_set_ifindex(struct ap_session *ses)
ses->acct_tx_packets_i = stats.tx_packets;
ses->acct_rx_bytes_i = stats.rx_bytes;
ses->acct_tx_bytes_i = stats.tx_bytes;
ses->acct_rx_bytes = 0;
ses->acct_tx_bytes = 0;
ses->acct_input_gigawords = 0;
ses->acct_output_gigawords = 0;
}
}
......@@ -512,12 +507,6 @@ static void load_config(void)
conf_seq_file = conf_get_opt("common", "seq-file");
if (!conf_seq_file)
conf_seq_file = "/var/lib/accel-ppp/seq";
opt = conf_get_opt("common", "max-sessions");
if (opt)
conf_max_sessions = atoi(opt);
else
conf_max_sessions = 0;
}
static void init(void)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册