Changeset 7540 in orxonox.OLD for branches/network/src/lib/network/network_socket.h

Timestamp:

May 5, 2006, 3:16:09 PM (18 years ago)

Author:

rennerc

Message:

implemented udp sockets

File:

• branches/network/src/lib/network/network_socket.h (modified) (2 diffs)

branches/network/src/lib/network/network_socket.h

@@ -8 +8 @@
 #define _NETWORK_SOCKET
 
-//TODO HACK else gdb will not work on server
-#define DONTEXITTHREADS
-
-//if you want to use outgoing buffer define _USE_OUTGOING_BUFFER
-#define _USE_OUTGOING_BUFFER
-
-#define _INCOMING_BUFFER_SIZE 2024000
-#define _OUTGOING_BUFFER_SIZE 2024000
-#define _LOCAL_BUFFER_SIZE 1024
-//sleep if incoming buffer is full
-#define _MSECONDS_SLEEP_FULL_BUFFER 10
-//sleep if outgoing buffer is empty
-#define _MSECONDS_SLEEP_EMPTY_BUFFER 10
-
-
-/* contains memmove and memcpy */
-#include <string.h>
-
-#ifdef HAVE_SDL_H
- #include <SDL_thread.h>
-#else
- #include <SDL/SDL_thread.h>
-#endif
 /* include this file, it contains some default definitions */
 #include "netdefs.h"
@@ -38 +15 @@
 #include "base_object.h"
 
-/* using namespace std is default, this needs to be here */
-using namespace std;
-
 class NetworkSocket : public BaseObject
 {
+  public:
+    NetworkSocket();
+    virtual ~NetworkSocket();
 
-private:
-//  IPaddress serverAddress;
-//  unsigned int port;
-  TCPsocket tcpSocket;
-//  UDPsocket udpSocket;
+    /**
+     * connect to server on host with port port
+     * @param host hostname might be xxx.xxx.xxx.xxx or localhost ...
+     * @param port port to connect to
+     */
+    virtual void connectToServer( std::string host, int port ) = 0;
+    
+    /**
+     * disconnect from server
+     */
+    virtual void disconnectServer() = 0;
 
-  byte incomingBuffer[_INCOMING_BUFFER_SIZE];
-#ifdef _USE_OUTGOING_BUFFER
-  byte outgoingBuffer[_OUTGOING_BUFFER_SIZE];
-#endif
-  int incomingBufferLength;
-#ifdef _USE_OUTGOING_BUFFER
-  int outgoingBufferLength;
-#endif
+    /**
+     * send packet to connected socket. will be recieved as whole packet
+     * @param data pointer to data to send
+     * @param length lengt of packet to send
+     * @return true on success
+     */
+    virtual bool writePacket(byte * data, int length) = 0;
+    
+    /**
+     * read a packet sent by another NetworkSocket
+     * @param data data will be copied here
+     * @param maxLength readPacket will not read more than maxLength
+     * @return bytes read. on error less than zero
+     */
+    virtual int readPacket(byte * data, int maxLength) = 0;
 
-  SDL_mutex * incomingBufferMutex;
-#ifdef _USE_OUTGOING_BUFFER
-  SDL_mutex * outgoingBufferMutex;
-#endif
-  SDL_mutex * socketMutex;
-  bool terminateThread;
-
-  SDL_mutex* threadTerminationMutex;
-  static int thread_read(void * data);
-  bool thread_read_running;
-  bool thread_write_running;
-
-  SDL_Thread*            readThread;
-  SDL_Thread*            writeThread;
-
-#ifdef _USE_OUTGOING_BUFFER
-  static int thread_write(void * data);
-#endif
-
-  int writeBytes(byte * data, int length);
-  int readBytes(byte * data, int length);
-  int readBlock(byte * data, int length);
-
-  void init();
-
-public:
-
-  NetworkSocket();
-  virtual ~NetworkSocket();
-  NetworkSocket(IPaddress ip);
-  NetworkSocket(TCPsocket sock);
-  void destroy() { terminateThread = true; };
-
-
-  void connectToServer(IPaddress ip);
-  void disconnectServer();
-
-  bool writePacket(byte * data, int length);
-  int readPacket(byte * data, int maxLength);
-
-  inline bool isOk() { return tcpSocket!=NULL; }
+    /**
+     * check if socket is ok
+     * @return true if socket is ok
+     */
+    inline bool isOk() { return this->bOk; }
+  
+  protected:
+    bool bOk;            //!< check for socket status
 
 };