peerstore service implementation More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "peerstore.h"
#include "gnunet_peerstore_plugin.h"
#include "peerstore_common.h"

Include dependency graph for gnunet-service-peerstore.c:

Macros
#define	EXPIRED_RECORDS_CLEANUP_INTERVAL 300 /* 5mins */
	Interval for expired records cleanup (in seconds) More...

Functions
static void	do_shutdown ()
	Perform the actual shutdown operations. More...

static void	shutdown_task (void *cls)
	Task run during shutdown. More...

static void	expire_records_continuation (void *cls, int success)
	Continuation to expire_records called by the peerstore plugin. More...

static void	cleanup_expired_records (void *cls)
	Deletes any expired records from storage. More...

static void *	client_connect_cb (void cls, struct GNUNET_SERVICE_Client client, struct GNUNET_MQ_Handle *mq)
	A client disconnected. More...

static int	client_disconnect_it (void cls, const struct GNUNET_HashCode key, void *value)
	Search for a disconnected client and remove it. More...

static void	client_disconnect_cb (void cls, struct GNUNET_SERVICE_Client client, void *app_cls)
	A client disconnected. More...

static void	record_iterator (void cls, const struct GNUNET_PEERSTORE_Record record, const char *emsg)
	Function called by for each matching record. More...

static int	watch_notifier_it (void cls, const struct GNUNET_HashCode key, void *value)
	Iterator over all watcher clients to notify them of a new record. More...

static void	watch_notifier (struct GNUNET_PEERSTORE_Record *record)
	Given a new record, notifies watchers. More...

static void	handle_watch_cancel (void cls, const struct StoreKeyHashMessage hm)
	Handle a watch cancel request from client. More...

static void	handle_watch (void cls, const struct StoreKeyHashMessage hm)
	Handle a watch request from client. More...

static int	check_iterate (void cls, const struct StoreRecordMessage srm)
	Check an iterate request from client. More...

static void	handle_iterate (void cls, const struct StoreRecordMessage srm)
	Handle an iterate request from client. More...

static void	store_record_continuation (void *cls, int success)
	Continuation of store_record called by the peerstore plugin. More...

static int	check_store (void cls, const struct StoreRecordMessage srm)
	Check a store request from client. More...

static void	handle_store (void cls, const struct StoreRecordMessage srm)
	Handle a store request from client. More...

static void	run (void cls, const struct GNUNET_CONFIGURATION_Handle c, struct GNUNET_SERVICE_Handle *service)
	Peerstore service runner. More...

	GNUNET_SERVICE_MAIN ("peerstore", GNUNET_SERVICE_OPTION_SOFT_SHUTDOWN, &run, &client_connect_cb, &client_disconnect_cb, NULL, GNUNET_MQ_hd_var_size(store, GNUNET_MESSAGE_TYPE_PEERSTORE_STORE, struct StoreRecordMessage, NULL), GNUNET_MQ_hd_var_size(iterate, GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE, struct StoreRecordMessage, NULL), GNUNET_MQ_hd_fixed_size(watch, GNUNET_MESSAGE_TYPE_PEERSTORE_WATCH, struct StoreKeyHashMessage, NULL), GNUNET_MQ_hd_fixed_size(watch_cancel, GNUNET_MESSAGE_TYPE_PEERSTORE_WATCH_CANCEL, struct StoreKeyHashMessage, NULL), GNUNET_MQ_handler_end())
	Define "main" method using service macro. More...

Variables
static const struct GNUNET_CONFIGURATION_Handle *	cfg
	Our configuration. More...

static char *	db_lib_name
	Database plugin library name. More...

static struct GNUNET_PEERSTORE_PluginFunctions *	db
	Database handle. More...

static struct GNUNET_CONTAINER_MultiHashMap *	watchers
	Hashmap with all watch requests. More...

static struct GNUNET_SCHEDULER_Task *	expire_task
	Task run to clean up expired records. More...

static int	in_shutdown
	Are we in the process of shutting down the service? GNUNET_YES / GNUNET_NO. More...

static unsigned int	num_clients
	Number of connected clients. More...

Detailed Description

peerstore service implementation

Author: Omar Tarabai

Definition in file gnunet-service-peerstore.c.

Macro Definition Documentation

◆ EXPIRED_RECORDS_CLEANUP_INTERVAL

#define EXPIRED_RECORDS_CLEANUP_INTERVAL 300 /* 5mins */

Interval for expired records cleanup (in seconds)

Definition at line 36 of file gnunet-service-peerstore.c.

Function Documentation

◆ do_shutdown()

static void do_shutdown ( )

static

Perform the actual shutdown operations.

Definition at line 78 of file gnunet-service-peerstore.c.

 {
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Shutting down peerstore, bye.\n");
   if (NULL != db_lib_name)
   {
     GNUNET_break (NULL == GNUNET_PLUGIN_unload (db_lib_name, db));
     GNUNET_free (db_lib_name);
     db_lib_name = NULL;
   }
   if (NULL != watchers)
   {
     GNUNET_CONTAINER_multihashmap_destroy (watchers);
     watchers = NULL;
   }
   if (NULL != expire_task)
   {
     GNUNET_SCHEDULER_cancel (expire_task);
     expire_task = NULL;
   }
   GNUNET_SCHEDULER_shutdown ();
 }

References db, db_lib_name, expire_task, GNUNET_break, GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_log, GNUNET_PLUGIN_unload(), GNUNET_SCHEDULER_cancel(), GNUNET_SCHEDULER_shutdown(), and watchers.

Referenced by client_disconnect_cb(), and shutdown_task().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ shutdown_task()

static void shutdown_task ( void * cls )

static

Task run during shutdown.

Parameters

cls unused

Definition at line 108 of file gnunet-service-peerstore.c.

 {
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Priming PEERSTORE for shutdown.\n");
   in_shutdown = GNUNET_YES;
   if (0 == num_clients) /* Only when no connected clients. */
     do_shutdown ();
 }

References do_shutdown(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_YES, in_shutdown, and num_clients.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ expire_records_continuation()

static void expire_records_continuation	(	void *	cls,
		int	success
	)

static

Continuation to expire_records called by the peerstore plugin.

Parameters

cls	unused
success	count of records deleted or GNUNET_SYSERR

Definition at line 156 of file gnunet-service-peerstore.c.

 {
   if (success > 0)
     GNUNET_log (GNUNET_ERROR_TYPE_INFO, "%d records expired.\n", success);
   GNUNET_assert (NULL == expire_task);
   expire_task = GNUNET_SCHEDULER_add_delayed (
     GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS,
                                    EXPIRED_RECORDS_CLEANUP_INTERVAL),
     &cleanup_expired_records,
     NULL);
 }

References cleanup_expired_records(), expire_task, EXPIRED_RECORDS_CLEANUP_INTERVAL, GNUNET_assert, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_relative_multiply(), and GNUNET_TIME_UNIT_SECONDS.

Referenced by cleanup_expired_records().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ cleanup_expired_records()

static void cleanup_expired_records ( void * cls )

static

Deletes any expired records from storage.

Definition at line 127 of file gnunet-service-peerstore.c.

 {
   int ret;
  
   expire_task = NULL;
   GNUNET_assert (NULL != db);
   ret = db->expire_records (db->cls,
                             GNUNET_TIME_absolute_get (),
                             &expire_records_continuation,
                             NULL);
   if (GNUNET_OK != ret)
   {
     GNUNET_assert (NULL == expire_task);
     expire_task = GNUNET_SCHEDULER_add_delayed (
       GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS,
                                      EXPIRED_RECORDS_CLEANUP_INTERVAL),
       &cleanup_expired_records,
       NULL);
   }
 }

References GNUNET_PEERSTORE_PluginFunctions::cls, db, GNUNET_PEERSTORE_PluginFunctions::expire_records, expire_records_continuation(), expire_task, EXPIRED_RECORDS_CLEANUP_INTERVAL, GNUNET_assert, GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_absolute_get(), GNUNET_TIME_relative_multiply(), GNUNET_TIME_UNIT_SECONDS, and ret.

Referenced by expire_records_continuation(), and run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ client_connect_cb()

static void* client_connect_cb	(	void *	cls,
		struct GNUNET_SERVICE_Client *	client,
		struct GNUNET_MQ_Handle *	mq
	)

static

A client disconnected.

Remove all of its data structure entries.

Parameters

cls	closure, NULL
client	identification of the client
mq	the message queue

Returns

Definition at line 178 of file gnunet-service-peerstore.c.

 {
   num_clients++;
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "A client connected (now %u)\n", num_clients);
   return client;
 }

References GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, and num_clients.

◆ client_disconnect_it()

static int client_disconnect_it	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Search for a disconnected client and remove it.

Parameters

cls	closuer, a `struct GNUNET_SERVICE_Client`
key	hash of record key
value	the watcher client, a `struct GNUNET_SERVICE_Client *`

Returns: GNUNET_OK to continue iterating

Definition at line 198 of file gnunet-service-peerstore.c.

 {
   if (value == cls)
   {
     GNUNET_assert (GNUNET_YES ==
                    GNUNET_CONTAINER_multihashmap_remove (watchers, key, value));
     num_clients++; /* Watchers do not count */
   }
   return GNUNET_OK;
 }

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_remove(), GNUNET_OK, GNUNET_YES, key, num_clients, value, and watchers.

Referenced by client_disconnect_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ client_disconnect_cb()

static void client_disconnect_cb	(	void *	cls,
		struct GNUNET_SERVICE_Client *	client,
		void *	app_cls
	)

static

A client disconnected.

Remove all of its data structure entries.

Parameters

cls	closure, NULL
client	identification of the client

Definition at line 217 of file gnunet-service-peerstore.c.

 {
   num_clients--;
   if (NULL != watchers)
     GNUNET_CONTAINER_multihashmap_iterate (watchers,
                                            &client_disconnect_it,
                                            client);
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "A client disconnected (%u remaining).\n",
               num_clients);
   if ((0 == num_clients) && in_shutdown)
     do_shutdown ();
 }

References client_disconnect_it(), do_shutdown(), GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, in_shutdown, num_clients, and watchers.

Here is the call graph for this function:

◆ record_iterator()

static void record_iterator	(	void *	cls,
		const struct GNUNET_PEERSTORE_Record *	record,
		const char *	emsg
	)

static

Function called by for each matching record.

Parameters

cls	closure
record	peerstore record found
emsg	error message or NULL if no errors

Returns: GNUNET_YES to continue iteration

Definition at line 243 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_PEERSTORE_Record *cls_record = cls;
   struct GNUNET_MQ_Envelope *env;
  
   if (NULL == record)
   {
     /* No more records */
     struct GNUNET_MessageHeader *endmsg;
  
     env = GNUNET_MQ_msg (endmsg, GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE_END);
     GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (cls_record->client), env);
     if (NULL == emsg)
     {
       GNUNET_SERVICE_client_continue (cls_record->client);
     }
     else
     {
       GNUNET_break (0);
       GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to iterate: %s\n", emsg);
       GNUNET_SERVICE_client_drop (cls_record->client);
     }
     PEERSTORE_destroy_record (cls_record);
     return;
   }
  
   env = PEERSTORE_create_record_mq_envelope (
     record->sub_system,
     &record->peer,
     record->key,
     record->value,
     record->value_size,
     record->expiry,
     0,
     GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE_RECORD);
   GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (cls_record->client), env);
 }

References GNUNET_PEERSTORE_Record::client, env, GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE_END, GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE_RECORD, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), GNUNET_SERVICE_client_get_mq(), PEERSTORE_create_record_mq_envelope(), PEERSTORE_destroy_record(), and record().

Referenced by handle_iterate().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ watch_notifier_it()

static int watch_notifier_it	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Iterator over all watcher clients to notify them of a new record.

Parameters

cls	closure, a `struct GNUNET_PEERSTORE_Record *`
key	hash of record key
value	the watcher client, a `struct GNUNET_SERVICE_Client *`

Returns: GNUNET_YES to continue iterating

Definition at line 294 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_PEERSTORE_Record *record = cls;
   struct GNUNET_SERVICE_Client *client = value;
   struct GNUNET_MQ_Envelope *env;
  
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Found a watcher to update.\n");
   env = PEERSTORE_create_record_mq_envelope (
     record->sub_system,
     &record->peer,
     record->key,
     record->value,
     record->value_size,
     record->expiry,
     0,
     GNUNET_MESSAGE_TYPE_PEERSTORE_WATCH_RECORD);
   GNUNET_MQ_send (GNUNET_SERVICE_client_get_mq (client), env);
   return GNUNET_YES;
 }

References env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MESSAGE_TYPE_PEERSTORE_WATCH_RECORD, GNUNET_MQ_send(), GNUNET_SERVICE_client_get_mq(), GNUNET_YES, PEERSTORE_create_record_mq_envelope(), record(), and value.

Referenced by watch_notifier().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ watch_notifier()

static void watch_notifier ( struct GNUNET_PEERSTORE_Record * record )

static

Given a new record, notifies watchers.

Parameters

record changed record to update watchers with

Definition at line 321 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_HashCode keyhash;
  
   PEERSTORE_hash_key (record->sub_system, &record->peer, record->key, &keyhash);
   GNUNET_CONTAINER_multihashmap_get_multiple (watchers,
                                               &keyhash,
                                               &watch_notifier_it,
                                               record);
 }

References GNUNET_CONTAINER_multihashmap_get_multiple(), PEERSTORE_hash_key(), record(), watch_notifier_it(), and watchers.

Referenced by store_record_continuation().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ handle_watch_cancel()

static void handle_watch_cancel	(	void *	cls,
		const struct StoreKeyHashMessage *	hm
	)

static

Handle a watch cancel request from client.

Parameters

cls	identification of the client
hm	the actual message

Definition at line 340 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_SERVICE_Client *client = cls;
  
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received a watch cancel request.\n");
   if (GNUNET_OK !=
       GNUNET_CONTAINER_multihashmap_remove (watchers, &hm->keyhash, client))
   {
     GNUNET_break (0);
     GNUNET_SERVICE_client_drop (client);
     return;
   }
   num_clients++;
   GNUNET_SERVICE_client_continue (client);
 }

References GNUNET_break, GNUNET_CONTAINER_multihashmap_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_OK, GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), StoreKeyHashMessage::keyhash, num_clients, and watchers.

Here is the call graph for this function:

◆ handle_watch()

static void handle_watch	(	void *	cls,
		const struct StoreKeyHashMessage *	hm
	)

static

Handle a watch request from client.

Parameters

cls	identification of the client
hm	the actual message

Definition at line 364 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_SERVICE_Client *client = cls;
  
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Received a watch request.\n");
   num_clients--; /* do not count watchers */
   GNUNET_SERVICE_client_mark_monitor (client);
   GNUNET_CONTAINER_multihashmap_put (watchers,
                                      &hm->keyhash,
                                      client,
                                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
   GNUNET_SERVICE_client_continue (client);
 }

References GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_mark_monitor(), StoreKeyHashMessage::keyhash, num_clients, and watchers.

Here is the call graph for this function:

◆ check_iterate()

static int check_iterate	(	void *	cls,
		const struct StoreRecordMessage *	srm
	)

static

Check an iterate request from client.

Parameters

cls	client identification of the client
srm	the actual message

Returns: GNUNET_OK if srm is well-formed

Definition at line 387 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_PEERSTORE_Record *record;
  
   record = PEERSTORE_parse_record_message (srm);
   if (NULL == record)
   {
     GNUNET_break (0);
     return GNUNET_SYSERR;
   }
   if (NULL == record->sub_system)
   {
     GNUNET_break (0);
     PEERSTORE_destroy_record (record);
     return GNUNET_SYSERR;
   }
   PEERSTORE_destroy_record (record);
   return GNUNET_OK;
 }

References GNUNET_break, GNUNET_OK, GNUNET_SYSERR, PEERSTORE_destroy_record(), PEERSTORE_parse_record_message(), and record().

Here is the call graph for this function:

◆ handle_iterate()

static void handle_iterate	(	void *	cls,
		const struct StoreRecordMessage *	srm
	)

static

Handle an iterate request from client.

Parameters

cls	identification of the client
srm	the actual message

Definition at line 415 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_SERVICE_Client *client = cls;
   struct GNUNET_PEERSTORE_Record *record;
  
   record = PEERSTORE_parse_record_message (srm);
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Iterate request: ss `%s', peer `%s', key `%s'\n",
               record->sub_system,
               GNUNET_i2s (&record->peer),
               (NULL == record->key) ? "NULL" : record->key);
   record->client = client;
   if (GNUNET_OK !=
       db->iterate_records (db->cls,
                            record->sub_system,
                            (ntohs (srm->peer_set)) ? &record->peer : NULL,
                            record->key,
                            &record_iterator,
                            record))
   {
     GNUNET_break (0);
     GNUNET_SERVICE_client_drop (client);
     PEERSTORE_destroy_record (record);
   }
 }

References GNUNET_PEERSTORE_Record::client, GNUNET_PEERSTORE_PluginFunctions::cls, db, GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, GNUNET_OK, GNUNET_SERVICE_client_drop(), GNUNET_PEERSTORE_PluginFunctions::iterate_records, StoreRecordMessage::peer_set, PEERSTORE_destroy_record(), PEERSTORE_parse_record_message(), record(), and record_iterator().

Here is the call graph for this function:

◆ store_record_continuation()

static void store_record_continuation	(	void *	cls,
		int	success
	)

static

Continuation of store_record called by the peerstore plugin.

Parameters

cls	closure
success	result

Definition at line 449 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_PEERSTORE_Record *record = cls;
  
   if (GNUNET_OK == success)
   {
     watch_notifier (record);
     GNUNET_SERVICE_client_continue (record->client);
   }
   else
   {
     GNUNET_break (0);
     GNUNET_SERVICE_client_drop (record->client);
   }
   PEERSTORE_destroy_record (record);
 }

References GNUNET_break, GNUNET_OK, GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), PEERSTORE_destroy_record(), record(), and watch_notifier().

Referenced by handle_store().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ check_store()

static int check_store	(	void *	cls,
		const struct StoreRecordMessage *	srm
	)

static

Check a store request from client.

Parameters

cls	client identification of the client
srm	the actual message

Returns: GNUNET_OK if srm is well-formed

Definition at line 475 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_PEERSTORE_Record *record;
  
   record = PEERSTORE_parse_record_message (srm);
   if (NULL == record)
   {
     GNUNET_break (0);
     return GNUNET_SYSERR;
   }
   if ((NULL == record->sub_system) || (NULL == record->key))
   {
     GNUNET_break (0);
     PEERSTORE_destroy_record (record);
     return GNUNET_SYSERR;
   }
   PEERSTORE_destroy_record (record);
   return GNUNET_OK;
 }

References GNUNET_break, GNUNET_OK, GNUNET_SYSERR, PEERSTORE_destroy_record(), PEERSTORE_parse_record_message(), and record().

Here is the call graph for this function:

◆ handle_store()

static void handle_store	(	void *	cls,
		const struct StoreRecordMessage *	srm
	)

static

Handle a store request from client.

Parameters

cls	client identification of the client
srm	the actual message

Definition at line 503 of file gnunet-service-peerstore.c.

 {
   struct GNUNET_SERVICE_Client *client = cls;
   struct GNUNET_PEERSTORE_Record *record;
  
   record = PEERSTORE_parse_record_message (srm);
   GNUNET_log (
     GNUNET_ERROR_TYPE_INFO,
     "Received a store request. Sub system `%s' Peer `%s Key `%s' Options: %u.\n",
     record->sub_system,
     GNUNET_i2s (&record->peer),
     record->key,
     (uint32_t) ntohl (srm->options));
   record->client = client;
   if (GNUNET_OK != db->store_record (db->cls,
                                      record->sub_system,
                                      &record->peer,
                                      record->key,
                                      record->value,
                                      record->value_size,
                                      record->expiry,
                                      ntohl (srm->options),
                                      &store_record_continuation,
                                      record))
   {
     GNUNET_break (0);
     PEERSTORE_destroy_record (record);
     GNUNET_SERVICE_client_drop (client);
     return;
   }
 }

References GNUNET_PEERSTORE_Record::client, GNUNET_PEERSTORE_PluginFunctions::cls, db, GNUNET_break, GNUNET_ERROR_TYPE_INFO, GNUNET_i2s(), GNUNET_log, GNUNET_OK, GNUNET_SERVICE_client_drop(), StoreRecordMessage::options, PEERSTORE_destroy_record(), PEERSTORE_parse_record_message(), record(), GNUNET_PEERSTORE_PluginFunctions::store_record, and store_record_continuation().

Here is the call graph for this function:

◆ run()

static void run	(	void *	cls,
		const struct GNUNET_CONFIGURATION_Handle *	c,
		struct GNUNET_SERVICE_Handle *	service
	)

static

Peerstore service runner.

Parameters

cls	closure
c	configuration to use
service	the initialized service

Definition at line 544 of file gnunet-service-peerstore.c.

 {
   char *database;
  
   in_shutdown = GNUNET_NO;
   num_clients = 0;
   cfg = c;
   if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_string (cfg,
                                                           "peerstore",
                                                           "DATABASE",
                                                           &database))
   {
     GNUNET_log_config_missing (GNUNET_ERROR_TYPE_ERROR,
                                "peerstore",
                                "DATABASE");
     GNUNET_SCHEDULER_shutdown ();
     return;
   }
   GNUNET_asprintf (&db_lib_name, "libgnunet_plugin_peerstore_%s", database);
   db = GNUNET_PLUGIN_load (db_lib_name, (void *) cfg);
   GNUNET_free (database);
   if (NULL == db)
   {
     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                 _ ("Could not load database backend `%s'\n"),
                 db_lib_name);
     GNUNET_SCHEDULER_shutdown ();
     return;
   }
   watchers = GNUNET_CONTAINER_multihashmap_create (10, GNUNET_NO);
   expire_task = GNUNET_SCHEDULER_add_now (&cleanup_expired_records, NULL);
   GNUNET_SCHEDULER_add_shutdown (&shutdown_task, NULL);
 }

References _, cfg, cleanup_expired_records(), db, db_lib_name, expire_task, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONTAINER_multihashmap_create(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, GNUNET_log_config_missing(), GNUNET_NO, GNUNET_OK, GNUNET_PLUGIN_load(), GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_add_shutdown(), GNUNET_SCHEDULER_shutdown(), in_shutdown, num_clients, shutdown_task(), and watchers.

Here is the call graph for this function:

◆ GNUNET_SERVICE_MAIN()

GNUNET_SERVICE_MAIN	(	"peerstore"	,
		GNUNET_SERVICE_OPTION_SOFT_SHUTDOWN	,
		&	run,
		&	client_connect_cb,
		&	client_disconnect_cb,
		NULL	,
		GNUNET_MQ_hd_var_size(store, GNUNET_MESSAGE_TYPE_PEERSTORE_STORE, struct StoreRecordMessage, NULL)	,
		GNUNET_MQ_hd_var_size(iterate, GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE, struct StoreRecordMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(watch, GNUNET_MESSAGE_TYPE_PEERSTORE_WATCH, struct StoreKeyHashMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(watch_cancel, GNUNET_MESSAGE_TYPE_PEERSTORE_WATCH_CANCEL, struct StoreKeyHashMessage, NULL)	,
		GNUNET_MQ_handler_end()
	)

Define "main" method using service macro.

Variable Documentation

◆ cfg

const struct GNUNET_CONFIGURATION_Handle* cfg

static

Our configuration.

Definition at line 41 of file gnunet-service-peerstore.c.

Referenced by run().

◆ db_lib_name

char* db_lib_name

static

Database plugin library name.

Definition at line 46 of file gnunet-service-peerstore.c.

Referenced by do_shutdown(), and run().

◆ db

struct GNUNET_PEERSTORE_PluginFunctions* db

static

Database handle.

Definition at line 51 of file gnunet-service-peerstore.c.

Referenced by cleanup_expired_records(), do_shutdown(), handle_iterate(), handle_store(), and run().

◆ watchers

struct GNUNET_CONTAINER_MultiHashMap* watchers

static

Hashmap with all watch requests.

Definition at line 56 of file gnunet-service-peerstore.c.

Referenced by client_disconnect_cb(), client_disconnect_it(), do_shutdown(), handle_watch(), handle_watch_cancel(), run(), and watch_notifier().

◆ expire_task

struct GNUNET_SCHEDULER_Task* expire_task

static

Task run to clean up expired records.

Definition at line 61 of file gnunet-service-peerstore.c.

Referenced by cleanup_expired_records(), do_shutdown(), expire_records_continuation(), and run().

◆ in_shutdown

int in_shutdown

static

Are we in the process of shutting down the service? GNUNET_YES / GNUNET_NO.

Definition at line 66 of file gnunet-service-peerstore.c.

Referenced by client_disconnect_cb(), run(), and shutdown_task().

◆ num_clients

unsigned int num_clients

static

Number of connected clients.

Definition at line 71 of file gnunet-service-peerstore.c.

Referenced by client_connect_cb(), client_disconnect_cb(), client_disconnect_it(), handle_watch(), handle_watch_cancel(), run(), and shutdown_task().

Macros

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ EXPIRED_RECORDS_CLEANUP_INTERVAL

Function Documentation

◆ do_shutdown()

◆ shutdown_task()

◆ expire_records_continuation()

◆ cleanup_expired_records()

◆ client_connect_cb()

◆ client_disconnect_it()

◆ client_disconnect_cb()

◆ record_iterator()

◆ watch_notifier_it()

◆ watch_notifier()

◆ handle_watch_cancel()

◆ handle_watch()

◆ check_iterate()

◆ handle_iterate()

◆ store_record_continuation()

◆ check_store()

◆ handle_store()

◆ run()

◆ GNUNET_SERVICE_MAIN()

Variable Documentation

◆ cfg

◆ db_lib_name

◆ db

◆ watchers

◆ expire_task

◆ in_shutdown

◆ num_clients