gnunet-service-scalarproduct-ecc_bob.c

Go to the documentation of this file.

/*
     This file is part of GNUnet.
     Copyright (C) 2013-2017 GNUnet e.V.

     GNUnet is free software: you can redistribute it and/or modify it
     under the terms of the GNU Affero General Public License as published
     by the Free Software Foundation, either version 3 of the License,
     or (at your option) any later version.

     GNUnet is distributed in the hope that it will be useful, but
     WITHOUT ANY WARRANTY; without even the implied warranty of
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
     Affero General Public License for more details.

     You should have received a copy of the GNU Affero General Public License
     along with this program.  If not, see <http://www.gnu.org/licenses/>.

     SPDX-License-Identifier: AGPL3.0-or-later
 */
#include "platform.h"
#include <limits.h>
#include <gcrypt.h>
#include "gnunet_util_lib.h"
#include "gnunet_core_service.h"
#include "gnunet_cadet_service.h"
#include "gnunet_applications.h"
#include "gnunet_protocols.h"
#include "gnunet_scalarproduct_service.h"
#include "gnunet_set_service.h"
#include "scalarproduct.h"
#include "gnunet-service-scalarproduct-ecc.h"

#define LOG(kind, ...) GNUNET_log_from(kind, "scalarproduct-bob", __VA_ARGS__)


struct MpiElement {
  const struct GNUNET_HashCode *key;

  gcry_mpi_t value;
};


struct BobServiceSession {
  struct GNUNET_SERVICE_Client *client;

  struct GNUNET_MQ_Handle *client_mq;

  struct GNUNET_CONTAINER_MultiHashMap *intersected_elements;

  struct GNUNET_SET_Handle *intersection_set;

  struct GNUNET_SET_OperationHandle *intersection_op;

  struct GNUNET_CADET_Port *port;

  struct MpiElement *sorted_elements;

  gcry_mpi_point_t prod_g_i_b_i;

  gcry_mpi_point_t prod_h_i_b_i;

  uint32_t total;

  uint32_t client_received_element_count;

  uint32_t used_element_count;

  uint32_t cadet_received_element_count;

  enum GNUNET_SCALARPRODUCT_ResponseStatus status;

  int in_destroy;

  struct GNUNET_CADET_Channel *channel;

  struct GNUNET_PeerIdentity peer;

  struct GNUNET_HashCode session_id;

  struct GNUNET_MQ_Handle *cadet_mq;
};


static const struct GNUNET_CONFIGURATION_Handle *cfg;

static struct GNUNET_CADET_Handle *my_cadet;

static struct GNUNET_CRYPTO_EccDlogContext *edc;


static int
free_element_cb(void *cls,
                const struct GNUNET_HashCode *key,
                void *value)
{
  struct GNUNET_SCALARPRODUCT_Element *element = value;

  GNUNET_free(element);
  return GNUNET_OK;
}


static void
destroy_service_session(struct BobServiceSession *s)
{
  unsigned int i;

  if (GNUNET_YES == s->in_destroy)
    return;
  s->in_destroy = GNUNET_YES;
  if (NULL != s->client)
    {
      struct GNUNET_SERVICE_Client *c = s->client;

      s->client = NULL;
      GNUNET_SERVICE_client_drop(c);
    }
  if (NULL != s->intersected_elements)
    {
      GNUNET_CONTAINER_multihashmap_iterate(s->intersected_elements,
                                            &free_element_cb,
                                            NULL);
      GNUNET_CONTAINER_multihashmap_destroy(s->intersected_elements);
      s->intersected_elements = NULL;
    }
  if (NULL != s->intersection_op)
    {
      GNUNET_SET_operation_cancel(s->intersection_op);
      s->intersection_op = NULL;
    }
  if (NULL != s->intersection_set)
    {
      GNUNET_SET_destroy(s->intersection_set);
      s->intersection_set = NULL;
    }
  if (NULL != s->sorted_elements)
    {
      for (i = 0; i < s->used_element_count; i++)
        gcry_mpi_release(s->sorted_elements[i].value);
      GNUNET_free(s->sorted_elements);
      s->sorted_elements = NULL;
    }
  if (NULL != s->prod_g_i_b_i)
    {
      gcry_mpi_point_release(s->prod_g_i_b_i);
      s->prod_g_i_b_i = NULL;
    }
  if (NULL != s->prod_h_i_b_i)
    {
      gcry_mpi_point_release(s->prod_h_i_b_i);
      s->prod_h_i_b_i = NULL;
    }
  if (NULL != s->port)
    {
      GNUNET_CADET_close_port(s->port);
      s->port = NULL;
    }
  if (NULL != s->channel)
    {
      GNUNET_CADET_channel_destroy(s->channel);
      s->channel = NULL;
    }
  GNUNET_free(s);
}


static void
prepare_client_end_notification(struct BobServiceSession *session)
{
  struct ClientResponseMessage *msg;
  struct GNUNET_MQ_Envelope *e;

  if (NULL == session->client_mq)
    return; /* no client left to be notified */
  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Sending session-end notification with status %d to client for session %s\n",
             session->status,
             GNUNET_h2s(&session->session_id));
  e = GNUNET_MQ_msg(msg,
                    GNUNET_MESSAGE_TYPE_SCALARPRODUCT_RESULT);
  msg->range = 0;
  msg->product_length = htonl(0);
  msg->status = htonl(session->status);
  GNUNET_MQ_send(session->client_mq,
                 e);
}


static void
cb_channel_destruction(void *cls,
                       const struct GNUNET_CADET_Channel *channel)
{
  struct BobServiceSession *s = cls;

  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Peer disconnected, terminating session %s with peer %s\n",
             GNUNET_h2s(&s->session_id),
             GNUNET_i2s(&s->peer));
  s->channel = NULL;
  if (GNUNET_SCALARPRODUCT_STATUS_ACTIVE == s->status)
    {
      s->status = GNUNET_SCALARPRODUCT_STATUS_FAILURE;
      prepare_client_end_notification(s);
    }
  destroy_service_session(s);
}


static void
bob_cadet_done_cb(void *cls)
{
  struct BobServiceSession *session = cls;

  session->status = GNUNET_SCALARPRODUCT_STATUS_SUCCESS;
  prepare_client_end_notification(session);
}


static void
transmit_bobs_cryptodata_message(struct BobServiceSession *s)
{
  struct EccBobCryptodataMessage *msg;
  struct GNUNET_MQ_Envelope *e;

  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Sending response to Alice\n");
  e = GNUNET_MQ_msg(msg,
                    GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ECC_BOB_CRYPTODATA);
  msg->contained_element_count = htonl(2);
  if (NULL != s->prod_g_i_b_i)
    GNUNET_CRYPTO_ecc_point_to_bin(edc,
                                   s->prod_g_i_b_i,
                                   &msg->prod_g_i_b_i);
  if (NULL != s->prod_h_i_b_i)
    GNUNET_CRYPTO_ecc_point_to_bin(edc,
                                   s->prod_h_i_b_i,
                                   &msg->prod_h_i_b_i);
  GNUNET_MQ_notify_sent(e,
                        &bob_cadet_done_cb,
                        s);
  GNUNET_MQ_send(s->cadet_mq,
                 e);
}


static int
copy_element_cb(void *cls,
                const struct GNUNET_HashCode *key,
                void *value)
{
  struct BobServiceSession *s = cls;
  struct GNUNET_SCALARPRODUCT_Element *e = value;
  gcry_mpi_t mval;
  int64_t val;

  mval = gcry_mpi_new(0);
  val = (int64_t)GNUNET_ntohll(e->value);
  if (0 > val)
    gcry_mpi_sub_ui(mval, mval, -val);
  else
    gcry_mpi_add_ui(mval, mval, val);
  s->sorted_elements [s->used_element_count].value = mval;
  s->sorted_elements [s->used_element_count].key = &e->key;
  s->used_element_count++;
  return GNUNET_OK;
}


static int
element_cmp(const void *a,
            const void *b)
{
  const struct MpiElement *ma = a;
  const struct MpiElement *mb = b;

  return GNUNET_CRYPTO_hash_cmp(ma->key,
                                mb->key);
}


static int
check_alices_cryptodata_message(void *cls,
                                const struct EccAliceCryptodataMessage *msg)
{
  struct BobServiceSession *s = cls;
  uint32_t contained_elements;
  size_t msg_length;
  uint16_t msize;
  unsigned int max;

  msize = ntohs(msg->header.size);
  if (msize <= sizeof(struct EccAliceCryptodataMessage))
    {
      GNUNET_break_op(0);
      return GNUNET_SYSERR;
    }
  contained_elements = ntohl(msg->contained_element_count);
  /* Our intersection may still be ongoing, but this is nevertheless
     an upper bound on the required array size */
  max = GNUNET_CONTAINER_multihashmap_size(s->intersected_elements);
  msg_length = sizeof(struct EccAliceCryptodataMessage)
               + contained_elements * sizeof(struct GNUNET_CRYPTO_EccPoint) * 2;
  if ((msize != msg_length) ||
      (0 == contained_elements) ||
      (contained_elements > UINT16_MAX) ||
      (max < contained_elements + s->cadet_received_element_count))
    {
      GNUNET_break_op(0);
      return GNUNET_SYSERR;
    }
  return GNUNET_OK;
}


static void
handle_alices_cryptodata_message(void *cls,
                                 const struct EccAliceCryptodataMessage *msg)
{
  struct BobServiceSession *s = cls;
  const struct GNUNET_CRYPTO_EccPoint *payload;
  uint32_t contained_elements;
  unsigned int max;
  unsigned int i;
  const struct MpiElement *b_i;
  gcry_mpi_point_t tmp;
  gcry_mpi_point_t g_i;
  gcry_mpi_point_t h_i;
  gcry_mpi_point_t g_i_b_i;
  gcry_mpi_point_t h_i_b_i;

  contained_elements = ntohl(msg->contained_element_count);
  max = GNUNET_CONTAINER_multihashmap_size(s->intersected_elements);
  /* sort our vector for the computation */
  if (NULL == s->sorted_elements)
    {
      s->sorted_elements
        = GNUNET_new_array(GNUNET_CONTAINER_multihashmap_size(s->intersected_elements),
                           struct MpiElement);
      s->used_element_count = 0;
      GNUNET_CONTAINER_multihashmap_iterate(s->intersected_elements,
                                            &copy_element_cb,
                                            s);
      qsort(s->sorted_elements,
            s->used_element_count,
            sizeof(struct MpiElement),
            &element_cmp);
    }

  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Received %u crypto values from Alice\n",
             (unsigned int)contained_elements);
  payload = (const struct GNUNET_CRYPTO_EccPoint *)&msg[1];

  for (i = 0; i < contained_elements; i++)
    {
      b_i = &s->sorted_elements[i + s->cadet_received_element_count];
      g_i = GNUNET_CRYPTO_ecc_bin_to_point(edc,
                                           &payload[i * 2]);
      g_i_b_i = GNUNET_CRYPTO_ecc_pmul_mpi(edc,
                                           g_i,
                                           b_i->value);
      gcry_mpi_point_release(g_i);
      h_i = GNUNET_CRYPTO_ecc_bin_to_point(edc,
                                           &payload[i * 2 + 1]);
      h_i_b_i = GNUNET_CRYPTO_ecc_pmul_mpi(edc,
                                           h_i,
                                           b_i->value);
      gcry_mpi_point_release(h_i);
      if (0 == i + s->cadet_received_element_count)
        {
          /* first iteration, nothing to add */
          s->prod_g_i_b_i = g_i_b_i;
          s->prod_h_i_b_i = h_i_b_i;
        }
      else
        {
          /* further iterations, cummulate resulting value */
          tmp = GNUNET_CRYPTO_ecc_add(edc,
                                      s->prod_g_i_b_i,
                                      g_i_b_i);
          gcry_mpi_point_release(s->prod_g_i_b_i);
          gcry_mpi_point_release(g_i_b_i);
          s->prod_g_i_b_i = tmp;
          tmp = GNUNET_CRYPTO_ecc_add(edc,
                                      s->prod_h_i_b_i,
                                      h_i_b_i);
          gcry_mpi_point_release(s->prod_h_i_b_i);
          gcry_mpi_point_release(h_i_b_i);
          s->prod_h_i_b_i = tmp;
        }
    }
  s->cadet_received_element_count += contained_elements;
  if ((s->cadet_received_element_count == max) &&
      (NULL == s->intersection_op))
    {
      /* intersection has finished also on our side, and
         we got the full set, so we can proceed with the
         CADET response(s) */
      transmit_bobs_cryptodata_message(s);
    }
  GNUNET_CADET_receive_done(s->channel);
}


static void
cb_intersection_element_removed(void *cls,
                                const struct GNUNET_SET_Element *element,
                                uint64_t current_size,
                                enum GNUNET_SET_Status status)
{
  struct BobServiceSession *s = cls;
  struct GNUNET_SCALARPRODUCT_Element *se;

  switch (status)
    {
    case GNUNET_SET_STATUS_OK:
      /* this element has been removed from the set */
      se = GNUNET_CONTAINER_multihashmap_get(s->intersected_elements,
                                             element->data);
      GNUNET_assert(NULL != se);
      LOG(GNUNET_ERROR_TYPE_DEBUG,
          "Removed element with key %s and value %lld\n",
          GNUNET_h2s(&se->key),
          (long long)GNUNET_ntohll(se->value));
      GNUNET_assert(GNUNET_YES ==
                    GNUNET_CONTAINER_multihashmap_remove(s->intersected_elements,
                                                         element->data,
                                                         se));
      GNUNET_free(se);
      return;

    case GNUNET_SET_STATUS_DONE:
      s->intersection_op = NULL;
      GNUNET_break(NULL == s->intersection_set);
      GNUNET_CADET_receive_done(s->channel);
      LOG(GNUNET_ERROR_TYPE_DEBUG,
          "Finished intersection, %d items remain\n",
          GNUNET_CONTAINER_multihashmap_size(s->intersected_elements));
      if (s->client_received_element_count ==
          GNUNET_CONTAINER_multihashmap_size(s->intersected_elements))
        {
          /* CADET transmission from Alice is also already done,
             start with our own reply */
          transmit_bobs_cryptodata_message(s);
        }
      return;

    case GNUNET_SET_STATUS_HALF_DONE:
      /* unexpected for intersection */
      GNUNET_break(0);
      return;

    case GNUNET_SET_STATUS_FAILURE:
      /* unhandled status code */
      LOG(GNUNET_ERROR_TYPE_DEBUG,
          "Set intersection failed!\n");
      s->intersection_op = NULL;
      if (NULL != s->intersection_set)
        {
          GNUNET_SET_destroy(s->intersection_set);
          s->intersection_set = NULL;
        }
      s->status = GNUNET_SCALARPRODUCT_STATUS_FAILURE;
      prepare_client_end_notification(s);
      return;

    default:
      GNUNET_break(0);
      return;
    }
}


static void
start_intersection(struct BobServiceSession *s)
{
  struct GNUNET_HashCode set_sid;

  GNUNET_CRYPTO_hash(&s->session_id,
                     sizeof(struct GNUNET_HashCode),
                     &set_sid);
  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Got session with key %s and %u elements, starting intersection.\n",
             GNUNET_h2s(&s->session_id),
             (unsigned int)s->total);

  s->intersection_op
    = GNUNET_SET_prepare(&s->peer,
                         &set_sid,
                         NULL,
                         GNUNET_SET_RESULT_REMOVED,
                         (struct GNUNET_SET_Option[]) { { 0 } },
                         &cb_intersection_element_removed,
                         s);
  if (GNUNET_OK !=
      GNUNET_SET_commit(s->intersection_op,
                        s->intersection_set))
    {
      GNUNET_break(0);
      s->status = GNUNET_SCALARPRODUCT_STATUS_FAILURE;
      prepare_client_end_notification(s);
      return;
    }
  GNUNET_SET_destroy(s->intersection_set);
  s->intersection_set = NULL;
}


static void
handle_alices_computation_request(void *cls,
                                  const struct EccServiceRequestMessage *msg)
{
  struct BobServiceSession *s = cls;

  s->session_id = msg->session_id; // ??
  if (s->client_received_element_count < s->total)
    {
      GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
                 "Alice ready, still waiting for Bob client data!\n");
      return;
    }
  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Both ready, launching intersection!\n");
  start_intersection(s);
}


static void *
cb_channel_incoming(void *cls,
                    struct GNUNET_CADET_Channel *channel,
                    const struct GNUNET_PeerIdentity *initiator)
{
  struct BobServiceSession *s = cls;

  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "New incoming channel from peer %s.\n",
             GNUNET_i2s(initiator));
  GNUNET_CADET_close_port(s->port);
  s->port = NULL;
  s->peer = *initiator;
  s->channel = channel;
  s->cadet_mq = GNUNET_CADET_get_mq(s->channel);
  return s;
}


static int
check_bob_client_message_multipart(void *cls,
                                   const struct ComputationBobCryptodataMultipartMessage *msg)
{
  struct BobServiceSession *s = cls;
  uint32_t contained_count;
  uint16_t msize;

  msize = ntohs(msg->header.size);
  contained_count = ntohl(msg->element_count_contained);
  if ((msize != (sizeof(struct ComputationBobCryptodataMultipartMessage) +
                 contained_count * sizeof(struct GNUNET_SCALARPRODUCT_Element))) ||
      (0 == contained_count) ||
      (UINT16_MAX < contained_count) ||
      (s->total == s->client_received_element_count) ||
      (s->total < s->client_received_element_count + contained_count))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  return GNUNET_OK;
}


static void
handle_bob_client_message_multipart(void *cls,
                                    const struct ComputationBobCryptodataMultipartMessage *msg)
{
  struct BobServiceSession *s = cls;
  uint32_t contained_count;
  const struct GNUNET_SCALARPRODUCT_Element *elements;
  struct GNUNET_SET_Element set_elem;
  struct GNUNET_SCALARPRODUCT_Element *elem;

  contained_count = ntohl(msg->element_count_contained);
  elements = (const struct GNUNET_SCALARPRODUCT_Element *)&msg[1];
  for (uint32_t i = 0; i < contained_count; i++)
    {
      elem = GNUNET_new(struct GNUNET_SCALARPRODUCT_Element);
      GNUNET_memcpy(elem,
                    &elements[i],
                    sizeof(struct GNUNET_SCALARPRODUCT_Element));
      if (GNUNET_SYSERR ==
          GNUNET_CONTAINER_multihashmap_put(s->intersected_elements,
                                            &elem->key,
                                            elem,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY))
        {
          GNUNET_break(0);
          GNUNET_free(elem);
          continue;
        }
      set_elem.data = &elem->key;
      set_elem.size = sizeof(elem->key);
      set_elem.element_type = 0;
      GNUNET_SET_add_element(s->intersection_set,
                             &set_elem,
                             NULL, NULL);
    }
  s->client_received_element_count += contained_count;
  GNUNET_SERVICE_client_continue(s->client);
  if (s->total != s->client_received_element_count)
    {
      /* more to come */
      GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
                 "Request still partial, waiting for more client data!\n");
      return;
    }
  if (NULL == s->channel)
    {
      /* no Alice waiting for this request, wait for Alice */
      GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
                 "Client ready, still waiting for Alice!\n");
      return;
    }
  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Both ready, launching intersection!\n");
  start_intersection(s);
}


static int
check_bob_client_message(void *cls,
                         const struct BobComputationMessage *msg)
{
  struct BobServiceSession *s = cls;
  uint32_t contained_count;
  uint32_t total_count;
  uint16_t msize;

  if (GNUNET_SCALARPRODUCT_STATUS_INIT != s->status)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  msize = ntohs(msg->header.size);
  total_count = ntohl(msg->element_count_total);
  contained_count = ntohl(msg->element_count_contained);
  if ((0 == total_count) ||
      (0 == contained_count) ||
      (UINT16_MAX < contained_count) ||
      (msize != (sizeof(struct BobComputationMessage) +
                 contained_count * sizeof(struct GNUNET_SCALARPRODUCT_Element))))
    {
      GNUNET_break_op(0);
      return GNUNET_SYSERR;
    }
  return GNUNET_OK;
}


static void
handle_bob_client_message(void *cls,
                          const struct BobComputationMessage *msg)
{
  struct BobServiceSession *s = cls;
  struct GNUNET_MQ_MessageHandler cadet_handlers[] = {
    GNUNET_MQ_hd_fixed_size(alices_computation_request,
                            GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ECC_SESSION_INITIALIZATION,
                            struct EccServiceRequestMessage,
                            s),
    GNUNET_MQ_hd_var_size(alices_cryptodata_message,
                          GNUNET_MESSAGE_TYPE_SCALARPRODUCT_ECC_ALICE_CRYPTODATA,
                          struct EccAliceCryptodataMessage,
                          s),
    GNUNET_MQ_handler_end()
  };
  uint32_t contained_count;
  uint32_t total_count;
  const struct GNUNET_SCALARPRODUCT_Element *elements;
  struct GNUNET_SET_Element set_elem;
  struct GNUNET_SCALARPRODUCT_Element *elem;

  total_count = ntohl(msg->element_count_total);
  contained_count = ntohl(msg->element_count_contained);

  s->status = GNUNET_SCALARPRODUCT_STATUS_ACTIVE;
  s->total = total_count;
  s->client_received_element_count = contained_count;
  s->session_id = msg->session_key;
  elements = (const struct GNUNET_SCALARPRODUCT_Element *)&msg[1];
  s->intersected_elements
    = GNUNET_CONTAINER_multihashmap_create(s->total,
                                           GNUNET_YES);
  s->intersection_set
    = GNUNET_SET_create(cfg,
                        GNUNET_SET_OPERATION_INTERSECTION);
  for (uint32_t i = 0; i < contained_count; i++)
    {
      if (0 == GNUNET_ntohll(elements[i].value))
        continue;
      elem = GNUNET_new(struct GNUNET_SCALARPRODUCT_Element);
      GNUNET_memcpy(elem,
                    &elements[i],
                    sizeof(struct GNUNET_SCALARPRODUCT_Element));
      if (GNUNET_SYSERR ==
          GNUNET_CONTAINER_multihashmap_put(s->intersected_elements,
                                            &elem->key,
                                            elem,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY))
        {
          GNUNET_break(0);
          GNUNET_free(elem);
          continue;
        }
      set_elem.data = &elem->key;
      set_elem.size = sizeof(elem->key);
      set_elem.element_type = 0;
      GNUNET_SET_add_element(s->intersection_set,
                             &set_elem,
                             NULL, NULL);
      s->used_element_count++;
    }
  GNUNET_SERVICE_client_continue(s->client);
  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Received client request, opening port %s!\n",
             GNUNET_h2s(&msg->session_key));
  s->port = GNUNET_CADET_open_port(my_cadet,
                                   &msg->session_key,
                                   &cb_channel_incoming,
                                   s,
                                   NULL,
                                   &cb_channel_destruction,
                                   cadet_handlers);
  if (NULL == s->port)
    {
      GNUNET_break(0);
      GNUNET_SERVICE_client_drop(s->client);
      return;
    }
}


static void
shutdown_task(void *cls)
{
  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Shutting down, initiating cleanup.\n");
  // FIXME: we have to cut our connections to CADET first!
  if (NULL != my_cadet)
    {
      GNUNET_CADET_disconnect(my_cadet);
      my_cadet = NULL;
    }
  if (NULL != edc)
    {
      GNUNET_CRYPTO_ecc_dlog_release(edc);
      edc = NULL;
    }
}


static void *
client_connect_cb(void *cls,
                  struct GNUNET_SERVICE_Client *client,
                  struct GNUNET_MQ_Handle *mq)
{
  struct BobServiceSession *s;

  s = GNUNET_new(struct BobServiceSession);
  s->client = client;
  s->client_mq = mq;
  return s;
}


static void
client_disconnect_cb(void *cls,
                     struct GNUNET_SERVICE_Client *client,
                     void *app_cls)
{
  struct BobServiceSession *s = app_cls;

  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
             "Client disconnected from us.\n");
  s->client = NULL;
  destroy_service_session(s);
}


static void
run(void *cls,
    const struct GNUNET_CONFIGURATION_Handle *c,
    struct GNUNET_SERVICE_Handle *service)
{
  cfg = c;
  /* We don't really do DLOG, so we can setup with very minimal resources */
  edc = GNUNET_CRYPTO_ecc_dlog_prepare(4 /* max value */,
                                       2 /* RAM */);
  my_cadet = GNUNET_CADET_connect(cfg);
  GNUNET_SCHEDULER_add_shutdown(&shutdown_task,
                                NULL);
  if (NULL == my_cadet)
    {
      GNUNET_log(GNUNET_ERROR_TYPE_ERROR,
                 _("Connect to CADET failed\n"));
      GNUNET_SCHEDULER_shutdown();
      return;
    }
}


GNUNET_SERVICE_MAIN
  ("scalarproduct-bob",
  GNUNET_SERVICE_OPTION_NONE,
  &run,
  &client_connect_cb,
  &client_disconnect_cb,
  NULL,
  GNUNET_MQ_hd_var_size(bob_client_message,
                        GNUNET_MESSAGE_TYPE_SCALARPRODUCT_CLIENT_TO_BOB,
                        struct BobComputationMessage,
                        NULL),
  GNUNET_MQ_hd_var_size(bob_client_message_multipart,
                        GNUNET_MESSAGE_TYPE_SCALARPRODUCT_CLIENT_MULTIPART_BOB,
                        struct ComputationBobCryptodataMultipartMessage,
                        NULL),
  GNUNET_MQ_handler_end());


/* end of gnunet-service-scalarproduct-ecc_bob.c */