Info
Get involved
Documentation

src/SAL_network.cpp

/*
    SAL - Simple Application Library
    Copyright (C) 2006-2006 Kronon

    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Lesser General Public
    License as published by the Free Software Foundation; either
    version 2.1 of the License, or (at your option) any later version.

    This library is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public
    License along with this library; if not, write to the Free Software
    Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

    Kronon
    kronon88@users.sourceforge.net
*/

//SAL network functionality
//Created by Kronon

//Doxy gen information

#include "SAL_network.h"
 
int SAL_start_network()
{
        //Start SDLNet library
        if(SDLNet_Init()==-1)
        {
                salError("Couldn't start network.", SDLNet_GetError());
                exit(2);
        }
        return 0;
}

int SAL_stop_network()
{
        //Stop threads
        for(SAL_struct.internal.event.network_listeners.setLoopBegin(); SAL_struct.internal.event.network_listeners.inLoop(); )
        {
                //Free thread
                SDL_WaitThread(SAL_struct.internal.event.network_listeners.getLoopEntry()->thread, NULL);
                //Free socket set
                SDLNet_FreeSocketSet(SAL_struct.internal.event.network_listeners.getLoopEntry()->socketSet);
                //Free all sockets in network listener
                for(SAL_struct.internal.event.network_listeners.getLoopEntry()->sockets.setLoopBegin(); SAL_struct.internal.event.network_listeners.getLoopEntry()->sockets.inLoop(); )
                {
                        SDLNet_UDP_Close(SAL_struct.internal.event.network_listeners.getLoopEntry()->sockets.getLoopEntry());
                }
        }
        
        SDLNet_Quit();
        return 0;
}

int addUdpInputSocket(Uint16 portNr)
{
        if(SAL_struct.internal.event.network_listeners.getSize() == 0)
        {
                //Add first network listener thread
                SAL_struct.internal.event.last_network_listener = new SAL_network_listener;
                SAL_struct.internal.event.last_network_listener->socketSet = SDLNet_AllocSocketSet(SAL_struct.setting.common.max_con_network_listener);
                SAL_struct.internal.event.network_listeners.append(SAL_struct.internal.event.last_network_listener);
                SAL_struct.internal.event.last_network_listener->thread = SDL_CreateThread(SAL_network_listener_thread, NULL);
                printf("0 listeners adding 1\n");
        }
        else if(SAL_struct.internal.event.last_network_listener->sockets.getSize() < SAL_struct.setting.common.max_con_network_listener)
        {
                //Add another network listener thread
                SAL_struct.internal.event.last_network_listener = new SAL_network_listener;
                SAL_struct.internal.event.last_network_listener->socketSet = SDLNet_AllocSocketSet(SAL_struct.setting.common.max_con_network_listener);
                SAL_struct.internal.event.network_listeners.append(SAL_struct.internal.event.last_network_listener);
                SAL_struct.internal.event.last_network_listener->thread = SDL_CreateThread(SAL_network_listener_thread, NULL);
                printf("Multi listeners adding 1\n");
        }
        //Create and safe socket
        UDPsocket socket = SDLNet_UDP_Open(portNr);
        SAL_struct.internal.event.last_network_listener->sockets.append(socket);
        
        //Add socket to listening socket set
        if(SDLNet_UDP_AddSocket(SAL_struct.internal.event.last_network_listener->socketSet, socket) == -1)
        {
                salError("Failed to sign socket to socket set");
        }
        
        return 0;
}

int addUdpOutputSocket(Uint16 portNr)
{
        UDPsocket socket = NULL;
        socket = SDLNet_UDP_Open(portNr);
        if(!socket)                                                                                                                                     //Couldn't open specified socket
        {
                socket = SDLNet_UDP_Open(0);                                                                                    //Check if it helps to open an random socket instead
                if(!socket)
                {
                        salError("Couldn open any socket");
                        return -1;
                }
                else
                        salError("Couldn't open socket, opend random socket instead");
        }
        SAL_struct.internal.event.socketsOut.append(socket);
        return 0;
}

int sendUdpMessage(const char* message, Uint16 mesLen, IPaddress *addresses, Uint8 numIp, UDPsocket socket)
{
        UDPpacket *packet =     SDLNet_AllocPacket(mesLen);                             //Create new packet thats used over and over again
        int numSent;
        packet->len = mesLen;
        packet->data = (Uint8 *)message;
        
        if(numIp == 0)                                                                                          //Send message to one ip address
        {
                packet->address = *addresses;                                                   //Set recipient NOTE:does this work?
                numSent = SDLNet_UDP_Send(socket, -1, packet);                  //Send message
                if(!numSent)
                {
                        salError("Packet couldn't be send");
                        return -1;
                }
        }
        else                                                                                                            //Send message to enlisted ip addresses
        {
                for(int i = 0; i< numIp; i++)                                                   //Loop truh enlisted addresses
                {
                        packet->address = *addresses;                                           //NOTE:Does this work?
                        numSent = SDLNet_UDP_Send(socket, -1, packet);
                        if(!numSent)
                        {
                                salError("Packet couldn't be send");
                                return -1;
                        }
                        addresses++;                                                                                    //Select next address
                }
        }
        return 0;
}

int SAL_network_listener_thread(void * unused)
{
        UDPpacket *packet;
        SAL_network_listener *listener;                                                                                         //This network listener
        int numRecv = 0, numWaiting = 0;                                                                                        //Number of connections receved
        listener = SAL_struct.internal.event.last_network_listener;
         
        packet = SDLNet_AllocPacket(SAL_MAX_PACKET_SIZE);                                                       //Create new packet thats used over and over again
        if(!packet)
        {
                salError("Failed to create packet",SDLNet_GetError());
        }
        
        while(SAL_struct.internal.checks.alive)
        {
                //Wait for network activity or network time out
                numWaiting = SDLNet_CheckSockets(listener->socketSet, SAL_struct.setting.common.network_time_out_time);
                if(numWaiting==-1)
                {
                        salError("Network error while waiting for package");
                }
                else if(numWaiting == 0)                                                                                                //Time out
                {
                        if(SAL_struct.setting.common.network_time_out_function)
                        {
                                SAL_struct.setting.common.network_time_out_function();
                        }
                        continue;
                }
                
                for(listener->sockets.setLoopBegin(); listener->sockets.inLoop(); )
                {
                        numRecv=SDLNet_UDP_Recv(listener->sockets.getLoopEntry(), packet);      //Fetch new packet
                        
                        //Message whas receved on other port
                        if(numRecv == 0)
                        {
//                              printf("message goes to other\n");
                                continue;
                        }
                        //Port whas caught in an error
                        if(numRecv == -1)
                        {
                                salError("Network error while retreaving packet");
                        }
                        else
                        {
                                //TODO:Fetch data using network byte order
                                
                                //Get space for incoming data
                                Uint32 *data = (Uint32 *)malloc(sizeof(char) * packet->len);
                                //Translate incomming message to correct Endian and store into memory
                                Uint32 *tData = (Uint32 *)packet->data;                                                 //32 bits is faster then 8 bits:)
                                for(Uint16 i = 0; i < packet->len/4; i++)
                                {
                                        data[i] = tData[i];                                                                                     //Copy data
                                }
                                
#ifdef SAL_DEBUG
                                char * cData = (char *) data;                                                                   //To be able to read the data as chars
                                for(Uint16 i = 0; i < packet->len; i++)
                                {
                                        printf("%c",(char) cData[i]);
                                }
                                
                                printf("\n");
#endif
                                //TODO: run  event handler
                        }
                }
        }
        SDLNet_FreePacket(packet);
        return 0;
}

int salSetNetworkHandler(int (*network_handler)(char *message, IPaddress *address))
{
        SAL_struct.internal.event.network_handler.handler = network_handler;
        return 0;
}