diff options
| author | Dusan Durech <dusan@debian.(none)> | 2008-10-11 13:58:00 +0200 |
|---|---|---|
| committer | Dusan Durech <dusan@debian.(none)> | 2008-10-11 13:58:00 +0200 |
| commit | 03cec15266fe1f71d0c9ef0a981ecc725a2a71b3 (patch) | |
| tree | 9c41f4ddc95d89d9f6303afd995eb31929cbf0f6 | |
| parent | 2910d829327e15dcc410a21c0c9539b9cac3206b (diff) | |
- odstranenie podpory TCP
| -rw-r--r-- | src/base/server.c | 99 | ||||
| -rw-r--r-- | src/client/client.c | 149 | ||||
| -rw-r--r-- | src/screen/screen_downArena.c | 6 |
3 files changed, 14 insertions, 240 deletions
diff --git a/src/base/server.c b/src/base/server.c index c907dc0..836b9d2 100644 --- a/src/base/server.c +++ b/src/base/server.c @@ -40,13 +40,8 @@ #include "heightScore.h" #endif -#ifdef SUPPORT_UDP -#include "udp_server.h" -#endif -#ifdef SUPPORT_TCP -#include "tcp_server.h" -#endif +#include "udp_server.h" static list_t *listClient; @@ -154,27 +149,6 @@ void destroyAnyClient(client_t *p) free(p); } -static void destroyUdpOrTcpClient(client_t *client) -{ - switch( client->type ) - { -#ifdef SUPPORT_UDP - case CLIENT_TYPE_UDP : - destroyUdpClient(client); - break; -#endif - -#ifdef SUPPORT_TCP - case CLIENT_TYPE_TCP : - destroyTcpClient(client); - break; -#endif - default : - assert( ! _("Bad client type (TCP/UDP)!")); - break; - } -} - static void eventDelClientFromListClient(client_t *client) { int offset; @@ -183,7 +157,7 @@ static void eventDelClientFromListClient(client_t *client) assert( offset != -1 ); - delListItem(listClient, offset, destroyUdpOrTcpClient); + delListItem(listClient, offset, destroyUdpClient); } static void delZombieCLient(void *p_nothink) @@ -275,23 +249,12 @@ int initServer(char *ip4, int port4, char *ip6, int port6) setServerMaxClients(SERVER_MAX_CLIENTS); setServerTimer(); -#ifdef SUPPORT_UDP ret = initUdpServer(ip4, port4, ip6, port6); if( ret == 0 ) { return -1; } -#endif - -#ifdef SUPPORT_TCP - ret = initTcpServer(ip4, port4, ip6, port6); - - if( ret == 0 ) - { - return -1; - } -#endif return ret; } @@ -327,25 +290,8 @@ void sendClient(client_t *p, char *msg) } #endif - switch( p->type ) - { -#ifdef SUPPORT_UDP - case CLIENT_TYPE_UDP : - ret = writeUdpSocket(p->socket_udp, p->socket_udp, msg, strlen(msg)); - break; -#endif - -#ifdef SUPPORT_TCP - case CLIENT_TYPE_TCP : - ret = addBuffer(p->sendBuffer, msg, strlen(msg)); - break; -#endif + ret = writeUdpSocket(p->socket_udp, p->socket_udp, msg, strlen(msg)); - default : - assert( ! _("Bad client type (TCP/UDP)!")); - break; - } - if( ret <= 0 ) { p->status = NET_STATUS_ZOMBIE; @@ -401,13 +347,6 @@ static void porcesListClients() eventClientWorkRecvList(thisClient); eventMsgInCheckFront(thisClient); - -#ifdef SUPPORT_TCP - if( thisClient->type == CLIENT_TYPE_TCP ) - { - sendTcpClientBuffer(thisClient); - } -#endif } } @@ -416,16 +355,8 @@ void eventServer() #ifndef PUBLIC_SERVER int count; -#ifdef SUPPORT_TCP - do{ - restartSelect(); - setServerTcpSelect(); - actionSelect(); - count = selectServerTcpSocket(); - }while( count > 0 ); -#endif -#ifdef SUPPORT_UDP + do{ restartSelect(); setServerUdpSelect(); @@ -434,32 +365,18 @@ void eventServer() }while( count > 0 ); #endif -#endif - #ifdef PUBLIC_SERVER int ret; restartSelect(); -#ifdef SUPPORT_TCP - setServerTcpSelect(); -#endif - -#ifdef SUPPORT_UDP setServerUdpSelect(); -#endif ret = actionSelect(); if( ret > 0 ) { -#ifdef SUPPORT_TCP - selectServerTcpSocket(); -#endif - -#ifdef SUPPORT_UDP selectServerUdpSocket(); -#endif } #endif @@ -473,15 +390,9 @@ void quitServer() assert( listClient != NULL ); - destroyListItem(listClient, destroyUdpOrTcpClient); + destroyListItem(listClient, destroyUdpClient); destroyTimer(listServerTimer); -#ifdef SUPPORT_UDP quitUdpServer(); -#endif - -#ifdef SUPPORT_TCP - quitTcpServer(); -#endif } diff --git a/src/client/client.c b/src/client/client.c index 399324a..7512ab8 100644 --- a/src/client/client.c +++ b/src/client/client.c @@ -27,21 +27,9 @@ #include "screen_world.h" #include "buffer.h" -#ifdef SUPPORT_UDP #include "udp.h" -#endif - -#ifdef SUPPORT_TCP -#include "tcp.h" -#endif -#ifdef SUPPORT_UDP static sock_udp_t *sock_server_udp; -#endif - -#ifdef SUPPORT_TCP -static sock_tcp_t *sock_server_tcp; -#endif static list_t *listRecvMsg; @@ -103,8 +91,6 @@ static proto_cmd_client_t* findCmdProto(char *msg) return NULL; } -#ifdef SUPPORT_UDP - static int initUdpClient(char *ip, int port, int proto) { sock_server_udp = connectUdpSocket(ip, port, proto); @@ -119,30 +105,6 @@ static int initUdpClient(char *ip, int port, int proto) return 0; } -#endif - -#ifdef SUPPORT_TCP - -static int initTcpClient(char *ip, int port, int proto) -{ - sock_server_tcp = connectTcpSocket(ip, port, proto); - - if( sock_server_tcp == NULL ) - { - return -1; - } - - disableNagle(sock_server_tcp); - setTcpSockNonBlock(sock_server_tcp); - -#ifdef DEBUG - printf(_("Connected to: %s on port: %d via TCP\n"), ip, port); -#endif - return 0; -} - -#endif - int initClient(char *ip, int port, int proto) { char name[STR_NAME_SIZE]; @@ -161,23 +123,12 @@ int initClient(char *ip, int port, int proto) clientRecvBuffer = newBuffer(CLIENT_BUFFER_LIMIT); clientSendBuffer = newBuffer(CLIENT_BUFFER_LIMIT); -#ifdef SUPPORT_UDP ret = initUdpClient(ip, port, proto); if( ret < 0 ) { return -1; } -#endif - -#ifdef SUPPORT_TCP - ret = initTcpClient(ip, port, proto); - - if( ret < 0 ) - { - return -1; - } -#endif getSettingNameRight(name); proto_send_hello_client(name); @@ -192,36 +143,6 @@ static void errorWithServer() setWorldEnd(); } -#ifdef SUPPORT_TCP - -static void sendBuffer() -{ - void *data; - int len; - int res; - - len = getBufferSize(clientSendBuffer); - - if( len == 0 ) - { - return; - } - - data = getBufferData(clientSendBuffer); - - res = writeTcpSocket(sock_server_tcp, data, len); - - if( res < 0 ) - { - errorWithServer(); - return; - } - - cutBuffer(clientSendBuffer, res); -} - -#endif - void sendServer(char *msg) { int ret; @@ -242,20 +163,10 @@ void sendServer(char *msg) traffic_up += strlen(msg); #endif -#ifdef SUPPORT_UDP if( sock_server_udp != NULL ) { ret = writeUdpSocket(sock_server_udp, sock_server_udp, msg, strlen(msg)); } -#endif - -#ifdef SUPPORT_TCP - if( sock_server_tcp != NULL ) - { - //ret = writeTcpSocket(sock_server_tcp, msg, strlen(msg)); - ret = addBuffer(clientSendBuffer, msg, strlen(msg)); - } -#endif if( ret < 0 ) { @@ -272,19 +183,10 @@ static int eventServerSelect() memset(buffer, 0, STR_PROTO_SIZE); ret = -1; -#ifdef SUPPORT_UDP if( sock_server_udp != NULL ) { ret = readUdpSocket(sock_server_udp, sock_server_udp, buffer, STR_PROTO_SIZE-1); } -#endif - -#ifdef SUPPORT_TCP - if( sock_server_tcp != NULL ) - { - ret = readTcpSocket(sock_server_tcp, buffer, STR_PROTO_SIZE-1); - } -#endif if( ret < 0 ) { @@ -296,6 +198,9 @@ static int eventServerSelect() traffic_down += ret; #endif + addList(listRecvMsg, strdup(buffer)); + +#if 0 if( addBuffer(clientRecvBuffer, buffer, ret) < 0 ) { errorWithServer(); @@ -309,7 +214,8 @@ static int eventServerSelect() addList(listRecvMsg, strdup(buffer) ); } } - +#endif + return ret; } @@ -358,8 +264,6 @@ static void eventPingServer() } } -#ifdef SUPPORT_UDP - static bool_t isServerAlive() { my_time_t currentTime; @@ -374,8 +278,6 @@ static bool_t isServerAlive() return TRUE; } -#endif - static void selectClientSocket() { fd_set readfds; @@ -387,7 +289,6 @@ static void selectClientSocket() max_fd = 0; sock = 0; -#ifdef SUPPORT_UDP if( sock_server_udp != NULL ) { if( isServerAlive() == FALSE ) @@ -396,7 +297,6 @@ static void selectClientSocket() return; } } -#endif do{ isNext = FALSE; @@ -406,19 +306,11 @@ static void selectClientSocket() FD_ZERO(&readfds); -#ifdef SUPPORT_UDP if( sock_server_udp != NULL ) { sock = sock_server_udp->sock; } -#endif - -#ifdef SUPPORT_TCP - if( sock_server_tcp != NULL ) - { - sock = sock_server_tcp->sock; - } -#endif + FD_SET(sock, &readfds); max_fd = sock; select(max_fd+1, &readfds, (fd_set *)NULL, (fd_set *)NULL, &tv); @@ -467,13 +359,8 @@ void eventClient() selectClientSocket(); eventClientWorkRecvList(); -#ifdef SUPPORT_TCP - sendBuffer(); -#endif } -#ifdef SUPPORT_UDP - static void quitUdpClient() { assert( sock_server_udp != NULL ); @@ -483,21 +370,6 @@ static void quitUdpClient() #endif } -#endif - -#ifdef SUPPORT_TCP - -static void quitTcpClient() -{ - assert( sock_server_tcp != NULL ); - closeTcpSocket(sock_server_tcp); -#ifdef DEBUG - printf(_("Closing TCP connection.\n")); -#endif -} - -#endif - void quitClient() { proto_send_end_client(); @@ -508,18 +380,9 @@ void quitClient() destroyBuffer(clientRecvBuffer); destroyBuffer(clientSendBuffer); -#ifdef SUPPORT_UDP if( sock_server_udp != NULL ) { quitUdpClient(); } -#endif - -#ifdef SUPPORT_TCP - if( sock_server_tcp != NULL ) - { - quitTcpClient(); - } -#endif } diff --git a/src/screen/screen_downArena.c b/src/screen/screen_downArena.c index f7534b5..19887fd 100644 --- a/src/screen/screen_downArena.c +++ b/src/screen/screen_downArena.c @@ -274,16 +274,16 @@ static void readArenaFromStatus() closeUdpSocket(sock_server_udp); sock_server_udp = NULL; strncpy(arenaNetName, offset_begin, offset_end-offset_begin); -/* + if( getArenaFileFormNetName(arenaNetName) != NULL ) { setScreen("world"); return; } -*/ + connectToDownServer(); - //printf("arenaNetName = >>%s<<\n", arenaNetName); + printf("arenaNetName = >>%s<<\n", arenaNetName); } } } |