/*
* 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;
};
struct GNUNET_PSYC_TransmitHandle *tmit;
/**
- * Receipt handle.
- */
- struct GNUNET_PSYC_ReceiveHandle *recv;
-
- /**
- * Slicer for processing incoming methods.
+ * Slicer for processing incoming messages.
*/
struct GNUNET_PSYC_Slicer *slicer;
* 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;
};
struct GNUNET_SOCIAL_Place plc;
/**
- * Receipt handle.
- */
- struct GNUNET_PSYC_ReceiveHandle *recv;
-
- /**
- * Slicer for processing incoming methods.
+ * Slicer for processing incoming messages from guests.
*/
struct GNUNET_PSYC_Slicer *slicer;
{
struct GNUNET_SOCIAL_Place plc;
- /**
- * Receipt handle.
- */
- struct GNUNET_PSYC_ReceiveHandle *recv;
-
- /**
- * Slicer for processing incoming methods.
- */
- struct GNUNET_PSYC_Slicer *slicer;
-
GNUNET_SOCIAL_GuestEnterCallback enter_cb;
GNUNET_SOCIAL_EntryDecisionCallback entry_dcsn_cb;
uint64_t op_id;
/**
- * Message handler.
+ * Slicer for processing incoming messages.
*/
- struct GNUNET_PSYC_ReceiveHandle *recv;
+ struct GNUNET_PSYC_Slicer *slicer;
/**
* Function to call when the operation finished.
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,
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Host received modifier for _notice_place_leave message with ID %" PRIu64 ":\n"
"%c%s: %.*s\n",
- message_id, oper, name, value_size, value);
+ message_id, oper, name, value_size, (const char *) value);
/* skip _nym, it's added later in eom() */
if (0 == memcmp (name, "_nym", sizeof ("_nym"))
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_MessageHeader * cmsg = GNUNET_malloc (cmsg_size);
memcpy (cmsg, app->connect_msg, cmsg_size);
GNUNET_CLIENT_MANAGER_transmit_now (app->client, cmsg);
+ GNUNET_free (cmsg);
}
struct GNUNET_MessageHeader * cmsg = GNUNET_malloc (cmsg_size);
memcpy (cmsg, plc->connect_msg, cmsg_size);
GNUNET_CLIENT_MANAGER_transmit_now (plc->client, cmsg);
+ GNUNET_free (cmsg);
}
if (NULL != hist->result_cb)
hist->result_cb (hist->cls, result, err_msg, err_msg_size);
- GNUNET_PSYC_receive_destroy (hist->recv);
GNUNET_free (hist);
}
return;
}
- GNUNET_PSYC_receive_message (hist->recv,
- (const struct GNUNET_PSYC_MessageHeader *) pmsg);
+ GNUNET_PSYC_slicer_message (hist->slicer,
+ (const struct GNUNET_PSYC_MessageHeader *) pmsg);
}
{
struct GNUNET_SOCIAL_Place *
plc = GNUNET_CLIENT_MANAGER_get_user_context_ (client, sizeof (*plc));
- GNUNET_PSYC_receive_message (plc->recv,
+ GNUNET_PSYC_slicer_message (plc->slicer,
(const struct GNUNET_PSYC_MessageHeader *) msg);
}
{
struct GNUNET_SOCIAL_Host *
hst = GNUNET_CLIENT_MANAGER_get_user_context_ (client, sizeof (hst->plc));
- GNUNET_PSYC_receive_message (hst->recv,
- (const struct GNUNET_PSYC_MessageHeader *) msg);
- GNUNET_PSYC_receive_message (hst->plc.recv,
- (const struct GNUNET_PSYC_MessageHeader *) msg);
+ GNUNET_PSYC_slicer_message (hst->slicer,
+ (const struct GNUNET_PSYC_MessageHeader *) msg);
+ GNUNET_PSYC_slicer_message (hst->plc.slicer,
+ (const struct GNUNET_PSYC_MessageHeader *) msg);
}
&data, &data_size))
{
GNUNET_break_op (0);
- str = GNUNET_CRYPTO_ecdsa_public_key_to_string (&req->slave_key);
+ str = GNUNET_CRYPTO_ecdsa_public_key_to_string (&req->slave_pub_key);
LOG (GNUNET_ERROR_TYPE_WARNING,
"Ignoring invalid entry request from nym %s.\n",
str);
}
}
- struct GNUNET_SOCIAL_Nym *nym = nym_get_or_create (&req->slave_key);
+ 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,
ego = GNUNET_CONTAINER_multihashmap_get (app->egos, &ego_pub_hash);
if (NULL == ego)
{
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Failure to obtain ego. Is identity service running?\n");
GNUNET_break (0);
return;
}
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->recv)
- GNUNET_PSYC_receive_destroy (plc->recv);
if (NULL != plc->connect_msg)
GNUNET_free (plc->connect_msg);
if (NULL != plc->disconnect_cb)
{
struct GNUNET_SOCIAL_Host *hst = cls;
place_cleanup (&hst->plc);
- if (NULL != hst->recv)
- {
- GNUNET_PSYC_receive_destroy (hst->recv);
- hst->recv = NULL;
- }
if (NULL != hst->slicer)
{
GNUNET_PSYC_slicer_destroy (hst->slicer);
GNUNET_CLIENT_MANAGER_set_user_context_ (plc->client, hst, sizeof (*plc));
plc->tmit = GNUNET_PSYC_transmit_create (plc->client);
- plc->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, plc->slicer);
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);
- hst->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, hst->slicer);
uint16_t app_id_size = strlen (app->id) + 1;
struct HostEnterRequest *hreq = GNUNET_malloc (sizeof (*hreq) + app_id_size);
GNUNET_CLIENT_MANAGER_set_user_context_ (plc->client, hst, sizeof (*plc));
plc->tmit = GNUNET_PSYC_transmit_create (plc->client);
- plc->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, plc->slicer);
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);
- hst->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, hst->slicer);
hreq->header.size = htons (sizeof (*hreq) + app_id_size);
hreq->header.type = htons (GNUNET_MESSAGE_TYPE_SOCIAL_HOST_ENTER);
dcsn->header.size = htons (sizeof (*dcsn) + entry_resp_size);
dcsn->header.type = htons (GNUNET_MESSAGE_TYPE_PSYC_JOIN_DECISION);
dcsn->is_admitted = htonl (is_admitted);
- dcsn->slave_key = nym->pub_key;
+ dcsn->slave_pub_key = nym->pub_key;
if (0 < entry_resp_size)
memcpy (&dcsn[1], entry_resp, entry_resp_size);
GNUNET_CLIENT_MANAGER_transmit (hst->plc.client, &dcsn->header);
+ GNUNET_free (dcsn);
return GNUNET_OK;
}
}
-
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;
GNUNET_CLIENT_MANAGER_set_user_context_ (plc->client, gst, sizeof (*plc));
plc->tmit = GNUNET_PSYC_transmit_create (plc->client);
- plc->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, plc->slicer);
struct GuestEnterRequest *
greq = guest_enter_request_create (app->id, &ego->pub_key, &plc->pub_key,
GNUNET_CLIENT_MANAGER_set_user_context_ (plc->client, gst, sizeof (*plc));
plc->tmit = GNUNET_PSYC_transmit_create (plc->client);
- plc->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, plc->slicer);
plc->connect_msg = &greq->header;
place_send_connect_msg (plc);
GNUNET_CLIENT_MANAGER_set_user_context_ (plc->client, gst, sizeof (*plc));
plc->tmit = GNUNET_PSYC_transmit_create (plc->client);
- plc->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, plc->slicer);
plc->connect_msg = &greq->header;
place_send_connect_msg (plc);
* @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;
}
+/**
+ * Set message processing @a flags for a @a method_prefix.
+ *
+ * @param plc
+ * Place.
+ * @param method_prefix
+ * Method prefix @a flags apply to.
+ * @param flags
+ * The flags that apply to a matching @a method_prefix.
+ */
+void
+GNUNET_SOCIAL_place_msg_proc_set (struct GNUNET_SOCIAL_Place *plc,
+ const char *method_prefix,
+ enum GNUNET_SOCIAL_MsgProcFlags flags)
+{
+ GNUNET_assert (NULL != method_prefix);
+ struct MsgProcRequest *mpreq;
+ uint16_t method_size = strnlen (method_prefix,
+ GNUNET_SERVER_MAX_MESSAGE_SIZE
+ - sizeof (*mpreq)) + 1;
+ GNUNET_assert ('\0' == method_prefix[method_size - 1]);
+ mpreq = GNUNET_malloc (sizeof (*mpreq) + method_size);
+
+ mpreq->header.type = htons (GNUNET_MESSAGE_TYPE_SOCIAL_MSG_PROC_SET);
+ mpreq->header.size = htons (sizeof (*mpreq) + method_size);
+ mpreq->flags = htonl (flags);
+ memcpy (&mpreq[1], method_prefix, method_size);
+
+ GNUNET_CLIENT_MANAGER_transmit (plc->client, &mpreq->header);
+ GNUNET_free (mpreq);
+}
+
+
+/**
+ * Clear all message processing flags previously set for this place.
+ */
+void
+GNUNET_SOCIAL_place_msg_proc_clear (struct GNUNET_SOCIAL_Place *plc)
+{
+ struct GNUNET_MessageHeader req;
+ req.type = htons (GNUNET_MESSAGE_TYPE_SOCIAL_MSG_PROC_CLEAR);
+ req.size = htons (sizeof (req));
+ GNUNET_CLIENT_MANAGER_transmit (plc->client, &req);
+}
+
+
static struct GNUNET_SOCIAL_HistoryRequest *
place_history_replay (struct GNUNET_SOCIAL_Place *plc,
uint64_t start_message_id,
struct GNUNET_PSYC_HistoryRequestMessage *req;
struct GNUNET_SOCIAL_HistoryRequest *hist = GNUNET_malloc (sizeof (*hist));
hist->plc = plc;
- hist->recv = GNUNET_PSYC_receive_create (NULL, GNUNET_PSYC_slicer_message, slicer);
+ hist->slicer = slicer;
hist->result_cb = result_cb;
hist->cls = cls;
hist->op_id = GNUNET_CLIENT_MANAGER_op_add (plc->client,
memcpy (&req[1], method_prefix, method_size);
GNUNET_CLIENT_MANAGER_transmit (plc->client, &req->header);
+ GNUNET_free (req);
return hist;
}
void
GNUNET_SOCIAL_place_history_replay_cancel (struct GNUNET_SOCIAL_HistoryRequest *hist)
{
- GNUNET_PSYC_receive_destroy (hist->recv);
GNUNET_CLIENT_MANAGER_op_cancel (hist->plc->client, hist->op_id);
GNUNET_free (hist);
}
memcpy (&req[1], name, name_size);
GNUNET_CLIENT_MANAGER_transmit (plc->client, &req->header);
+ GNUNET_free (req);
return look;
}
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",
* Application handle.
*/
void
-GNUNET_SOCIAL_app_disconnect (struct GNUNET_SOCIAL_App *app)
+GNUNET_SOCIAL_app_disconnect (struct GNUNET_SOCIAL_App *app,
+ GNUNET_ContinuationCallback disconnect_cb,
+ void *disconnect_cls)
{
- GNUNET_CLIENT_MANAGER_disconnect (app->client, GNUNET_NO, NULL, NULL);
+ GNUNET_CLIENT_MANAGER_disconnect (app->client, GNUNET_NO,
+ disconnect_cb, disconnect_cls);
}
projects / oweals / gnunet.git / blobdiff