---

net.h

Go to the documentation of this file.

// OMICRON ENGINE HEADER FILE
//
// --------------------------------------------------------------------------
// Copyright (C) 2001-2002 by Bjoern Paetzel <kolrabi@gmx.de>
//
// This file is part of the Omicron Engine.
//
// The Omicron Engine is free software; you can redistribute it and/or modify
// it under the terms of the  GNU General Public License  as published by the
// Free Software Foundation;  either version  2  of the License,  or (at your
// option) any later version.
//
// The Omicron Engine  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 General Public License
// for more details.
//
// You should have  received a copy of the  GNU General Public License  along
// with The Omicron Engine;  if not,  write to the  Free Software Foundation,
// Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA 
//
// --------------------------------------------------------------------------
// Last modified:       $Date: 2002/12/07 19:02:17 $
// By           :       $Author: kolrabi $
// $Id: net.h,v 1.1.1.1 2002/12/07 19:02:17 kolrabi Exp $ 

/*

  $Log: net.h,v $
  Revision 1.1.1.1  2002/12/07 19:02:17  kolrabi
  initial release


*/

#include            "forward.h"

#if defined(WIN32) 

//#   include    <winsock2.h>

#   define      socklen_t int

#else

#   include     <netdb.h>
#   include     <sys/types.h>
#   include     <sys/socket.h>
#   include     <netinet/in.h>
#   include     <arpa/inet.h>

// winsock like definitions

#   define      SOCKET          int
#   define      INVALID_SOCKET  -1
#   define      SOCKET_ERROR    -1
#   define      HOSTENT         struct hostent
#   define      SOCKADDR_IN     struct sockaddr_in

    typedef     struct sockaddr SOCKADDR;
    typedef     SOCKADDR*       LPSOCKADDR;

#   define      closesocket(a)  close(a)
#   define      TIMEVAL         struct timeval

#endif

/****************************************************************************
 ****************************************************************************
 * DEFINES ******************************************************************
 ****************************************************************************
 ****************************************************************************/

#define             NETMSG_PING             0x0000
#define             NETMSG_PONG             0x0001
#define             NETMSG_USERDEFINED      0x1000

#define             NETSTAT_CONNECTING      1
#define             NETSTAT_CONNECTED       2
#define             NETSTAT_DISCONNECTED    3

typedef struct net_message_header_s
{
    ushort          type;               
    ulong           len;                
    ulong           time;
    // char[len - sizeof(net_message_header_t)] bytes of data following
} net_message_header_t;

typedef struct net_message_ping_s
{
    net_message_header_t    header;     
} net_message_ping_t;

typedef struct net_message_pong_s
{
    net_message_header_t    header;     
} net_message_pong_t;

class net_client_c
{
protected:

    friend class    net_manager_c;

    ulong           id;                 

    SOCKET          sock;               
    SOCKADDR_IN     laddress;           

    list_c<char>    *queue;             
    ulong           queuelen;           

    ulong           status;             
    ulong           latency;

public:

    net_client_c();
    virtual ~net_client_c();

    void                                
        send_message(net_message_header_t *msg, bool reliable = true);

    void                                
        receive_message();

    ulong
        get_latency() { AssertThisV; return latency; };
};

class net_manager_c
{
protected:

    friend class    net_client_c;

    // server part 

    array_c <net_client_c> *clients;    

    SOCKET          sv_socket;          

    ulong           sv_lastupdate;      
    ulong           sv_gametime;        

    // client part 

    SOCKET          cl_socket;          

    ulong           frametime;          

    ulong           cl_lastupdate;      
    ulong           cl_connecttime;     

    list_c<char>    *cl_queue;
    ulong           cl_queuelen;

#if defined(WIN32) 

    WSADATA         wsadata;            

#endif

    bool            isserver;           
    bool            isclient;           

public:

    net_manager_c();
    ~net_manager_c();

    // server part

    void                                
        set_frametime(ulong t) { AssertThis; frametime = t; };

    void                                
        start_listen(ushort port, bool local);

    void                                
        stop_listen();

    float
        sv_get_framefrac() 
    { 
        AssertThisV;
        return ((float)(_time_get()-sv_lastupdate)/(float)frametime);
    }

    void                                
        broadcast(net_message_header_t *msg);

    void                                
        unicast(ulong clnum, net_message_header_t *msg);

    // client part

    float
        cl_get_framefrac() 
    { 
        AssertThisV;
        return ((float)(_time_get()-cl_lastupdate)/(float)frametime);
    }

    bool
        connect_to_server(char *name, ushort port);

    void
        disconnect_from_server();

    void                                
        cl_sendmessage(net_message_header_t *msg);

    void
        cl_receivemessage(net_message_header_t *msg);

    // common part

    void
        update();
};

---