#include <tinyara/config.h>
#include <apps/shell/tash.h>
-#include <apps/netutils/dhcpc.h>
-#include <apps/netutils/netlib.h>
-#include <apps/netutils/webclient.h>
+#include <protocols/dhcpc.h>
+#include <protocols/netlib.h>
+#include <protocols/webclient.h>
#include <net/if.h>
#include <dm/dm_error.h>
#include <dm/dm_connectivity.h>
-#include <apps/netutils/wifi/slsi_wifi_api.h>
+#include <protocols/wifi/slsi_wifi_api.h>
/****************************************************************************
* Definitions
#include <semaphore.h>
#include <time.h>
#include <sys/socket.h>
-#include <apps/netutils/webserver/http_server.h>
-#include <apps/netutils/webserver/http_keyvalue_list.h>
-#include <apps/netutils/cJSON.h>
+#include <protocols/webserver/http_server.h>
+#include <protocols/webserver/http_keyvalue_list.h>
+#include <json/cJSON.h>
#include "wifi_api.h"
/****************************************************************************
#include <netinet/in.h>
#include <arpa/inet.h>
-#include <apps/netutils/netlib.h>
-#include <apps/netutils/ftpd.h>
+#include <protocols/netlib.h>
+#include <protocols/ftpd.h>
#include "ftpd.h"
#include <net/if.h>
#include <netinet/in.h>
#include <arpa/inet.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Definitions
#include <arpa/inet.h>
#include <netdb.h>
-#include <apps/netutils/libcoap/coap.h>
+#include <protocols/libcoap/coap.h>
#ifdef WITH_MBEDTLS
#define COAP_MBEDTLS_CIPHERSUIT "TLS-PSK-WITH-AES-128-CBC-SHA"
#include <errno.h>
#include <signal.h>
-#include <apps/netutils/libcoap/coap.h>
+#include <protocols/libcoap/coap.h>
#define COAP_RESOURCE_CHECK_TIME 2
#include <stdio.h>
#include <stdlib.h>
-#include <apps/netutils/mdnsd.h>
+#include <protocols/mdnsd.h>
#include <netinet/in.h>
#include <netdb.h>
#include <tinyara/clock.h>
#include <errno.h>
-#include <apps/netutils/mqtt_api.h>
+#include <mqtt/mqtt_api.h>
#if defined(CONFIG_NETUTILS_MQTT_SECURITY)
#include "tls/x509_crt.h"
#include <sys/socket.h>
#include <errno.h>
-#include <apps/netutils/mqtt_api.h>
+#include <mqtt/mqtt_api.h>
#if defined(CONFIG_NETUTILS_MQTT_SECURITY)
#include "tls/x509_crt.h"
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/select.h>
#include <sys/socket.h>
#include <string.h>
#include <time.h>
-#include <apps/netutils/ntpclient.h>
+#include <protocols/ntpclient.h>
/****************************************************************************
* Definitions
#include <net/lwip/ipv4/inet.h>
#include <net/lwip/dhcp.h>
#include <net/lwip/sys.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <net/lwip/tcpip.h>
#include <net/lwip/netif.h>
#include <net/lwip/arch/sys_arch.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <tinyara/config.h>
-#include <apps/netutils/telnetd.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/telnetd.h>
+#include <protocols/netlib.h>
#include "telnetd.h"
/****************************************************************************
#include <errno.h>
#include <sys/stat.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include "tc_internal.h"
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <sys/ioctl.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <sys/ioctl.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#ifdef CONFIG_LIBC_NETDB
#include <errno.h>
#include <sys/stat.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include "tc_internal.h"
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/stat.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include "tc_internal.h"
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/stat.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include "tc_internal.h"
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <sys/stat.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include "tc_internal.h"
#include <stdio.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <netinet/in.h>
//#include <arch/board/board.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <errno.h>
#include <sys/stat.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include "tc_internal.h"
#include <stdio.h>
#include <stdlib.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include "itc_internal.h"
#include "dm_lwm2m.h"
#include <dm/dm_error.h>
#include <dm/dm_connectivity.h>
-#include <apps/netutils/dhcpc.h>
+#include <protocols/dhcpc.h>
-#include <apps/netutils/wifi/slsi_wifi_api.h>
+#include <protocols/wifi/slsi_wifi_api.h>
#define NET_DEVNAME "wl1"
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include <sys/socket.h>
#include "utc_internal.h"
#include <dm/dm_error.h>
#include <dm/dm_connectivity.h>
-#include <apps/netutils/dhcpc.h>
-#include <apps/netutils/wifi/slsi_wifi_api.h>
+#include <protocols/dhcpc.h>
+#include <protocols/wifi/slsi_wifi_api.h>
#define NET_DEVNAME "wl1"
#include <tinyara/wqueue.h>
#include <tinyara/clock.h>
-#include <apps/netutils/dhcpc.h>
+#include <protocols/dhcpc.h>
-#include <apps/netutils/wifi/slsi_wifi_api.h>
+#include <protocols/wifi/slsi_wifi_api.h>
#define NET_DEVNAME "wl1"
#include <unistd.h>
#include <string.h>
-#include <apps/netutils/webclient.h>
+#include <protocols/webclient.h>
/****************************************************************************
* Preprocessor Definitions
#include <netinet/in.h>
#include <tinyara/net/ethernet.h>
-#include <apps/netutils/netlib.h>
-#include <apps/netutils/webserver/http_server.h>
-#include <apps/netutils/webserver/http_keyvalue_list.h>
+#include <protocols/netlib.h>
+#include <protocols/webserver/http_server.h>
+#include <protocols/webserver/http_keyvalue_list.h>
#define WEBSERVER_STACK_SIZE (1024 * 8)
#define WEBSERVER_SCHED_PRI 100
#include <string.h>
#include <errno.h>
-#include <apps/netutils/websocket.h>
+#include <protocols/websocket.h>
#include <tls/config.h>
#include <tls/entropy.h>
****************************************************************************/
#include <string.h>
-#include <apps/netutils/xmlrpc.h>
+#include <protocols/xmlrpc.h>
/****************************************************************************
* Private Function Prototypes
#include <net/if.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
-#include <apps/netutils/xmlrpc.h>
+#include <protocols/netlib.h>
+#include <protocols/xmlrpc.h>
/****************************************************************************
* Private Data
#include <net/lwip/dhcp.h>
#include <net/lwip/stats.h>
#include <tinyara/net/ip.h>
-#include <apps/netutils/dhcpc.h>
+#include <protocols/dhcpc.h>
#ifdef CONFIG_NETUTILS_NETLIB
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#endif
-#include <apps/netutils/netlib.h>
-#include <apps/netutils/tftp.h>
+#include <protocols/netlib.h>
+#include <protocols/tftp.h>
#ifdef CONFIG_HAVE_GETHOSTBYNAME
#include <netdb.h>
#endif
-#include <apps/netutils/dhcpc.h>
+#include <protocols/dhcpc.h>
#ifndef DNS_DEFAULT_PORT
#define DNS_DEFAULT_PORT 53
#endif
#include <net/if.h>
-#include <dhcpd.h>
+#include <protocols/dhcpd.h>
/****************************************************************************
* Preprocessor Definitions
#include <sys/socket.h>
#include <arpa/inet.h>
#include "netcmd.h"
-#include <apps/netutils/tftp.h>
+#include <protocols/tftp.h>
#if defined(CONFIG_NETUTILS_TFTPC)
struct tftpc_args_s {
---help---
enable AWS IoT Device SDK
+source "$EXTERNALDIR/json/Kconfig"
+source "$EXTERNALDIR/codecs/Kconfig"
+
include aws/src/Make.defs
endif
-#DHCPD
-include dhcpd/Make.defs
+
+include dhcpd/Make.defs #DHCPD
+include xmlrpc/Make.defs
+include ntpclient/Make.defs
+include webserver/Make.defs
+include ftpc/Make.defs
+include mdns/Make.defs
+include webclient/Make.defs
+include mosquitto/Make.defs
+include ftpd/Make.defs
+include dhcpc/Make.defs
+include websocket/Make.defs
+include libcoap/Make.defs
+include tftpc/Make.defs
+include telnetd/Make.defs
+include smtp/Make.defs
+include netlib/Make.defs
+include json/Make.defs
+
AOBJS = $(ASRCS:.S=$(OBJEXT))
COBJS = $(CSRCS:.c=$(OBJEXT))
# language governing permissions and limitations under the License.
#
###########################################################################
-# apps/netutils/ftpc/Make.defs
+# apps/netutils/codecs/Make.defs
# Adds selected applications to apps/ build
#
# Copyright (C) 2016 Gregory Nutt. All rights reserved.
#
############################################################################
-ifeq ($(CONFIG_NETUTILS_FTPC),y)
-CONFIGURED_APPS += netutils/ftpc
+ifeq ($(CONFIG_NETUTILS_CODECS),y)
+
+ifeq ($(CONFIG_CODECS_BASE64),y)
+CSRCS += codecs/base64.c
+endif
+ifeq ($(CONFIG_CODECS_HASH_MD5),y)
+CSRCS += codecs/md5.c
+endif
+ifeq ($(CONFIG_CODECS_URLCODE),y)
+CSRCS += codecs/urldecode.c
+endif
+
+DEPPATH += --dep-path codecs
+VPATH += :codecs
endif
############################################################################
ifeq ($(CONFIG_NETUTILS_DHCPC),y)
-CONFIGURED_APPS += netutils/dhcpc
+
+CSRCS += dhcpc/dhcpc.c
+
+DEPPATH += --dep-path dhcpc
+VPATH += :dhcpc
+
endif
#include <net/if.h>
#include <arpa/inet.h>
-#include <apps/netutils/dhcpc.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/dhcpc.h>
+#include <protocols/netlib.h>
#if defined(CONFIG_NETDB_DNSCLIENT) && defined(CONFIG_NETDB_DNSSERVER_BY_DHCP)
#include <tinyara/net/dns.h>
--- /dev/null
+#
+# For a description of the syntax of this configuration file,
+# see kconfig-language at https://www.kernel.org/doc/Documentation/kbuild/kconfig-language.txt
+#
+
+config NETUTILS_DHCPD
+ bool "DHCP server"
+ default n
+ depends on NET_IPv4
+ ---help---
+ Enable support for the DHCP server.
+
+if NETUTILS_DHCPD
+
+config NETUTILS_DHCPD_HOST
+ bool "Host-based DHCPD build"
+ default n
+ depends on EXPERIMENTAL
+ ---help---
+ DHCPD supports a host based build for testing on a PC. It is
+ enabled by this configuration, however, ti cannot really be used
+ in the context to the TinyAra build as it currently stands.
+
+config NETUTILS_DHCPD_IGNOREBROADCAST
+ bool "Ignore client broadcast"
+ default y
+ ---help---
+ This is a hack. I've had problems with Windows machines responding
+ to unicast. I think this is associated with a Windows registry key in
+ HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\DHCPServer\Parameters:
+ The IgnoreBroadcastFlag value controls this behavior: A value of 1 will
+ cause the server to ignore the client broadcast flag and always respond
+ with multicast; the value 0 to allows clients to request unicast.
+
+config NETUTILS_DHCPD_INTERFACE
+ string "DHCPD network interface"
+ default "wl1"
+
+config NETUTILS_DHCPD_LEASETIME
+ int "Lease time (seconds)"
+ default 864000
+ ---help---
+ Default: 10 days
+
+config NETUTILS_DHCPD_MINLEASETIME
+ int "Minimum lease time (seconds)"
+ default 86400
+ ---help---
+ Default: 1 days
+
+config NETUTILS_DHCPD_MAXLEASETIME
+ int "Maximum lease time (seconds)"
+ default 2592000
+ ---help---
+ Default: 30 days
+
+config NETUTILS_DHCPD_MAXLEASES
+ int "Maximum number of leases"
+ default 6
+
+config NETUTILS_DHCPD_STARTIP
+ hex "First IP address"
+ default 0xc0a82f02
+
+config NETUTILS_DHCPD_ROUTERIP
+ hex "Router IP (0 to disable)"
+ default 0xc0a82f01
+
+config NETUTILS_DHCPD_NETMASK
+ hex "Netmask (0 to disable)"
+ default 0xffffff00
+
+config NETUTILS_DHCPD_DNSIP
+ hex "DNS (0 to disable)"
+ default 0x08080808
+
+config NETUTILS_DHCPD_OFFERTIME
+ int "Offer time (seconds)"
+ default 3600
+ ---help---
+ Default: 1 hour
+
+config NETUTILS_DHCPD_DECLINETIME
+ int "Decline time (seconds)"
+ default 3600
+ ---help---
+ Default: 1 hour
+
+endif
# language governing permissions and limitations under the License.
#
###########################################################################
-# apps/netutils/codecs/Make.defs
+# apps/netutils/dhcpd/Make.defs
# Adds selected applications to apps/ build
#
# Copyright (C) 2016 Gregory Nutt. All rights reserved.
#
############################################################################
-ifeq ($(CONFIG_NETUTILS_CODECS),y)
-CONFIGURED_APPS += netutils/codecs
+ifeq ($(CONFIG_NETUTILS_DHCPD),y)
+
+CSRCS += dhcpd/dhcpd.c
+
+DEPPATH += --dep-path dhcpd
+VPATH += :dhcpd
+
endif
--- /dev/null
+/****************************************************************************
+ * netutils/dhcpd/dhcpd.c
+ *
+ * Copyright 2016 Samsung Electronics All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+ * either express or implied. See the License for the specific
+ * language governing permissions and limitations under the License.
+ *
+ ****************************************************************************/
+/****************************************************************************
+ * netutils/dhcpd/dhcpd.c
+ *
+ * Copyright (C) 2007-2009, 2011-2014 Gregory Nutt. All rights reserved.
+ * Author: Gregory Nutt <gnutt@nuttx.org>
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in
+ * the documentation and/or other materials provided with the
+ * distribution.
+ * 3. Neither the name NuttX nor the names of its contributors may be
+ * used to endorse or promote products derived from this software
+ * without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+ * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+ * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+ * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
+ * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
+ * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+ * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
+ * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+ * POSSIBILITY OF SUCH DAMAGE.
+ *
+ ****************************************************************************/
+
+/****************************************************************************
+ * Included Files
+ ****************************************************************************/
+
+#ifdef CONFIG_NETUTILS_DHCPD_HOST
+#include <stdio.h>
+
+#define HTONS(a) htons(a)
+#define HTONL(a) htonl(a)
+
+#define CONFIG_CPP_HAVE_WARNING 1
+#define FAR
+
+#define ndbg(...) printf(__VA_ARGS__)
+#define nvdbg(...) printf(__VA_ARGS__)
+
+#define ERROR (-1)
+#define OK (0)
+#else
+#include <tinyara/config.h> /* TinyAra configuration */
+#include <debug.h> /* For ndbg, vdbg */
+#include <tinyara/compiler.h> /* For CONFIG_CPP_HAVE_WARNING */
+#include <arch/irq.h> /* For irqstore() and friends -- REVISIT */
+#include <tinyara/net/net.h> /* For net_lock() and friends */
+#include <protocols/dhcpd.h> /* Advertised DHCPD APIs */
+#endif /* CONFIG_NETUTILS_DHCPD_HOST */
+
+#include <sys/socket.h>
+#include <sys/ioctl.h>
+#include <sys/select.h>
+
+#include <stdint.h>
+#include <stdbool.h>
+#include <string.h>
+#include <unistd.h>
+#include <time.h>
+#include <errno.h>
+
+#include <net/if.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+
+/****************************************************************************
+ * Global Data
+ ****************************************************************************/
+
+/****************************************************************************
+ * Private Data
+ ****************************************************************************/
+#define DHCPD_SELECT 1
+
+#define DHCP_SERVER_PORT 67
+#define DHCP_CLIENT_PORT 68
+
+/* Option codes understood in this file */
+/* Code Data Description */
+/* Length */
+#define DHCP_OPTION_PAD 0 /* 1 Pad */
+#define DHCP_OPTION_SUBNET_MASK 1 /* 1 Subnet Mask */
+#define DHCP_OPTION_ROUTER 3 /* 4 Router */
+#define DHCP_OPTION_DNS_SERVER 6 /* 4N DNS */
+#define DHCP_OPTION_REQ_IPADDR 50 /* 4 Requested IP Address */
+#define DHCP_OPTION_LEASE_TIME 51 /* 4 IP address lease time */
+#define DHCP_OPTION_OVERLOAD 52 /* 1 Option overload */
+#define DHCP_OPTION_MSG_TYPE 53 /* 1 DHCP message type */
+#define DHCP_OPTION_SERVER_ID 54 /* 4 Server identifier */
+#define DHCP_OPTION_END 255 /* 0 End */
+
+/* Values for the dhcp msg 'op' field */
+
+#define DHCP_REQUEST 1
+#define DHCP_REPLY 2
+
+/* DHCP message types understood in this file */
+
+#define DHCPDISCOVER 1 /* Received from client only */
+#define DHCPOFFER 2 /* Sent from server only */
+#define DHCPREQUEST 3 /* Received from client only */
+#define DHCPDECLINE 4 /* Received from client only */
+#define DHCPACK 5 /* Sent from server only */
+#define DHCPNAK 6 /* Sent from server only */
+#define DHCPRELEASE 7 /* Received from client only */
+#define DHCPINFORM 8 /* Not used */
+
+/* The form of an option is:
+ * code - 1 byte
+ * length - 1 byte
+ * data - variable number of bytes
+ */
+
+#define DHCPD_OPTION_CODE 0
+#define DHCPD_OPTION_LENGTH 1
+#define DHCPD_OPTION_DATA 2
+
+/* Size of options in DHCP message */
+
+#define DHCPD_OPTIONS_SIZE 312
+
+/* Values for htype and hlen field */
+
+#define DHCP_HTYPE_ETHERNET 1
+#define DHCP_HLEN_ETHERNET 6
+
+/* Values for flags field */
+
+#define BOOTP_BROADCAST 0x8000
+
+/* Legal values for this option are:
+ *
+ * 1 the 'file' field is used to hold options
+ * 2 the 'sname' field is used to hold options
+ * 3 both fields are used to hold options
+ */
+
+#define DHCPD_OPTION_FIELD 0
+#define DHCPD_FILE_FIELD 1
+#define DHCPD_SNAME_FIELD 2
+
+#ifndef CONFIG_NETUTILS_DHCPD_LEASETIME
+#define CONFIG_NETUTILS_DHCPD_LEASETIME (60*60*24*10) /* 10 days */
+#undef CONFIG_NETUTILS_DHCPD_MINLEASETIME
+#undef CONFIG_NETUTILS_DHCPD_MAXLEASETIME
+#endif
+
+#ifndef CONFIG_NETUTILS_DHCPD_MINLEASETIME
+#define CONFIG_NETUTILS_DHCPD_MINLEASETIME (60*60*24*1) /* 1 days */
+#endif
+
+#ifndef CONFIG_NETUTILS_DHCPD_MAXLEASETIME
+#define CONFIG_NETUTILS_DHCPD_MAXLEASETIME (60*60*24*30) /* 30 days */
+#endif
+
+#ifndef CONFIG_NETUTILS_DHCPD_INTERFACE
+#define CONFIG_NETUTILS_DHCPD_INTERFACE "eth0"
+#endif
+
+#ifndef CONFIG_NETUTILS_DHCPD_MAXLEASES
+#define CONFIG_NETUTILS_DHCPD_MAXLEASES 16
+#endif
+
+#ifndef CONFIG_NETUTILS_DHCPD_STARTIP
+#define CONFIG_NETUTILS_DHCPD_STARTIP (192L<<24|168L<<16|0L<<8|3L)
+#endif
+
+#undef CONFIG_NETUTILS_DHCP_OPTION_ENDIP
+#define CONFIG_NETUTILS_DHCP_OPTION_ENDIP (CONFIG_NETUTILS_DHCPD_STARTIP + CONFIG_NETUTILS_DHCPD_MAXLEASES - 1)
+
+#ifndef CONFIG_NETUTILS_DHCPD_OFFERTIME
+#define CONFIG_NETUTILS_DHCPD_OFFERTIME (60*60) /* 1 hour */
+#endif
+
+#ifndef CONFIG_NETUTILS_DHCPD_DECLINETIME
+#define CONFIG_NETUTILS_DHCPD_DECLINETIME (60*60) /* 1 hour */
+#endif
+
+#undef HAVE_ROUTERIP
+#if defined(CONFIG_NETUTILS_DHCPD_ROUTERIP) && CONFIG_NETUTILS_DHCPD_ROUTERIP
+#define HAVE_ROUTERIP 1
+#endif
+
+#undef HAVE_NETMASK
+#if defined(CONFIG_NETUTILS_DHCPD_NETMASK) && CONFIG_NETUTILS_DHCPD_NETMASK
+#define HAVE_NETMASK 1
+#endif
+
+#undef HAVE_DNSIP
+#if defined(CONFIG_NETUTILS_DHCPD_DNSIP) && CONFIG_NETUTILS_DHCPD_DNSIP
+#define HAVE_DNSIP 1
+#endif
+
+#undef HAVE_LEASE_TIME
+#if defined(CONFIG_NETUTILS_DHCPD_HOST) || !defined(CONFIG_DISABLE_POSIX_TIMERS)
+#define HAVE_LEASE_TIME 1
+#endif
+
+/****************************************************************************
+ * Private Types
+ ****************************************************************************/
+
+/* This structure describes one element in the lease table. There is one slot
+ * in the lease table for each assign-able IP address (hence, the IP address
+ * itself does not have to be in the table.
+ */
+
+struct lease_s {
+ uint8_t mac[DHCP_HLEN_ETHERNET]; /* MAC address (network order) -- could be larger! */
+ bool allocated; /* true: IP address is allocated */
+#ifdef HAVE_LEASE_TIME
+ time_t expiry; /* Lease expiration time (seconds past Epoch) */
+#endif
+};
+
+struct dhcpmsg_s {
+ uint8_t op;
+ uint8_t htype;
+ uint8_t hlen;
+ uint8_t hops;
+ uint8_t xid[4];
+ uint16_t secs;
+ uint16_t flags;
+ uint8_t ciaddr[4];
+ uint8_t yiaddr[4];
+ uint8_t siaddr[4];
+ uint8_t giaddr[4];
+ uint8_t chaddr[16];
+#ifndef CONFIG_NET_DHCP_LIGHT
+ uint8_t sname[64];
+ uint8_t file[128];
+#endif
+ uint8_t options[312];
+};
+
+struct dhcpd_state_s {
+ /* Server configuration */
+
+ in_addr_t ds_serverip; /* The server IP address */
+
+ /* Message buffers */
+
+ struct dhcpmsg_s ds_inpacket; /* Holds the incoming DHCP client message */
+ struct dhcpmsg_s ds_outpacket; /* Holds the outgoing DHCP server message */
+
+ /* Parsed options from the incoming DHCP client message */
+
+ uint8_t ds_optmsgtype; /* Incoming DHCP message type */
+ in_addr_t ds_optreqip; /* Requested IP address (host order) */
+ in_addr_t ds_optserverip; /* Serverip IP address (host order) */
+ time_t ds_optleasetime; /* Requested lease time (host order) */
+
+ /* End option pointer for outgoing DHCP server message */
+
+ uint8_t *ds_optend;
+
+ /* Leases */
+
+ struct lease_s ds_leases[CONFIG_NETUTILS_DHCPD_MAXLEASES];
+};
+
+/****************************************************************************
+ * Private Data
+ ****************************************************************************/
+
+static const uint8_t g_magiccookie[4] = { 99, 130, 83, 99 };
+static const uint8_t g_anyipaddr[4] = { 0, 0, 0, 0 };
+
+static struct dhcpd_state_s g_state;
+
+static int g_dhcpd_running = 0;
+static int g_dhcpd_quit = 0;
+
+static pthread_t g_tid = 0;
+
+static char DHCPD_IFNAME[IFNAMSIZ] = {0,};
+
+#if DHCPD_SELECT
+static struct timeval g_select_timeout = {10, 0};
+#endif
+
+/****************************************************************************
+ * Private Functions
+ ****************************************************************************/
+
+/****************************************************************************
+ * Name: dhcpd_arpupdate
+ ****************************************************************************/
+
+#ifndef CONFIG_NETUTILS_DHCPD_HOST
+#ifndef CONFIG_NET_LWIP
+static inline void dhcpd_arpupdate(uint16_t *pipaddr, uint8_t *phwaddr)
+{
+ net_lock_t flags;
+
+ /* Disable interrupts and update the ARP table -- very non-portable hack.
+ * REVISIT -- switch to the SIOCSARP ioctl call if/when it is implemented.
+ */
+
+ flags = net_lock();
+ arp_update(pipaddr, phwaddr);
+ net_unlock(flags);
+}
+#else
+#define dhcpd_arpupdate(pipaddr, phwaddr)
+#endif /* CONFIG_NET_LWIP */
+#else
+#define dhcpd_arpupdate(pipaddr, phwaddr)
+#endif
+
+/****************************************************************************
+ * Name: dhcpd_time
+ ****************************************************************************/
+
+#ifdef CONFIG_NETUTILS_DHCPD_HOST
+#define dhcpd_time() time(0)
+#elif defined(HAVE_LEASE_TIME)
+static time_t dhcpd_time(void)
+{
+ struct timespec ts;
+ time_t ret = 0;
+
+ if (clock_gettime(CLOCK_REALTIME, &ts) == OK) {
+ ret = ts.tv_sec;
+ }
+
+ return ret;
+}
+#else
+#define dhcpd_time() (0)
+#endif
+
+/****************************************************************************
+ * Name: dhcpd_leaseexpired
+ ****************************************************************************/
+
+#ifdef HAVE_LEASE_TIME
+static inline bool dhcpd_leaseexpired(struct lease_s *lease)
+{
+ ndbg("dhcpd_leaseexpired is called!!\n");
+
+ return false;
+
+ if (lease->expiry < dhcpd_time()) {
+ return false;
+ } else {
+// memset(lease, 0, sizeof(struct lease_s));
+ return true;
+ }
+}
+#else
+#define dhcpd_leaseexpired(lease) (false)
+#endif
+
+/****************************************************************************
+ * Name: dhcpd_setlease
+ ****************************************************************************/
+
+struct lease_s *dhcpd_setlease(const uint8_t *mac, in_addr_t ipaddr, time_t expiry)
+{
+ /* Calculate the offset from the first IP address managed by DHCPD.
+ * ipaddr must be in host order!
+ */
+
+ int ndx = ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP;
+ struct lease_s *ret = NULL;
+
+ nvdbg("ipaddr: %08x ipaddr: %08x ndx: %d MAX: %d\n", ipaddr, CONFIG_NETUTILS_DHCPD_STARTIP, ndx, CONFIG_NETUTILS_DHCPD_MAXLEASES);
+
+ /* Verify that the address offset is within the supported range */
+
+ if (ndx >= 0 && ndx < CONFIG_NETUTILS_DHCPD_MAXLEASES) {
+ ret = &g_state.ds_leases[ndx];
+ memcpy(ret->mac, mac, DHCP_HLEN_ETHERNET);
+ ret->allocated = true;
+#ifdef HAVE_LEASE_TIME
+ ret->expiry = dhcpd_time() + expiry;
+#endif
+ }
+
+ return ret;
+}
+
+/****************************************************************************
+ * Name: dhcp_leaseipaddr
+ ****************************************************************************/
+
+static inline in_addr_t dhcp_leaseipaddr(struct lease_s *lease)
+{
+ /* Return IP address in host order */
+
+ return (in_addr_t)(lease - g_state.ds_leases) + CONFIG_NETUTILS_DHCPD_STARTIP;
+}
+
+/****************************************************************************
+ * Name: dhcpd_findbymac
+ ****************************************************************************/
+
+static struct lease_s *dhcpd_findbymac(const uint8_t *mac)
+{
+ int i;
+
+ for (i = 0; i < CONFIG_NETUTILS_DHCPD_MAXLEASES; i++) {
+ if (memcmp(g_state.ds_leases[i].mac, mac, DHCP_HLEN_ETHERNET) == 0) {
+ return &(g_state.ds_leases[i]);
+ }
+ }
+
+ return NULL;
+}
+
+/****************************************************************************
+ * Name: dhcpd_findbyipaddr
+ ****************************************************************************/
+
+static struct lease_s *dhcpd_findbyipaddr(in_addr_t ipaddr)
+{
+ if (ipaddr >= CONFIG_NETUTILS_DHCPD_STARTIP && ipaddr <= CONFIG_NETUTILS_DHCP_OPTION_ENDIP) {
+
+ struct lease_s *lease = &g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP];
+ ndbg("dhcpd_findbyipaddr lease index = %d\n", ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP);
+
+ if (lease->allocated > 0) {
+ ndbg("returen lease %d %d\n", ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP, g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].allocated);
+ return lease;
+ }
+ }
+
+ ndbg("returen null\n");
+
+ return NULL;
+}
+
+/****************************************************************************
+ * Name: dhcpd_allocipaddr
+ ****************************************************************************/
+
+static in_addr_t dhcpd_allocipaddr(void)
+{
+ struct lease_s *lease = NULL;
+ in_addr_t ipaddr;
+
+ ipaddr = CONFIG_NETUTILS_DHCPD_STARTIP;
+ for (; ipaddr <= CONFIG_NETUTILS_DHCP_OPTION_ENDIP; ipaddr++) {
+ /* Skip over address ending in 0 or 255 */
+
+ if ((ipaddr & 0xff) == 0 || (ipaddr & 0xff) == 0xff) {
+ continue;
+ }
+
+ /* Is there already a lease on this address? If so, has it expired? */
+
+ lease = dhcpd_findbyipaddr(ipaddr);
+ if ((lease == NULL || dhcpd_leaseexpired(lease))) {
+ ndbg("lease pass!!\n");
+#ifdef CONFIG_CPP_HAVE_WARNING
+/**
+#warning "FIXME: Should check if anything responds to an ARP request or ping"
+#warning " to verify that there is no other user of this IP address"
+**/
+#endif
+
+ ndbg("leases talbe = %d %d \n", ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP, g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].allocated);
+
+ memset(g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].mac, 0, DHCP_HLEN_ETHERNET);
+ g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].allocated = true;
+#ifdef HAVE_LEASE_TIME
+ g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].expiry = dhcpd_time()
+ + CONFIG_NETUTILS_DHCPD_OFFERTIME;
+#endif
+ /* Return the address in host order */
+
+ ndbg("return ipaddr\n");
+ return ipaddr;
+ }
+ }
+ ndbg("return ipaddr = 0\n");
+ return 0;
+}
+
+/****************************************************************************
+ * Name: dhcpd_parseoptions
+ ****************************************************************************/
+
+static inline bool dhcpd_parseoptions(void)
+{
+ uint32_t tmp;
+ uint8_t *ptr;
+#ifndef CONFIG_NET_DHCP_LIGHT
+ uint8_t overloaded;
+ uint8_t currfield;
+#endif
+ int optlen = 0;
+ int remaining;
+
+ /* Verify that the option field starts with a valid magic number */
+
+ ptr = g_state.ds_inpacket.options;
+ if (memcmp(ptr, g_magiccookie, 4) != 0) {
+ /* Bad magic number... skip g_state.ds_outpacket */
+
+ ndbg("Bad magic: %d,%d,%d,%d\n", ptr[0], ptr[1], ptr[2], ptr[3]);
+ return false;
+ }
+
+ /* Set up to parse the options */
+
+ ptr += 4;
+ remaining = DHCPD_OPTIONS_SIZE - 4;
+#ifndef CONFIG_NET_DHCP_LIGHT
+ overloaded = DHCPD_OPTION_FIELD;
+ currfield = DHCPD_OPTION_FIELD;
+#endif
+
+ /* Set all options to the default value */
+
+ g_state.ds_optmsgtype = 0; /* Incoming DHCP message type */
+ g_state.ds_optreqip = 0; /* Requested IP address (host order) */
+ g_state.ds_optserverip = 0; /* Serverip IP address (host order) */
+ g_state.ds_optleasetime = 0; /* Requested lease time (host order) */
+ g_state.ds_optend = NULL;
+
+ do {
+ /* The form of an option is:
+ * code - 1 byte
+ * length - 1 byte
+ * data - variable number of bytes
+ */
+
+ switch (ptr[DHCPD_OPTION_CODE]) {
+ /* Skip over any padding bytes */
+
+ case DHCP_OPTION_PAD:
+ optlen = 1;
+ break;
+
+ /* the Overload option is used to indicate that the DHCP 'sname' or 'file'
+ * fields are being overloaded by using them to carry DHCP options. A DHCP
+ * server inserts this option if the returned parameters will exceed the
+ * usual space allotted for options.
+ *
+ * If this option is present, the client interprets the specified additional
+ * fields after it concludes interpretation of the standard option fields.
+ *
+ * Legal values for this option are:
+ *
+ * 1 the 'file' field is used to hold options
+ * 2 the 'sname' field is used to hold options
+ * 3 both fields are used to hold options
+ */
+
+#ifndef CONFIG_NET_DHCP_LIGHT
+ case DHCP_OPTION_OVERLOAD:
+ optlen = ptr[DHCPD_OPTION_LENGTH] + 2;
+ if (optlen >= 1 && optlen < remaining) {
+ overloaded = ptr[DHCPD_OPTION_DATA];
+ }
+ break;
+#endif
+
+ case DHCP_OPTION_END:
+#ifndef CONFIG_NET_DHCP_LIGHT
+ if (currfield == DHCPD_OPTION_FIELD && (overloaded & DHCPD_FILE_FIELD) != 0) {
+ ptr = g_state.ds_inpacket.file;
+ remaining = sizeof(g_state.ds_inpacket.file);
+ currfield = DHCPD_FILE_FIELD;
+ } else if (currfield == DHCPD_FILE_FIELD && (overloaded & DHCPD_SNAME_FIELD) != 0) {
+ ptr = g_state.ds_inpacket.sname;
+ remaining = sizeof(g_state.ds_inpacket.sname);
+ currfield = DHCPD_SNAME_FIELD;
+ } else {
+ return true;
+ }
+ break;
+#else
+ return true;
+#endif
+
+ case DHCP_OPTION_REQ_IPADDR: /* Requested IP Address */
+ optlen = ptr[DHCPD_OPTION_LENGTH] + 2;
+ if (optlen >= 4 && optlen < remaining) {
+ memcpy(&tmp, &ptr[DHCPD_OPTION_DATA], 4);
+ g_state.ds_optreqip = (in_addr_t)ntohl(tmp);
+ }
+ break;
+
+ case DHCP_OPTION_LEASE_TIME: /* IP address lease time */
+ optlen = ptr[DHCPD_OPTION_LENGTH] + 2;
+ if (optlen >= 4 && optlen < remaining) {
+ memcpy(&tmp, &ptr[DHCPD_OPTION_DATA], 4);
+ g_state.ds_optleasetime = (time_t)ntohl(tmp);
+ }
+ break;
+
+ case DHCP_OPTION_MSG_TYPE: /* DHCP message type */
+ optlen = ptr[DHCPD_OPTION_LENGTH] + 2;
+ if (optlen >= 1 && optlen < remaining) {
+ g_state.ds_optmsgtype = ptr[DHCPD_OPTION_DATA];
+ }
+ break;
+
+ case DHCP_OPTION_SERVER_ID: /* Server identifier */
+ optlen = ptr[DHCPD_OPTION_LENGTH] + 2;
+ if (optlen >= 4 && optlen < remaining) {
+ memcpy(&tmp, &ptr[DHCPD_OPTION_DATA], 4);
+ g_state.ds_optserverip = (in_addr_t)ntohl(tmp);
+ }
+ break;
+
+ default:
+ /* Skip over unsupported options */
+
+ optlen = ptr[DHCPD_OPTION_LENGTH] + 2;
+ break;
+ }
+
+ /* Advance to the next option */
+
+ ptr += optlen;
+ remaining -= optlen;
+ } while (remaining > 0);
+
+ return false;
+}
+
+/****************************************************************************
+ * Name: dhcpd_verifyreqip
+ ****************************************************************************/
+
+static inline bool dhcpd_verifyreqip(void)
+{
+ struct lease_s *lease;
+
+ /* Verify that the requested IP address is within the supported lease range */
+
+ if (g_state.ds_optreqip >= CONFIG_NETUTILS_DHCPD_STARTIP && g_state.ds_optreqip <= CONFIG_NETUTILS_DHCP_OPTION_ENDIP) {
+ /* And verify that the lease has not already been taken or offered
+ * (unless the lease/offer is expired, then the address is free game).
+ */
+
+ lease = dhcpd_findbyipaddr(g_state.ds_optreqip);
+ ndbg(" lease = %d\n", lease);
+ if (!lease || dhcpd_leaseexpired(lease)) {
+ ndbg("can use IP %08lx\n", (long)g_state.ds_optreqip);
+ return true;
+ }
+ }
+ ndbg("can't use IP %08lx\n", (long)g_state.ds_optreqip);
+ return false;
+}
+
+/****************************************************************************
+ * Name: dhcpd_verifyreqleasetime
+ ****************************************************************************/
+
+static inline bool dhcpd_verifyreqleasetime(uint32_t *leasetime)
+{
+ uint32_t tmp = g_state.ds_optleasetime;
+
+ /* Did the client request a specific lease time? */
+
+ if (tmp != 0) {
+ /* Yes.. Verify that the requested lease time is within a valid range */
+
+ if (tmp > CONFIG_NETUTILS_DHCPD_MAXLEASETIME) {
+ tmp = CONFIG_NETUTILS_DHCPD_MAXLEASETIME;
+ } else if (tmp < CONFIG_NETUTILS_DHCPD_MINLEASETIME) {
+ tmp = CONFIG_NETUTILS_DHCPD_MINLEASETIME;
+ }
+
+ /* Return the clipped lease time */
+
+ *leasetime = tmp;
+ return true;
+ }
+
+ return false;
+}
+
+/****************************************************************************
+ * Name: dhcpd_addoption
+ ****************************************************************************/
+
+static int dhcpd_addoption(uint8_t *option)
+{
+ int offset;
+ int len = 4;
+
+ if (g_state.ds_optend) {
+ offset = g_state.ds_outpacket.options - g_state.ds_optend;
+ len = option[DHCPD_OPTION_LENGTH] + 2;
+
+ /* Check if the option will fit into the options array */
+
+ if (offset + len + 1 < DHCPD_OPTIONS_SIZE) {
+ /* Copy the option into the option array */
+
+ memcpy(g_state.ds_optend, option, len);
+ g_state.ds_optend += len;
+ *g_state.ds_optend = DHCP_OPTION_END;
+ }
+ }
+
+ return len;
+}
+
+/****************************************************************************
+ * Name: dhcpd_addoption8
+ ****************************************************************************/
+
+static int dhcpd_addoption8(uint8_t code, uint8_t value)
+{
+ uint8_t option[3];
+
+ /* Construct the option sequence */
+
+ option[DHCPD_OPTION_CODE] = code;
+ option[DHCPD_OPTION_LENGTH] = 1;
+ option[DHCPD_OPTION_DATA] = value;
+
+ /* Add the option sequence to the response */
+
+ return dhcpd_addoption(option);
+}
+
+/****************************************************************************
+ * Name: dhcpd_addoption32
+ ****************************************************************************/
+
+static int dhcpd_addoption32(uint8_t code, uint32_t value)
+{
+ uint8_t option[6];
+
+ /* Construct the option sequence */
+
+ option[DHCPD_OPTION_CODE] = code;
+ option[DHCPD_OPTION_LENGTH] = 4;
+ memcpy(&option[DHCPD_OPTION_DATA], &value, 4);
+
+ /* Add the option sequence to the response */
+
+ return dhcpd_addoption(option);
+}
+
+/****************************************************************************
+ * Name: dhcp_addoption32p
+ ****************************************************************************/
+
+#if HAVE_DNSIP
+static int dhcp_addoption32p(uint8_t code, FAR uint8_t *value)
+{
+ uint8_t option[6];
+
+ /* Construct the option sequence */
+
+ option[DHCPD_OPTION_CODE] = code;
+ option[DHCPD_OPTION_LENGTH] = 4;
+ memcpy(&option[DHCPD_OPTION_DATA], value, 4);
+
+ /* Add the option sequence to the response */
+
+ return dhcpd_addoption(option);
+}
+#endif
+
+/****************************************************************************
+ * Name: dhcpd_soclet
+ ****************************************************************************/
+
+static inline int dhcpd_socket(void)
+{
+ int sockfd;
+ int optval;
+ int ret;
+
+ /* Create a socket to listen for requests from DHCP clients */
+
+ sockfd = socket(PF_INET, SOCK_DGRAM, 0);
+ if (sockfd < 0) {
+ ndbg("socket failed: %d\n", errno);
+ return ERROR;
+ }
+
+ /* Configure the socket */
+ optval = 1;
+ ret = setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, (void *)&optval, sizeof(int));
+ if (ret < 0) {
+ ndbg("setsockopt SO_REUSEADDR failed: %d\n", errno);
+ close(sockfd);
+ return ERROR;
+ }
+
+ optval = 1;
+ ret = setsockopt(sockfd, SOL_SOCKET, SO_BROADCAST, (void *)&optval, sizeof(int));
+ if (ret < 0) {
+ ndbg("setsockopt SO_BROADCAST failed: %d\n", errno);
+ close(sockfd);
+ return ERROR;
+ }
+
+ return sockfd;
+
+}
+
+/****************************************************************************
+ * Name: dhcpd_openresponder
+ ****************************************************************************/
+
+static inline int dhcpd_openresponder(void)
+{
+ struct sockaddr_in addr;
+ int sockfd;
+ int ret;
+
+ nvdbg("Responder: %08lx\n", ntohl(g_state.ds_serverip));
+
+ /* Create a socket to listen for requests from DHCP clients */
+
+ sockfd = dhcpd_socket();
+ if (sockfd < 0) {
+ ndbg("socket failed: %d\n", errno);
+ return ERROR;
+ }
+
+ /* Bind the socket to a local port. */
+
+ addr.sin_family = AF_INET;
+ addr.sin_port = HTONS(DHCP_SERVER_PORT);
+ addr.sin_addr.s_addr = g_state.ds_serverip;
+
+ ret = bind(sockfd, (struct sockaddr *)&addr, sizeof(struct sockaddr_in));
+ if (ret < 0) {
+ ndbg("bind failed, port=%d addr=%08lx: %d\n", addr.sin_port, (long)addr.sin_addr.s_addr, errno);
+ close(sockfd);
+ return ERROR;
+ }
+
+ return sockfd;
+}
+
+/****************************************************************************
+ * Name: dhcpd_initpacket
+ ****************************************************************************/
+
+static void dhcpd_initpacket(uint8_t mtype)
+{
+ uint32_t nulladdr = 0;
+
+ /* Set up the generic parts of the DHCP server message */
+
+ memset(&g_state.ds_outpacket, 0, sizeof(struct dhcpmsg_s));
+
+ g_state.ds_outpacket.op = DHCP_REPLY;
+ g_state.ds_outpacket.htype = g_state.ds_inpacket.htype;
+ g_state.ds_outpacket.hlen = g_state.ds_inpacket.hlen;
+
+ memcpy(&g_state.ds_outpacket.xid, &g_state.ds_inpacket.xid, 4);
+ memcpy(g_state.ds_outpacket.chaddr, g_state.ds_inpacket.chaddr, 16);
+
+ if (memcmp(g_state.ds_outpacket.giaddr, &nulladdr, 4) != 0) {
+ g_state.ds_outpacket.flags = g_state.ds_inpacket.flags;
+ } else {
+ g_state.ds_outpacket.flags = 0;
+ }
+ memset(g_state.ds_outpacket.giaddr, 0, 4);
+
+ /* Add the generic options */
+
+ memcpy(g_state.ds_outpacket.options, g_magiccookie, 4);
+ g_state.ds_optend = &g_state.ds_outpacket.options[4];
+ *g_state.ds_optend = DHCP_OPTION_END;
+ dhcpd_addoption8(DHCP_OPTION_MSG_TYPE, mtype);
+ dhcpd_addoption32(DHCP_OPTION_SERVER_ID, g_state.ds_serverip);
+}
+
+/****************************************************************************
+ * Name: dhcpd_sendpacket
+ ****************************************************************************/
+
+static int dhcpd_sendpacket(int bbroadcast)
+{
+ struct sockaddr_in addr;
+ in_addr_t ipaddr;
+ int sockfd;
+ int len;
+ int ret = ERROR;
+
+#ifdef CONFIG_NETUTILS_DHCPD_IGNOREBROADCAST
+ /* This is a hack. I've had problems with Windows machines responding
+ * to unicast. I think this is associated with a Windows registry key in
+ * HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\DHCPServer\Parameters:
+ * The IgnoreBroadcastFlag value controls this behavior: A value of 1 will
+ * cause the server to ignore the client broadcast flag and always respond
+ * with multicast; the value 0 to allows clients to request unicast.
+ */
+
+ ipaddr = INADDR_BROADCAST;
+#else
+ /* Determine which address to respond to (or if we need to broadcast the response)
+ *
+ * (1) If he caller know that it needs to multicast the response, it will set bbroadcast.
+ * (2) Otherwise, if the client already has and address (ciaddr), then use that for uni-cast
+ * (3) Broadcast if the client says it can't handle uni-cast (BOOTP_BROADCAST set)
+ * (4) Otherwise, the client claims it can handle the uni-casst response and we
+ * will uni-cast to the offered address (yiaddr).
+ *
+ * NOTE: We really should also check the giaddr field. If no zero, the server should
+ * send any return messages to the 'DHCP server' port on the BOOTP relay agent whose
+ * address appears in 'giaddr'.
+ */
+
+ if (bbroadcast) {
+ ipaddr = INADDR_BROADCAST;
+ } else if (memcmp(g_state.ds_outpacket.ciaddr, g_anyipaddr, 4) != 0) {
+ dhcpd_arpupdate((uint16_t *)g_state.ds_outpacket.ciaddr, g_state.ds_outpacket.chaddr);
+ memcpy(&ipaddr, g_state.ds_outpacket.ciaddr, 4);
+ } else if (g_state.ds_outpacket.flags & HTONS(BOOTP_BROADCAST)) {
+ ipaddr = INADDR_BROADCAST;
+ } else {
+ dhcpd_arpupdate((uint16_t *)g_state.ds_outpacket.yiaddr, g_state.ds_outpacket.chaddr);
+ memcpy(&ipaddr, g_state.ds_outpacket.yiaddr, 4);
+ }
+#endif
+
+ /* Create a socket to respond with a packet to the client. We
+ * cannot re-use the listener socket because it is not bound correctly
+ */
+
+ sockfd = dhcpd_openresponder();
+ if (sockfd >= 0) {
+ /* Then send the reponse to the DHCP client port at that address */
+
+ memset(&addr, 0, sizeof(struct sockaddr_in));
+ addr.sin_family = AF_INET;
+ addr.sin_port = HTONS(DHCP_CLIENT_PORT);
+ addr.sin_addr.s_addr = ipaddr;
+
+ /* Send the minimum sized packet that includes the END option */
+
+ len = (g_state.ds_optend - (uint8_t *)&g_state.ds_outpacket) + 1;
+ nvdbg("sendto %08lx:%04x len=%d\n", (long)ntohl(addr.sin_addr.s_addr), ntohs(addr.sin_port), len);
+ ret = sendto(sockfd, &g_state.ds_outpacket, len, 0, (struct sockaddr *)&addr, sizeof(struct sockaddr_in));
+ close(sockfd);
+ } else {
+ ndbg("create socket failed : %d\n", sockfd);
+ }
+
+ return ret;
+}
+
+/****************************************************************************
+ * Name: dhcpd_send_offerpacket
+ ****************************************************************************/
+
+static int dhcpd_send_offerpacket(void)
+{
+ struct sockaddr_in addr;
+ in_addr_t ipaddr;
+ int sockfd;
+ int len;
+ int ret = ERROR;
+
+ memcpy(&ipaddr, g_state.ds_outpacket.yiaddr, 4);
+
+#if HAVE_NETMASK
+ /* A dhcp offer message should be sent as broadcast message
+ * Some platform might discard 255.255.255.255 broadcast message, so replace it to subnet broadcast message
+ */
+ ipaddr |= (~htonl(CONFIG_NETUTILS_DHCPD_NETMASK));
+#else
+ ipaddr = htonl(IPADDR_BROADCAST);
+#endif
+
+ sockfd = dhcpd_openresponder();
+ if (sockfd >= 0) {
+ /* Then send the reponse to the DHCP client port at that address */
+
+ memset(&addr, 0, sizeof(struct sockaddr_in));
+ addr.sin_family = AF_INET;
+ addr.sin_port = HTONS(DHCP_CLIENT_PORT);
+ addr.sin_addr.s_addr = ipaddr;
+
+ /* Send the minimum sized packet that includes the END option */
+
+ len = (g_state.ds_optend - (uint8_t *)&g_state.ds_outpacket) + 1;
+ nvdbg("dhcp offer sendto %08lx:%04x len=%d\n", (long)ntohl(addr.sin_addr.s_addr), ntohs(addr.sin_port), len);
+ ret = sendto(sockfd, &g_state.ds_outpacket, len, 0, (struct sockaddr *)&addr, sizeof(struct sockaddr_in));
+ close(sockfd);
+ } else {
+ ndbg("create socket failed : %d\n", sockfd);
+ }
+
+ return ret;
+}
+
+
+/****************************************************************************
+ * Name: dhcpd_sendoffer
+ ****************************************************************************/
+
+static inline int dhcpd_sendoffer(in_addr_t ipaddr, uint32_t leasetime)
+{
+ in_addr_t netaddr;
+#if HAVE_DNSIP
+ uint32_t dnsaddr;
+ dnsaddr = htonl(CONFIG_NETUTILS_DHCPD_DNSIP);
+#endif
+ /* IP address is in host order */
+
+ nvdbg("Sending offer: %08lx\n", (long)ipaddr);
+
+ /* Initialize the outgoing packet */
+
+ dhcpd_initpacket(DHCPOFFER);
+
+ /* Add the address offered to the client (converting to network order) */
+
+ netaddr = htonl(ipaddr);
+ memcpy(g_state.ds_outpacket.yiaddr, &netaddr, 4);
+
+ /* Add the leasetime to the response options */
+
+ dhcpd_addoption32(DHCP_OPTION_LEASE_TIME, htonl(leasetime));
+#if HAVE_NETMASK
+ dhcpd_addoption32(DHCP_OPTION_SUBNET_MASK, htonl(CONFIG_NETUTILS_DHCPD_NETMASK));
+#endif
+#if HAVE_ROUTERIP
+ dhcpd_addoption32(DHCP_OPTION_ROUTER, htonl(CONFIG_NETUTILS_DHCPD_ROUTERIP));
+#endif
+#if HAVE_DNSIP
+ dhcp_addoption32p(DHCP_OPTION_DNS_SERVER, (FAR uint8_t *)&dnsaddr);
+#endif
+
+ /* Send the offer response */
+ return dhcpd_send_offerpacket();
+}
+
+/****************************************************************************
+ * Name: dhcpd_sendnak
+ ****************************************************************************/
+
+static int dhcpd_sendnak(void)
+{
+ /* Initialize and send the NAK response */
+
+ dhcpd_initpacket(DHCPNAK);
+ memcpy(g_state.ds_outpacket.ciaddr, g_state.ds_inpacket.ciaddr, 4);
+ return dhcpd_sendpacket(true);
+}
+
+/****************************************************************************
+ * Name: dhcpd_sendack
+ ****************************************************************************/
+
+int dhcpd_sendack(in_addr_t ipaddr)
+{
+ uint32_t leasetime = CONFIG_NETUTILS_DHCPD_LEASETIME;
+ in_addr_t netaddr;
+#if HAVE_DNSIP
+ uint32_t dnsaddr;
+ dnsaddr = htonl(CONFIG_NETUTILS_DHCPD_DNSIP);
+#endif
+
+ /* Initialize the ACK response */
+
+ dhcpd_initpacket(DHCPACK);
+ memcpy(g_state.ds_outpacket.ciaddr, g_state.ds_inpacket.ciaddr, 4);
+
+ /* Add the IP address assigned to the client */
+
+ netaddr = htonl(ipaddr);
+ memcpy(g_state.ds_outpacket.yiaddr, &netaddr, 4);
+
+ /* Did the client request a specific lease time? */
+
+ (void)dhcpd_verifyreqleasetime(&leasetime);
+
+ /* Add the lease time to the response */
+
+ dhcpd_addoption32(DHCP_OPTION_LEASE_TIME, htonl(leasetime));
+#if HAVE_NETMASK
+ dhcpd_addoption32(DHCP_OPTION_SUBNET_MASK, htonl(CONFIG_NETUTILS_DHCPD_NETMASK));
+#endif
+#if HAVE_ROUTERIP
+ dhcpd_addoption32(DHCP_OPTION_ROUTER, htonl(CONFIG_NETUTILS_DHCPD_ROUTERIP));
+#endif
+#if HAVE_DNSIP
+ dhcp_addoption32p(DHCP_OPTION_DNS_SERVER, (FAR uint8_t *)&dnsaddr);
+#endif
+
+ if (dhcpd_sendpacket(true) < 0) {
+ return ERROR;
+ }
+
+ dhcpd_setlease(g_state.ds_inpacket.chaddr, ipaddr, leasetime);
+ return OK;
+}
+
+/****************************************************************************
+ * Name: dhcpd_discover
+ ****************************************************************************/
+
+static inline int dhcpd_discover(void)
+{
+ struct lease_s *lease;
+ in_addr_t ipaddr;
+ uint32_t leasetime = CONFIG_NETUTILS_DHCPD_LEASETIME;
+
+ /* Check if the client is aleady in the lease table */
+
+ lease = dhcpd_findbymac(g_state.ds_inpacket.chaddr);
+ if (lease) {
+ /* Yes... get the remaining time on the lease */
+
+#ifdef HAVE_LEASE_TIME
+ if (!dhcpd_leaseexpired(lease)) {
+ leasetime = lease->expiry - dhcpd_time();
+ if (leasetime < CONFIG_NETUTILS_DHCPD_MINLEASETIME) {
+ leasetime = CONFIG_NETUTILS_DHCPD_MINLEASETIME;
+ }
+ }
+#endif
+ /* Get the IP address associated with the lease (host order) */
+
+ ipaddr = dhcp_leaseipaddr(lease);
+ ndbg("Already have lease for IP %08lx\n", (long)ipaddr);
+ }
+
+ /* Check if the client has requested a specific IP address */
+
+ else if (dhcpd_verifyreqip()) {
+ /* Use the requested IP address (host order) */
+
+ ipaddr = g_state.ds_optreqip;
+
+ ndbg("User requested IP %08lx\n", (long)ipaddr);
+ } else {
+ /* No... allocate a new IP address (host order) */
+
+ ipaddr = dhcpd_allocipaddr();
+ ndbg("Allocated IP %08lx\n", (long)ipaddr);
+ }
+
+ /* Did we get any IP address? */
+
+ if (!ipaddr) {
+ /* Nope... return failure */
+
+ ndbg("Failed to get IP address\n");
+ return ERROR;
+ }
+
+ /* Reserve the leased IP for a shorter time for the offer */
+
+ if (!dhcpd_setlease(g_state.ds_inpacket.chaddr, ipaddr, CONFIG_NETUTILS_DHCPD_OFFERTIME)) {
+ ndbg("Failed to set lease\n");
+ return ERROR;
+ }
+
+ /* Check if the client has requested a specific lease time */
+
+ (void)dhcpd_verifyreqleasetime(&leasetime);
+
+ /* Send the offer response */
+
+ return dhcpd_sendoffer(ipaddr, leasetime);
+}
+
+/****************************************************************************
+ * Name: dhcpd_request
+ ****************************************************************************/
+
+static inline int dhcpd_request(void)
+{
+ struct lease_s *lease;
+ in_addr_t ipaddr = 0;
+ uint8_t response = 0;
+
+ /* Check if this client already holds a lease. This can happen when the client (1)
+ * the IP is reserved for the client from a previous offer, or (2) the client is
+ * re-initializing or rebooting while the lease is still valid.
+ */
+
+ lease = dhcpd_findbymac(g_state.ds_inpacket.chaddr);
+ if (lease) {
+ /* Yes.. the client already holds a lease. Verify that the request is consistent
+ * with the existing lease (host order).
+ */
+
+ ipaddr = dhcp_leaseipaddr(lease);
+ ndbg("Lease ipaddr: %08x Server IP: %08x Requested IP: %08x\n", ipaddr, g_state.ds_optserverip, g_state.ds_optreqip);
+
+ if (g_state.ds_optserverip) {
+ /* ACK if the serverip is correct and the requested IP address is the one
+ * already offered to the client.
+ */
+
+ if (g_state.ds_optserverip == ntohl(g_state.ds_serverip) && (g_state.ds_optreqip != 0 || g_state.ds_optreqip == ipaddr)) {
+ response = DHCPACK;
+ } else {
+ response = DHCPNAK;
+ }
+ }
+
+ /* We have the lease and no server IP was requested. Was a specific IP address
+ * requested? (host order)
+ */
+
+ else if (g_state.ds_optreqip) {
+ /* Yes..ACK if the requested IP address is the one already leased.
+ * Both addresses are in host order.
+ */
+
+ if (ipaddr == g_state.ds_optreqip) {
+ response = DHCPACK;
+ } else {
+ response = DHCPNAK;
+ }
+ }
+
+ /* The client has specified neither a server IP nor requested IP address */
+
+ else {
+ /* ACK if the IP used by the client is the one already assigned to it.
+ * NOTE ipaddr is in host order; ciaddr is network order!
+ */
+
+ uint32_t tmp = htonl(ipaddr);
+ if (memcmp(&tmp, g_state.ds_inpacket.ciaddr, 4) == 0) {
+ response = DHCPACK;
+ } else {
+ response = DHCPNAK;
+ }
+ }
+ }
+
+ /* The client does not hold a lease (referenced by its MAC address) and is
+ * requesting a specific IP address that was, apparently, never offered to
+ * to the client. Perform some sanity checks before sending the NAK.
+ */
+
+ else if (g_state.ds_optreqip && !g_state.ds_optserverip) {
+ ndbg("Server IP: %08x Requested IP: %08x\n", g_state.ds_optserverip, g_state.ds_optreqip);
+
+ /* Is this IP address already assigned? */
+
+ lease = dhcpd_findbyipaddr(g_state.ds_optreqip);
+ if (lease) {
+ /* Yes.. Send NAK unless the lease has expired */
+
+ if (!dhcpd_leaseexpired(lease)) {
+ response = DHCPNAK;
+ }
+ }
+
+ /* No.. is the requested IP address in range? NAK if not */
+
+ else if (g_state.ds_optreqip < CONFIG_NETUTILS_DHCPD_STARTIP || g_state.ds_optreqip > CONFIG_NETUTILS_DHCP_OPTION_ENDIP) {
+ response = DHCPNAK;
+ }
+ }
+
+ /* Otherwise, the client does not hold a lease and is not requesting any
+ * specific IP address.
+ */
+
+ /* Finally, either (1) send the ACK, (2) send a NAK, or (3) remain silent
+ * based on the checks above.
+ */
+
+ if (response == DHCPACK) {
+ ndbg("ACK IP %08lx\n", (long)ipaddr);
+
+ memset(g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].mac, 0, DHCP_HLEN_ETHERNET);
+ g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].allocated = true;
+#ifdef HAVE_LEASE_TIME
+ g_state.ds_leases[ipaddr - CONFIG_NETUTILS_DHCPD_STARTIP].expiry = dhcpd_time() + CONFIG_NETUTILS_DHCPD_OFFERTIME;
+#endif
+ if (dhcpd_sendack(ipaddr) == ERROR) {
+ ndbg("Failed to send ACK\n");
+ return ERROR;
+ }
+ } else if (response == DHCPNAK) {
+ ndbg("NAK IP %08lx\n", (long)ipaddr);
+ if (dhcpd_sendnak() == ERROR) {
+ ndbg("Failed to send NAK\n");
+ return ERROR;
+ }
+ } else {
+ ndbg("Remaining silent IP %08lx\n", (long)ipaddr);
+ }
+
+ return OK;
+}
+
+/****************************************************************************
+ * Name: dhcpd_decline
+ ****************************************************************************/
+
+static inline int dhcpd_decline(void)
+{
+ struct lease_s *lease;
+
+ /* Find the lease associated with this hardware address */
+
+ lease = dhcpd_findbymac(g_state.ds_inpacket.chaddr);
+ if (lease) {
+ /* Disassociate the IP from the MAC, but prevent re-used of this
+ * address for a period of time.
+ */
+
+ memset(lease->mac, 0, DHCP_HLEN_ETHERNET);
+#ifdef HAVE_LEASE_TIME
+ lease->expiry = dhcpd_time() + CONFIG_NETUTILS_DHCPD_DECLINETIME;
+#endif
+ }
+
+ return OK;
+}
+
+static inline int dhcpd_release(void)
+{
+ struct lease_s *lease;
+
+ /* Find the lease associated with this hardware address */
+
+ lease = dhcpd_findbymac(g_state.ds_inpacket.chaddr);
+ if (lease) {
+ /* Release the IP address now */
+
+ memset(lease, 0, sizeof(struct lease_s));
+ }
+
+ return OK;
+}
+
+/****************************************************************************
+ * Name: dhcpd_openlistener
+ ****************************************************************************/
+
+static inline int dhcpd_openlistener(void)
+{
+ struct sockaddr_in addr;
+ struct ifreq req;
+ int sockfd;
+ int ret;
+
+ /* Create a socket to listen for requests from DHCP clients */
+
+ sockfd = dhcpd_socket();
+ if (sockfd < 0) {
+ ndbg("socket failed: %d\n", errno);
+ return ERROR;
+ }
+
+ /* Get the IP address of the selected device */
+
+ strncpy(req.ifr_name, DHCPD_IFNAME, IFNAMSIZ);
+ ret = ioctl(sockfd, SIOCGIFADDR, (unsigned long)&req);
+ if (ret < 0) {
+ ndbg("setsockopt SIOCGIFADDR failed: %d\n", errno);
+ close(sockfd);
+ return ERROR;
+ }
+
+ g_state.ds_serverip = ((struct sockaddr_in *)&req.ifr_addr)->sin_addr.s_addr;
+ nvdbg("serverip: %08lx\n", ntohl(g_state.ds_serverip));
+
+ /* Bind the socket to a local port. We have to bind to INADDRY_ANY to
+ * receive broadcast messages.
+ */
+
+ addr.sin_family = AF_INET;
+ addr.sin_port = htons(DHCP_SERVER_PORT);
+ addr.sin_addr.s_addr = INADDR_ANY;
+
+ ret = bind(sockfd, (struct sockaddr *)&addr, sizeof(struct sockaddr_in));
+ if (ret < 0) {
+ ndbg("bind failed, port=%d addr=%08lx: %d\n", addr.sin_port, (long)addr.sin_addr.s_addr, errno);
+ close(sockfd);
+ return ERROR;
+ }
+
+ return sockfd;
+}
+
+
+/****************************************************************************
+ * Private Functions
+ ****************************************************************************/
+/****************************************************************************
+ * Name: dhcpd_netif_init
+ ****************************************************************************/
+static int dhcpd_netif_init(char *intf)
+{
+ struct in_addr server_ipaddr;
+ struct in_addr netmask_ipaddr;
+
+ server_ipaddr.s_addr = htonl(CONFIG_NETUTILS_DHCPD_ROUTERIP);
+ netmask_ipaddr.s_addr = htonl(CONFIG_NETUTILS_DHCPD_NETMASK);
+
+ if (netlib_set_ipv4addr(intf, &server_ipaddr) == ERROR) {
+ ndbg("failed to set server IP address\n");
+ return -1;
+ }
+
+ if (netlib_set_ipv4netmask(intf, &netmask_ipaddr.s_addr) == ERROR) {
+ ndbg("failed to set netmask\n");
+ return -1;
+ }
+
+ if (netlib_set_dripv4addr(intf, &server_ipaddr) == ERROR) {
+ ndbg("failed to set default gateway\n");
+ return -1;
+ }
+
+ ndbg("\n");
+
+ ndbg("Server IP address set : %u.%u.%u.%u\n",
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 24) & 0xff),
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 16) & 0xff),
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 8) & 0xff),
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 0) & 0xff));
+
+ ndbg("Server netmask address set : %u.%u.%u.%u\n",
+ (unsigned char)((htonl(netmask_ipaddr.s_addr) >> 24) & 0xff),
+ (unsigned char)((htonl(netmask_ipaddr.s_addr) >> 16) & 0xff),
+ (unsigned char)((htonl(netmask_ipaddr.s_addr) >> 8) & 0xff),
+ (unsigned char)((htonl(netmask_ipaddr.s_addr) >> 0) & 0xff));
+
+ ndbg("Server default gateway address set : %u.%u.%u.%u\n",
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 24) & 0xff),
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 16) & 0xff),
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 8) & 0xff),
+ (unsigned char)((htonl(server_ipaddr.s_addr) >> 0) & 0xff));
+
+ ndbg("\n");
+ return 0;
+}
+
+
+/****************************************************************************
+ * Private Functions
+ ****************************************************************************/
+/****************************************************************************
+ * Name: dhcpd_netif_deinit
+ ****************************************************************************/
+static int dhcpd_netif_deinit(char *intf)
+{
+ struct in_addr server_ipaddr;
+ struct in_addr netmask_ipaddr;
+
+ server_ipaddr.s_addr = IPADDR_ANY;
+ netmask_ipaddr.s_addr = IPADDR_NONE;
+
+ if (netlib_set_ipv4addr(intf, &server_ipaddr) == ERROR) {
+ ndbg("failed to set server IP address\n");
+ return -1;
+ }
+
+ if (netlib_set_ipv4netmask(intf, &netmask_ipaddr.s_addr) == ERROR) {
+ ndbg("failed to set netmask\n");
+ return -1;
+ }
+
+ if (netlib_set_dripv4addr(intf, &server_ipaddr) == ERROR) {
+ ndbg("failed to set default gateway\n");
+ return -1;
+ }
+
+ return 0;
+}
+
+
+/****************************************************************************
+ * Public Functions
+ ****************************************************************************/
+/****************************************************************************
+ * Name: dhcpd_status
+ ****************************************************************************/
+int dhcpd_status(void)
+{
+ return g_dhcpd_running;
+}
+
+/****************************************************************************
+ * Public Functions
+ ****************************************************************************/
+/****************************************************************************
+ * Name: dhcpd_stop
+ ****************************************************************************/
+void dhcpd_stop(void)
+{
+ g_dhcpd_quit = 1;
+#if DHCPD_SELECT
+ ndbg("WARN : dhcpd will be stopped after %d seconds\n", g_select_timeout.tv_sec);
+#endif
+}
+
+
+/****************************************************************************
+ * Public Functions
+ ****************************************************************************/
+/****************************************************************************
+ * Name: dhcpd_run
+ ****************************************************************************/
+
+int dhcpd_run(void *arg)
+{
+ int sockfd;
+ int nbytes;
+#if DHCPD_SELECT
+ int ret = OK;
+ fd_set sockfd_set;
+#endif
+ ndbg("Started on %s\n", DHCPD_IFNAME);
+
+ /* Initialize everything to zero */
+
+ memset(&g_state, 0, sizeof(struct dhcpd_state_s));
+
+ /* Initialize netif address (ip address, netmask, default gateway) */
+
+ if (dhcpd_netif_init(DHCPD_IFNAME) < 0) {
+ ndbg("Failed to initialize network interface %s\n", DHCPD_IFNAME);
+ ret = ERROR;
+ return ret;
+ }
+
+ /* Now loop indefinitely, reading packets from the DHCP server socket */
+
+ sockfd = -1;
+
+ g_dhcpd_quit = 0;
+ g_dhcpd_running = 1;
+
+ while (!g_dhcpd_quit) {
+ /* Create a socket to listen for requests from DHCP clients */
+
+ /* TODO : Need to add cancellation point */
+
+ if (sockfd < 0) {
+ sockfd = dhcpd_openlistener();
+ if (sockfd < 0) {
+ ndbg("Failed to create socket\n");
+ ret = ERROR;
+ break;
+ }
+ }
+#if DHCPD_SELECT
+ nbytes = -1;
+ FD_ZERO(&sockfd_set);
+ FD_SET(sockfd, &sockfd_set);
+
+ ret = select(sockfd+1, &sockfd_set, NULL, NULL, &g_select_timeout);
+ if ((ret > 0) && FD_ISSET(sockfd, &sockfd_set)) {
+ /* Read the next g_state.ds_outpacket */
+ nbytes = recv(sockfd, &g_state.ds_inpacket, sizeof(struct dhcpmsg_s), 0);
+ } else if (ret == 0) {
+ if (!g_dhcpd_quit)
+ continue;
+ else {
+ ndbg("select timeout exit\n");
+ break;
+ }
+ } else {
+ /* Debugging purpose : Error case*/
+ ndbg("ERROR, select ret %d [errno %d]\n", ret, errno);
+ break;
+ }
+#else
+ nbytes = recv(sockfd, &g_state.ds_inpacket, sizeof(struct dhcpmsg_s), 0);
+#endif
+ if (nbytes < 0) {
+ /* On errors (other EINTR), close the socket and try again */
+
+ ndbg("recv failed: %d\n", errno);
+ if (errno != EINTR) {
+ close(sockfd);
+ sockfd = -1;
+ }
+ continue;
+ }
+
+ /* Parse the incoming message options */
+
+ if (!dhcpd_parseoptions()) {
+ /* Failed to parse the message options */
+
+ ndbg("No msg type\n");
+
+ continue;
+ }
+#ifdef CONFIG_NETUTILS_DHCPD_HOST
+ /* Get the poor little uC a change to get its recvfrom in place */
+
+ usleep(500 * 1000);
+#endif
+
+ /* Now process the incoming DHCP message by its message type */
+
+ switch (g_state.ds_optmsgtype) {
+ case DHCPDISCOVER:
+ ndbg("DHCPDISCOVER\n");
+ if (dhcpd_discover() == ERROR) {
+ ndbg("DHCPDISCOVER : Failed to send DHCP Discover, errno %d\n", errno);
+ }
+ break;
+
+ case DHCPREQUEST:
+ ndbg("DHCPREQUEST\n");
+ dhcpd_request();
+ break;
+
+ case DHCPDECLINE:
+ ndbg("DHCPDECLINE\n");
+ dhcpd_decline();
+ break;
+
+ case DHCPRELEASE:
+ ndbg("DHCPRELEASE\n");
+ dhcpd_release();
+ break;
+
+ case DHCPINFORM: /* Not supported */
+ default:
+ ndbg("Unsupported message type: %d\n", g_state.ds_optmsgtype);
+ break;
+ }
+ }
+
+ if (sockfd != -1) {
+ close(sockfd);
+ }
+ g_dhcpd_running = 0;
+
+ /* de-initialize netif address (ip address, netmask, default gateway) */
+
+ if (dhcpd_netif_deinit(DHCPD_IFNAME) < 0) {
+ ndbg("Failed to deinit netif %s\n", DHCPD_IFNAME);
+ }
+
+ return ret;
+}
+
+
+/****************************************************************************
+ * Public Functions
+ ****************************************************************************/
+/****************************************************************************
+ * Name: dhcpd_start
+ ****************************************************************************/
+
+#define DHCPD_STACK_SIZE 20480
+#define DHCPD_SCHED_PRI 100
+#define DHCPD_SCHED_POLICY SCHED_RR
+
+int dhcpd_start(char *intf)
+{
+ pthread_attr_t attr;
+ int status;
+ struct sched_param sparam;
+
+ /* Set network interface name for DHCPD */
+ if (intf) {
+ strncpy(DHCPD_IFNAME, intf, strlen(intf));
+ } else {
+ strncpy(DHCPD_IFNAME, CONFIG_NETUTILS_DHCPD_INTERFACE, IFNAMSIZ);
+ }
+
+ status = pthread_attr_init(&attr);
+ if (status != 0) {
+ ndbg("failed to start dhcpd\n");
+ goto err_exit;
+ }
+
+ sparam.sched_priority = DHCPD_SCHED_PRI;
+ status = pthread_attr_setschedparam(&attr, &sparam);
+ if (status != 0) {
+ ndbg("failed to pthread_attr_setschedparam, ret %d, errno %d\n",
+ status, errno);
+ goto err_exit;
+ }
+
+ status = pthread_attr_setschedpolicy(&attr, DHCPD_SCHED_POLICY);
+ if (status != 0) {
+ ndbg("failed to pthread_attr_setchedpolicy, ret %d, errno %d\n",
+ status, errno);
+ goto err_exit;
+ }
+
+ status = pthread_attr_setstacksize(&attr, DHCPD_STACK_SIZE);
+ if (status != 0) {
+ ndbg("failed to pthread_attr_setstacksize, ret %d, errno %d\n",
+ status, errno);
+ goto err_exit;
+ }
+
+ status = pthread_create(&g_tid, &attr, (pthread_startroutine_t)dhcpd_run, NULL);
+ if (status != 0) {
+ ndbg("failed to start dhcpd\n");
+ goto err_exit;
+ }
+
+ pthread_setname_np(g_tid, "dhcpd");
+ pthread_detach(g_tid);
+
+ return 0;
+err_exit:
+ return -1;
+}
--- /dev/null
+###########################################################################
+#
+# Copyright 2017 Samsung Electronics All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+# either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+#
+###########################################################################
+# apps/netutils/ftpc/Make.defs
+# Adds selected applications to apps/ build
+#
+# Copyright (C) 2016 Gregory Nutt. All rights reserved.
+# Author: Gregory Nutt <gnutt@nuttx.org>
+#
+# Redistribution and use in source and binary forms, with or without
+# modification, are permitted provided that the following conditions
+# are met:
+#
+# 1. Redistributions of source code must retain the above copyright
+# notice, this list of conditions and the following disclaimer.
+# 2. Redistributions in binary form must reproduce the above copyright
+# notice, this list of conditions and the following disclaimer in
+# the documentation and/or other materials provided with the
+# distribution.
+# 3. Neither the name NuttX nor the names of its contributors may be
+# used to endorse or promote products derived from this software
+# without specific prior written permission.
+#
+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+# FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+# COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+# INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
+# BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
+# OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
+# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+# POSSIBILITY OF SUCH DAMAGE.
+#
+############################################################################
+
+ifeq ($(CONFIG_NETUTILS_FTPC),y)
+
+# FTP connection management
+CSRCS += ftpc/ftpc_connect.c \
+ ftpc/ftpc_disconnect.c
+
+# FTP commands
+CSRCS += ftpc/ftpc_cdup.c \
+ ftpc/ftpc_chdir.c \
+ ftpc/ftpc_chmod.c \
+ ftpc/ftpc_filesize.c \
+ ftpc/ftpc_filetime.c
+CSRCS += ftpc/ftpc_help.c \
+ ftpc/ftpc_idle.c \
+ ftpc/ftpc_listdir.c \
+ ftpc/ftpc_login.c \
+ ftpc/ftpc_mkdir.c
+CSRCS += ftpc/ftpc_noop.c \
+ ftpc/ftpc_rpwd.c \
+ ftpc/ftpc_quit.c \
+ ftpc/ftpc_rename.c \
+ ftpc/ftpc_rmdir.c \
+ ftpc/ftpc_unlink.c
+CSRCS += ftpc/ftpc_cmd.c
+
+# FTP transfers
+CSRCS += ftpc/ftpc_getfile.c \
+ ftpc/ftpc_putfile.c \
+ ftpc/ftpc_transfer.c
+
+# FTP responses
+CSRCS += ftpc/ftpc_response.c \
+ ftpc/ftpc_getreply.c
+
+# FTP helpers
+CSRCS += ftpc/ftpc_utils.c \
+ ftpc/ftpc_socket.c
+
+DEPPATH += --dep-path ftpc
+VPATH += :ftpc
+
+endif
+
############################################################################
ifeq ($(CONFIG_NETUTILS_FTPD),y)
-CONFIGURED_APPS += netutils/ftpd
+
+ifeq ($(CONFIG_NET_LWIP),y)
+CSRCS += ftpd/ftpd.c
+endif
+
+DEPPATH += --dep-path ftpd
+VPATH += :ftpd
+
endif
#include <arpa/inet.h>
-#include <apps/netutils/ftpd.h>
+#include <protocols/ftpd.h>
#include "ftpd.h"
--- /dev/null
+/****************************************************************************
+ *
+ * Copyright 2016 Samsung Electronics All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+ * either express or implied. See the License for the specific
+ * language governing permissions and limitations under the License.
+ *
+ ****************************************************************************/
+/****************************************************************************
+ * apps/include/netutils/dhcpd.h
+ *
+ * Copyright (C) 2007, 2009, 2011 Gregory Nutt. All rights reserved.
+ * Author: Gregory Nutt <gnutt@nuttx.org>
+ *
+ * This logic was leveraged from uIP which also has a BSD-style license:
+ *
+ * Copyright (c) 2005, Swedish Institute of Computer Science
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * 3. Neither the name of the Institute nor the names of its contributors
+ * may be used to endorse or promote products derived from this software
+ * without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE INSTITUTE AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE INSTITUTE OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ */
+ /**
+ * @addtogroup DHCP
+ * @ingroup NETWORK
+ * @{
+ */
+
+/**
+ * @file netif.h
+ * @brief netif API (to be used from lwIP TCPIP thread)
+ */
+
+#ifndef __APPS_INCLUDE_NETUTILS_DHCPD_H
+#define __APPS_INCLUDE_NETUTILS_DHCPD_H
+
+/****************************************************************************
+ * Included Files
+ ****************************************************************************/
+
+/****************************************************************************
+ * Pre-processor Definitions
+ ****************************************************************************/
+
+/****************************************************************************
+ * Public Types
+ ****************************************************************************/
+
+/****************************************************************************
+ * Public Function Prototypes
+ ****************************************************************************/
+
+#ifdef __cplusplus
+#define EXTERN extern "C"
+extern "C" {
+#else
+#define EXTERN extern
+#endif
+
+/**
+ * @brief Starts DHCP server which is attached given network interface.
+ *
+ * @param[in] intf the name of network interface to run DHCP server
+ * @return On success, 0. On failure, returns error
+*/
+int dhcpd_run(void *arg);
+
+/**
+ * @brief Starts DHCP server as daemon which is attached given network interface.
+ *
+ * @param[in] intf the name of network interface to run DHCP server
+ * @return On success, 0. On failure, returns -1
+*/
+int dhcpd_start(char *intf);
+
+#undef EXTERN
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* __APPS_INCLUDE_NETUTILS_DHCPD_H */
+/** @} */
#ifndef _COAP_ADDRESS_H_
#define _COAP_ADDRESS_H_
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#ifdef HAVE_ASSERT_H
#include <assert.h>
#ifndef _COAP_ASYNC_H_
#define _COAP_ASYNC_H_
-#include <apps/netutils/libcoap/config.h>
-#include <apps/netutils/libcoap/net.h>
+#include <protocols/libcoap/config.h>
+#include <protocols/libcoap/net.h>
#ifndef WITHOUT_ASYNC
#ifndef _COAP_BLOCK_H_
#define _COAP_BLOCK_H_
-#include <apps/netutils/libcoap/option.h>
-#include <apps/netutils/libcoap/encode.h>
-#include <apps/netutils/libcoap/pdu.h>
+#include <protocols/libcoap/option.h>
+#include <protocols/libcoap/encode.h>
+#include <protocols/libcoap/pdu.h>
/**
* @defgroup block Block Transfer
extern "C" {
#endif
-#include <apps/netutils/libcoap/config.h>
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/mem.h>
-#include <apps/netutils/libcoap/coap_list.h>
-#include <apps/netutils/libcoap/pdu.h>
-#include <apps/netutils/libcoap/option.h>
-#include <apps/netutils/libcoap/net.h>
-#include <apps/netutils/libcoap/encode.h>
-#include <apps/netutils/libcoap/str.h>
-#include <apps/netutils/libcoap/uri.h>
-#include <apps/netutils/libcoap/async.h>
-#include <apps/netutils/libcoap/resource.h>
-#include <apps/netutils/libcoap/subscribe.h>
-#include <apps/netutils/libcoap/block.h>
+#include <protocols/libcoap/config.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/mem.h>
+#include <protocols/libcoap/coap_list.h>
+#include <protocols/libcoap/pdu.h>
+#include <protocols/libcoap/option.h>
+#include <protocols/libcoap/net.h>
+#include <protocols/libcoap/encode.h>
+#include <protocols/libcoap/str.h>
+#include <protocols/libcoap/uri.h>
+#include <protocols/libcoap/async.h>
+#include <protocols/libcoap/resource.h>
+#include <protocols/libcoap/subscribe.h>
+#include <protocols/libcoap/block.h>
#ifdef __cplusplus
}
extern "C" {
#endif
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
/**
* @defgroup clock Clock Handling
#ifndef _COAP_DEBUG_H_
#define _COAP_DEBUG_H_
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#ifndef COAP_DEBUG_FD
#define COAP_DEBUG_FD stdout
#define warn(...) coap_log(LOG_WARNING, __VA_ARGS__)
#define debug(...) coap_log(LOG_DEBUG, __VA_ARGS__)
-#include <apps/netutils/libcoap/pdu.h>
+#include <protocols/libcoap/pdu.h>
void coap_show_pdu2(const coap_pdu_t *, coap_protocol_t protocol);
void coap_show_pdu(const coap_pdu_t *);
#ifndef _COAP_ENCODE_H_
#define _COAP_ENCODE_H_
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#if defined (__TINYARA__)
#include <string.h>
#ifndef _COAP_HASHKEY_H_
#define _COAP_HASHKEY_H_
-#include <apps/netutils/libcoap/str.h>
+#include <protocols/libcoap/str.h>
typedef unsigned char coap_key_t[4];
extern "C" {
#endif
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#ifdef HAVE_ASSERT_H
#include <assert.h>
#include <net/lwip/ipv4/ip_addr.h>
#endif
-#include <apps/netutils/libcoap/option.h>
-#include <apps/netutils/libcoap/address.h>
-#include <apps/netutils/libcoap/prng.h>
-#include <apps/netutils/libcoap/pdu.h>
-#include <apps/netutils/libcoap/coap_time.h>
+#include <protocols/libcoap/option.h>
+#include <protocols/libcoap/address.h>
+#include <protocols/libcoap/prng.h>
+#include <protocols/libcoap/pdu.h>
+#include <protocols/libcoap/coap_time.h>
#ifdef WITH_MBEDTLS
#include "tls/certs.h"
#ifndef _OPTION_H_
#define _OPTION_H_
-#include <apps/netutils/libcoap/bits.h>
-#include <apps/netutils/libcoap/pdu.h>
+#include <protocols/libcoap/bits.h>
+#include <protocols/libcoap/pdu.h>
/**
* Use byte-oriented access methods here because sliding a complex
#ifndef _PDU_H_
#define _PDU_H_
-#include <apps/netutils/libcoap/config.h>
-#include <apps/netutils/libcoap/coap_list.h>
-#include <apps/netutils/libcoap/uri.h>
+#include <protocols/libcoap/config.h>
+#include <protocols/libcoap/coap_list.h>
+#include <protocols/libcoap/uri.h>
#ifdef WITH_LWIP
#include <net/lwip/pbuf.h>
#ifndef _COAP_PRNG_H_
#define _COAP_PRNG_H_
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
/**
* @defgroup prng Pseudo Random Numbers
#ifndef _COAP_RESOURCE_H_
#define _COAP_RESOURCE_H_
-#include <apps/netutils/libcoap/config.h>
-#include <apps/netutils/libcoap/t_list.h>
+#include <protocols/libcoap/config.h>
+#include <protocols/libcoap/t_list.h>
#if defined(HAVE_ASSERT_H) && !defined(assert)
#include <assert.h>
#ifndef WITH_CONTIKI
#ifdef COAP_RESOURCES_NOHASH
-#include <apps/netutils/libcoap/utlist.h>
+#include <protocols/libcoap/utlist.h>
#else
-#include <apps/netutils/libcoap/uthash.h>
+#include <protocols/libcoap/uthash.h>
#endif
#else /* WITH_CONTIKI */
#endif /* WITH_CONTIKI */
-#include <apps/netutils/libcoap/hashkey.h>
-#include <apps/netutils/libcoap/async.h>
-#include <apps/netutils/libcoap/str.h>
-#include <apps/netutils/libcoap/pdu.h>
-#include <apps/netutils/libcoap/net.h>
-#include <apps/netutils/libcoap/subscribe.h>
+#include <protocols/libcoap/hashkey.h>
+#include <protocols/libcoap/async.h>
+#include <protocols/libcoap/str.h>
+#include <protocols/libcoap/pdu.h>
+#include <protocols/libcoap/net.h>
+#include <protocols/libcoap/subscribe.h>
/** Definition of message handler function (@sa coap_resource_t). */
typedef void (*coap_method_handler_t)
#ifndef _COAP_SUBSCRIBE_H_
#define _COAP_SUBSCRIBE_H_
-#include <apps/netutils/libcoap/config.h>
-#include <apps/netutils/libcoap/address.h>
+#include <protocols/libcoap/config.h>
+#include <protocols/libcoap/address.h>
/**
* @defgroup observe Resource observation
}
#else /* WITH_CONTIKI */
-#include <apps/netutils/libcoap/list.h>
+#include <protocols/libcoap/list.h>
#endif /* WITH_CONTIKI */
#endif /* _DTLS_LIST_H_ */
#ifndef _COAP_URI_H_
#define _COAP_URI_H_
-#include <apps/netutils/libcoap/hashkey.h>
-#include <apps/netutils/libcoap/str.h>
+#include <protocols/libcoap/hashkey.h>
+#include <protocols/libcoap/str.h>
/** Representation of parsed URI. Components may be filled from a
* string with coap_split_uri() and can be used as input for
#include "tls/ssl_cache.h"
#endif
-#include <apps/netutils/webserver/http_keyvalue_list.h>
+#include <protocols/webserver/http_keyvalue_list.h>
/****************************************************************************
* Pre-processor Definitions
****************************************************************************/
#include <stdio.h>
-#include <apps/netutils/webserver/http_server.h>
+#include <protocols/webserver/http_server.h>
#ifdef __cplusplus
#define EXTERN extern "C"
#include <netinet/in.h>
#ifdef CONFIG_NETUTILS_WEBSOCKET
-#include <apps/netutils/websocket.h>
+#include <protocols/websocket.h>
#endif
#ifdef CONFIG_NET_SECURITY_TLS
#include <stdint.h>
#include <netinet/in.h>
-#include <apps/netutils/wslay/wslay.h>
+#include <protocols/wslay/wslay.h>
#include <tinyara/wqueue.h>
#include "tls/config.h"
#include "compilersupport_p.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include <cJSON.h>
#endif
#define IOTVT_SRM_PSI_H
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "ocstack.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "cainterface.h"
#include "base64.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "cainterface.h"
#include "base64.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "oic_time.h"
#include "logger.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "credentialgenerator.h"
#include "cainterface.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "oic_string.h"
#include "logger.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "oic_malloc.h"
#include "oic_string.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "oic_malloc.h"
#include "oic_string.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include <string.h>
#include "utlist.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "oic_string.h"
#include "logger.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "oicgroup.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "CoapHttpParser.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "CoapHttpParser.h"
#include "CoapHttpMap.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include "CoapHttpParser.h"
#include "CoapHttpMap.h"
#if defined (__TIZENRT__)
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
#else
#include "cJSON.h"
#endif
#include <fstream>\r
#include <algorithm>\r
#if defined (__TIZENRT__)\r
-#include <apps/netutils/cJSON.h>\r
+#include <json/cJSON.h>\r
#else\r
#include "cJSON.h"\r
#endif\r
#include "Properties.h"\r
#include "Definitions.h"\r
#if defined (__TIZENRT__)\r
-#include <apps/netutils/cJSON.h>\r
+#include <json/cJSON.h>\r
#else\r
#include "cJSON.h"\r
#endif\r
#include <boost/lexical_cast.hpp>\r
#include <limits>\r
#if defined (__TIZENRT__)\r
-#include <apps/netutils/cJSON.h>\r
+#include <json/cJSON.h>\r
#else\r
#include "cJSON.h"\r
#endif\r
#include "RamlExceptions.h"\r
#include "RamlUtils.h"\r
#if defined (__TIZENRT__)\r
-#include <apps/netutils/cJSON.h>\r
+#include <json/cJSON.h>\r
#else\r
#include "cJSON.h"\r
#endif\r
\r
#include <string>\r
#if defined (__TIZENRT__)\r
-#include <apps/netutils/cJSON.h>\r
+#include <json/cJSON.h>\r
#else\r
#include "cJSON.h"\r
#endif\r
############################################################################
ifeq ($(CONFIG_NETUTILS_JSON),y)
-CONFIGURED_APPS += netutils/json
+
+CSRCS += json/cJSON.c
+
+DEPPATH += --dep-path json
+VPATH += :json
+
endif
#include <ctype.h>
#include <unistd.h>
-#include <apps/netutils/cJSON.h>
+#include <json/cJSON.h>
/****************************************************************************
* Pre-processor Definitions
############################################################################
ifeq ($(CONFIG_NETUTILS_LIBCOAP),y)
-CONFIGURED_APPS += netutils/libcoap
+
+CSRCS += libcoap/async.c
+CSRCS += libcoap/block.c
+CSRCS += libcoap/coap_list.c
+CSRCS += libcoap/debug.c
+CSRCS += libcoap/encode.c
+CSRCS += libcoap/hashkey.c
+CSRCS += libcoap/net.c
+CSRCS += libcoap/option.c
+CSRCS += libcoap/pdu.c
+CSRCS += libcoap/resource.c
+CSRCS += libcoap/str.c
+CSRCS += libcoap/subscribe.c
+CSRCS += libcoap/uri.c
+
+DEPPATH += --dep-path libcoap
+VPATH += :libcoap
+
endif
+
#ifndef WITHOUT_ASYNC
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
-#include <apps/netutils/libcoap/utlist.h>
+#include <protocols/libcoap/utlist.h>
-#include <apps/netutils/libcoap/mem.h>
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/async.h>
+#include <protocols/libcoap/mem.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/async.h>
coap_async_state_t *coap_register_async(coap_context_t *context, coap_address_t *peer, coap_pdu_t *request, unsigned char flags, void *data)
{
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#if defined(HAVE_ASSERT_H) && !defined(assert)
#include <assert.h>
#endif
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/block.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/block.h>
#define min(a,b) ((a) < (b) ? (a) : (b))
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#include <stdio.h>
#include <string.h>
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/mem.h>
-#include <apps/netutils/libcoap/coap_list.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/mem.h>
+#include <protocols/libcoap/coap_list.h>
int coap_insert(coap_list_t **queue, coap_list_t *node, int (*order)(void *, void *node))
{
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#if defined(HAVE_ASSERT_H) && !defined(assert)
#include <assert.h>
#include <time.h>
#endif
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/net.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/net.h>
#ifdef WITH_CONTIKI
#ifndef DEBUG
#include <stdio.h>
#endif
-#include <apps/netutils/libcoap/config.h>
-#include <apps/netutils/libcoap/encode.h>
+#include <protocols/libcoap/config.h>
+#include <protocols/libcoap/encode.h>
/* Carsten suggested this when fls() is not available: */
int coap_fls(unsigned int i)
* README for terms of use.
*/
-#include <apps/netutils/libcoap/hashkey.h>
+#include <protocols/libcoap/hashkey.h>
/* Caution: When changing this, update COAP_DEFAULT_WKC_HASHKEY
* accordingly (see int coap_hash_path());
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#include <ctype.h>
#include <stdio.h>
#include <net/lwip/timers.h>
#endif
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/mem.h>
-#include <apps/netutils/libcoap/str.h>
-#include <apps/netutils/libcoap/async.h>
-#include <apps/netutils/libcoap/resource.h>
-#include <apps/netutils/libcoap/option.h>
-#include <apps/netutils/libcoap/encode.h>
-#include <apps/netutils/libcoap/block.h>
-#include <apps/netutils/libcoap/net.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/mem.h>
+#include <protocols/libcoap/str.h>
+#include <protocols/libcoap/async.h>
+#include <protocols/libcoap/resource.h>
+#include <protocols/libcoap/option.h>
+#include <protocols/libcoap/encode.h>
+#include <protocols/libcoap/block.h>
+#include <protocols/libcoap/net.h>
#if defined(WITH_POSIX)
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#if defined(HAVE_ASSERT_H) && !defined(assert)
#include <assert.h>
#include <stdio.h>
#include <string.h>
-#include <apps/netutils/libcoap/option.h>
-#include <apps/netutils/libcoap/debug.h>
+#include <protocols/libcoap/option.h>
+#include <protocols/libcoap/debug.h>
coap_opt_t *options_start(coap_pdu_t *pdu, coap_transport_t transport)
{
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#if defined(HAVE_ASSERT_H) && !defined(assert)
#include <assert.h>
#include <arpa/inet.h>
#endif
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/pdu.h>
-#include <apps/netutils/libcoap/option.h>
-#include <apps/netutils/libcoap/encode.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/pdu.h>
+#include <protocols/libcoap/option.h>
+#include <protocols/libcoap/encode.h>
#ifdef WITH_CONTIKI
#include "memb.h"
memb_init(&pdu_storage);
}
#else /* WITH_CONTIKI */
-#include <apps/netutils/libcoap/mem.h>
+#include <protocols/libcoap/mem.h>
#endif /* WITH_CONTIKI */
void coap_pdu_clear(coap_pdu_t *pdu, size_t size)
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
-#include <apps/netutils/libcoap/net.h>
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/resource.h>
-#include <apps/netutils/libcoap/subscribe.h>
+#include <protocols/libcoap/config.h>
+#include <protocols/libcoap/net.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/resource.h>
+#include <protocols/libcoap/subscribe.h>
#ifdef WITH_LWIP
#include "utlist.h"
#endif
#ifdef WITH_POSIX
-#include <apps/netutils/libcoap/utlist.h>
-#include <apps/netutils/libcoap/mem.h>
+#include <protocols/libcoap/utlist.h>
+#include <protocols/libcoap/mem.h>
#define COAP_MALLOC_TYPE(Type) \
((coap_##Type##_t *)coap_malloc(sizeof(coap_##Type##_t)))
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#include <stdio.h>
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/mem.h>
-#include <apps/netutils/libcoap/str.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/mem.h>
+#include <protocols/libcoap/str.h>
str *coap_new_string(size_t size)
{
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#if defined(HAVE_ASSERT_H) && !defined(assert)
#include <assert.h>
/* #include "resource.h" */
-#include <apps/netutils/libcoap/mem.h>
-#include <apps/netutils/libcoap/encode.h>
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/subscribe.h>
+#include <protocols/libcoap/mem.h>
+#include <protocols/libcoap/encode.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/subscribe.h>
void coap_subscription_init(coap_subscription_t *s)
{
* README for terms of use.
*/
-#include <apps/netutils/libcoap/config.h>
+#include <protocols/libcoap/config.h>
#if defined(HAVE_ASSERT_H) && !defined(assert)
#include <assert.h>
#include <string.h>
#include <ctype.h>
-#include <apps/netutils/libcoap/mem.h>
-#include <apps/netutils/libcoap/debug.h>
-#include <apps/netutils/libcoap/pdu.h>
-#include <apps/netutils/libcoap/option.h>
-#include <apps/netutils/libcoap/uri.h>
+#include <protocols/libcoap/mem.h>
+#include <protocols/libcoap/debug.h>
+#include <protocols/libcoap/pdu.h>
+#include <protocols/libcoap/option.h>
+#include <protocols/libcoap/uri.h>
/**
* A length-safe version of strchr(). This function returns a pointer
###########################################################################
ifeq ($(CONFIG_NETUTILS_MDNS),y)
-CONFIGURED_APPS += netutils/mdns
+
+CSRCS += mdns/mdns.c mdns/mdnsd.c
+
+DEPPATH += --dep-path mdns
+VPATH += :mdns
+
endif
#endif
#include "mdns.h"
-#include <apps/netutils/mdnsd.h>
+#include <protocols/mdnsd.h>
#if (MDNS_DEBUG_PRINTF == 1) && (MDNS_RR_DEBUG == 1)
#define MDNSD_RR_DEBUG
--- /dev/null
+###########################################################################
+#
+# Copyright 2017 Samsung Electronics All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+# either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+#
+###########################################################################
+# apps/netutils/dhcpd/Make.defs
+# Adds selected applications to apps/ build
+#
+# Copyright (C) 2016 Gregory Nutt. All rights reserved.
+# Author: Gregory Nutt <gnutt@nuttx.org>
+#
+# Redistribution and use in source and binary forms, with or without
+# modification, are permitted provided that the following conditions
+# are met:
+#
+# 1. Redistributions of source code must retain the above copyright
+# notice, this list of conditions and the following disclaimer.
+# 2. Redistributions in binary form must reproduce the above copyright
+# notice, this list of conditions and the following disclaimer in
+# the documentation and/or other materials provided with the
+# distribution.
+# 3. Neither the name NuttX nor the names of its contributors may be
+# used to endorse or promote products derived from this software
+# without specific prior written permission.
+#
+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
+# FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
+# COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
+# INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
+# BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
+# OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
+# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
+# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
+# POSSIBILITY OF SUCH DAMAGE.
+#
+############################################################################
+
+ifeq ($(CONFIG_NETUTILS_MQTT),y)
+
+include mosquitto/config.mk
+
+CSRCS += mosquitto/tls_mosq.c
+CSRCS += mosquitto/net_mosq.c
+CSRCS += mosquitto/send_client_mosq.c
+CSRCS += mosquitto/messages_mosq.c
+CSRCS += mosquitto/util_mosq.c
+CSRCS += mosquitto/socks_mosq.c
+CSRCS += mosquitto/will_mosq.c
+CSRCS += mosquitto/mosquitto.c
+CSRCS += mosquitto/logging_mosq.c
+CSRCS += mosquitto/send_mosq.c
+CSRCS += mosquitto/read_handle_shared.c
+CSRCS += mosquitto/srv_mosq.c
+CSRCS += mosquitto/thread_mosq.c
+CSRCS += mosquitto/read_handle_client.c
+CSRCS += mosquitto/read_handle.c
+CSRCS += mosquitto/time_mosq.c
+CSRCS += mosquitto/memory_mosq.c
+
+#CFLAGS += -Imosquitto
+
+DEPPATH += --dep-path mosquitto
+VPATH += :mosquitto
+
+endif
+
--- /dev/null
+###########################################################################
+#
+# Copyright 2016 Samsung Electronics All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+# either express or implied. See the License for the specific
+# language governing permissions and limitations under the License.
+#
+###########################################################################
+# =============================================================================
+# User configuration section.
+#
+# These options control compilation on all systems apart from Windows and Mac
+# OS X. Use CMake to compile on Windows and Mac.
+#
+# Largely, these are options that are designed to make mosquitto run more
+# easily in restrictive environments by removing features.
+#
+# Modify the variable below to enable/disable features.
+#
+# Can also be overriden at the command line, e.g.:
+#
+# make WITH_TLS=no
+# =============================================================================
+
+# Uncomment to compile the broker with tcpd/libwrap support.
+#WITH_WRAP:=yes
+
+# Comment out to disable SSL/TLS support in the broker and client.
+# Disabling this will also mean that passwords must be stored in plain text. It
+# is strongly recommended that you only disable WITH_TLS if you are not using
+# password authentication at all.
+WITH_TLS:=no
+
+# Comment out to disable TLS/PSK support in the broker and client. Requires
+# WITH_TLS=yes.
+# This must be disabled if using openssl < 1.0.
+WITH_TLS_PSK:=no
+
+# Comment out to disable client client threading support.
+WITH_THREADING:=yes
+
+# Comment out to remove bridge support from the broker. This allow the broker
+# to connect to other brokers and subscribe/publish to topics. You probably
+# want to leave this included unless you want to save a very small amount of
+# memory size and CPU time.
+WITH_BRIDGE:=no
+
+# Comment out to remove persistent database support from the broker. This
+# allows the broker to store retained messages and durable subscriptions to a
+# file periodically and on shutdown. This is usually desirable (and is
+# suggested by the MQTT spec), but it can be disabled if required.
+WITH_PERSISTENCE:=no
+
+# Comment out to remove memory tracking support from the broker. If disabled,
+# mosquitto won't track heap memory usage nor export '$SYS/broker/heap/current
+# size', but will use slightly less memory and CPU time.
+WITH_MEMORY_TRACKING:=no
+
+# Compile with database upgrading support? If disabled, mosquitto won't
+# automatically upgrade old database versions.
+# Not currently supported.
+#WITH_DB_UPGRADE:=yes
+
+# Comment out to remove publishing of the $SYS topic hierarchy containing
+# information about the broker state.
+WITH_SYS_TREE:=no
+
+# Build with SRV lookup support.
+WITH_SRV:=no
+
+# Build using libuuid for clientid generation (Linux only - please report if
+# supported on your platform).
+WITH_UUID:=no
+
+# Build with websockets support on the broker.
+WITH_WEBSOCKETS:=no
+
+# Use elliptic keys in broker
+WITH_EC:=no
+
+# Build man page documentation by default.
+WITH_DOCS:=no
+
+# Build with client support for SOCK5 proxy.
+WITH_SOCKS:=no
+
+# =============================================================================
+# End of user configuration
+# =============================================================================
+-include $(TOPDIR)/.config
+
+#MQTT_TOP=$(EXTDIR)/mosquitto
+MQTT_TOP=mosquitto
+VERSION=1.4.10
+
+ifeq ($(WITH_THREADING),yes)
+ LIB_CFLAGS:=$(LIB_CFLAGS) -DWITH_THREADING
+endif
+
+ifeq ($(CONFIG_NETUTILS_MQTT_SECURITY),y)
+ LIB_CFLAGS:=$(LIB_CFLAGS) -DWITH_MBEDTLS
+endif
+
+MQTT_LIB_CFLAGS := $(LIB_CFLAGS) -D__TINYARA__ -DVERSION="\"${VERSION}\""
+MQTT_LIB_CFLAGS += -I$(MQTT_TOP)
+CFLAGS += $(MQTT_LIB_CFLAGS)
############################################################################
ifeq ($(CONFIG_NETUTILS_NETLIB),y)
-CONFIGURED_APPS += netutils/netlib
+
+CSRCS += netlib/netlib.c
+CSRCS += netlib/netlib_parsehttpurl.c
+CSRCS += netlib/netlib_setifstatus.c \
+ netlib/netlib_getifstatus.c
+
+
+ifeq ($(CONFIG_NET_IPv4),y)
+CSRCS += netlib/netlib_setipv4addr.c \
+ netlib/netlib_getipv4addr.c \
+ netlib/netlib_getdripv4addr.c \
+ netlib/netlib_setdripv4addr.c \
+ netlib/netlib_setipv4netmask.c
+endif
+
+ifeq ($(CONFIG_NET_IPv6),y)
+CSRCS += netlib/netlib_setipv6addr.c \
+ netlib/netlib_getipv6addr.c \
+ netlib/netlib_getdripv6addr.c \
+ netlib/netlib_setdripv6addr.c \
+ netlib/netlib_setipv6netmask.c \
+ netlib/netlib_prefix2ipv6netmask.c \
+ netlib/netlib_ipv6netmask2prefix.c
+endif
+
+
+# No MAC address support for SLIP (Ethernet only)
+
+ifeq ($(CONFIG_NET_ETHERNET),y)
+CSRCS += netlib/netlib_setmacaddr.c \
+ netlib/netlib_getmacaddr.c
+endif
+
+# IGMP support
+
+ifeq ($(CONFIG_NET_IGMP),y)
+ifeq ($(CONFIG_NET_IPv4),y) # Not yet available for IPv6
+CSRCS += netlib/netlib_ipmsfilter.c
+endif
+endif
+
+DEPPATH += --dep-path netlib
+VPATH += :netlib
+
+
endif
#include <string.h>
#include <debug.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Pre-processor Definitions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Pre-processor Definitions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Pre-processor Definitions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Pre-processor Definitions
#include <netinet/in.h>
#include <sys/sockio.h>
-#include <apps/netutils/netlib.h>
-#include <apps/netutils/ipmsfilter.h>
+#include <protocols/netlib.h>
+#include <protocols/ipmsfilter.h>
#ifdef CONFIG_NET_IGMP
#include <stdint.h>
#include <arpa/inet.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#ifdef CONFIG_NET_IPv6
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <string.h>
#include <errno.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Private Data
#include <stdint.h>
#include <netinet/ip.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#ifdef CONFIG_NET_IPv6
#include <netinet/in.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Pre-processor Definitions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Public Functions
#include <netinet/in.h>
#include <net/if.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Pre-processor Definitions
############################################################################
ifeq ($(CONFIG_NETUTILS_NTPCLIENT),y)
-CONFIGURED_APPS += netutils/ntpclient
+
+CSRCS += ntpclient/ntpclient.c
+
+DEPPATH += --dep-path ntpclient
+VPATH += :ntpclient
+
endif
#include <errno.h>
#include <debug.h>
#include <netinet/in.h>
-#include <apps/netutils/ntpclient.h>
+#include <protocols/ntpclient.h>
#include <netdb.h>
#include "ntpv3.h"
############################################################################
ifeq ($(CONFIG_NETUTILS_SMTP),y)
-CONFIGURED_APPS += netutils/smtp
+
+CSRCS += smtp/smtp.c
+
+DEPPATH += --dep-path smtp
+VPATH += :smtp
+
endif
#include <arpa/inet.h>
#include <tinyara/net/ip.h>
-#include <apps/netutils/smtp.h>
+#include <protocols/smtp.h>
/****************************************************************************
* Pre-processor Definitions
ifeq ($(CONFIG_NETUTILS_TELNETD),y)
CONFIGURED_APPS += netutils/telnetd
+
+CSRCS += telnetd/telnetd_daemon.c
+
+DEPPATH += --dep-path telnetd
+VPATH += :telnetd
+
endif
#include <tinyara/net/telnet.h>
-#include <apps/netutils/telnetd.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/telnetd.h>
+#include <protocols/netlib.h>
/****************************************************************************
* Private Types
############################################################################
ifeq ($(CONFIG_NETUTILS_TFTPC),y)
-CONFIGURED_APPS += netutils/tftpc
+
+CSRCS += tftpc/tftpc_get.c tftpc/tftpc_put.c tftpc/tftpc_packets.c
+
+DEPPATH += --dep-path tftpc
+VPATH += :tftpc
+
endif
#include <arpa/inet.h>
-#include <apps/netutils/tftp.h>
+#include <protocols/tftp.h>
#include "tftpc_internal.h"
#include <netinet/in.h>
#include <arpa/inet.h>
-#include <apps/netutils/tftp.h>
+#include <protocols/tftp.h>
#include "tftpc_internal.h"
#include <errno.h>
#include <debug.h>
-#include <apps/netutils/tftp.h>
+#include <protocols/tftp.h>
#include "tftpc_internal.h"
############################################################################
ifeq ($(CONFIG_NETUTILS_WEBCLIENT),y)
-CONFIGURED_APPS += netutils/webclient
+
+ifeq ($(CONFIG_NETUTILS_WEBCLIENT),y)
+CSRCS += webclient/webclient.c
+endif
+
+DEPPATH += --dep-path webclient
+VPATH += :webclient
+
endif
#include <netinet/in.h>
#include <tinyara/version.h>
-#include <apps/netutils/netlib.h>
+#include <protocols/netlib.h>
#include "../webserver/http_string_util.h"
#include "../webserver/http_client.h"
-#include <apps/netutils/webclient.h>
+#include <protocols/webclient.h>
#if defined(CONFIG_NETUTILS_CODECS)
# if defined(CONFIG_CODECS_URLCODE)
# define WGET_USE_URLENCODE 1
-# include <apps/netutils/urldecode.h>
+# include <protocols/urldecode.h>
# endif
# if defined(CONFIG_CODECS_BASE64)
-# include <apps/netutils/base64.h>
+# include <protocols/base64.h>
# endif
#else
# undef CONFIG_CODECS_URLCODE
ifeq ($(CONFIG_NETUTILS_WEBSERVER),y)
CONFIGURED_APPS += netutils/webserver
+
+ifeq ($(CONFIG_NETUTILS_WEBSERVER),y)
+CSRCS += webserver/http.c
+CSRCS += webserver/http_server.c
+CSRCS += webserver/http_client.c
+ifeq ($(CONFIG_NET_SECURITY_TLS),y)
+CSRCS += webserver/http_client_tls.c
+CSRCS += webserver/http_server_tls.c
+endif
+CSRCS += webserver/http_string_util.c
+CSRCS += webserver/http_keyvalue_list.c
+CSRCS += webserver/http_query.c
+endif
+
+DEPPATH += --dep-path webserver
+VPATH += :webserver
+
endif
*
****************************************************************************/
-#include <apps/netutils/webserver/http_err.h>
-#include <apps/netutils/webserver/http_server.h>
-#include <apps/netutils/webserver/http_keyvalue_list.h>
+#include <protocols/webserver/http_err.h>
+#include <protocols/webserver/http_server.h>
+#include <protocols/webserver/http_keyvalue_list.h>
#include <fcntl.h>
#include "http.h"
****************************************************************************/
#include <fcntl.h>
-#include <apps/netutils/webserver/http_err.h>
-#include <apps/netutils/webserver/http_keyvalue_list.h>
-#include <apps/netutils/webclient.h>
-#include <apps/netutils/websocket.h>
+#include <protocols/webserver/http_err.h>
+#include <protocols/webserver/http_keyvalue_list.h>
+#include <protocols/webclient.h>
+#include <protocols/websocket.h>
#include <tinyara/fs/fs.h>
#include <tinyara/fs/dirent.h>
#ifndef __http_client_h__
#define __http_client_h__
-#include <apps/netutils/webserver/http_server.h>
-#include <apps/netutils/webclient.h>
-#include <apps/netutils/websocket.h>
+#include <protocols/webserver/http_server.h>
+#include <protocols/webclient.h>
+#include <protocols/websocket.h>
#ifdef CONFIG_NET_SECURITY_TLS
#include "tls/config.h"
*
****************************************************************************/
-#include <apps/netutils/webserver/http_err.h>
+#include <protocols/webserver/http_err.h>
#include "http.h"
#include "http_client.h"
#include <tinyara/progmem.h>
#include <sys/stat.h>
-#include <apps/netutils/webserver/http_err.h>
-#include <apps/netutils/webserver/http_keyvalue_list.h>
+#include <protocols/webserver/http_err.h>
+#include <protocols/webserver/http_keyvalue_list.h>
#include "http.h"
#include "http_arch.h"
#include <tinyara/progmem.h>
#include <sys/stat.h>
-#include <apps/netutils/webserver/http_err.h>
-#include <apps/netutils/webserver/http_keyvalue_list.h>
+#include <protocols/webserver/http_err.h>
+#include <protocols/webserver/http_keyvalue_list.h>
#include "http.h"
#include "http_client.h"
****************************************************************************/
#include <stdlib.h>
-#include <apps/netutils/webserver/http_err.h>
-#include <apps/netutils/webserver/http_server.h>
+#include <protocols/webserver/http_err.h>
+#include <protocols/webserver/http_server.h>
#include "http_client.h"
#include "http_arch.h"
*
****************************************************************************/
-#include <apps/netutils/webserver/http_err.h>
-#include <apps/netutils/webserver/http_server.h>
+#include <protocols/webserver/http_err.h>
+#include <protocols/webserver/http_server.h>
#include "http_client.h"
#include "http_arch.h"
#include <string.h>
#include <stdlib.h>
-#include <apps/netutils/webserver/http_err.h>
-#include <apps/netutils/webserver/http_server.h>
+#include <protocols/webserver/http_err.h>
+#include <protocols/webserver/http_server.h>
#include "http.h"
#include "http_string_util.h"
ifeq ($(CONFIG_NETUTILS_WEBSOCKET),y)
CONFIGURED_APPS += netutils/websocket
+
+CSRCS += websocket/websocket.c
+CSRCS += websocket/wslay/wslay_net.c \
+ websocket/wslay/wslay_queue.c \
+ websocket/wslay/wslay_frame.c \
+ websocket/wslay/wslay_event.c
+
+DEPPATH += --dep-path websocket
+VPATH += :websocket
+
endif
#include <sys/time.h>
#include <tls/sha1.h>
#include <tls/base64.h>
-#include <apps/netutils/netlib.h>
-#include <apps/netutils/websocket.h>
-#include <apps/netutils/wslay/wslay.h>
+#include <protocols/netlib.h>
+#include <protocols/websocket.h>
+#include <protocols/wslay/wslay.h>
/****************************************************************************
* Definitions
#include "wslay_frame.h"
#include "wslay_net.h"
-#include <apps/netutils/websocket.h>
+#include <protocols/websocket.h>
#define UTF8_ACCEPT 0
#define UTF8_REJECT 12
#define WSLAY_EVENT_H
#include <tinyara/config.h>
-#include <apps/netutils/wslay/wslay.h>
+#include <protocols/wslay/wslay.h>
struct wslay_stack;
struct wslay_queue;
#define WSLAY_FRAME_H
#include <tinyara/config.h>
-#include <apps/netutils/wslay/wslay.h>
+#include <protocols/wslay/wslay.h>
enum wslay_frame_state {
PREP_HEADER,
#include <tinyara/config.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <apps/netutils/wslay/wslay.h>
+#include <protocols/wslay/wslay.h>
#ifdef WORDS_BIGENDIAN
#define ntoh64(x) (x)
#define WSLAY_QUEUE_H
#include <tinyara/config.h>
-#include <apps/netutils/wslay/wslay.h>
+#include <protocols/wslay/wslay.h>
struct wslay_queue_cell {
void *data;
#define WSLAY_STACK_H
#include "tinyara/config.h"
-#include <apps/netutils/wslay/wslay.h>
+#include <protocols/wslay/wslay.h>
struct wslay_stack_cell {
void *data;
--- /dev/null
+/.built
+/.depend
+/Make.dep
+/*.src
+/*.obj
+/*.lst
############################################################################
ifeq ($(CONFIG_NETUTILS_XMLRPC),y)
-CONFIGURED_APPS += netutils/xmlrpc
+
+CSRCS += xmlrpc/xmlparser.c \
+ xmlrpc/response.c
+
+DEPPATH += --dep-path xmlrpc
+VPATH += :xmlrpc
+
endif
#include <stdarg.h>
#include <string.h>
#include <stdio.h>
-#include <apps/netutils/xmlrpc.h>
+#include <protocols/xmlrpc.h>
/****************************************************************************
* Private Functions
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
-#include <apps/netutils/xmlrpc.h>
+#include <protocols/xmlrpc.h>
/****************************************************************************
* Pre-processor Definitions
include src$(DELIM)arastorage$(DELIM)Make.defs
endif
+ifeq ($(CONFIG_NETUTILS_MQTT), y)
+include src$(DELIM)mqtt$(DELIM)Make.defs
+endif
+
AOBJS = $(ASRCS:.S=$(OBJEXT))
COBJS = $(CSRCS:.c=$(OBJEXT))
#include <dm/dm_error.h>
#include <dm/dm_connectivity.h>
-#include <apps/netutils/dhcpc.h>
+#include <protocols/dhcpc.h>
#include <apps/netutils/wifi/slsi_wifi_api.h>
#include <apps/netutils/wifi/slsi_wifi_utils.h>
#include <arpa/inet.h>
############################################################################
ifeq ($(CONFIG_NETUTILS_MQTT),y)
-CONFIGURED_APPS += netutils/mqtt
+
+include ../external/mosquitto/config.mk
+
+CSRCS += mqtt_api.c
+
+CFLAGS += -I../external/mosquitto
+
+DEPPATH += --dep-path src/mqtt
+VPATH += :src/mqtt
+
endif
--- /dev/null
+/****************************************************************************
+ *
+ * Copyright 2016 Samsung Electronics All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+ * either express or implied. See the License for the specific
+ * language governing permissions and limitations under the License.
+ *
+ ****************************************************************************/
+
+/* ============================================================
+ * Control compile time options.
+ * ============================================================
+ *
+ * Compile time options have moved to config.mk.
+ */
+
+/* ============================================================
+ * Compatibility defines
+ *
+ * Generally for Windows native support.
+ * ============================================================ */
+
+#if defined(_MSC_VER) && _MSC_VER < 1900
+# define snprintf sprintf_s
+#endif
+
+#ifdef WIN32
+# ifndef strcasecmp
+# define strcasecmp strcmpi
+# endif
+#define strtok_r strtok_s
+#define strerror_r(e, b, l) strerror_s(b, l, e)
+#endif
+
+#define uthash_malloc(sz) _mosquitto_malloc(sz)
+#define uthash_free(ptr,sz) _mosquitto_free(ptr)
+
+#ifndef EPROTO
+# define EPROTO ECONNABORTED
+#endif
+
+#ifdef WITH_MBEDTLS
+#include "tls/ssl.h"
+#include "tls/net.h"
+#include "tls/x509_crt.h"
+#include "tls/pk.h"
+#include "tls/ctr_drbg.h"
+#include "tls/ssl_cache.h"
+#include "tls/entropy.h"
+#endif
#include "mosquitto_internal.h"
#include "memory_mosq.h"
-#include <apps/netutils/mqtt_api.h>
+#include <mqtt/mqtt_api.h>
/****************************************************************************
* Pre-processor Definitions
source net/route/Kconfig
menu "Protocols"
-source ../external/dhcpd/Kconfig.protocol
+
+source "$EXTERNALDIR/dhcpd/Kconfig.protocol"
+source "$EXTERNALDIR/xmlrpc/Kconfig.protocol"
+source "$EXTERNALDIR/ntpclient/Kconfig.protocol"
+source "$EXTERNALDIR/webserver/Kconfig.protocol"
+source "$EXTERNALDIR/ftpc/Kconfig.protocol"
+source "$EXTERNALDIR/mdns/Kconfig.protocol"
+source "$EXTERNALDIR/webclient/Kconfig.protocol"
+source "$EXTERNALDIR/ftpd/Kconfig.protocol"
+source "$EXTERNALDIR/dhcpc/Kconfig.protocol"
+source "$EXTERNALDIR/websocket/Kconfig.protocol"
+source "$EXTERNALDIR/libcoap/Kconfig.protocol"
+source "$EXTERNALDIR/tftpc/Kconfig.protocol"
+source "$EXTERNALDIR/telnetd/Kconfig.protocol"
+source "$EXTERNALDIR/smtp/Kconfig.protocol"
+source "$EXTERNALDIR/netlib/Kconfig.protocl"
+
+source "../framework/src/mqtt/Kconfig.protocol"
+
endmenu #Protocols