1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
--- datapipe.c.orig Tue Jan 4 09:48:55 2000
+++ datapipe.c Thu Jul 24 16:28:56 2003
@@ -59,6 +59,7 @@
#include <unistd.h>
#include <netdb.h>
#include <strings.h>
+ #include <syslog.h>
#define recv(x,y,z,a) read(x,y,z)
#define send(x,y,z,a) write(x,y,z)
#define closesocket(s) close(s)
@@ -77,7 +78,7 @@
time_t activity;
};
-#define MAXCLIENTS 20
+#define MAXCLIENTS 128
#define IDLETIMEOUT 300
@@ -88,7 +89,8 @@
SOCKET lsock;
char buf[4096];
struct sockaddr_in laddr, oaddr;
- int i;
+ int i, lport, oport;
+ char *laddr_str, *oaddr_str;
struct client_t clients[MAXCLIENTS];
@@ -114,7 +116,7 @@
/* determine the listener address and port */
bzero(&laddr, sizeof(struct sockaddr_in));
laddr.sin_family = AF_INET;
- laddr.sin_port = htons((unsigned short) atol(argv[2]));
+ laddr.sin_port = htons((unsigned short) lport=atol(argv[2]));
laddr.sin_addr.s_addr = inet_addr(argv[1]);
if (!laddr.sin_port) {
fprintf(stderr, "invalid listener port\n");
@@ -128,12 +130,13 @@
}
bcopy(n->h_addr, (char *) &laddr.sin_addr, n->h_length);
}
+ laddr_str=strdup(inet_ntoa(laddr.sin_addr));
/* determine the outgoing address and port */
bzero(&oaddr, sizeof(struct sockaddr_in));
oaddr.sin_family = AF_INET;
- oaddr.sin_port = htons((unsigned short) atol(argv[4]));
+ oaddr.sin_port = htons((unsigned short) oport=atol(argv[4]));
if (!oaddr.sin_port) {
fprintf(stderr, "invalid target port\n");
return 25;
@@ -147,6 +150,7 @@
}
bcopy(n->h_addr, (char *) &oaddr.sin_addr, n->h_length);
}
+ oaddr_str=strdup(inet_ntoa(oaddr.sin_addr));
/* create the listener socket */
@@ -154,6 +158,15 @@
perror("socket");
return 20;
}
+ {
+ int j=1;
+ setsockopt(lsock, SOL_SOCKET, SO_REUSEADDR,
+ (const char *) &j, sizeof(j));
+ setsockopt(lsock, SOL_SOCKET, SO_KEEPALIVE,
+ (const char *) &j, sizeof(j));
+ setsockopt(lsock, SOL_SOCKET, SO_LINGER,
+ (const char *) &j, sizeof(j));
+ }
if (bind(lsock, (struct sockaddr *)&laddr, sizeof(laddr))) {
perror("bind");
return 20;
@@ -180,7 +193,10 @@
setsid();
#endif
-
+ openlog(argv[0], LOG_NDELAY|LOG_CONS|LOG_PID, LOG_LOCAL4);
+ syslog( LOG_INFO, "Datapipe started: %s:%i -> %s:%i",
+ laddr_str, lport, oaddr_str, oport);
+
/* main polling loop. */
while (1)
{
@@ -203,15 +219,22 @@
maxsock = (int) clients[i].osock;
}
if (select(maxsock + 1, &fdsr, NULL, NULL, &tv) < 0) {
- return 30;
+ syslog( LOG_INFO, "select, maxsock=%i", maxsock);
+ continue;
}
/* check if there are new connections to accept. */
if (FD_ISSET(lsock, &fdsr))
{
- SOCKET csock = accept(lsock, NULL, 0);
-
+ struct sockaddr_in raddr;
+ int len=sizeof(raddr);
+ SOCKET csock = accept(lsock, (struct sockaddr *)&raddr, &len);
+ if(csock >= 0) {
+ syslog( LOG_INFO, "Connection(%i) from %s:%i to %s:%i -> %s:%i",
+ csock, inet_ntoa(raddr.sin_addr), ntohs(raddr.sin_port),
+ laddr_str, lport, oaddr_str, oport);
+
for (i = 0; i < MAXCLIENTS; i++)
if (!clients[i].inuse) break;
if (i < MAXCLIENTS)
@@ -219,16 +242,16 @@
/* connect a socket to the outgoing host/port */
SOCKET osock;
if ((osock = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
- perror("socket");
+ syslog( LOG_INFO, "socket\n");
closesocket(csock);
}
else if (bind(osock, (struct sockaddr *)&laddr, sizeof(laddr))) {
- perror("bind");
+ syslog( LOG_INFO, "bind\n");
closesocket(csock);
closesocket(osock);
}
else if (connect(osock, (struct sockaddr *)&oaddr, sizeof(oaddr))) {
- perror("connect");
+ syslog( LOG_INFO, "connect\n");
closesocket(csock);
closesocket(osock);
}
@@ -239,9 +262,14 @@
clients[i].inuse = 1;
}
} else {
- fprintf(stderr, "too many clients\n");
+ syslog( LOG_INFO, "too many clients\n");
closesocket(csock);
- }
+ }
+ } else {
+ syslog( LOG_INFO, "Connection accept error(%i) from %s:%i to %s:%i -> %s:%i",
+ csock, inet_ntoa(raddr.sin_addr), ntohs(raddr.sin_port),
+ laddr_str, lport, oaddr_str, oport);
+ }
}
|
