[Top][All Lists]
[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) {
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r1722 - GNUnet/src/server,
grothoff <=