#ifndef __GLOBALS_H__
#define __GLOBALS_H__
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <dirent.h>
#include <time.h>
#include <poll.h>
#include <errno.h>
#include <signal.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <limits.h>
#include <stdarg.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ioctl.h>
#include <pthread.h>
#define SERVER_PORT 1001
#define MOD_CONN_TCP 1
#define MOD_CONN_UDP 2
#define true 1
#define false 0
typedef short bool;
struct server_module
{
int type;
char desc[16];
void (*handler)();
int (*init)();
int (*recv)();
};
struct server_client
{
int type;
struct in_addr ip;
int port;
bool connected;
bool conn_flag;
time_t login;
time_t expire;
};
extern struct server_client *client[];
extern int con_idx;
struct nt_protocol
{
char type[5]; // sollte int sein
char status[5]; // dito
char cmd[10];
};
#endif
#include "globals.h"
#define MAX_CONNECTIONS 256
int con_idx = 0;
struct server_client *client[256];
static fd_set master;
static fd_set read_fds;
int check_for_disconnect(int s)
{
int i;
for (i = 0; i < MAX_CONNECTIONS; i++)
{
if (i == s)
{
char buf[200];
strcpy(buf, "ServerSide disconnect");
if ((send(s, buf, strlen(buf), 0)) == -1)
printf("Server: send() data to: %s error,\n",
(client[i]->ip.s_addr));
close(s);
FD_CLR(i, &master);
--con_idx;
client[s]->connected = false;
break;
}
}
}
char *trim(char *str)
{
char ptr[strlen(str)+1];
int i, j = 0;
for (i = 0; str[i] != '\0'; i++)
{
if (str[i] != ' ' && str[i] != '\t')
ptr[j++] = str[i];
}
ptr[j] = '\0';
str = ptr;
}
int main()
{
int yes = 1;
int fdmax;
int newfd;
int nbytes;
char buf[1024];
int i;
for (i = 0; i < MAX_CONNECTIONS; i++)
{
client[i] = (struct server_client*) malloc(sizeof(struct server_client)+1);
client[i]->type = 0;
client[i]->connected = false;
}
FD_ZERO(&master);
FD_ZERO(&read_fds);
int listener;
if ((listener = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
exit(1);
}
else {
printf("Server: socket() is OK!\n");
}
if (setsockopt(listener, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1)
{
perror("Server: socket() error.");
exit(1);
}
printf("Server: setsockopt() is Ok...\n");
struct sockaddr_in service;
struct sockaddr_in clientaddr;
service.sin_family = AF_INET;
service.sin_addr.s_addr = INADDR_ANY; //inet_addr("192.168.178.79");
service.sin_port = htons(SERVER_PORT);
memset(&(service.sin_zero),'\0', 8);
if (bind(listener, (struct sockaddr*)&service, sizeof(service)) == -1)
{
printf("Server: bind() failed:\n");
exit(1);
}
printf("Server: bind() is OK!\n");
if (listen(listener, 10) == -1)
{
printf("Server: listen(): Error listening on socket\n");
exit(1);
}
printf("Server: listen() is OK, I'm waiting for connections...\n");
FD_SET(listener, &master);
fdmax = listener;
int addrlen;
for (;;)
{
read_fds = master;
if(select(fdmax+1, &read_fds, NULL, NULL, NULL) == -1)
{
perror("Server-select() error lol!");
exit(1);
}
printf("Server-select() is OK...\n");
labse:
i = 0;
for (i = 0; i <= fdmax; i++)
{
if (FD_ISSET(i, &read_fds))
{
if (i == listener)
{
addrlen = sizeof(clientaddr);
if ((newfd = accept(listener, (struct sockaddr *)&clientaddr, &addrlen)) == -1)
{
perror("Server: accept() error.");
exit(1);
}
else
{
printf("Server: accept() is Ok...\n");
FD_SET(newfd, &master);
if (newfd > fdmax)
fdmax = newfd;
printf("new connection from: %s on socket: %d\n",
inet_ntoa(clientaddr.sin_addr), newfd);
client[newfd]->ip = clientaddr.sin_addr;
client[newfd]->port = SERVER_PORT;
client[newfd]->connected = true;
client[newfd]->conn_flag = false;
con_idx++;
char buf[200];
if (con_idx > 4)
{
sprintf(buf,
"Fehler:\n"
"Maximale Verbindungsanzahl erreicht!");
send(newfd, buf, strlen(buf), 0);
printf("Server: max connection reached.\n");
}
else {
sprintf(buf,
" Willkommen auf den CS-Server\n"
"Copyright (c) 2012 by paulemh & paule22");
if (send(newfd, buf, strlen(buf), 0) == -1)
{
printf("Client: can't send data.\n");
close(newfd);
}
}
printf("send to client ok.\n");
break;
}
}
else
{
struct nt_protocol *mp = (struct nt_protocol*) malloc(sizeof(struct nt_protocol));;
char field1[4];
char field2[4];
char field3[10];
int n1,n2,n3;
/*
if ((n1 = recv(i,(char*)field1,4,0)) == -1)
{
if (n1 == 0)
printf("socket: %d hang up\n",i);
else
perror("Server: recv() error!");
close(i);
close(newfd);
FD_CLR(i, &master);
--con_idx;
break;
}
if ((n2 = recv(i,(char*)field1,4,0)) == -1)
{
if (n2 == 0)
printf("socket: %d hang up\n",i);
else
perror("Server: recv() error!");
close(i);
close(newfd);
FD_CLR(i, &master);
--con_idx;
break;
}
if ((n3 = recv(i,(char*)field1,10,0)) == -1)
{
if (n1 == 0)
printf("socket: %d hang up\n",i);
else
perror("Server: recv() error!");
close(i);
close(newfd);
FD_CLR(i, &master);
--con_idx;
break;
}
strcpy(mp->type,field1);
strcpy(mp->status,field2);
strcpy(mp->cmd,trim(field3));
*/
if ((nbytes = recv(i, (struct nt_protocol*)mp, sizeof(struct nt_protocol), 0)) <= 0)
{
if (nbytes == 0)
printf("socket: %d hang up\n",i);
else
perror("Server: recv() error!");
close(i);
close(newfd);
FD_CLR(i, &master);
--con_idx;
break;
}
else
{
if (!strcmp(mp->cmd,trim("pc1")))
{
DIR *dir;
struct dirent *ent;
dir = opendir("/");
if (dir != NULL)
{
char *dbs = malloc(4096);
strcpy(dbs,"");
while ((ent = readdir(dir)) != NULL)
{
if ((strstr(ent->d_name,"..") == NULL )
|| ((strstr(ent->d_name,"." ) == NULL) && (strlen(ent->d_name) == 1))) {
sprintf(buf,"%s\n",ent->d_name);
strcat(dbs,buf); }
}
if ((send(newfd, dbs, strlen(dbs), 0)) == -1)
printf("Server: send() data to: %s error,\n",
inet_ntoa(clientaddr.sin_addr));
free(dbs);
}
else {
perror("error open");
}
} else if (!strcmp(mp->cmd,"pc2"))
{
printf("--> pc2 command\n");
}
int j;
for (j = 0; j <= fdmax; j++)
{
if (FD_ISSET(j, &master))
{
if (j != listener && j == i)
{
if (client[j]->conn_flag == true)
check_for_disconnect(j);
break;
}
}
}
}
}
}
}
}
return 0;
}