GNUnet 0.28.1-dev.3-2-g4c5d45bb5
 
Loading...
Searching...
No Matches
Functions
gnunet-daemon-hostlist_server.h File Reference

hostlist support. More...

#include "gnunet_core_service.h"
#include "gnunet_statistics_service.h"
#include "gnunet_util_lib.h"
Include dependency graph for gnunet-daemon-hostlist_server.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

int GNUNET_HOSTLIST_server_start (const struct GNUNET_CONFIGURATION_Handle *c, struct GNUNET_STATISTICS_Handle *st, struct GNUNET_CORE_Handle *core, GNUNET_CORE_ConnectEventHandler *server_ch, int advertise)
 Start server offering our hostlist.
 
void GNUNET_HOSTLIST_server_stop (void)
 Stop server offering our hostlist.
 

Detailed Description

hostlist support.

Downloads HELLOs via HTTP.

Author
Christian Grothoff

Definition in file gnunet-daemon-hostlist_server.h.

Function Documentation

◆ GNUNET_HOSTLIST_server_start()

int GNUNET_HOSTLIST_server_start ( const struct GNUNET_CONFIGURATION_Handle *  c,
struct GNUNET_STATISTICS_Handle *  st,
struct GNUNET_CORE_Handle *  co,
GNUNET_CORE_ConnectEventHandler *  server_ch,
int  advertise 
)

Start server offering our hostlist.

Parameters
cconfiguration to use
ststatistics handle to use
cocore handle to use
[out]server_chset to handler for CORE connect events
advertiseGNUNET_YES if we should advertise our hostlist
Returns
GNUNET_OK on success

Definition at line 753 of file gnunet-daemon-hostlist_server.c.

758{
759 unsigned long long port;
760 char *hostname;
761 char *ipv4;
762 char *ipv6;
763 size_t size;
764 struct in_addr i4;
765 struct in6_addr i6;
766 struct sockaddr_in v4;
767 struct sockaddr_in6 v6;
768 const struct sockaddr *sa4;
769 const struct sockaddr *sa6;
770
771 hellos = GNUNET_CONTAINER_multipeermap_create (16, GNUNET_YES);
772 advertising = advertise;
773 if (! advertising)
774 {
775 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
776 "Advertising not enabled on this hostlist server\n");
777 }
778 else
779 {
780 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
781 "Advertising enabled on this hostlist server\n");
782 }
783 cfg = c;
784 stats = st;
785 peerstore = GNUNET_PEERSTORE_connect (cfg);
786 if (NULL == peerstore)
787 {
788 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
789 _ ("Could not access PEERSTORE service. Exiting.\n"));
790 return GNUNET_SYSERR;
791 }
792 if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (cfg,
793 "HOSTLIST",
794 "HTTPPORT",
795 &port))
796 return GNUNET_SYSERR;
797 if ((0 == port) || (port > UINT16_MAX))
798 {
799 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
800 _ ("Invalid port number %llu. Exiting.\n"),
801 port);
802 return GNUNET_SYSERR;
803 }
804
805 if (GNUNET_SYSERR ==
806 GNUNET_CONFIGURATION_get_value_string (cfg,
807 "HOSTLIST",
808 "EXTERNAL_DNS_NAME",
809 &hostname))
810 hostname = GNUNET_RESOLVER_local_fqdn_get ();
811 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
812 _ ("Hostlist service starts on %s:%llu\n"),
813 hostname,
814 port);
815 if (NULL != hostname)
816 {
817 size = strlen (hostname);
818 if (size + 15 > MAX_URL_LEN)
819 {
820 GNUNET_break (0);
821 }
822 else
823 {
824 GNUNET_asprintf (&hostlist_uri,
825 "http://%s:%u/",
826 hostname,
827 (unsigned int) port);
828 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
829 _ ("Address to obtain hostlist: `%s'\n"),
830 hostlist_uri);
831 }
832 GNUNET_free (hostname);
833 }
834
835 if (GNUNET_CONFIGURATION_have_value (cfg, "HOSTLIST", "BINDTOIPV4"))
836 {
837 if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_string (cfg,
838 "HOSTLIST",
839 "BINDTOIP",
840 &ipv4))
841 {
842 GNUNET_log (
843 GNUNET_ERROR_TYPE_WARNING,
844 _ ("BINDTOIP does not a valid IPv4 address! Ignoring BINDTOIPV4.\n"));
845 }
846 }
847 else
848 ipv4 = NULL;
849 if (GNUNET_CONFIGURATION_have_value (cfg, "HOSTLIST", "BINDTOIPV6"))
850 {
851 if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_string (cfg,
852 "HOSTLIST",
853 "BINDTOIP",
854 &ipv6))
855 {
856 GNUNET_log (
857 GNUNET_ERROR_TYPE_WARNING,
858 _ ("BINDTOIP does not a valid IPv4 address! Ignoring BINDTOIPV6.\n"));
859 }
860 }
861 else
862 ipv6 = NULL;
863 sa4 = NULL;
864 if (NULL != ipv4)
865 {
866 if (1 == inet_pton (AF_INET, ipv4, &i4))
867 {
868 memset (&v4, 0, sizeof(v4));
869 v4.sin_family = AF_INET;
870 v4.sin_addr = i4;
871 v4.sin_port = htons (port);
872#if HAVE_SOCKADDR_IN_SIN_LEN
873 v4.sin_len = sizeof(v4);
874#endif
875 sa4 = (const struct sockaddr *) &v4;
876 }
877 else
878 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
879 _ (
880 "`%s' is not a valid IPv4 address! Ignoring BINDTOIPV4.\n"),
881 ipv4);
882 GNUNET_free (ipv4);
883 }
884 sa6 = NULL;
885 if (NULL != ipv6)
886 {
887 if (1 == inet_pton (AF_INET6, ipv6, &i6))
888 {
889 memset (&v6, 0, sizeof(v6));
890 v6.sin6_family = AF_INET6;
891 v6.sin6_addr = i6;
892 v6.sin6_port = htons (port);
893#if HAVE_SOCKADDR_IN_SIN_LEN
894 v6.sin6_len = sizeof(v6);
895#endif
896 sa6 = (const struct sockaddr *) &v6;
897 }
898 else
899 GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
900 _ (
901 "`%s' is not a valid IPv6 address! Ignoring BINDTOIPV6.\n"),
902 ipv6);
903 GNUNET_free (ipv6);
904 }
905
906 daemon_handle_v6 = MHD_start_daemon (MHD_USE_IPv6 | MHD_USE_DEBUG,
907 (uint16_t) port,
908 &accept_policy_callback,
909 NULL,
910 &access_handler_callback,
911 NULL,
912 MHD_OPTION_CONNECTION_LIMIT,
913 (unsigned int) 128,
914 MHD_OPTION_PER_IP_CONNECTION_LIMIT,
915 (unsigned int) 32,
916 MHD_OPTION_CONNECTION_TIMEOUT,
917 (unsigned int) 16,
918 MHD_OPTION_CONNECTION_MEMORY_LIMIT,
919 (size_t) (16 * 1024),
920 MHD_OPTION_SOCK_ADDR,
921 sa6,
922 MHD_OPTION_END);
923 daemon_handle_v4 = MHD_start_daemon (MHD_NO_FLAG | MHD_USE_DEBUG,
924 (uint16_t) port,
925 &accept_policy_callback,
926 NULL,
927 &access_handler_callback,
928 NULL,
929 MHD_OPTION_CONNECTION_LIMIT,
930 (unsigned int) 128,
931 MHD_OPTION_PER_IP_CONNECTION_LIMIT,
932 (unsigned int) 32,
933 MHD_OPTION_CONNECTION_TIMEOUT,
934 (unsigned int) 16,
935 MHD_OPTION_CONNECTION_MEMORY_LIMIT,
936 (size_t) (16 * 1024),
937 MHD_OPTION_SOCK_ADDR,
938 sa4,
939 MHD_OPTION_END);
940
941 if ((NULL == daemon_handle_v6) && (NULL == daemon_handle_v4))
942 {
943 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
944 _ ("Could not start hostlist HTTP server on port %u\n"),
945 (unsigned short) port);
946 return GNUNET_SYSERR;
947 }
948
949 core = co;
950 *server_ch = &connect_handler;
951 if (NULL != daemon_handle_v4)
952 hostlist_task_v4 = prepare_daemon (daemon_handle_v4);
953 if (NULL != daemon_handle_v6)
954 hostlist_task_v6 = prepare_daemon (daemon_handle_v6);
955 peerstore_notify_task = GNUNET_SCHEDULER_add_delayed (
956 GNUNET_TIME_UNIT_MINUTES,
957 start_notify,
958 NULL);
959 return GNUNET_OK;
960}
port
static uint16_t port
Port number.
Definition gnunet-bcd.c:146
st
static struct GNUNET_SCHEDULER_Task * st
The shutdown task.
Definition gnunet-conversation-test.c:82
server_ch
static GNUNET_CORE_ConnectEventHandler server_ch
Handle to hostlist server's connect handler.
Definition gnunet-daemon-hostlist.c:48
MAX_URL_LEN
#define MAX_URL_LEN
How long can hostlist URLs be?
Definition gnunet-daemon-hostlist.h:36
daemon_handle_v6
static struct MHD_Daemon * daemon_handle_v6
Handle to the HTTP server as provided by libmicrohttpd for IPv6.
Definition gnunet-daemon-hostlist_server.c:55
connect_handler
static void * connect_handler(void *cls, const struct GNUNET_PeerIdentity *peer, struct GNUNET_MQ_Handle *mq, enum GNUNET_CORE_PeerClass class)
Method called whenever a given peer connects.
Definition gnunet-daemon-hostlist_server.c:511
daemon_handle_v4
static struct MHD_Daemon * daemon_handle_v4
Handle to the HTTP server as provided by libmicrohttpd for IPv4.
Definition gnunet-daemon-hostlist_server.c:60
hostlist_task_v4
static struct GNUNET_SCHEDULER_Task * hostlist_task_v4
Our primary task for IPv4.
Definition gnunet-daemon-hostlist_server.c:92
core
static struct GNUNET_CORE_Handle * core
Handle to the core service (NULL until we've connected to it).
Definition gnunet-daemon-hostlist_server.c:75
advertising
static int advertising
Set if we are allowed to advertise our hostlist to others.
Definition gnunet-daemon-hostlist_server.c:117
stats
static struct GNUNET_STATISTICS_Handle * stats
For keeping statistics.
Definition gnunet-daemon-hostlist_server.c:70
hellos
struct GNUNET_CONTAINER_MultiPeerMap * hellos
Map with hellos we build the hostlist with.
Definition gnunet-daemon-hostlist_server.c:50
cfg
static const struct GNUNET_CONFIGURATION_Handle * cfg
Our configuration.
Definition gnunet-daemon-hostlist_server.c:65
hostlist_task_v6
static struct GNUNET_SCHEDULER_Task * hostlist_task_v6
Our primary task for IPv6.
Definition gnunet-daemon-hostlist_server.c:97
peerstore
static struct GNUNET_PEERSTORE_Handle * peerstore
Handle to the PEERSTORE service.
Definition gnunet-daemon-hostlist_server.c:112
prepare_daemon
static struct GNUNET_SCHEDULER_Task * prepare_daemon(struct MHD_Daemon *daemon_handle)
Function that queries MHD's select sets and starts the task waiting for them.
Definition gnunet-daemon-hostlist_server.c:667
start_notify
static void start_notify(void *cls)
Definition gnunet-daemon-hostlist_server.c:723
peerstore_notify_task
struct GNUNET_SCHEDULER_Task * peerstore_notify_task
The task to delayed start the notification process initially.
Definition gnunet-daemon-hostlist_server.c:81
access_handler_callback
static MHD_RESULT access_handler_callback(void *cls, struct MHD_Connection *connection, const char *url, const char *method, const char *version, const char *upload_data, size_t *upload_data_size, void **con_cls)
Main request handler.
Definition gnunet-daemon-hostlist_server.c:373
hostlist_uri
static char * hostlist_uri
Buffer for the hostlist address.
Definition gnunet-daemon-hostlist_server.c:122
accept_policy_callback
static MHD_RESULT accept_policy_callback(void *cls, const struct sockaddr *addr, socklen_t addrlen)
Hostlist access policy (very permissive, allows everything).
Definition gnunet-daemon-hostlist_server.c:306
ipv4
static int ipv4
Option -4: IPv4 requested.
Definition gnunet-vpn.c:60
ipv6
static int ipv6
Option -6: IPv6 requested.
Definition gnunet-vpn.c:65
GNUNET_CONFIGURATION_get_value_number
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_number(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option, unsigned long long *number)
Get a configuration value that should be a number.
Definition configuration.c:1847
GNUNET_CONFIGURATION_get_value_string
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_string(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option, char **value)
Get a configuration value that should be a string.
Definition configuration.c:1988
GNUNET_CONFIGURATION_have_value
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_have_value(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option)
Test if we have a value for a particular option.
Definition configuration.c:2081
GNUNET_CONTAINER_multipeermap_create
struct GNUNET_CONTAINER_MultiPeerMap * GNUNET_CONTAINER_multipeermap_create(unsigned int len, int do_not_copy_keys)
Create a multi peer map (hash map for public keys of peers).
Definition container_multipeermap.c:179
GNUNET_log
#define GNUNET_log(kind,...)
Definition gnunet_common.h:552
GNUNET_OK
@ GNUNET_OK
Definition gnunet_common.h:115
GNUNET_YES
@ GNUNET_YES
Definition gnunet_common.h:117
GNUNET_SYSERR
@ GNUNET_SYSERR
Definition gnunet_common.h:113
GNUNET_break
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.
Definition gnunet_common.h:1056
GNUNET_ERROR_TYPE_WARNING
@ GNUNET_ERROR_TYPE_WARNING
Definition gnunet_common.h:419
GNUNET_ERROR_TYPE_ERROR
@ GNUNET_ERROR_TYPE_ERROR
Definition gnunet_common.h:418
GNUNET_ERROR_TYPE_DEBUG
@ GNUNET_ERROR_TYPE_DEBUG
Definition gnunet_common.h:425
GNUNET_ERROR_TYPE_INFO
@ GNUNET_ERROR_TYPE_INFO
Definition gnunet_common.h:424
GNUNET_asprintf
int int GNUNET_asprintf(char **buf, const char *format,...) __attribute__((format(printf
Like asprintf, just portable.
GNUNET_free
#define GNUNET_free(ptr)
Wrapper around free.
Definition gnunet_common.h:1426
GNUNET_PEERSTORE_connect
struct GNUNET_PEERSTORE_Handle * GNUNET_PEERSTORE_connect(const struct GNUNET_CONFIGURATION_Handle *cfg)
Connect to the PEERSTORE service.
Definition peerstore_api.c:495
GNUNET_RESOLVER_local_fqdn_get
char * GNUNET_RESOLVER_local_fqdn_get(void)
Get local fully qualified domain name.
Definition resolver_api.c:1149
GNUNET_SCHEDULER_add_delayed
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_delayed(struct GNUNET_TIME_Relative delay, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay.
Definition scheduler.c:1283
GNUNET_TIME_UNIT_MINUTES
#define GNUNET_TIME_UNIT_MINUTES
One minute.
Definition gnunet_time_lib.h:161
size
static unsigned int size
Size of the "table".
Definition peer.c:68
_
#define _(String)
GNU gettext support macro.
Definition platform.h:179

References _, accept_policy_callback(), access_handler_callback(), advertising, cfg, connect_handler(), core, daemon_handle_v4, daemon_handle_v6, GNUNET_asprintf(), GNUNET_break, GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_have_value(), GNUNET_CONTAINER_multipeermap_create(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_PEERSTORE_connect(), GNUNET_RESOLVER_local_fqdn_get(), GNUNET_SCHEDULER_add_delayed(), GNUNET_SYSERR, GNUNET_TIME_UNIT_MINUTES, GNUNET_YES, hellos, hostlist_task_v4, hostlist_task_v6, hostlist_uri, ipv4, ipv6, MAX_URL_LEN, peerstore, peerstore_notify_task, port, prepare_daemon(), server_ch, size, st, start_notify(), and stats.

Referenced by run().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ GNUNET_HOSTLIST_server_stop()

void GNUNET_HOSTLIST_server_stop ( void  )

Stop server offering our hostlist.

Definition at line 967 of file gnunet-daemon-hostlist_server.c.

968{
969 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Hostlist server shutdown\n");
970 if (NULL != hostlist_task_v6)
971 {
972 GNUNET_SCHEDULER_cancel (hostlist_task_v6);
973 hostlist_task_v6 = NULL;
974 }
975 if (NULL != hostlist_task_v4)
976 {
977 GNUNET_SCHEDULER_cancel (hostlist_task_v4);
978 hostlist_task_v4 = NULL;
979 }
980 if (NULL != daemon_handle_v4)
981 {
982 MHD_stop_daemon (daemon_handle_v4);
983 daemon_handle_v4 = NULL;
984 }
985 if (NULL != daemon_handle_v6)
986 {
987 MHD_stop_daemon (daemon_handle_v6);
988 daemon_handle_v6 = NULL;
989 }
990 if (NULL != response)
991 {
992 MHD_destroy_response (response);
993 response = NULL;
994 }
995 if (NULL != response_json)
996 {
997 MHD_destroy_response (response_json);
998 response_json = NULL;
999 }
1000 if (NULL != peerstore_notify)
1001 {
1002 GNUNET_PEERSTORE_monitor_stop (peerstore_notify);
1003 peerstore_notify = NULL;
1004 }
1005 else if (NULL != peerstore_notify_task)
1006 {
1007 GNUNET_SCHEDULER_cancel (peerstore_notify_task);
1008 }
1009 if (NULL != builder)
1010 {
1011 GNUNET_free (builder->data);
1012 GNUNET_free (builder);
1013 builder = NULL;
1014 }
1015 if (NULL != peerstore)
1016 {
1017 GNUNET_PEERSTORE_disconnect (peerstore);
1018 peerstore = NULL;
1019 }
1020 cfg = NULL;
1021 stats = NULL;
1022 core = NULL;
1023}
response
static struct MHD_Response * response
Our canonical response.
Definition gnunet-daemon-hostlist_server.c:102
builder
static struct HostSet * builder
NULL if we are not currently iterating over peer information.
Definition gnunet-daemon-hostlist_server.c:145
peerstore_notify
static struct GNUNET_PEERSTORE_Monitor * peerstore_notify
Our peerstore notification context.
Definition gnunet-daemon-hostlist_server.c:87
response_json
static struct MHD_Response * response_json
Our json response.
Definition gnunet-daemon-hostlist_server.c:107
GNUNET_PEERSTORE_monitor_stop
void GNUNET_PEERSTORE_monitor_stop(struct GNUNET_PEERSTORE_Monitor *zm)
Stop monitoring.
Definition peerstore_api_monitor.c:303
GNUNET_PEERSTORE_disconnect
void GNUNET_PEERSTORE_disconnect(struct GNUNET_PEERSTORE_Handle *h)
Disconnect from the PEERSTORE service.
Definition peerstore_api.c:526
GNUNET_SCHEDULER_cancel
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
Definition scheduler.c:986
HostSet::data
char * data
Place where we accumulate all of the HELLO messages.
Definition gnunet-daemon-hostlist_server.c:133

References builder, cfg, core, daemon_handle_v4, daemon_handle_v6, HostSet::data, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_log, GNUNET_PEERSTORE_disconnect(), GNUNET_PEERSTORE_monitor_stop(), GNUNET_SCHEDULER_cancel(), hostlist_task_v4, hostlist_task_v6, peerstore, peerstore_notify, peerstore_notify_task, response, response_json, and stats.

Referenced by cleaning_task().

Here is the call graph for this function:
Here is the caller graph for this function: