GNUnet 0.22.2
gnunet-daemon-hostlist_server.h File Reference

hostlist support. More...

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. More...
 
void GNUNET_HOSTLIST_server_stop (void)
 Stop server offering our hostlist. More...
 

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 725 of file gnunet-daemon-hostlist_server.c.

730{
731 unsigned long long port;
732 char *hostname;
733 char *ipv4;
734 char *ipv6;
735 size_t size;
736 struct in_addr i4;
737 struct in6_addr i6;
738 struct sockaddr_in v4;
739 struct sockaddr_in6 v6;
740 const struct sockaddr *sa4;
741 const struct sockaddr *sa6;
742
744 advertising = advertise;
745 if (! advertising)
746 {
748 "Advertising not enabled on this hostlist server\n");
749 }
750 else
751 {
753 "Advertising enabled on this hostlist server\n");
754 }
755 cfg = c;
756 stats = st;
758 if (NULL == peerstore)
759 {
761 _ ("Could not access PEERSTORE service. Exiting.\n"));
762 return GNUNET_SYSERR;
763 }
765 "HOSTLIST",
766 "HTTPPORT",
767 &port))
768 return GNUNET_SYSERR;
769 if ((0 == port) || (port > UINT16_MAX))
770 {
772 _ ("Invalid port number %llu. Exiting.\n"),
773 port);
774 return GNUNET_SYSERR;
775 }
776
777 if (GNUNET_SYSERR ==
779 "HOSTLIST",
780 "EXTERNAL_DNS_NAME",
781 &hostname))
782 hostname = GNUNET_RESOLVER_local_fqdn_get ();
784 _ ("Hostlist service starts on %s:%llu\n"),
785 hostname,
786 port);
787 if (NULL != hostname)
788 {
789 size = strlen (hostname);
790 if (size + 15 > MAX_URL_LEN)
791 {
792 GNUNET_break (0);
793 }
794 else
795 {
797 "http://%s:%u/",
798 hostname,
799 (unsigned int) port);
801 _ ("Address to obtain hostlist: `%s'\n"),
803 }
804 GNUNET_free (hostname);
805 }
806
807 if (GNUNET_CONFIGURATION_have_value (cfg, "HOSTLIST", "BINDTOIPV4"))
808 {
810 "HOSTLIST",
811 "BINDTOIP",
812 &ipv4))
813 {
814 GNUNET_log (
816 _ ("BINDTOIP does not a valid IPv4 address! Ignoring BINDTOIPV4.\n"));
817 }
818 }
819 else
820 ipv4 = NULL;
821 if (GNUNET_CONFIGURATION_have_value (cfg, "HOSTLIST", "BINDTOIPV6"))
822 {
824 "HOSTLIST",
825 "BINDTOIP",
826 &ipv6))
827 {
828 GNUNET_log (
830 _ ("BINDTOIP does not a valid IPv4 address! Ignoring BINDTOIPV6.\n"));
831 }
832 }
833 else
834 ipv6 = NULL;
835 sa4 = NULL;
836 if (NULL != ipv4)
837 {
838 if (1 == inet_pton (AF_INET, ipv4, &i4))
839 {
840 memset (&v4, 0, sizeof(v4));
841 v4.sin_family = AF_INET;
842 v4.sin_addr = i4;
843 v4.sin_port = htons (port);
844#if HAVE_SOCKADDR_IN_SIN_LEN
845 v4.sin_len = sizeof(v4);
846#endif
847 sa4 = (const struct sockaddr *) &v4;
848 }
849 else
851 _ (
852 "`%s' is not a valid IPv4 address! Ignoring BINDTOIPV4.\n"),
853 ipv4);
855 }
856 sa6 = NULL;
857 if (NULL != ipv6)
858 {
859 if (1 == inet_pton (AF_INET6, ipv6, &i6))
860 {
861 memset (&v6, 0, sizeof(v6));
862 v6.sin6_family = AF_INET6;
863 v6.sin6_addr = i6;
864 v6.sin6_port = htons (port);
865#if HAVE_SOCKADDR_IN_SIN_LEN
866 v6.sin6_len = sizeof(v6);
867#endif
868 sa6 = (const struct sockaddr *) &v6;
869 }
870 else
872 _ (
873 "`%s' is not a valid IPv6 address! Ignoring BINDTOIPV6.\n"),
874 ipv6);
876 }
877
878 daemon_handle_v6 = MHD_start_daemon (MHD_USE_IPv6 | MHD_USE_DEBUG,
879 (uint16_t) port,
881 NULL,
883 NULL,
884 MHD_OPTION_CONNECTION_LIMIT,
885 (unsigned int) 128,
886 MHD_OPTION_PER_IP_CONNECTION_LIMIT,
887 (unsigned int) 32,
888 MHD_OPTION_CONNECTION_TIMEOUT,
889 (unsigned int) 16,
890 MHD_OPTION_CONNECTION_MEMORY_LIMIT,
891 (size_t) (16 * 1024),
892 MHD_OPTION_SOCK_ADDR,
893 sa6,
894 MHD_OPTION_END);
895 daemon_handle_v4 = MHD_start_daemon (MHD_NO_FLAG | MHD_USE_DEBUG,
896 (uint16_t) port,
898 NULL,
900 NULL,
901 MHD_OPTION_CONNECTION_LIMIT,
902 (unsigned int) 128,
903 MHD_OPTION_PER_IP_CONNECTION_LIMIT,
904 (unsigned int) 32,
905 MHD_OPTION_CONNECTION_TIMEOUT,
906 (unsigned int) 16,
907 MHD_OPTION_CONNECTION_MEMORY_LIMIT,
908 (size_t) (16 * 1024),
909 MHD_OPTION_SOCK_ADDR,
910 sa4,
911 MHD_OPTION_END);
912
913 if ((NULL == daemon_handle_v6) && (NULL == daemon_handle_v4))
914 {
916 _ ("Could not start hostlist HTTP server on port %u\n"),
917 (unsigned short) port);
918 return GNUNET_SYSERR;
919 }
920
921 core = co;
923 if (NULL != daemon_handle_v4)
925 if (NULL != daemon_handle_v6)
930 NULL);
931 return GNUNET_OK;
932}
static uint16_t port
Port number.
Definition: gnunet-bcd.c:146
static struct GNUNET_SCHEDULER_Task * st
The shutdown task.
static GNUNET_CORE_ConnectEventHandler server_ch
Handle to hostlist server's connect handler.
#define MAX_URL_LEN
How long can hostlist URLs be?
static struct MHD_Daemon * daemon_handle_v6
Handle to the HTTP server as provided by libmicrohttpd for IPv6.
static struct MHD_Daemon * daemon_handle_v4
Handle to the HTTP server as provided by libmicrohttpd for IPv4.
static struct GNUNET_SCHEDULER_Task * hostlist_task_v4
Our primary task for IPv4.
static struct GNUNET_CORE_Handle * core
Handle to the core service (NULL until we've connected to it).
static int advertising
Set if we are allowed to advertise our hostlist to others.
static void * connect_handler(void *cls, const struct GNUNET_PeerIdentity *peer, struct GNUNET_MQ_Handle *mq)
Method called whenever a given peer connects.
static struct GNUNET_STATISTICS_Handle * stats
For keeping statistics.
struct GNUNET_CONTAINER_MultiPeerMap * hellos
Map with hellos we build the hostlist with.
static const struct GNUNET_CONFIGURATION_Handle * cfg
Our configuration.
static struct GNUNET_SCHEDULER_Task * hostlist_task_v6
Our primary task for IPv6.
static struct GNUNET_PEERSTORE_Handle * peerstore
Handle to the PEERSTORE service.
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.
static void start_notify(void *cls)
struct GNUNET_SCHEDULER_Task * peerstore_notify_task
The task to delayed start the notification process initially.
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.
static char * hostlist_uri
Buffer for the hostlist address.
static MHD_RESULT accept_policy_callback(void *cls, const struct sockaddr *addr, socklen_t addrlen)
Hostlist access policy (very permissive, allows everything).
static int ipv4
Option -4: IPv4 requested.
Definition: gnunet-vpn.c:60
static int ipv6
Option -6: IPv6 requested.
Definition: gnunet-vpn.c:65
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.
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.
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.
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).
#define GNUNET_log(kind,...)
@ GNUNET_OK
@ GNUNET_YES
@ GNUNET_SYSERR
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.
@ GNUNET_ERROR_TYPE_WARNING
@ GNUNET_ERROR_TYPE_ERROR
@ GNUNET_ERROR_TYPE_DEBUG
@ GNUNET_ERROR_TYPE_INFO
int int GNUNET_asprintf(char **buf, const char *format,...) __attribute__((format(printf
Like asprintf, just portable.
#define GNUNET_free(ptr)
Wrapper around free.
struct GNUNET_PEERSTORE_Handle * GNUNET_PEERSTORE_connect(const struct GNUNET_CONFIGURATION_Handle *cfg)
Connect to the PEERSTORE service.
char * GNUNET_RESOLVER_local_fqdn_get(void)
Get local fully qualified domain name.
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:1276
#define GNUNET_TIME_UNIT_MINUTES
One minute.
static unsigned int size
Size of the "table".
Definition: peer.c:68
#define _(String)
GNU gettext support macro.
Definition: platform.h:178

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 939 of file gnunet-daemon-hostlist_server.c.

940{
941 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Hostlist server shutdown\n");
942 if (NULL != hostlist_task_v6)
943 {
945 hostlist_task_v6 = NULL;
946 }
947 if (NULL != hostlist_task_v4)
948 {
950 hostlist_task_v4 = NULL;
951 }
952 if (NULL != daemon_handle_v4)
953 {
954 MHD_stop_daemon (daemon_handle_v4);
955 daemon_handle_v4 = NULL;
956 }
957 if (NULL != daemon_handle_v6)
958 {
959 MHD_stop_daemon (daemon_handle_v6);
960 daemon_handle_v6 = NULL;
961 }
962 if (NULL != response)
963 {
964 MHD_destroy_response (response);
965 response = NULL;
966 }
967 if (NULL != response_json)
968 {
969 MHD_destroy_response (response_json);
970 response_json = NULL;
971 }
972 if (NULL != peerstore_notify)
973 {
975 peerstore_notify = NULL;
976 }
977 else if (NULL != peerstore_notify_task)
978 {
980 }
981 if (NULL != builder)
982 {
985 builder = NULL;
986 }
987 if (NULL != peerstore)
988 {
990 peerstore = NULL;
991 }
992 cfg = NULL;
993 stats = NULL;
994 core = NULL;
995}
static struct MHD_Response * response
Our canonical response.
static struct HostSet * builder
NULL if we are not currently iterating over peer information.
static struct GNUNET_PEERSTORE_Monitor * peerstore_notify
Our peerstore notification context.
static struct MHD_Response * response_json
Our json response.
void GNUNET_PEERSTORE_monitor_stop(struct GNUNET_PEERSTORE_Monitor *zm)
Stop monitoring.
void GNUNET_PEERSTORE_disconnect(struct GNUNET_PEERSTORE_Handle *h)
Disconnect from the PEERSTORE service.
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
Definition: scheduler.c:979
char * data
Place where we accumulate all of the HELLO messages.

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: