const struct GNUNET_OperationResultMessage *res)
{
const struct GNUNET_MessageHeader *mod = GNUNET_MQ_extract_nested_mh (res);
- uint16_t mod_size = ntohs (mod->size);
- uint16_t size = ntohs (res->header.size);
+ if (NULL == mod)
+ {
+ GNUNET_break_op (0);
+ LOG (GNUNET_ERROR_TYPE_WARNING,
+ "Invalid modifier in state result\n");
+ return GNUNET_SYSERR;
+ }
- if (NULL == mod || size - sizeof (*res) != mod_size)
+ uint16_t size = ntohs (res->header.size);
+ uint16_t mod_size = ntohs (mod->size);
+ if (size - sizeof (*res) != mod_size)
{
GNUNET_break_op (0);
LOG (GNUNET_ERROR_TYPE_WARNING,
const char *name = (const char *) &pmod[1];
uint16_t name_size = ntohs (pmod->name_size);
- if ('\0' != name[name_size - 1])
+ if (0 == name_size
+ || mod_size - sizeof (*pmod) < name_size
+ || '\0' != name[name_size - 1])
{
GNUNET_break_op (0);
LOG (GNUNET_ERROR_TYPE_WARNING,
struct GNUNET_SOCIAL_Guest *gst = cls;
struct GNUNET_PSYC_Message *pmsg = NULL;
- if (ntohs (dcsn->header.size) <= sizeof (*dcsn) + sizeof (*pmsg))
+ if (ntohs (dcsn->header.size) > sizeof (*dcsn))
pmsg = (struct GNUNET_PSYC_Message *) GNUNET_MQ_extract_nested_mh (dcsn);
if (NULL != gst->entry_dcsn_cb)
if (NULL != plc->mq)
{
- struct GNUNET_MQ_Envelope *last = GNUNET_MQ_get_last_envelope (plc->mq);
- if (NULL != last)
+ struct GNUNET_MQ_Envelope *env = GNUNET_MQ_get_last_envelope (plc->mq);
+ if (NULL != env)
{
- GNUNET_MQ_notify_sent (last,
- (GNUNET_MQ_NotifyCallback) place_cleanup, plc);
+ GNUNET_MQ_notify_sent (env, (GNUNET_SCHEDULER_TaskCallback) place_cleanup, plc);
}
else
{
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Host client disconnected (%d), re-connecting\n",
(int) error);
- if (NULL != plc->mq)
- {
- GNUNET_MQ_destroy (plc->mq);
- plc->mq = NULL;
- }
if (NULL != plc->tmit)
{
GNUNET_PSYC_transmit_destroy (plc->tmit);
plc->tmit = NULL;
}
+ if (NULL != plc->mq)
+ {
+ GNUNET_MQ_destroy (plc->mq);
+ plc->mq = NULL;
+ }
plc->reconnect_task = GNUNET_SCHEDULER_add_delayed (plc->reconnect_delay,
host_reconnect,
GNUNET_MQ_handler_end ()
};
- plc->mq = GNUNET_CLIENT_connecT (plc->cfg, "social",
+ plc->mq = GNUNET_CLIENT_connect (plc->cfg, "social",
handlers, host_disconnected, hst);
GNUNET_assert (NULL != plc->mq);
plc->tmit = GNUNET_PSYC_transmit_create (plc->mq);
LOG (GNUNET_ERROR_TYPE_DEBUG,
"Guest client disconnected (%d), re-connecting\n",
(int) error);
- if (NULL != plc->mq)
- {
- GNUNET_MQ_destroy (plc->mq);
- plc->mq = NULL;
- }
if (NULL != plc->tmit)
{
GNUNET_PSYC_transmit_destroy (plc->tmit);
plc->tmit = NULL;
}
+ if (NULL != plc->mq)
+ {
+ GNUNET_MQ_destroy (plc->mq);
+ plc->mq = NULL;
+ }
plc->reconnect_task = GNUNET_SCHEDULER_add_delayed (plc->reconnect_delay,
guest_reconnect,
GNUNET_MQ_handler_end ()
};
- plc->mq = GNUNET_CLIENT_connecT (plc->cfg, "social",
+ plc->mq = GNUNET_CLIENT_connect (plc->cfg, "social",
handlers, guest_disconnected, gst);
GNUNET_assert (NULL != plc->mq);
plc->tmit = GNUNET_PSYC_transmit_create (plc->mq);
GNUNET_MQ_handler_end ()
};
- app->mq = GNUNET_CLIENT_connecT (app->cfg, "social",
+ app->mq = GNUNET_CLIENT_connect (app->cfg, "social",
handlers, app_disconnected, app);
GNUNET_assert (NULL != app->mq);
GNUNET_MQ_send_copy (app->mq, app->connect_env);
if (NULL != app->mq)
{
- struct GNUNET_MQ_Envelope *last = GNUNET_MQ_get_last_envelope (app->mq);
- if (NULL != last)
+ struct GNUNET_MQ_Envelope *env = GNUNET_MQ_get_last_envelope (app->mq);
+ if (NULL != env)
{
- GNUNET_MQ_notify_sent (last,
- (GNUNET_MQ_NotifyCallback) app_cleanup, app);
+ GNUNET_MQ_notify_sent (env, (GNUNET_SCHEDULER_TaskCallback) app_cleanup, app);
}
else
{
struct GNUNET_MQ_Envelope *
env = GNUNET_MQ_msg (dreq, GNUNET_MESSAGE_TYPE_SOCIAL_APP_DETACH);
dreq->place_pub_key = plc->pub_key;
+ dreq->ego_pub_key = plc->ego_pub_key;
GNUNET_MQ_send (app->mq, env);
}