X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Fpsycstore%2Fgnunet-service-psycstore.c;h=33e894b5ec292191c9179fe9bf571671c23bafb2;hb=3aab63d5c50db0eb784d3b65b2bd989d3458c960;hp=737cff42279f88e55a55e004c7b24db92eb94b8a;hpb=29e6158507a0758192075ac6ece7ba8e75ddc49a;p=oweals%2Fgnunet.git diff --git a/src/psycstore/gnunet-service-psycstore.c b/src/psycstore/gnunet-service-psycstore.c index 737cff422..33e894b5e 100644 --- a/src/psycstore/gnunet-service-psycstore.c +++ b/src/psycstore/gnunet-service-psycstore.c @@ -117,7 +117,7 @@ send_result_code (struct GNUNET_SERVER_Client *client, uint64_t op_id, res->op_id = op_id; if (0 < err_size) { - memcpy (&res[1], err_msg, err_size); + GNUNET_memcpy (&res[1], err_msg, err_size); ((char *) &res[1])[err_size - 1] = '\0'; } GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, @@ -201,7 +201,7 @@ send_fragment (void *cls, struct GNUNET_MULTICAST_MessageHeader *msg, res->header.size = htons (sizeof (struct FragmentResult) + msg_size); res->op_id = sc->op_id; res->psycstore_flags = htonl (flags); - memcpy (&res[1], msg, msg_size); + GNUNET_memcpy (&res[1], msg, msg_size); GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending fragment %ld to client\n", GNUNET_ntohll (msg->fragment_id)); @@ -229,8 +229,8 @@ send_state_var (void *cls, const char *name, res->header.size = htons (sizeof (struct StateResult) + name_size + value_size); res->op_id = sc->op_id; res->name_size = htons (name_size); - memcpy (&res[1], name, name_size); - memcpy ((char *) &res[1] + name_size, value, value_size); + GNUNET_memcpy (&res[1], name, name_size); + GNUNET_memcpy ((char *) &res[1] + name_size, value, value_size); GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending state variable %s to client\n", name); GNUNET_SERVER_notification_context_add (nc, sc->client); @@ -383,7 +383,8 @@ handle_message_get (void *cls, { GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Message get: invalid method prefix. size: %u < %u?\n", - size, sizeof (*req) + 1); + size, + (unsigned int) (sizeof (*req) + 1)); GNUNET_break (0); GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); return; @@ -562,13 +563,13 @@ recv_state_message_part (void *cls, { scls->mod_oper = pmod->oper; scls->mod_name = GNUNET_malloc (name_size); - memcpy (scls->mod_name, name, name_size); + GNUNET_memcpy (scls->mod_name, name, name_size); scls->mod_value_size = value_size; scls->mod_value = GNUNET_malloc (scls->mod_value_size); scls->mod_value_remaining = scls->mod_value_size - (psize - sizeof (*pmod) - name_size); - memcpy (scls->mod_value, value, value_size - scls->mod_value_remaining); + GNUNET_memcpy (scls->mod_value, value, value_size - scls->mod_value_remaining); } } scls->msg_state = GNUNET_PSYC_MESSAGE_STATE_MODIFIER; @@ -584,7 +585,7 @@ recv_state_message_part (void *cls, scls->msg_state = GNUNET_PSYC_MESSAGE_STATE_ERROR; } psize = ntohs (pmsg->size); - memcpy (scls->mod_value + (scls->mod_value_size - scls->mod_value_remaining), + GNUNET_memcpy (scls->mod_value + (scls->mod_value_size - scls->mod_value_remaining), &pmsg[1], psize - sizeof (*pmsg)); scls->mod_value_remaining -= psize - sizeof (*pmsg); if (0 == scls->mod_value_remaining) @@ -813,7 +814,7 @@ handle_state_get (void *cls, if (GNUNET_NO == ret && name_size >= 5) /* min: _a_b\0 */ { char *p, *n = GNUNET_malloc (name_size); - memcpy (n, name, name_size); + GNUNET_memcpy (n, name, name_size); while (&n[1] < (p = strrchr (n, '_')) && GNUNET_NO == ret) { *p = '\0'; @@ -946,11 +947,15 @@ run (void *cls, struct GNUNET_SERVER_Handle *server, GNUNET_CONFIGURATION_get_value_string (cfg, "psycstore", "database", &database)) { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "No database backend configured\n"); + GNUNET_log_config_missing (GNUNET_ERROR_TYPE_ERROR, + "psycstore", + "database"); } else { - GNUNET_asprintf (&db_lib_name, "libgnunet_plugin_psycstore_%s", database); + GNUNET_asprintf (&db_lib_name, + "libgnunet_plugin_psycstore_%s", + database); db = GNUNET_PLUGIN_load (db_lib_name, (void *) cfg); GNUNET_free (database); } @@ -966,8 +971,8 @@ run (void *cls, struct GNUNET_SERVER_Handle *server, stats = GNUNET_STATISTICS_create ("psycstore", cfg); GNUNET_SERVER_add_handlers (server, handlers); nc = GNUNET_SERVER_notification_context_create (server, 1); - GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_FOREVER_REL, &shutdown_task, - NULL); + GNUNET_SCHEDULER_add_shutdown (&shutdown_task, + NULL); }