datastore_api.c		datastore_api.c
	skipping to change at line 1191		skipping to change at line 1191
	{		{
	GNUNET_break (ntohs (msg->size) == sizeof (struct GNUNET_MessageHeader) );		GNUNET_break (ntohs (msg->size) == sizeof (struct GNUNET_MessageHeader) );
	qe = h->queue_head;		qe = h->queue_head;
	rc = qe->qc.rc;		rc = qe->qc.rc;
	GNUNET_assert (GNUNET_YES == qe->was_transmitted);		GNUNET_assert (GNUNET_YES == qe->was_transmitted);
	free_queue_entry (qe);		free_queue_entry (qe);
	#if DEBUG_DATASTORE		#if DEBUG_DATASTORE
	LOG (GNUNET_ERROR_TYPE_DEBUG,		LOG (GNUNET_ERROR_TYPE_DEBUG,
	"Received end of result set, new queue size is %u\n", h->queue_siz e);		"Received end of result set, new queue size is %u\n", h->queue_siz e);
	#endif		#endif
	if (rc.proc != NULL)
	rc.proc (rc.proc_cls, NULL, 0, NULL, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_A
	BS,
	0);
	h->retry_time.rel_value = 0;		h->retry_time.rel_value = 0;
	h->result_count = 0;		h->result_count = 0;
	process_queue (h);		process_queue (h);
			if (rc.proc != NULL)
			rc.proc (rc.proc_cls, NULL, 0, NULL, 0, 0, 0, GNUNET_TIME_UNIT_ZERO_A
			BS,
			0);
	return;		return;
	}		}
	qe = h->queue_head;		qe = h->queue_head;
	GNUNET_assert (NULL != qe);		GNUNET_assert (NULL != qe);
	rc = qe->qc.rc;		rc = qe->qc.rc;
	if (GNUNET_YES != qe->was_transmitted)		if (GNUNET_YES != qe->was_transmitted)
	{		{
	GNUNET_break (0);		GNUNET_break (0);
	free_queue_entry (qe);		free_queue_entry (qe);
	h->retry_time = GNUNET_TIME_UNIT_ZERO;		h->retry_time = GNUNET_TIME_UNIT_ZERO;
End of changes. 2 change blocks.
	4 lines changed or deleted		4 lines changed or added
This html diff was produced by rfcdiff 1.41. The latest version is available from http://tools.ietf.org/tools/rfcdiff/