/*
* This file is part of GNUnet
- * Copyright (C) 2013 Christian Grothoff (and other contributing authors)
+ * Copyright (C) 2013 GNUnet e.V.
*
* GNUnet is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published
GNUNET_SOCIAL_AppEgoCallback ego_cb;
GNUNET_SOCIAL_AppHostPlaceCallback host_cb;
GNUNET_SOCIAL_AppGuestPlaceCallback guest_cb;
+ GNUNET_SOCIAL_AppConnectedCallback connected_cb;
void *cb_cls;
-
- /**
- * Is this place in the process of disconnecting from the service?
- * #GNUNET_YES or #GNUNET_NO
- */
- uint8_t is_disconnecting;
};
* Does this place belong to a host (#GNUNET_YES) or guest (#GNUNET_NO)?
*/
uint8_t is_host;
-
- /**
- * Is this place in the process of disconnecting from the service?
- * #GNUNET_YES or #GNUNET_NO
- */
- uint8_t is_disconnecting;
};
static void
host_recv_notice_place_leave_method (void *cls,
+ const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_PSYC_MessageMethod *meth,
uint64_t message_id,
- uint32_t flags,
- const struct GNUNET_CRYPTO_EcdsaPublicKey *nym_pub_key,
const char *method_name)
{
struct GNUNET_SOCIAL_Host *hst = cls;
if (0 == memcmp (&(struct GNUNET_CRYPTO_EcdsaPublicKey) {},
- nym_pub_key, sizeof (*nym_pub_key)))
+ &msg->slave_pub_key, sizeof (msg->slave_pub_key)))
return;
- struct GNUNET_SOCIAL_Nym *nym = nym_get_or_create (nym_pub_key);
+ struct GNUNET_SOCIAL_Nym *nym = nym_get_or_create (&msg->slave_pub_key);
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Host received method for message ID %" PRIu64 " from nym %s: %s\n",
static void
host_recv_notice_place_leave_modifier (void *cls,
- const struct GNUNET_MessageHeader *msg,
+ const struct GNUNET_PSYC_MessageHeader *msg,
+ const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
enum GNUNET_PSYC_Operator oper,
const char *name,
static void
host_recv_notice_place_leave_eom (void *cls,
- const struct GNUNET_MessageHeader *msg,
+ const struct GNUNET_PSYC_MessageHeader *msg,
+ const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
- uint8_t cancelled)
+ uint8_t is_cancelled)
{
struct GNUNET_SOCIAL_Host *hst = cls;
if (NULL == hst->notice_place_leave_env)
"_notice_place_leave: got EOM from nym %s (%s).\n",
GNUNET_h2s (&hst->notice_place_leave_nym->pub_key_hash), str);
- if (GNUNET_YES != cancelled)
+ if (GNUNET_YES != is_cancelled)
{
if (NULL != hst->farewell_cb)
hst->farewell_cb (hst->cb_cls, hst->notice_place_leave_nym,
struct GNUNET_SOCIAL_Nym *nym = nym_get_or_create (&req->slave_pub_key);
hst->answer_door_cb (hst->cb_cls, nym, method_name, env,
- data_size, data);
+ data, data_size);
} while (0);
if (NULL != env)
cres = (struct GNUNET_PSYC_CountersResultMessage *) msg;
int32_t result = ntohl (cres->result_code);
if (NULL != gst->enter_cb)
- gst->enter_cb (gst->cb_cls, result, GNUNET_ntohll (cres->max_message_id));
+ gst->enter_cb (gst->cb_cls, result, &gst->plc.pub_key,
+ GNUNET_ntohll (cres->max_message_id));
}
}
+static void
+app_recv_ego_end (void *cls,
+ struct GNUNET_CLIENT_MANAGER_Connection *client,
+ const struct GNUNET_MessageHeader *msg)
+{
+ struct GNUNET_SOCIAL_App *
+ app = GNUNET_CLIENT_MANAGER_get_user_context_ (client, sizeof (*app));
+}
+
+
static void
app_recv_place (void *cls,
struct GNUNET_CLIENT_MANAGER_Connection *client,
struct GNUNET_SOCIAL_HostConnection *hconn = GNUNET_malloc (sizeof (*hconn));
hconn->app = app;
hconn->plc_msg = *pmsg;
- app->host_cb (app->cb_cls, hconn, ego, &pmsg->place_pub_key, pmsg->place_state);
+ if (NULL != app->host_cb)
+ app->host_cb (app->cb_cls, hconn, ego, &pmsg->place_pub_key, pmsg->place_state);
}
else
{
struct GNUNET_SOCIAL_GuestConnection *gconn = GNUNET_malloc (sizeof (*gconn));
gconn->app = app;
gconn->plc_msg = *pmsg;
- app->guest_cb (app->cb_cls, gconn, ego, &pmsg->place_pub_key, pmsg->place_state);
+ if (NULL != app->guest_cb)
+ app->guest_cb (app->cb_cls, gconn, ego, &pmsg->place_pub_key, pmsg->place_state);
}
}
+static void
+app_recv_place_end (void *cls,
+ struct GNUNET_CLIENT_MANAGER_Connection *client,
+ const struct GNUNET_MessageHeader *msg)
+{
+ struct GNUNET_SOCIAL_App *
+ app = GNUNET_CLIENT_MANAGER_get_user_context_ (client, sizeof (*app));
+
+ if (NULL != app->connected_cb)
+ app->connected_cb (app->cb_cls);
+}
+
+
static struct GNUNET_CLIENT_MANAGER_MessageHandler host_handlers[] =
{
{ host_recv_enter_ack, NULL,
};
-
static struct GNUNET_CLIENT_MANAGER_MessageHandler app_handlers[] =
{
{ app_recv_ego, NULL,
GNUNET_MESSAGE_TYPE_SOCIAL_APP_EGO,
sizeof (struct AppEgoMessage), GNUNET_YES },
+ { app_recv_ego_end, NULL,
+ GNUNET_MESSAGE_TYPE_SOCIAL_APP_EGO_END,
+ sizeof (struct GNUNET_MessageHeader), GNUNET_NO },
+
{ app_recv_place, NULL,
GNUNET_MESSAGE_TYPE_SOCIAL_APP_PLACE,
sizeof (struct AppPlaceMessage), GNUNET_NO },
+ { app_recv_place_end, NULL,
+ GNUNET_MESSAGE_TYPE_SOCIAL_APP_PLACE_END,
+ sizeof (struct GNUNET_MessageHeader), GNUNET_NO },
+
{ app_recv_result, NULL,
GNUNET_MESSAGE_TYPE_PSYC_RESULT_CODE,
sizeof (struct GNUNET_OperationResultMessage), GNUNET_YES },
static void
place_cleanup (struct GNUNET_SOCIAL_Place *plc)
{
+ struct GNUNET_HashCode place_pub_hash;
+ GNUNET_CRYPTO_hash (&plc->pub_key, sizeof (plc->pub_key), &place_pub_hash);
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "%s place cleanup: %s\n",
+ GNUNET_YES == plc->is_host ? "host" : "guest",
+ GNUNET_h2s (&place_pub_hash));
+
if (NULL != plc->tmit)
GNUNET_PSYC_transmit_destroy (plc->tmit);
if (NULL != plc->connect_msg)
plc->tmit = GNUNET_PSYC_transmit_create (plc->client);
hst->slicer = GNUNET_PSYC_slicer_create ();
- GNUNET_PSYC_slicer_method_add (hst->slicer, "_notice_place_leave",
+ GNUNET_PSYC_slicer_method_add (hst->slicer, "_notice_place_leave", NULL,
host_recv_notice_place_leave_method,
host_recv_notice_place_leave_modifier,
NULL, host_recv_notice_place_leave_eom, hst);
plc->tmit = GNUNET_PSYC_transmit_create (plc->client);
hst->slicer = GNUNET_PSYC_slicer_create ();
- GNUNET_PSYC_slicer_method_add (hst->slicer, "_notice_place_leave",
+ GNUNET_PSYC_slicer_method_add (hst->slicer, "_notice_place_leave", NULL,
host_recv_notice_place_leave_method,
host_recv_notice_place_leave_modifier,
NULL, host_recv_notice_place_leave_eom, hst);
}
-
void
place_leave (struct GNUNET_SOCIAL_Place *plc)
{
GNUNET_ContinuationCallback disconnect_cb,
void *disconnect_cls)
{
- plc->is_disconnecting = GNUNET_YES;
plc->disconnect_cb = disconnect_cb;
plc->disconnect_cls = disconnect_cls;
/**
* Stop hosting the home.
*
- * Sends a _notice_place_closed announcement to the home.
+ * Sends a _notice_place_closing announcement to the home.
* Invalidates host handle.
*
* @param hst
GNUNET_ContinuationCallback disconnect_cb,
void *cls)
{
- GNUNET_SOCIAL_host_announce (hst, "_notice_place_closed", env, NULL, NULL,
+ GNUNET_SOCIAL_host_announce (hst, "_notice_place_closing", env, NULL, NULL,
GNUNET_SOCIAL_ANNOUNCE_NONE);
place_leave (&hst->plc);
GNUNET_SOCIAL_host_disconnect (hst, disconnect_cb, cls);
plc->ego_pub_key = ego->pub_key;
plc->pub_key = *place_pub_key;
plc->cfg = app->cfg;
- plc->is_host = GNUNET_YES;
+ plc->is_host = GNUNET_NO;
plc->slicer = slicer;
gst->enter_cb = local_enter_cb;
* @return Public key of the place.
*/
const struct GNUNET_CRYPTO_EddsaPublicKey *
-GNUNET_SOCIAL_place_get_key (struct GNUNET_SOCIAL_Place *plc)
+GNUNET_SOCIAL_place_get_pub_key (const struct GNUNET_SOCIAL_Place *plc)
{
return &plc->pub_key;
}
op_recv_zone_add_place_result,
add_plc));
GNUNET_CLIENT_MANAGER_transmit_now (app->client, &preq->header);
- GNUNET_free (preq);
return GNUNET_OK;
}
GNUNET_SOCIAL_AppEgoCallback ego_cb,
GNUNET_SOCIAL_AppHostPlaceCallback host_cb,
GNUNET_SOCIAL_AppGuestPlaceCallback guest_cb,
+ GNUNET_SOCIAL_AppConnectedCallback connected_cb,
void *cls)
{
uint16_t app_id_size = strnlen (id, GNUNET_SOCIAL_APP_MAX_ID_SIZE);
app->ego_cb = ego_cb;
app->host_cb = host_cb;
app->guest_cb = guest_cb;
+ app->connected_cb = connected_cb;
app->cb_cls = cls;
app->egos = GNUNET_CONTAINER_multihashmap_create (1, GNUNET_NO);
app->client = GNUNET_CLIENT_MANAGER_connect (cfg, "social",
projects / oweals / gnunet.git / blobdiff