From 725ed2a06c5e376168dc1552d52cf0b77ed5c073 Mon Sep 17 00:00:00 2001
From: Matthias Schiffer <matthias@gamezock.de>
Date: Wed, 25 Jun 2008 03:16:01 +0200
Subject: Neuer Send-Stack

---
 src/Net/Connection.cpp | 32 ++++++++++++++++++++++++--------
 1 file changed, 24 insertions(+), 8 deletions(-)

(limited to 'src/Net/Connection.cpp')

diff --git a/src/Net/Connection.cpp b/src/Net/Connection.cpp
index 768d827..b0f505b 100644
--- a/src/Net/Connection.cpp
+++ b/src/Net/Connection.cpp
@@ -18,6 +18,7 @@
  */
 
 #include "Connection.h"
+#include <cstring>
 
 namespace Mad {
 namespace Net {
@@ -94,23 +95,38 @@ bool Connection::rawReceive(unsigned long length,
   return true;
 }
 
-bool Connection::rawSend(const unsigned char *data, unsigned long length) {
+void Connection::doSend() {
   if(!isConnected())
-    return false;
+    return;
   
-  while(length > 0) {
-    ssize_t ret = gnutls_record_send(getSession(), data, length);
+  while(!sendQueueEmpty()) {
+    ssize_t ret = gnutls_record_send(getSession(), transS.front().data+transS.front().transmitted, 
+        transS.front().length-transS.front().transmitted);
     
     if(ret < 0) {
       if(ret == GNUTLS_E_INTERRUPTED || ret == GNUTLS_E_AGAIN)
-        continue;
+        return;
       
-      return false;
+      // Error... disconnect?
+      return;
     }
     
-    data += ret;
-    length -= ret;
+    transS.front().transmitted += ret;
+    
+    if(transS.front().transmitted == transS.front().length) {
+      delete [] transS.front().data;
+      transS.pop();
+    }
   }
+}
+
+bool Connection::rawSend(const unsigned char *data, unsigned long length) {
+  if(!isConnected())
+    return false;
+  
+  Transmission trans = {length, 0, new unsigned char[length], sigc::slot<void,const void*,unsigned long>()};
+  std::memcpy(trans.data, data, length);
+  transS.push(trans);
   
   return true;
 }
-- 
cgit v1.2.3