gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r1722 - GNUnet/src/server


From: grothoff
Subject: [GNUnet-SVN] r1722 - GNUnet/src/server
Date: Wed, 17 Aug 2005 19:44:26 -0700 (PDT)

Author: grothoff
Date: 2005-08-17 19:44:25 -0700 (Wed, 17 Aug 2005)
New Revision: 1722

Modified:
   GNUnet/src/server/connection.c
Log:
fix

Modified: GNUnet/src/server/connection.c
===================================================================
--- GNUnet/src/server/connection.c      2005-08-18 02:24:34 UTC (rev 1721)
+++ GNUnet/src/server/connection.c      2005-08-18 02:44:25 UTC (rev 1722)
@@ -894,7 +894,7 @@
       i++;
     }
     if ( (i == 0) &&
-        (be->sendBuffer[i]->len <= be->available_send_window) )
+        (be->sendBuffer[i]->len > be->available_send_window) )
       return 0; /* always wait for the highest-priority
                 message (otherwise large messages may
                 starve! */
@@ -1098,7 +1098,6 @@
   SendEntry * entry;
 
   ret = 0;
-
   for (i=0;i<be->sendBufferSize;i++) {
     entry = be->sendBuffer[i];
 
@@ -1121,6 +1120,22 @@
       } else {
        ret++;
       }
+#if 1
+      {
+       P2P_MESSAGE_HEADER * hdr;
+       EncName enc;
+
+       hdr = (P2P_MESSAGE_HEADER*) entry->closure;
+       IFLOG(LOG_DEBUG,
+             hash2enc(&be->session.sender.hashPubKey,
+                      &enc));
+       LOG(LOG_DEBUG,
+           "Core selected message of type %u and size %u for sending to peer 
'%s'.\n",
+           ntohs(hdr->type),
+           ntohs(hdr->size),
+           &enc);
+      }
+#endif
     }
   }
   return ret;
@@ -1295,8 +1310,7 @@
       be->available_send_window,
       be->session.mtu);
 #endif
-
-  
+ 
   totalMessageSize = selectMessagesToSend(be,
                                          &priority);
   if (totalMessageSize == 0) {





reply via email to

[Prev in Thread] Current Thread [Next in Thread]