1 files changed, 134 insertions, 0 deletions
diff --git a/accel-pptpd/pptpd.c b/accel-pptpd/pptpd.c
new file mode 100644
index 0000000..e29e61f
--- /dev/null
+++ b/accel-pptpd/pptpd.c
@@ -0,0 +1,134 @@
+/*
+*  C Implementation: pptpd
+*
+* Description:
+*
+*
+* Author:  <xeb@mail.ru>, (C) 2009
+*
+* Copyright: See COPYING file that comes with this distribution
+*
+*/
+
+#include <unistd.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <pthread.h>
+#include <stdarg.h>
+#include <errno.h>
+#include <string.h>
+
+#include <sys/poll.h>
+#include <sys/socket.h>
+#include <sys/time.h>
+#include <netinet/in.h>
+
+#include "list.h"
+#include "pptp_prot.h"
+#include "triton/triton.h"
+#include "pptpd.h"
+#include "log.h"
+
+static struct ctrl_thread_t *threads=NULL;
+static int threads_count=0;
+
+int start_server(void)
+{
+  int sock,c_sock;
+  int r,min_thr,min_cnt;
+  struct pollfd pfd;
+  struct sockaddr_in addr;
+	socklen_t size;
+
+  sock=socket (PF_INET, SOCK_STREAM, 0);
+  if (sock<0)
+  {
+    log_error("failed to create socket\n");
+    return -1;
+  }
+  addr.sin_family = AF_INET;
+  addr.sin_port = htons (PPTP_PORT);
+  addr.sin_addr.s_addr = htonl (INADDR_ANY);
+  setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &sock, sizeof(sock));
+  if (bind (sock, (struct sockaddr *) &addr, sizeof (addr)) < 0)
+  {
+  	perror("bind");
+    log_error("failed to bind socket\n");
+    return -1;
+  }
+
+  if (listen (sock, 1000)<0)
+  {
+    log_error("failed to listen socket\n");
+    return -1;
+  }
+
+	pfd.fd=sock;
+	pfd.events=POLLIN;
+
+	while(1)
+	{
+		r=poll(&pfd,1,-1);
+		if (r<0 && errno!=EINTR)
+		{
+	    log_error("poll failed\n");
+  	  return -2;
+		}
+		if (r<=0) continue;
+  	if (!(pfd.revents&POLLIN)) continue;
+
+  	size=sizeof(addr);
+		c_sock=accept(sock,(struct sockaddr *)&addr,&size);
+		if (c_sock<0)
+		{
+			log_error("client accept failed\n");
+			continue;
+		}
+
+		min_thr=0; min_cnt=65536;
+		for(r=0; r<threads_count; r++)
+		{
+			pthread_mutex_lock(&threads[r].lock);
+			if (threads[r].count<min_cnt)
+			{
+				min_cnt=threads[r].count;
+				min_thr=r;
+			}
+			pthread_mutex_unlock(&threads[r].lock);
+		}
+		write(threads[min_thr].pipe_fd[1],&c_sock,sizeof(c_sock));
+	}
+}
+
+int start_threads(int cnt)
+{
+	int i;
+	if (!cnt) cnt=sysconf(_SC_NPROCESSORS_CONF);
+	threads=malloc(cnt*sizeof(*threads));
+	memset(threads,0,cnt*sizeof(*threads));
+
+	for(i=0; i<cnt; i++)
+	{
+		//threads[i].lock=PTHREAD_MUTEX_INITIALIZER;
+		if (pipe(threads[i].pipe_fd))
+		{
+			log_error("failed to create pipe\n");
+			return -1;
+		}
+		if (triton_run((int(*)(void*))ctrl_init,&threads[i]))
+		{
+			log_error("triton_run failed\n");
+			return -1;
+		}
+	}
+	threads_count=cnt;
+	return 0;
+}
+
+int main(int argc,char **argv)
+{
+	log_init(stdout,4,0);
+	start_threads(0);
+	start_server();
+	return EXIT_SUCCESS;
+}