summaryrefslogtreecommitdiff
path: root/src/net/udp.c~
diff options
context:
space:
mode:
Diffstat (limited to 'src/net/udp.c~')
-rw-r--r--src/net/udp.c~415
1 files changed, 0 insertions, 415 deletions
diff --git a/src/net/udp.c~ b/src/net/udp.c~
deleted file mode 100644
index f654a75..0000000
--- a/src/net/udp.c~
+++ /dev/null
@@ -1,415 +0,0 @@
-
-
-#ifndef __WIN32__
-# include <sys/socket.h>
-# include <sys/types.h>
-# include <netinet/in.h>
-# include <arpa/inet.h>
-# include <netdb.h>
-#else
-# include <windows.h>
-# include <wininet.h>
-#endif
-
-#include <unistd.h>
-#include <stdlib.h>
-#include <stdio.h>
-#include <string.h>
-#include <assert.h>
-#include <fcntl.h>
-
-
-#define BUFSIZE 1000
-
-#include "main.h"
-#include "net_multiplayer.h"
-
-#include "udp.h"
-
-sock_udp_t* newSockUdp(int proto)
-{
- sock_udp_t *new;
-
- new = malloc( sizeof(sock_udp_t) );
- memset(new, 0, sizeof(sock_udp_t));
- new->proto = proto;
-
- return new;
-}
-
-void destroySockUdp(sock_udp_t *p)
-{
- assert( p != NULL );
- free(p);
-}
-
-sock_udp_t* bindUdpSocket(char *address, int port, int proto)
-{
- sock_udp_t *new;
- int res = -1; // no warninng
-
- assert( port > 0 && port < 65535 );
-
- new = newSockUdp(proto);
-
- assert( new != NULL );
-
- if( new->proto == PROTO_UDPv4 )
- {
- new->sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
- }
-
-#ifdef SUPPORT_IPv6
- if( new->proto == PROTO_UDPv6 )
- {
- new->sock = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
- }
-#endif
-
- if( new->sock < 0 )
- {
- fprintf(stderr, _("Unable to create socket when binding!\n"));
- destroySockUdp(new);
-#ifdef __WIN32__
- WSACleanup();
-#endif
- return NULL;
- }
-
- memset(&(new->sockAddr), 0, sizeof(new->sockAddr));
-
- if( new->proto == PROTO_UDPv4 )
- {
- new->sockAddr.sin_family = AF_INET;
- new->sockAddr.sin_port = htons(port);
- new->sockAddr.sin_addr.s_addr = inet_addr(address);
-
- res = bind(new->sock, (struct sockaddr *)&(new->sockAddr), sizeof(new->sockAddr));
- }
-
-#ifdef SUPPORT_IPv6
- if( new->proto == PROTO_UDPv6 )
- {
- new->sockAddr6.sin6_family = AF_INET6;
- new->sockAddr6.sin6_port = htons(port);
- inet_pton(AF_INET6, address, &(new->sockAddr6.sin6_addr));
-
- res = bind(new->sock, (struct sockaddr *)&(new->sockAddr6), sizeof(new->sockAddr6));
- }
-#endif
-
- if( res < 0 )
- {
- fprintf(stderr, _("Unable to set socket %s %d!\n"), address, port);
- destroySockUdp(new);
-#ifdef __WIN32__
- WSACleanup();
-#endif
- return NULL;
- }
-
- return new;
-}
-
-sock_udp_t* connectUdpSocket(char *address, int port, int proto)
-{
- sock_udp_t *new;
-
- assert( address != NULL );
- assert( port > 0 && port < 65536 );
-
- new = newSockUdp(proto);
-
- assert( new != NULL );
-
- if( new->proto == PROTO_UDPv4 )
- {
- new->sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
- }
-
-#ifdef SUPPORT_IPv6
- if( new->proto == PROTO_UDPv6 )
- {
- new->sock = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
- }
-#endif
-
- if( new->sock < 0 )
- {
- fprintf(stderr, _("Unable to create socket when connecting!\n"));
- destroySockUdp(new);
-#ifdef __WIN32__
- WSACleanup();
-#endif
- return NULL;
- }
-
- memset(&(new->sockAddr), 0, sizeof(new->sockAddr));
-
- if( new->proto == PROTO_UDPv4 )
- {
- new->sockAddr.sin_family = AF_INET;
- new->sockAddr.sin_port = htons(port);
- new->sockAddr.sin_addr.s_addr = inet_addr(address);
- }
-
-#ifdef SUPPORT_IPv6
- if( new->proto == PROTO_UDPv6 )
- {
- new->sockAddr6.sin6_family = AF_INET6;
- new->sockAddr6.sin6_port = htons(port);
- inet_pton(AF_INET6, address, &(new->sockAddr6.sin6_addr));
- }
-#endif
- return new;
-}
-
-int setUdpSockNonBlock(sock_udp_t *p)
-{
- /* Set to nonblocking socket mode */
-#ifndef __WIN32__
- int oldFlag;
-
- oldFlag = fcntl (p->sock, F_GETFL, 0);
-
- if( fcntl(p->sock, F_SETFL, oldFlag | O_NONBLOCK) == -1 )
- {
- return -1;
- }
-#else
- unsigned long arg = 1;
- // Operation is FIONBIO. Parameter is pointer on non-zero number.
- if( ioctlsocket(p->sock, FIONBIO, &arg) == SOCKET_ERROR )
- {
- WSACleanup();
- return -1;
- }
-#endif
- return 0;
-}
-
-int readUdpSocket(sock_udp_t *src, sock_udp_t *dst, void *address, int len)
-{
- int addrlen;
- int size = -1; // no warninng
-
- assert( src != NULL );
- assert( dst != NULL );
- assert( address != NULL );
-
- if( dst->proto == PROTO_UDPv4 )
- {
- addrlen = sizeof(src->sockAddr);
-
-#ifndef __WIN32
- size = recvfrom(src->sock, address, len, 0, (struct sockaddr *)&dst->sockAddr, (socklen_t *)&addrlen);
-#else
- size = recvfrom(src->sock, address, len, 0, (struct sockaddr *)&dst->sockAddr, (int *)&addrlen);
-#endif
- }
-
-#ifdef SUPPORT_IPv6
- if( dst->proto == PROTO_UDPv6 )
- {
- addrlen = sizeof(src->sockAddr6);
-
- size = recvfrom(src->sock, address, len, 0,
- (struct sockaddr *)&dst->sockAddr6, (socklen_t *)&addrlen);
- }
-#endif
-
- dst->sock = src->sock;
-
- if( size < 0 )
- {
- char str_ip[STR_IP_SIZE];
-
- getSockUdpIp(dst, str_ip, STR_IP_SIZE);
-
- fprintf(stderr, _("Unable to read form socket %d %s %d!\n"), size, str_ip, getSockUdpPort(dst));
-#ifdef __WIN32__
- WSACleanup();
-#endif
- return -1;
- }
-
- return size;
-}
-
-int writeUdpSocket(sock_udp_t *src, sock_udp_t *dst, void *address, int len)
-{
- int addrlen;
- int size = -1; // no warninng
-
- assert( src != NULL );
- assert( dst != NULL );
- assert( address != NULL );
-
- if( dst->proto == PROTO_UDPv4 )
- {
- addrlen = sizeof(src->sockAddr);
-
- size = sendto(src->sock, address, len, 0, (struct sockaddr *)&dst->sockAddr, addrlen);
- }
-
-#ifdef SUPPORT_IPv6
- if( dst->proto == PROTO_UDPv6 )
- {
- addrlen = sizeof(src->sockAddr6);
-
- size = sendto(src->sock, address, len, 0, (struct sockaddr *)&dst->sockAddr6, addrlen);
- }
-#endif
-
- if( size < 0 )
- {
- char str_ip[STR_IP_SIZE];
-
- getSockUdpIp(dst, str_ip, STR_IP_SIZE);
-
- fprintf(stderr, _("Unable to write on socket %d %s %d!\n"), size, str_ip, getSockUdpPort(dst));
-#ifdef __WIN32__
- WSACleanup();
-#endif
- return -1;
- }
-
- return size;
-}
-
-void getSockUdpIp(sock_udp_t *p, char *str_ip, int len)
-{
- assert( p != NULL );
- assert( str_ip != NULL );
-
-
- if( p->proto == PROTO_UDPv4 )
- {
-#ifndef __WIN32__
- inet_ntop(AF_INET, &(p->sockAddr.sin_addr), str_ip, len);
-#else
- strcpy(str_ip, inet_ntoa(p->sockAddr.sin_addr));
- //printf("strcpy(str_ip, inet_ntoa(p->sockAddr.sin_addr));\n");
-#endif
- }
-
-#ifdef SUPPORT_IPv6
- if( p->proto == PROTO_UDPv6 )
- {
- inet_ntop(AF_INET6, &(p->sockAddr6.sin6_addr), str_ip, len);
- }
-#endif
-}
-
-int getSockUdpPort(sock_udp_t *p)
-{
- assert( p != NULL );
-
- if( p->proto == PROTO_UDPv4 )
- {
- return htons(p->sockAddr.sin_port);
- }
-
-#ifdef SUPPORT_IPv6
- if( p->proto == PROTO_UDPv6 )
- {
- return htons(p->sockAddr6.sin6_port);
- }
-#endif
-
- assert( ! _("Bad IP proto!") );
-
- return -1;
-}
-
-
-void closeUdpSocket(sock_udp_t *p)
-{
- assert( p != NULL );
-
-#ifndef __WIN32__
- close(p->sock);
-#else
- closesocket(p->sock);
- //WSACleanup(); //kdyz ukoncime socket dobre neni treba cleanup
-#endif
- destroySockUdp(p);
-}
-
-#if 0
-
-static int myWait(sock_udp_t *p)
-{
- fd_set readfds;
- fd_set errorfds;
- struct timeval tv;
- int max_fd;
-
- tv.tv_sec = 1;
- tv.tv_usec = 0;
-
- FD_ZERO(&readfds);
- FD_ZERO(&errorfds);
- max_fd = p->sock;
-
- FD_SET(p->sock, &readfds);
- FD_SET(p->sock, &errorfds);
-
- select(max_fd+1, &readfds, (fd_set *)0, &errorfds, &tv);
-
- if( FD_ISSET(p->sock, &readfds) )
- {
- FD_CLR(p->sock, &readfds);
- return 1;
- }
-
- return 0;
-}
-
-int main(int argc, char *argv[])
-{
- sock_udp_t *sock;
- char buf[BUFSIZE];
- int ret;
-
- if( strcmp(argv[1], "s") == 0 )
- {
- sock_udp_t *cli;
-
- //sock = bindUdpSocket("::1", atoi(argv[2]), PROTO_UDPv6 );
- sock = bindUdpSocket("127.0.0.1", atoi(argv[2]), PROTO_UDPv4 );
-
- //cli = newSockUdp(PROTO_UDPv6);
- cli = newSockUdp(PROTO_UDPv4);
-
- while(1)
- {
- while( myWait(sock) == 0 )
- ;
-
- memset(buf, 0, BUFSIZE);
- ret = readUdpSocket(sock, cli, buf, BUFSIZE);
- writeUdpSocket(sock, cli, buf, ret);
- }
- }
-
- if( strcmp(argv[1], "c") == 0 )
- {
- //sock = connectUdpSocket("::1", atoi(argv[2]), PROTO_UDPv6);
- sock = connectUdpSocket("127.0.0.1", atoi(argv[2]), PROTO_UDPv4);
-
- strcpy(buf, "Hello world !\n");
- writeUdpSocket(sock, sock, buf, strlen(buf));
-
- memset(buf, 0, BUFSIZE);
- readUdpSocket(sock, sock, buf, BUFSIZE);
-
- printf("buf = %s", buf);
- //while(1)sleep(1);
- closeUdpSocket(sock);
- }
-
- return 0;
-}
-#endif
-
generated by cgit v1.2.3 (git 2.46.0) at 2026-09-13 09:37:08 +0000