ret += pos->size;
size -= pos->size;
*priority += pos->priority;
+#if DEBUG_CORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Adding plaintext message with deadline %llu ms to batch\n",
+ GNUNET_TIME_absolute_get_remaining (pos->deadline).value);
+#endif
deadline->value = GNUNET_MIN (deadline->value, pos->deadline.value);
GNUNET_free (pos);
if (prev == NULL)
}
pos = next;
}
+#if DEBUG_CORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Deadline for message batch is %llu ms\n",
+ GNUNET_TIME_absolute_get_remaining (*deadline).value);
+#endif
return ret;
}
&retry_plaintext_processing, n);
return;
}
-
ph->sequence_number = htonl (++n->last_sequence_number_sent);
ph->inbound_bpm_limit = htonl (n->bpm_in);
ph->timestamp = GNUNET_TIME_absolute_hton (GNUNET_TIME_absolute_get ());
/* encrypt */
#if DEBUG_CORE
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Encrypting %u bytes of plaintext messages for `%4s' for transmission.\n",
+ "Encrypting %u bytes of plaintext messages for `%4s' for transmission in %llums.\n",
esize,
- GNUNET_i2s(&n->peer));
+ GNUNET_i2s(&n->peer),
+ (unsigned long long) GNUNET_TIME_absolute_get_remaining (deadline).value);
#endif
GNUNET_assert (GNUNET_OK ==
do_encrypt (n,
GNUNET_break (0);
break;
}
+#if DEBUG_CORE
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Have %llu ms left for `%s' transmission.\n",
+ (unsigned long long) GNUNET_TIME_absolute_get_remaining (me->deadline).value,
+ "SET_KEY");
+#endif
/* trigger queue processing */
process_encrypted_neighbour_queue (n);
if (n->status != PEER_STATE_KEY_CONFIRMED)
[PATHS]
-SERVICEHOME = /tmp/test-gnunetd-core-peer-1/
+SERVICEHOME = /tmp/test-gnunet-core-peer-1/
DEFAULTCONFIG = test_core_api_peer1.conf
[resolver]
[transport-tcp]
PORT = 12468
+#DEBUG = YES
[peerinfo]
PORT = 12469
#PREFIX = xterm -T peerinfo1 -e valgrind --tool=memcheck
#PREFIX = xterm -T peerinfo1 -e
+#DEBUG = YES
[core]
PORT = 12470
[PATHS]
-SERVICEHOME = /tmp/test-gnunetd-core-peer-2/
+SERVICEHOME = /tmp/test-gnunet-core-peer-2/
DEFAULTCONFIG = test_core_api_peer2.conf
[resolver]
[transport-tcp]
PORT = 22468
+#DEBUG = YES
[peerinfo]
PORT = 22469
#PREFIX = xterm -T peerinfo2 -e valgrind --tool=memcheck
#PREFIX = xterm -T peerinfo2 -e
+#DEBUG = YES
[core]
PORT = 22470