| 721 |
} |
} |
| 722 |
else |
else |
| 723 |
{ |
{ |
| 724 |
ret = hash_dict_inc(hash_dict_sockaddr_count, (uint64_t)j, -1); |
ret = hash_dict_inc(hash_dict_sockaddr_count, (in_addr_t)j, -1); |
| 725 |
if (ret < 0) |
if (ret <= 0) |
| 726 |
{ |
{ |
| 727 |
log_error("hash_dict_inc(hash_dict_sockaddr_count, %d, -1) error\n", j); |
log_error("hash_dict_inc(hash_dict_sockaddr_count, %d, -1) error: %d\n", (in_addr_t)j, ret); |
| 728 |
} |
} |
| 729 |
|
|
| 730 |
ret = hash_dict_del(hash_dict_pid_sockaddr, (uint64_t)pid); |
ret = hash_dict_del(hash_dict_pid_sockaddr, (uint64_t)pid); |
| 839 |
log_error("load_menu(top10_menu) error\n"); |
log_error("load_menu(top10_menu) error\n"); |
| 840 |
unload_menu(&top10_menu); |
unload_menu(&top10_menu); |
| 841 |
} |
} |
| 842 |
|
top10_menu.allow_exit = 1; |
| 843 |
|
|
| 844 |
for (int i = 0; i < data_files_load_startup_count; i++) |
for (int i = 0; i < data_files_load_startup_count; i++) |
| 845 |
{ |
{ |
| 937 |
|
|
| 938 |
port_client = ntohs(sin.sin_port); |
port_client = ntohs(sin.sin_port); |
| 939 |
|
|
|
log_common("Accept %s connection from %s:%d\n", (SSH_v2 ? "SSH" : "telnet"), hostaddr_client, port_client); |
|
|
|
|
| 940 |
if (SYS_child_process_count - 1 < BBS_max_client) |
if (SYS_child_process_count - 1 < BBS_max_client) |
| 941 |
{ |
{ |
| 942 |
j = 0; |
j = 0; |
| 960 |
log_error("hash_dict_set(hash_dict_pid_sockaddr, %d, %s) error\n", pid, hostaddr_client); |
log_error("hash_dict_set(hash_dict_pid_sockaddr, %d, %s) error\n", pid, hostaddr_client); |
| 961 |
} |
} |
| 962 |
|
|
| 963 |
ret = hash_dict_inc(hash_dict_sockaddr_count, (uint64_t)sin.sin_addr.s_addr, 1); |
if (j == 0) |
| 964 |
if (ret < 0) |
{ |
| 965 |
|
// First connection from this IP |
| 966 |
|
log_common("Accept %s connection from %s:%d\n", |
| 967 |
|
(SSH_v2 ? "SSH" : "telnet"), hostaddr_client, port_client); |
| 968 |
|
|
| 969 |
|
ret = hash_dict_set(hash_dict_sockaddr_count, (uint64_t)sin.sin_addr.s_addr, 1); |
| 970 |
|
if (ret < 0) |
| 971 |
|
{ |
| 972 |
|
log_error("hash_dict_set(hash_dict_sockaddr_count, %s, 1) error\n", hostaddr_client); |
| 973 |
|
} |
| 974 |
|
} |
| 975 |
|
else |
| 976 |
{ |
{ |
| 977 |
log_error("hash_dict_inc(hash_dict_sockaddr_count, %s, %d) error\n", hostaddr_client, 1); |
// Increase connection count from this IP |
| 978 |
|
log_common("Accept %s connection from %s:%d, already have %d connections\n", |
| 979 |
|
(SSH_v2 ? "SSH" : "telnet"), hostaddr_client, port_client, j); |
| 980 |
|
|
| 981 |
|
ret = hash_dict_inc(hash_dict_sockaddr_count, (uint64_t)sin.sin_addr.s_addr, 1); |
| 982 |
|
if (ret <= 0) |
| 983 |
|
{ |
| 984 |
|
log_error("hash_dict_inc(hash_dict_sockaddr_count, %s, 1) error: %d\n", hostaddr_client, ret); |
| 985 |
|
} |
| 986 |
} |
} |
| 987 |
} |
} |
| 988 |
} |
} |
| 989 |
else |
else |
| 990 |
{ |
{ |
| 991 |
log_error("Rejected client connection from %s over limit per IP (%d)\n", hostaddr_client, BBS_max_client_per_ip); |
log_error("Rejected %s connection from %s:%d over limit per IP (%d >= %d)\n", |
| 992 |
|
(SSH_v2 ? "SSH" : "telnet"), hostaddr_client, port_client, j, BBS_max_client_per_ip); |
| 993 |
} |
} |
| 994 |
} |
} |
| 995 |
else |
else |
| 996 |
{ |
{ |
| 997 |
log_error("Rejected client connection over limit (%d)\n", SYS_child_process_count - 1); |
log_error("Rejected %s connection from %s:%d over limit (%d >= %d)\n", |
| 998 |
|
(SSH_v2 ? "SSH" : "telnet"), hostaddr_client, port_client, SYS_child_process_count - 1, BBS_max_client); |
| 999 |
} |
} |
| 1000 |
|
|
| 1001 |
if (close(socket_client) == -1) |
if (close(socket_client) == -1) |