convert fs publish to MQ
[oweals/gnunet.git] / src / core / gnunet-service-core.c
1 /*
2      This file is part of GNUnet.
3      Copyright (C) 2009, 2010, 2011 GNUnet e.V.
4
5      GNUnet is free software; you can redistribute it and/or modify
6      it under the terms of the GNU General Public License as published
7      by the Free Software Foundation; either version 3, or (at your
8      option) any later version.
9
10      GNUnet is distributed in the hope that it will be useful, but
11      WITHOUT ANY WARRANTY; without even the implied warranty of
12      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
13      General Public License for more details.
14
15      You should have received a copy of the GNU General Public License
16      along with GNUnet; see the file COPYING.  If not, write to the
17      Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
18      Boston, MA 02110-1301, USA.
19 */
20
21 /**
22  * @file core/gnunet-service-core.c
23  * @brief high-level P2P messaging
24  * @author Christian Grothoff
25  */
26 #include "platform.h"
27 #include <gcrypt.h>
28 #include "gnunet_util_lib.h"
29 #include "gnunet-service-core.h"
30 #include "gnunet-service-core_clients.h"
31 #include "gnunet-service-core_kx.h"
32 #include "gnunet-service-core_neighbours.h"
33 #include "gnunet-service-core_sessions.h"
34 #include "gnunet-service-core_typemap.h"
35
36
37 /**
38  * Our identity.
39  */
40 struct GNUNET_PeerIdentity GSC_my_identity;
41
42 /**
43  * Our configuration.
44  */
45 const struct GNUNET_CONFIGURATION_Handle *GSC_cfg;
46
47 /**
48  * For creating statistics.
49  */
50 struct GNUNET_STATISTICS_Handle *GSC_stats;
51
52 /**
53  * Handle to the server of the core service.
54  */
55 static struct GNUNET_SERVER_Handle *GSC_server;
56
57
58 /**
59  * Last task run during shutdown.  Disconnects us from
60  * the transport.
61  *
62  * @param cls NULL, unused
63  */
64 static void
65 shutdown_task (void *cls)
66 {
67   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
68               "Core service shutting down.\n");
69   GSC_CLIENTS_done ();
70   GSC_NEIGHBOURS_done ();
71   GSC_SESSIONS_done ();
72   GSC_KX_done ();
73   GSC_TYPEMAP_done ();
74   if (NULL != GSC_stats)
75   {
76     GNUNET_STATISTICS_destroy (GSC_stats, GNUNET_NO);
77     GSC_stats = NULL;
78   }
79   GSC_cfg = NULL;
80 }
81
82
83 /**
84  * Initiate core service.
85  *
86  * @param cls closure
87  * @param server the initialized server
88  * @param c configuration to use
89  */
90 static void
91 run (void *cls, struct GNUNET_SERVER_Handle *server,
92      const struct GNUNET_CONFIGURATION_Handle *c)
93 {
94   struct GNUNET_CRYPTO_EddsaPrivateKey *pk;
95   char *keyfile;
96
97   GSC_cfg = c;
98   GSC_server = server;
99   if (GNUNET_OK !=
100       GNUNET_CONFIGURATION_get_value_filename (GSC_cfg, "PEER", "PRIVATE_KEY",
101                                                &keyfile))
102   {
103     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
104                 _("Core service is lacking HOSTKEY configuration setting.  Exiting.\n"));
105     GNUNET_SCHEDULER_shutdown ();
106     return;
107   }
108   GSC_stats = GNUNET_STATISTICS_create ("core", GSC_cfg);
109   GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
110                                  NULL);
111   GNUNET_SERVER_suspend (server);
112   GSC_TYPEMAP_init ();
113   pk = GNUNET_CRYPTO_eddsa_key_create_from_file (keyfile);
114   GNUNET_free (keyfile);
115   GNUNET_assert (NULL != pk);
116   if ((GNUNET_OK != GSC_KX_init (pk,
117                                  server)) ||
118       (GNUNET_OK != GSC_NEIGHBOURS_init ()))
119   {
120     GNUNET_SCHEDULER_shutdown ();
121     return;
122   }
123   GSC_SESSIONS_init ();
124   GSC_CLIENTS_init (GSC_server);
125   GNUNET_SERVER_resume (GSC_server);
126   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
127               _("Core service of `%4s' ready.\n"),
128               GNUNET_i2s (&GSC_my_identity));
129 }
130
131
132 /**
133  * The main function for the transport service.
134  *
135  * @param argc number of arguments from the command line
136  * @param argv command line arguments
137  * @return 0 ok, 1 on error
138  */
139 int
140 main (int argc, char *const *argv)
141 {
142   return (GNUNET_OK ==
143           GNUNET_SERVICE_run (argc, argv, "core",
144                               GNUNET_SERVICE_OPTION_NONE,
145                               &run, NULL)) ? 0 : 1;
146 }
147
148 /* end of gnunet-service-core.c */