r2328: add the start of a new system and protocol

independent socket library.

this is not used, but compiled currently

there're maybe some api changes later...

metze

source/lib/socket/socket_ipv4.c

@@ -0,0 +1,293 @@
+/* 
+   Unix SMB/CIFS implementation.
+   Socket IPv4 functions
+   Copyright (C) Stefan Metzmacher 2004
+   
+   This program is free software; you can redistribute it and/or modify
+   it under the terms of the GNU General Public License as published by
+   the Free Software Foundation; either version 2 of the License, or
+   (at your option) any later version.
+   
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+   
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+*/
+
+#include "includes.h"
+
+static NTSTATUS ipv4_tcp_init(struct socket_context *sock)
+{
+	sock->fd = socket(PF_INET, SOCK_STREAM, 0);
+	if (sock->fd == -1) {
+		/* TODO: we need to map from errno to NTSTATUS here! */ 
+		return NT_STATUS_FOOBAR;
+	}
+
+	return NT_STATUS_OK;
+}
+
+static void ipv4_tcp_close(struct socket_context *sock)
+{
+	close(sock->fd);
+}
+
+static NTSTATUS ipv4_tcp_connect(struct socket_context *sock,
+					const char *my_address, int my_port,
+					const char *srv_address, int srv_port,
+					uint32_t flags)
+{
+	struct sockaddr_in my_addr;
+	struct sockaddr_in srv_addr;
+	struct in_addr my_ip;
+	struct in_addr srv_ip;
+	int ret;
+
+	ret = inet_aton(my_address, &my_ip);
+	if (ret == 0) {
+		/* not a valid ipv4 address */
+		return NT_STATUS_FOOBAR;
+	}
+
+	ZERO_STRUCT(my_addr);
+#ifdef HAVE_SOCK_SIN_LEN
+	my_addr.sin_len		= sizeof(my_addr);
+#endif
+	my_addr.sin_addr	= my_ip;
+	my_addr.sin_port	= htons(my_port);
+	my_addr.sin_family	= PF_INET;
+
+	ret = inet_aton(srv_address, &srv_ip);
+	if (ret == 0) {
+		/* not a valid ipv4 address */
+		return NT_STATUS_FOOBAR;
+	}
+
+	ret = bind(sock->fd, &my_addr, sizeof(my_addr));
+	if (ret == -1) {
+		/* TODO: we need to map from errno to NTSTATUS here! */
+		return NT_STATUS_FOOBAR;
+	}
+
+	ZERO_STRUCT(srv_addr);
+#ifdef HAVE_SOCK_SIN_LEN
+	srv_addr.sin_len	= sizeof(srv_addr);
+#endif
+	srv_addr.sin_addr	= srv_ip;
+	srv_addr.sin_port	= htons(srv_port);
+	srv_addr.sin_family	= PF_INET;
+
+	if (!(flags & SOCKET_OPTION_BLOCK)) {
+		ret = set_blocking(sock->fd, False);
+		if (ret == -1) {
+			/* TODO: we need to map from errno to NTSTATUS here! */
+			return NT_STATUS_FOOBAR;
+		}
+	}
+
+
+	ret = connect(sock->fd, &srv_addr, sizeof(srv_addr));
+	if (ret == -1) {
+		/* TODO: we need to map from errno to NTSTATUS here! */
+		return NT_STATUS_FOOBAR;
+	}
+
+	sock->state = SOCKET_STATE_CLIENT_CONNECTED;
+
+	return NT_STATUS_OK;
+}
+
+static NTSTATUS ipv4_tcp_listen(struct socket_context *sock,
+					const char *my_address, int port,
+					int queue_size, uint32_t flags)
+{
+	struct sockaddr_in my_addr;
+	struct in_addr ip_addr;
+	int ret;
+
+	ZERO_STRUCT(my_addr);
+
+	ret = inet_aton(my_address, &ip_addr);
+	if (ret == 0) {
+		/* not a valid ipv4 address */
+		return NT_STATUS_FOOBAR;
+	}
+
+#ifdef HAVE_SOCK_SIN_LEN
+	my_addr.sin_len		= sizeof(my_addr);
+#endif
+	my_addr.sin_addr	= ip_addr;
+	my_addr.sin_port	= htons(port);
+	my_addr.sin_family	= PF_INET;
+
+	ret = bind(sock->fd, &my_addr, sizeof(my_addr));
+	if (ret == -1) {
+		/* TODO: we need to map from errno to NTSTATUS here! */
+		return NT_STATUS_FOOBAR;
+	}
+
+	ret = listen(sock->fd, queue_size);
+	if (ret == -1) {
+		/* TODO: we need to map from errno to NTSTATUS here! */
+		return NT_STATUS_FOOBAR;
+	}
+
+	return NT_STATUS_NOT_IMPLEMENTED;
+}
+
+static NTSTATUS ipv4_tcp_accept(struct socket_context *sock, struct socket_context **new_sock, uint32_t flags)
+{
+	struct sockaddr_in cli_addr;
+	socklen_t cli_addr_len = 0;
+	int new_fd;
+	int ret;
+
+	new_fd = accept(sock->fd, &cli_addr, &cli_addr_len);
+	if (new_fd == -1) {
+		/* TODO: we need to map from errno to NTSTATUS here! */
+		return NT_STATUS_FOOBAR;
+	}
+
+	if (!(flags & SOCKET_OPTION_BLOCK)) {
+		ret = set_blocking(sock->fd, False);
+		if (ret == -1) {
+			/* TODO: we need to map from errno to NTSTATUS here! */
+			return NT_STATUS_FOOBAR;
+		}
+	}
+
+	/* TODO: we could add a 'accept_check' hook here
+	 *	 which get the black/white lists via socket_set_accept_filter()
+	 *	 or something like that
+	 *	 --metze
+	 */
+
+	(*new_sock) = talloc_p(NULL, struct socket_context);
+	if (!(*new_sock)) {
+		return NT_STATUS_NO_MEMORY;
+	}
+
+	/* copy the socket_context */
+	(*new_sock)->type		= sock->type;
+	(*new_sock)->state		= SOCKET_STATE_SERVER_CONNECTED;
+	(*new_sock)->flags		= flags;
+
+	(*new_sock)->fd			= new_fd;
+
+	(*new_sock)->private_data	= NULL;
+	(*new_sock)->ops		= sock->ops;
+
+	return NT_STATUS_NOT_IMPLEMENTED;
+}
+
+static NTSTATUS ipv4_tcp_recv(struct socket_context *sock, TALLOC_CTX *mem_ctx,
+					DATA_BLOB *blob, size_t wantlen, uint32_t flags)
+{
+	ssize_t gotlen;
+	void *buf;
+	int flgs = 0;
+
+	buf = talloc(mem_ctx, wantlen);
+	if (!buf) {
+		return NT_STATUS_NO_MEMORY;
+	}
+
+	/* TODO: we need to map the flags here */
+
+	gotlen = recv(sock->fd, buf, wantlen, flgs);
+	if (gotlen == -1) {
+		talloc_free(buf);
+		/* TODO: we need to map from errno to NTSTATUS here! */
+		return NT_STATUS_FOOBAR;
+	}
+
+	blob->length = gotlen;
+	blob->data = buf;
+
+	return NT_STATUS_OK;
+}
+
+static NTSTATUS ipv4_tcp_send(struct socket_context *sock, TALLOC_CTX *mem_ctx,
+					const DATA_BLOB *blob, size_t *sendlen, uint32_t flags)
+{
+	ssize_t len;
+	int flgs = 0;
+
+	/* TODO: we need to map the flags here */
+
+	len = send(sock->fd, blob->data, blob->length, flgs);
+	if (len == -1) {
+		/* TODO: we need to map from errno to NTSTATUS here! */
+		return NT_STATUS_FOOBAR;
+	}	
+
+	*sendlen = len;
+
+	return NT_STATUS_OK;
+}
+
+static NTSTATUS ipv4_tcp_set_option(struct socket_context *sock, const char *option, const char *val)
+{
+	return NT_STATUS_NOT_SUPPORTED;
+}
+
+static const char *ipv4_tcp_get_peer_addr(struct socket_context *sock, TALLOC_CTX *mem_ctx)
+{
+	return NULL;
+}
+
+static int ipv4_tcp_get_peer_port(struct socket_context *sock, TALLOC_CTX *mem_ctx)
+{
+	return -1;
+}
+
+static const char *ipv4_tcp_get_my_addr(struct socket_context *sock, TALLOC_CTX *mem_ctx)
+{
+	return NULL;
+}
+
+static int ipv4_tcp_get_my_port(struct socket_context *sock, TALLOC_CTX *mem_ctx)
+{
+	return -1;
+}
+
+static int ipv4_tcp_get_fd(struct socket_context *sock, TALLOC_CTX *mem_ctx)
+{
+	return sock->fd;
+}
+
+static const struct socket_ops ipv4_tcp_ops = {
+	.name		= "ipv4",
+	.type		= SOCKET_TYPE_STREAM,
+
+	.init		= ipv4_tcp_init,
+	.connect	= ipv4_tcp_connect,
+	.listen		= ipv4_tcp_listen,
+	.accept		= ipv4_tcp_accept,
+	.recv		= ipv4_tcp_recv,
+	.send		= ipv4_tcp_send,
+	.close		= ipv4_tcp_close,
+
+	.set_option	= ipv4_tcp_set_option,
+
+	.get_peer_addr	= ipv4_tcp_get_peer_addr,
+	.get_peer_port	= ipv4_tcp_get_peer_port,
+	.get_my_addr	= ipv4_tcp_get_my_addr,
+	.get_my_port	= ipv4_tcp_get_my_port,
+
+	.get_fd		= ipv4_tcp_get_fd
+};
+
+const struct socket_ops *socket_ipv4_ops(void)
+{
+	return &ipv4_tcp_ops;
+}
+
+NTSTATUS socket_ipv4_init(void)
+{
+	return NT_STATUS_OK;
+}