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

Timestamp:

Nov 18, 2005, 2:21:30 PM (18 years ago)

Author:

rennerc

Message:

network_socket: uses now a thread to send

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
 
+//if you want to use outgoing buffer define _USE_OUTGOING_BUFFER
+#define _USE_OUTGOING_BUFFER
+
 #define _INCOMING_BUFFER_SIZE 10240
+#define _OUTGOING_BUFFER_SIZE 302400
 #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 */
@@ -36 +43 @@
 //  UDPsocket udpSocket;
 
-  byte buf[_INCOMING_BUFFER_SIZE];
-  int bufferlength;
+  byte incomingBuffer[_INCOMING_BUFFER_SIZE];
+#ifdef _USE_OUTGOING_BUFFER
+  byte outgoingBuffer[_OUTGOING_BUFFER_SIZE];
+#endif
+  int incomingBufferLength;
+#ifdef _USE_OUTGOING_BUFFER
+  int outgoingBufferLength;
+#endif
 
-  SDL_mutex * mutex;
-  SDL_mutex * socketmutex;
+  SDL_mutex * incomingBufferMutex;
+#ifdef _USE_OUTGOING_BUFFER
+  SDL_mutex * outgoingBufferMutex;
+#endif
+  SDL_mutex * socketMutex;
   bool terminateThread;
 
   static int thread_listen(void * data);
   static int thread_read(void * data);
+#ifdef _USE_OUTGOING_BUFFER
+  static int thread_write(void * data);
+#endif
+
+  bool _isListening;
 
 public: