From fd95a7e124618eb249769ce3ff6d7a16aeb873e8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Axel=20D=C3=B6rfler?= <axeld@pinc-software.de>
Date: Sun, 28 Dec 2008 22:18:21 +0000
Subject: [PATCH] * The net_server now accepts messages from the outside that
 want to configure   an interface (I don't remember why I didn't want this
 earlier, but well). * ifconfig now has an auto-config option that will
 trigger DHCP. * Also, it will now remove the IFF_AUTO_CONFIGURED and
 IFF_CONFIGURING flags   if an address is specified (any on-going
 auto-configuration should check for   these and abort if they aren't there
 anymore).

git-svn-id: file:///srv/svn/repos/haiku/haiku/trunk@28831 a95241bf-73f2-0310-859d-f6bbb57e9c96
---
 src/bin/network/ifconfig/Jamfile      |   6 +-
 src/bin/network/ifconfig/ifconfig.cpp | 135 +++++++++++++++++++-------
 src/servers/net/NetServer.cpp         |  28 +++---
 src/servers/net/NetServer.h           |   4 +-
 4 files changed, 122 insertions(+), 51 deletions(-)

diff --git a/src/bin/network/ifconfig/Jamfile b/src/bin/network/ifconfig/Jamfile
index c0890f13e2..bd91da3c02 100644
--- a/src/bin/network/ifconfig/Jamfile
+++ b/src/bin/network/ifconfig/Jamfile
@@ -6,9 +6,11 @@ if ! $(TARGET_PLATFORM_HAIKU_COMPATIBLE) {
 		# Unfortunately we get more than we want, namely all POSIX headers.
 }
 
+UseHeaders [ FDirName $(HAIKU_TOP) src servers net ] : true ;
+
 BinCommand ifconfig :
 	ifconfig.cpp
-	: libnetwork.so
+	: be network
 ;
 
 # Installation -- in the test directory for the time being
@@ -16,7 +18,7 @@ HaikuInstall install-networking
 	: [ FDirName $(HAIKU_TEST_DIR) kits net ]
 	: ifconfig ;
 
-HaikuInstall install-userland-networking 
+HaikuInstall install-userland-networking
 	: [ FDirName $(HAIKU_TEST_DIR) kits net userland ]
 	: ifconfig
 	: installed-userland-networking
diff --git a/src/bin/network/ifconfig/ifconfig.cpp b/src/bin/network/ifconfig/ifconfig.cpp
index ea13c5612a..021672bf0a 100644
--- a/src/bin/network/ifconfig/ifconfig.cpp
+++ b/src/bin/network/ifconfig/ifconfig.cpp
@@ -8,7 +8,8 @@
  */
 
 
-#include <SupportDefs.h>
+#include <Message.h>
+#include <Messenger.h>
 
 #include <arpa/inet.h>
 #include <net/if.h>
@@ -25,6 +26,8 @@
 #include <string.h>
 #include <unistd.h>
 
+#include <NetServer.h>
+
 
 extern const char* __progname;
 const char* kProgramName = __progname;
@@ -63,7 +66,7 @@ inet_parse_address(const char* string, sockaddr* _address)
 		return false;
 
 	sockaddr_in& address = *(sockaddr_in *)_address;
-	address.sin_family = AF_INET; 
+	address.sin_family = AF_INET;
 	address.sin_len = sizeof(struct sockaddr_in);
 	address.sin_port = 0;
 	address.sin_addr = inetAddress;
@@ -77,7 +80,7 @@ static void
 inet_print_address(sockaddr* _address)
 {
 	sockaddr_in& address = *(sockaddr_in *)_address;
-	
+
 	if (address.sin_family != AF_INET)
 		return;
 
@@ -153,7 +156,7 @@ media_parse_subtype(const char* string, int media, int* type)
 {
 	for (int32 i = 0; kMediaTypes[i].type >= 0; i++) {
 		// only check for generic or correct subtypes
-		if (kMediaTypes[i].type && 
+		if (kMediaTypes[i].type &&
 			kMediaTypes[i].type != media)
 			continue;
 		for (int32 j = 0; kMediaTypes[i].subtypes[j].subtype >= 0; j++) {
@@ -174,7 +177,8 @@ media_parse_subtype(const char* string, int media, int* type)
 void
 usage(int status)
 {
-	printf("usage: %s [<interface> [<address family>] [<address> [<mask>]] [<option/flags>...]]\n"
+	printf("usage: %s [<interface> [<address family>] [<address> [<mask>] | "
+			"auto-config] [<option/flags>...]]\n"
 		"\t%s --delete interface [...]\n\n"
 		"Where <option> can be the following:\n"
 		"  netmask <addr>   - networking subnet mask\n"
@@ -190,7 +194,10 @@ usage(int status)
 			printf("%s ", kMediaTypes[i].subtypes[j].name);
 		printf("\n");
 	}
-	printf("And <flags> can be: up, down, [-]promisc, [-]allmulti, [-]bcast, loopback\n\n"
+	printf("And <flags> can be: up, down, [-]promisc, [-]allmulti, [-]bcast, "
+			"loopback\n"
+		"If you specify \"auto-config\" instead of an address, it will be "
+			"configured automatically.\n\n"
 		"Example:\n"
 		"\t%s loop 127.0.0.1 255.0.0.0 up\n",
 		kProgramName);
@@ -316,7 +323,7 @@ list_interface(int socket, const char* name)
 			if (IFM_TYPE(request.ifr_media) == 0/*IFT_LOOP*/)
 				break;
 			// only check for generic or correct subtypes
-			if (kMediaTypes[i].type && 
+			if (kMediaTypes[i].type &&
 				kMediaTypes[i].type != IFM_TYPE(request.ifr_media))
 				continue;
 			for (int32 j = 0; kMediaTypes[i].subtypes[j].subtype >= 0; j++) {
@@ -497,10 +504,11 @@ configure_interface(int socket, const char* name, char* const* args,
 	if (ioctl(socket, SIOCGIFINDEX, &request, sizeof(request)) >= 0)
 		index = request.ifr_index;
 
-	bool hasAddress = false, hasMask = false, hasPeer = false, hasBroadcast = false;
+	bool hasAddress = false, hasMask = false, hasPeer = false;
+	bool hasBroadcast = false, doAutoConfig = false;
 	struct sockaddr address, mask, peer, broadcast;
 	int mtu = -1, metric = -1, media = -1;
-	int addFlags = 0, removeFlags = 0, currentFlags = 0;
+	int addFlags = 0, currentFlags = 0, removeFlags = 0;
 
 	// try to parse address family
 
@@ -552,8 +560,8 @@ configure_interface(int socket, const char* name, char* const* args,
 	while (i < argCount) {
 		if (!strcmp(args[i], "peer")) {
 			if (!parse_address(familyIndex, args[i + 1], peer)) {
-				fprintf(stderr, "%s: Option 'peer' needs valid address parameter\n",
-					kProgramName);
+				fprintf(stderr, "%s: Option 'peer' needs valid address "
+					"parameter\n", kProgramName);
 				exit(1);
 			}
 			hasPeer = true;
@@ -565,8 +573,8 @@ configure_interface(int socket, const char* name, char* const* args,
 				exit(1);
 			}
 			if (!parse_address(familyIndex, args[i + 1], mask)) {
-				fprintf(stderr, "%s: Option 'netmask' needs valid address parameter\n",
-					kProgramName);
+				fprintf(stderr, "%s: Option 'netmask' needs valid address "
+					"parameter\n", kProgramName);
 				exit(1);
 			}
 			hasMask = true;
@@ -578,8 +586,8 @@ configure_interface(int socket, const char* name, char* const* args,
 				exit(1);
 			}
 			if (!parse_address(familyIndex, args[i + 1], broadcast)) {
-				fprintf(stderr, "%s: Option 'broadcast' needs valid address parameter\n",
-					kProgramName);
+				fprintf(stderr, "%s: Option 'broadcast' needs valid address "
+					"parameter\n", kProgramName);
 				exit(1);
 			}
 			hasBroadcast = true;
@@ -588,8 +596,8 @@ configure_interface(int socket, const char* name, char* const* args,
 		} else if (!strcmp(args[i], "mtu")) {
 			mtu = args[i + 1] ? strtol(args[i + 1], NULL, 0) : 0;
 			if (mtu <= 500) {
-				fprintf(stderr, "%s: Option 'mtu' expected valid max transfer unit size\n",
-					kProgramName);
+				fprintf(stderr, "%s: Option 'mtu' expected valid max transfer "
+					"unit size\n", kProgramName);
 				exit(1);
 			}
 			i++;
@@ -602,7 +610,8 @@ configure_interface(int socket, const char* name, char* const* args,
 			metric = strtol(args[i + 1], NULL, 0);
 			i++;
 		} else if (!strcmp(args[i], "media")) {
-			if (ioctl(socket, SIOCGIFMEDIA, &request, sizeof(struct ifreq)) < 0) {
+			if (ioctl(socket, SIOCGIFMEDIA, &request,
+					sizeof(struct ifreq)) < 0) {
 				fprintf(stderr, "%s: Unable to detect media type\n",
 					kProgramName);
 				exit(1);
@@ -612,9 +621,10 @@ configure_interface(int socket, const char* name, char* const* args,
 					kProgramName);
 				exit(1);
 			}
-			if (!media_parse_subtype(args[i + 1], IFM_TYPE(request.ifr_media), &media)) {
-				fprintf(stderr, "%s: Invalid parameter for option 'media': '%s'\n",
-					kProgramName, args[i + 1]);
+			if (!media_parse_subtype(args[i + 1], IFM_TYPE(request.ifr_media),
+					&media)) {
+				fprintf(stderr, "%s: Invalid parameter for option 'media': "
+					"'%s'\n", kProgramName, args[i + 1]);
 				exit(1);
 			}
 			i++;
@@ -636,6 +646,8 @@ configure_interface(int socket, const char* name, char* const* args,
 			removeFlags |= IFF_ALLMULTI;
 		} else if (!strcmp(args[i], "loopback")) {
 			addFlags |= IFF_LOOPBACK;
+		} else if (!strcmp(args[i], "auto-config")) {
+			doAutoConfig = true;
 		} else
 			usage(1);
 
@@ -647,19 +659,26 @@ configure_interface(int socket, const char* name, char* const* args,
 		exit(1);
 	}
 
+	if (doAutoConfig && (hasAddress || hasMask || hasBroadcast || hasPeer)) {
+		fprintf(stderr, "%s: Contradicting changes specified\n", kProgramName);
+		exit(1);
+	}
+
 	// set address/mask/broadcast/peer
 
 	if (hasAddress) {
 		memcpy(&request.ifr_addr, &address, address.sa_len);
 
 		if (ioctl(socket, SIOCSIFADDR, &request, sizeof(struct ifreq)) < 0) {
-			fprintf(stderr, "%s: Setting address failed: %s\n", kProgramName, strerror(errno));
+			fprintf(stderr, "%s: Setting address failed: %s\n", kProgramName,
+				strerror(errno));
 			exit(1);
 		}
 	}
 
 	if (ioctl(socket, SIOCGIFFLAGS, &request, sizeof(struct ifreq)) < 0) {
-		fprintf(stderr, "%s: Getting flags failed: %s\n", kProgramName, strerror(errno));
+		fprintf(stderr, "%s: Getting flags failed: %s\n", kProgramName,
+			strerror(errno));
 		exit(1);
 	}
 	currentFlags = request.ifr_flags;
@@ -668,7 +687,8 @@ configure_interface(int socket, const char* name, char* const* args,
 		memcpy(&request.ifr_mask, &mask, mask.sa_len);
 
 		if (ioctl(socket, SIOCSIFNETMASK, &request, sizeof(struct ifreq)) < 0) {
-			fprintf(stderr, "%s: Setting subnet mask failed: %s\n", kProgramName, strerror(errno));
+			fprintf(stderr, "%s: Setting subnet mask failed: %s\n",
+				kProgramName, strerror(errno));
 			exit(1);
 		}
 	}
@@ -677,7 +697,8 @@ configure_interface(int socket, const char* name, char* const* args,
 		memcpy(&request.ifr_broadaddr, &broadcast, broadcast.sa_len);
 
 		if (ioctl(socket, SIOCSIFBRDADDR, &request, sizeof(struct ifreq)) < 0) {
-			fprintf(stderr, "%s: Setting broadcast address failed: %s\n", kProgramName, strerror(errno));
+			fprintf(stderr, "%s: Setting broadcast address failed: %s\n",
+				kProgramName, strerror(errno));
 			exit(1);
 		}
 	}
@@ -686,37 +707,79 @@ configure_interface(int socket, const char* name, char* const* args,
 		memcpy(&request.ifr_dstaddr, &peer, peer.sa_len);
 
 		if (ioctl(socket, SIOCSIFDSTADDR, &request, sizeof(struct ifreq)) < 0) {
-			fprintf(stderr, "%s: Setting peer address failed: %s\n", kProgramName, strerror(errno));
+			fprintf(stderr, "%s: Setting peer address failed: %s\n",
+				kProgramName, strerror(errno));
 			exit(1);
 		}
 	}
 
 	// set flags
 
+	if (hasAddress || hasMask || hasBroadcast || hasPeer) {
+		removeFlags = IFF_AUTO_CONFIGURED | IFF_CONFIGURING;
+	}
+printf("set flags: current %x, remove %x, add %x\n", currentFlags, removeFlags, addFlags);
 	if (addFlags || removeFlags) {
 		request.ifr_flags = (currentFlags & ~removeFlags) | addFlags;
-		if (ioctl(socket, SIOCSIFFLAGS, &request, sizeof(struct ifreq)) < 0)
-			fprintf(stderr, "%s: Setting flags failed: %s\n", kProgramName, strerror(errno));
+printf(" --> set %x\n", request.ifr_flags);
+		if (ioctl(socket, SIOCSIFFLAGS, &request, sizeof(struct ifreq)) < 0) {
+			fprintf(stderr, "%s: Setting flags failed: %s\n", kProgramName,
+				strerror(errno));
+		}
 	}
 
 	// set options
 
 	if (mtu != -1) {
 		request.ifr_mtu = mtu;
-		if (ioctl(socket, SIOCSIFMTU, &request, sizeof(struct ifreq)) < 0)
-			fprintf(stderr, "%s: Setting MTU failed: %s\n", kProgramName, strerror(errno));
+		if (ioctl(socket, SIOCSIFMTU, &request, sizeof(struct ifreq)) < 0) {
+			fprintf(stderr, "%s: Setting MTU failed: %s\n", kProgramName,
+				strerror(errno));
+		}
 	}
 
 	if (metric != -1) {
 		request.ifr_metric = metric;
-		if (ioctl(socket, SIOCSIFMETRIC, &request, sizeof(struct ifreq)) < 0)
-			fprintf(stderr, "%s: Setting metric failed: %s\n", kProgramName, strerror(errno));
+		if (ioctl(socket, SIOCSIFMETRIC, &request, sizeof(struct ifreq)) < 0) {
+			fprintf(stderr, "%s: Setting metric failed: %s\n", kProgramName,
+				strerror(errno));
+		}
 	}
 
 	if (media != -1) {
 		request.ifr_media = media;
-		if (ioctl(socket, SIOCSIFMEDIA, &request, sizeof(struct ifreq)) < 0)
-			fprintf(stderr, "%s: Setting media failed: %s\n", kProgramName, strerror(errno));
+		if (ioctl(socket, SIOCSIFMEDIA, &request, sizeof(struct ifreq)) < 0) {
+			fprintf(stderr, "%s: Setting media failed: %s\n", kProgramName,
+				strerror(errno));
+		}
+	}
+
+	// start auto configuration, if asked for
+
+	if (doAutoConfig) {
+		BMessage message(kMsgConfigureInterface);
+		message.AddString("device", name);
+		BMessage address;
+		address.AddString("family", "inet");
+		address.AddBool("auto config", true);
+		message.AddMessage("address", &address);
+
+		BMessenger networkServer(kNetServerSignature);
+		if (networkServer.IsValid()) {
+			BMessage reply;
+			status_t status = networkServer.SendMessage(&message, &reply);
+			if (status != B_OK) {
+				fprintf(stderr, "%s: Sending auto-config message failed: %s\n",
+					kProgramName, strerror(status));
+			} else if (reply.FindInt32("status", &status) == B_OK
+					&& status != B_OK) {
+				fprintf(stderr, "%s: Auto-configuring failed: %s\n",
+					kProgramName, strerror(status));
+			}
+		} else {
+			fprintf(stderr, "%s: The net_server needs to run for the auto "
+				"configuration!\n", kProgramName);
+		}
 	}
 }
 
@@ -746,8 +809,8 @@ main(int argc, char** argv)
 	// we need a socket to talk to the networking stack
 	int socket = ::socket(AF_INET, SOCK_DGRAM, 0);
 	if (socket < 0) {
-		fprintf(stderr, "%s: The networking stack doesn't seem to be available.\n",
-			kProgramName);
+		fprintf(stderr, "%s: The networking stack doesn't seem to be "
+			"available.\n", kProgramName);
 		return 1;
 	}
 
diff --git a/src/servers/net/NetServer.cpp b/src/servers/net/NetServer.cpp
index 258ef76bec..ce6489428b 100644
--- a/src/servers/net/NetServer.cpp
+++ b/src/servers/net/NetServer.cpp
@@ -39,9 +39,6 @@
 #include "Settings.h"
 
 
-static const char *kSignature = "application/x-vnd.haiku-net_server";
-
-
 typedef std::map<std::string, AutoconfigLooper*> LooperMap;
 
 
@@ -242,7 +239,7 @@ get_mac_address(const char* device, uint8* address)
 
 
 NetServer::NetServer(status_t& error)
-	: BServer(kSignature, false, &error)
+	: BServer(kNetServerSignature, false, &error)
 {
 }
 
@@ -306,10 +303,12 @@ NetServer::MessageReceived(BMessage* message)
 
 		case kMsgConfigureInterface:
 		{
+#if 0
 			if (!message->ReturnAddress().IsTargetLocal()) {
 				// for now, we only accept this message from add-ons
 				break;
 			}
+#endif
 
 			// we need a socket to talk to the networking stack
 			int socket = ::socket(AF_INET, SOCK_DGRAM, 0);
@@ -475,7 +474,8 @@ NetServer::_TestForInterface(int socket, const char* name)
 			break;
 		}
 
-		interface = (ifreq *)((addr_t)interface + IF_NAMESIZE + interface->ifr_addr.sa_len);
+		interface = (ifreq *)((addr_t)interface + IF_NAMESIZE
+			+ interface->ifr_addr.sa_len);
 	}
 
 	free(buffer);
@@ -484,7 +484,8 @@ NetServer::_TestForInterface(int socket, const char* name)
 
 
 status_t
-NetServer::_ConfigureInterface(int socket, BMessage& interface, bool fromMessage)
+NetServer::_ConfigureInterface(int socket, BMessage& interface,
+	bool fromMessage)
 {
 	const char *device;
 	if (interface.FindString("device", &device) != B_OK)
@@ -513,8 +514,8 @@ NetServer::_ConfigureInterface(int socket, BMessage& interface, bool fromMessage
 		metric = -1;
 
 	BMessage addressMessage;
-	for (int32 index = 0; interface.FindMessage("address", index, &addressMessage) == B_OK;
-			index++) {
+	for (int32 index = 0; interface.FindMessage("address", index,
+			&addressMessage) == B_OK; index++) {
 		const char* family;
 		if (addressMessage.FindString("family", &family) < B_OK)
 			continue;
@@ -556,12 +557,15 @@ NetServer::_ConfigureInterface(int socket, BMessage& interface, bool fromMessage
 		bool autoConfig;
 		if (addressMessage.FindBool("auto config", &autoConfig) != B_OK)
 			autoConfig = false;
+#if 0
 		if (autoConfig && fromMessage) {
 			// we don't accept auto-config messages this way
 			continue;
 		}
+#endif
 
-		bool hasAddress = false, hasMask = false, hasPeer = false, hasBroadcast = false;
+		bool hasAddress = false, hasMask = false, hasPeer = false;
+		bool hasBroadcast = false;
 		struct sockaddr address, mask, peer, broadcast, gateway;
 		const char* string;
 
@@ -794,8 +798,8 @@ NetServer::_BringUpInterfaces()
 	// we need a socket to talk to the networking stack
 	int socket = ::socket(AF_INET, SOCK_DGRAM, 0);
 	if (socket < 0) {
-		fprintf(stderr, "%s: The networking stack doesn't seem to be available.\n",
-			Name());
+		fprintf(stderr, "%s: The networking stack doesn't seem to be "
+			"available.\n", Name());
 		Quit();
 		return;
 	}
@@ -849,7 +853,7 @@ NetServer::_StartServices()
 
 
 int
-main()
+main(int argc, char** argv)
 {
 	status_t status;
 	NetServer server(status);
diff --git a/src/servers/net/NetServer.h b/src/servers/net/NetServer.h
index 1dff4d8821..2b09d339a8 100644
--- a/src/servers/net/NetServer.h
+++ b/src/servers/net/NetServer.h
@@ -1,5 +1,5 @@
 /*
- * Copyright 2006-2007, Haiku, Inc. All Rights Reserved.
+ * Copyright 2006-2008, Haiku, Inc. All Rights Reserved.
  * Distributed under the terms of the MIT License.
  *
  * Authors:
@@ -14,6 +14,8 @@
 #include <net/if.h>
 
 
+static const char* kNetServerSignature = "application/x-vnd.haiku-net_server";
+
 static const uint32 kMsgConfigureInterface = 'COif';