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)
struct GNUNET_MQ_Envelope *env = GNUNET_MQ_get_last_envelope (plc->mq);
if (NULL != env)
{
- GNUNET_MQ_notify_sent (env, (GNUNET_MQ_NotifyCallback) place_cleanup, plc);
+ GNUNET_MQ_notify_sent (env, (GNUNET_SCHEDULER_TaskCallback) place_cleanup, plc);
}
else
{
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);
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);
struct GNUNET_MQ_Envelope *env = GNUNET_MQ_get_last_envelope (app->mq);
if (NULL != env)
{
- GNUNET_MQ_notify_sent (env, (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);
}