debugging logs for ai network stuff

panda/src/nativenet/buffered_datagramconnection.h

@@ -115,6 +115,7 @@ private:
 // Argument         : void
 ////////////////////////////////////////////////////////////////////
 inline void Buffered_DatagramConnection::ClearAll(void) {
+  printf("Buffered_DatagramConnection::ClearAll Starting Auto Reset\n");
   Close();
   _Writer.ReSet();
   _Reader.ReSet();
@@ -126,8 +127,9 @@ inline bool Buffered_DatagramConnection::DoConnect(void) {
     
   if(ActiveOpen(_Adddress) == true) {
     SetNonBlocking(); // maybe should be blocking?
-    SetSendBufferSize(1024*50);  // we need to hand tune these for the os we are using
-    SetRecvBufferSize(1024*50);
+    //Let the operators do this
+    //SetSendBufferSize(1024*50);  // we need to hand tune these for the os we are using
+    //SetRecvBufferSize(1024*50);
     NewWriteBuffer();
     return true;
   }
@@ -208,7 +210,7 @@ inline Buffered_DatagramConnection::~Buffered_DatagramConnection(void)
 inline Buffered_DatagramConnection::Buffered_DatagramConnection(bool do_blocking_writes, int rbufsize, int wbufsize, int write_flush_point) 
 	:  _Writer(do_blocking_writes,wbufsize,write_flush_point) , _Reader(rbufsize) 
 {
-
+  printf("Buffered_DatagramConnection Constructor rbufsize = %d wbufsize = %d write_flush_point = %d\n",rbufsize, wbufsize, write_flush_point);
 }
 ////////////////////////////////////////////////////////////////////
 // Function name	:  Buffered_DatagramConnection::SendMessage
@@ -226,8 +228,7 @@ inline bool  Buffered_DatagramConnection::SendMessage(const Datagram &msg)
         
 	if(val >= 0)
 	  return true;
-
-//		LOGWARNING("Buffered_DatagramConnection::SendMessage->Error On Write--Out Buffer = %d",_Writer.AmountBuffered());
+	printf("Buffered_DatagramConnection::SendMessage->Error On Write--Out Buffer = %d\n",_Writer.AmountBuffered());
         ClearAll();
       }
       return false;
@@ -239,7 +240,7 @@ inline bool  Buffered_DatagramConnection::SendMessageBufferOnly(Datagram &msg)
 	if(val >= 0)
 	    return true;
 
-//	LOGWARNING("Buffered_DatagramConnection::SendMessageBufferOnly->Error On Write--Out Buffer = %d",_Writer.AmountBuffered());
+	printf("Buffered_DatagramConnection::SendMessageBufferOnly->Error On Write--Out Buffer = %d\n",_Writer.AmountBuffered());
 	ClearAll();
     return false;
 }
@@ -277,7 +278,7 @@ inline bool Buffered_DatagramConnection::GetMessage(Datagram  &val)
     if(ans1 == 0)
       return false;
     if(ans1 <0) {
-        //    		LOGWARNING("Buffered_DatagramConnection::GetMessage->Error On PumpMessageReader--Out Buffer = %d",_Writer.AmountBuffered());
+      printf("Buffered_DatagramConnection::GetMessage->Error On PumpMessageReader--Out Buffer = %d\n",_Writer.AmountBuffered());
       ClearAll();
       return false;
     }
@@ -300,8 +301,8 @@ bool Buffered_DatagramConnection::Flush(void)
         int flush_resp = _Writer.FlushNoBlock(*this);
 		if(flush_resp < 0)
 		{
-//			LOGWARNING("Buffered_DatagramConnection::Flush->Error On Flush [%d]",GetLastError());
-  //		    LOGWARNING("Buffered_DatagramConnection::Flush->Error ..Write--Out Buffer = %d",_Writer.AmountBuffered());
+                        printf("Buffered_DatagramConnection::Flush->Error On Flush [%d]\n",GetLastError());
+		        printf("Buffered_DatagramConnection::Flush->Error ..Write--Out Buffer = %d\n",_Writer.AmountBuffered());
 			ClearAll();  
 			return false;
 		}
@@ -318,6 +319,7 @@ bool Buffered_DatagramConnection::Flush(void)
 ////////////////////////////////////////////////////////////////////
 inline void Buffered_DatagramConnection::Reset()
 {
+    printf("Buffered_DatagramConnection::Reset()\n");
     ClearAll();
 };
 

panda/src/nativenet/buffered_datagramreader.h

@@ -22,7 +22,7 @@ public:
     // see socket_tcp and socket_ssl
 
     template < class SOCK_TYPE>
-        inline int PumpMessageReader(Datagram &inmsg, SOCK_TYPE &sck)
+    inline int PumpMessageReader(Datagram &inmsg, SOCK_TYPE &sck)
     {
         if(GetMessageFromBuffer(inmsg) == true)
             return 1;
@@ -39,7 +39,7 @@ public:
 
 
     template < class SOCK_TYPE>
-        inline int ReadPump(SOCK_TYPE &sck)
+    inline int ReadPump(SOCK_TYPE &sck)
     {		
         int		answer = 0;
         size_t		readsize = BufferAvailabe();
@@ -60,6 +60,7 @@ public:
                 if(!sck.ErrorIs_WouldBlocking(gotbytes) )
                 {
                     answer = -3;  // hard error ?
+                    printf("buffered_datagram_reader:ReadPump socket read error -- %d, %s\n", GETERROR(),  sck.getPeerName().get_ip_port().c_str());
                 }
                 else
                 {
@@ -75,11 +76,14 @@ public:
             else   // 0 mean other end disconect arggggg
             {
                 answer = -1;
+                printf("buffered_datagram_reader:ReadPump other end of socket closed -- %s\n",  sck.getPeerName().get_ip_port().c_str());
             }
         }		
         else
         {
             answer = -2;
+            printf("buffered_datagram_reader:ReadPump Yeep! buffer has no room to read to -- %s\nBufferAvaiable = %d, AmountBuffered = %d, BufferSize = %d\n", sck.getPeerName().get_ip_port().c_str(), readsize, AmountBuffered(), GetBufferSize());
+            
         }
         return answer;
     }

panda/src/nativenet/ringbuffer.h

@@ -31,7 +31,7 @@ inline bool PutFast(const char * data, size_t len);
 
 public:
 	inline size_t		AmountBuffered(void);
-	inline size_t      BufferAvailabe(void);
+        inline size_t           BufferAvailabe(void);
 	inline void		ResetContent(void);
 
 	inline RingBuffer(size_t in_size = 4096);