uint64_t flags)
{
member_replay_request (mem, fragment_id, 0, 0, flags);
- // FIXME: return
+ // FIXME: return something useful
+ return NULL;
}
uint64_t flags)
{
member_replay_request (mem, 0, message_id, fragment_offset, flags);
- // FIXME: return
+ // FIXME: return something useful
+ return NULL;
}
case GNUNET_NO:
GNUNET_MULTICAST_replay_response (rh, NULL,
GNUNET_MULTICAST_REC_NOT_FOUND);
- break;
+ return;
case GNUNET_PSYCSTORE_MEMBERSHIP_TEST_FAILED:
GNUNET_MULTICAST_replay_response (rh, NULL,
GNUNET_MULTICAST_REC_ACCESS_DENIED);
- break;
+ return;
case GNUNET_SYSERR:
GNUNET_MULTICAST_replay_response (rh, NULL,
GNUNET_MULTICAST_REC_INTERNAL_ERROR);
return;
}
+ /* GNUNET_MULTICAST_replay_response frees 'rh' when passed
+ * an error code, so it must be ensured no further processing
+ * is attempted on 'rh'. Maybe this should be refactored as
+ * it doesn't look very intuitive. --lynX
+ */
GNUNET_MULTICAST_replay_response_end (rh);
}
uint16_t size = ntohs (msg->size);
if (GNUNET_MULTICAST_FRAGMENT_MAX_PAYLOAD < size - sizeof (*msg))
{
+ /* Coverity says this printf has incompatible args
+ * but I don't see anything wrong with it.. FIXME
+ */
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%p Message payload too large: %u < %u.\n",
chn,
const void *err_msg, uint16_t err_msg_size)
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "slave_state_get_prefix:\t%" PRId64 " (%.s)\n",
+ "slave_state_get_prefix:\t%" PRId64 " (%.*s)\n",
result,
(int) err_msg_size,
(const char *) err_msg);
const void *err_msg, uint16_t err_msg_size)
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "master_state_get_prefix:\t%" PRId64 " (%s)\n", result, err_msg);
+ "master_state_get_prefix:\t%" PRId64 " (%s)\n", result, (char *) err_msg);
// FIXME: GNUNET_assert (2 == result);
slave_state_get_prefix ();
}
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"slave_state_get:\t%" PRId64 " (%.*s)\n",
- result, err_msg_size, err_msg);
+ result, err_msg_size, (char *) err_msg);
// FIXME: GNUNET_assert (2 == result);
master_state_get_prefix ();
}
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"master_state_get:\t%" PRId64 " (%.*s)\n",
- result, err_msg_size, err_msg);
+ result, err_msg_size, (char *) err_msg);
// FIXME: GNUNET_assert (1 == result);
slave_state_get ();
}
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"master_history_replay_latest:\t%" PRId64 " (%.*s)\n",
- result, err_msg_size, err_msg);
+ result, err_msg_size, (char *) err_msg);
GNUNET_assert (9 == result);
slave_history_replay_latest ();
{
struct TransmitClosure *tmit = cls;
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Test #%d: Transmit notify modifier: %lu bytes available, "
+ "Test #%d: Transmit notify modifier: %u bytes available, "
"%u modifiers left to process.\n",
test, *data_size, GNUNET_PSYC_env_get_count (tmit->env));
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"slave_remove:\t%" PRId64 " (%.*s)\n",
- result, err_msg_size, err_msg);
+ result, err_msg_size, (char *) err_msg);
slave_transmit ();
}
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"slave_add:\t%" PRId64 " (%.*s)\n",
- result, err_msg_size, err_msg);
+ result, err_msg_size, (char *) err_msg);
slave_remove ();
}
slave_join (int t)
{
test = t;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Test #%d: Joining slave.\n");
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Test #%d: Joining slave.\n", t);
struct GNUNET_PeerIdentity origin = this_peer;
struct GNUNET_PSYC_Environment *env = GNUNET_PSYC_env_create ();
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
" variable %s differs\nReceived: %.*s\nExpected: %.*s\n",
- name, value_size, value, val_size, val);
+ name, value_size, (char*) value, val_size, (char*) val);
GNUNET_assert (0);
return GNUNET_SYSERR;
}
{
struct StateClosure *scls = cls;
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_get_prefix_result:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_get_prefix_result:\t%ld\n", (long int) result);
GNUNET_assert (GNUNET_OK == result && 2 == scls->n);
op = GNUNET_PSYCSTORE_state_reset (h, &channel_pub_key,
const char *err_msg, uint16_t err_msg_size)
{
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_get_result:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_get_result:\t%ld\n", (long int) result);
GNUNET_assert (GNUNET_OK == result);
scls.n = 0;
const char *err_msg, uint16_t err_msg_size)
{
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_modify_result:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_modify_result:\t%ld\n", (long int) result);
GNUNET_assert (GNUNET_OK == result);
op = GNUNET_PSYCSTORE_counters_get (h, &channel_pub_key,
{
struct FragmentClosure *fcls = cls;
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_sync_result:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "state_sync_result:\t%ld\n", (long int) result);
GNUNET_assert (GNUNET_OK == result);
op = GNUNET_PSYCSTORE_state_modify (h, &channel_pub_key,
{
struct FragmentClosure *fcls = cls;
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "message_get_latest:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "message_get_latest:\t%ld\n", (long int) result);
GNUNET_assert (0 < result && fcls->n == fcls->n_expected);
modifiers[0] = (struct GNUNET_PSYC_Modifier) {
{
struct FragmentClosure *fcls = cls;
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "message_get:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "message_get:\t%ld\n", (long int) result);
GNUNET_assert (0 < result && fcls->n == fcls->n_expected);
fcls->n = 0;
{
struct FragmentClosure *fcls = cls;
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "message_get_fragment:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "message_get_fragment:\t%ld\n", (long int) result);
GNUNET_assert (0 < result && fcls->n == fcls->n_expected);
fcls->n = 0;
{
struct FragmentClosure *fcls = cls;
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "fragment_get_latest:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "fragment_get_latest:\t%ld\n", (long int) result);
GNUNET_assert (0 < result && fcls->n == fcls->n_expected);
fcls->n = 1;
const char *err_msg, uint16_t err_msg_size)
{
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "fragment_store:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "fragment_store:\t%ld\n", (long int) result);
GNUNET_assert (GNUNET_OK == result);
if ((intptr_t) cls == GNUNET_YES)
const char *err_msg, uint16_t err_msg_size)
{
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "membership_test:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "membership_test:\t%ld\n", (long int) result);
GNUNET_assert (GNUNET_OK == result);
fragment_store ();
const char *err_msg, uint16_t err_msg_size)
{
op = NULL;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "membership_store:\t%d\n", result);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "membership_store:\t%ld\n", (long int) result);
GNUNET_assert (GNUNET_OK == result);
op = GNUNET_PSYCSTORE_membership_test (h, &channel_pub_key, &slave_pub_key,