index : kernel.git	f32-user-thl-vanilla-fedora f33-user-thl-vanilla-fedora f34-user-thl-vanilla-fedora f35-user-thl-vanilla-fedora f36-user-thl-vanilla-fedora f37-user-thl-vanilla-fedora rawhide rawhide-user-thl-vanilla-fedora stabilization-user-thl-vanilla-fedora transition-user-thl-vanilla-fedora
	Linux vanilla kernels for Fedora – https://fedoraproject.org/wiki/Kernel_Vanilla_Repositories	Thorsten Leemhuis

summaryrefslogtreecommitdiffstats

log msg author committer range

path: root/baseconfig/CONFIG_SND_SOC_WM8731

stat options

Period:	week month quarter
Authors:	102550100all

Commits per author per week (path 'baseconfig/CONFIG_SND_SOC_WM8731')

Author	W22 2024	W23 2024	W24 2024	W25 2024	Total
Total	0	0	0	0	0

generated by cgit (git 2.34.1) at 2024-06-22 19:09:49 +0000

/* 
   Unix SMB/CIFS implementation.

   KDC Server startup

   Copyright (C) Andrew Bartlett <abartlet@samba.org> 2005
   Copyright (C) Andrew Tridgell	2005
   Copyright (C) Stefan Metzmacher	2005

   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"
#include "smbd/service_task.h"
#include "smbd/service_stream.h"
#include "lib/events/events.h"
#include "lib/socket/socket.h"
#include "kdc/kdc.h"
#include "system/network.h"
#include "dlinklist.h"
#include "lib/messaging/irpc.h"
#include "lib/stream/packet.h"

/* hold all the info needed to send a reply */
struct kdc_reply {
	struct kdc_reply *next, *prev;
	const char *dest_address;
	int dest_port;
	DATA_BLOB packet;
};

/* hold information about one kdc socket */
struct kdc_socket {
	struct socket_context *sock;
	struct kdc_server *kdc;
	struct fd_event *fde;

	/* a queue of outgoing replies that have been deferred */
	struct kdc_reply *send_queue;

	BOOL (*process)(struct kdc_server *kdc,
			TALLOC_CTX *mem_ctx, 
			DATA_BLOB *input, 
			DATA_BLOB *reply,
			const char *from,
			int src_port);
};
/*
  state of an open tcp connection
*/
struct kdc_tcp_connection {
	/* stream connection we belong to */
	struct stream_connection *conn;

	/* the kdc_server the connection belongs to */
	struct kdc_server *kdc;

	struct packet_context *packet;

	/* a queue of outgoing replies that have been deferred */
	struct data_blob_list_item *send_queue;

	BOOL (*process)(struct kdc_server *kdc,
			 TALLOC_CTX *mem_ctx, 
			 DATA_BLOB *input, 
			 DATA_BLOB *reply,
			 const char *from,
			 int src_port);
};

/*
  handle fd send events on a KDC socket
*/
static void kdc_send_handler(struct kdc_socket *kdc_socket)
{
	while (kdc_socket->send_queue) {
		struct kdc_reply *rep = kdc_socket->send_queue;
		NTSTATUS status;
		size_t sendlen;

		status = socket_sendto(kdc_socket->sock, &rep->packet, &sendlen, 0,
				       rep->dest_address, rep->dest_port);
		if (NT_STATUS_EQUAL(status, STATUS_MORE_ENTRIES)) {
			break;
		}
		if (NT_STATUS_EQUAL(status, NT_STATUS_INVALID_BUFFER_SIZE)) {
			/* Replace with a krb err, response to big */
		}
		
		DLIST_REMOVE(kdc_socket->send_queue, rep);
		talloc_free(rep);
	}

	if (kdc_socket->send_queue == NULL) {
		EVENT_FD_NOT_WRITEABLE(kdc_socket->fde);
	}
}


/*
  handle fd recv events on a KDC socket
*/
static void kdc_recv_handler(struct kdc_socket *kdc_socket)
{
	NTSTATUS status;
	TALLOC_CTX *tmp_ctx = talloc_new(kdc_socket);
	DATA_BLOB blob;
	struct kdc_reply *rep;
	DATA_BLOB reply;
	size_t nread, dsize;
	const char *src_addr;
	int src_port;
	int ret;

	status = socket_pending(kdc_socket->sock, &dsize);
	if (!NT_STATUS_IS_OK(status)) {
		talloc_free(tmp_ctx);
		return;
	}

	blob = data_blob_talloc(kdc_socket, NULL, dsize);
	if (blob.data == NULL) {
		/* hope this is a temporary low memory condition */
		talloc_free(tmp_ctx);
		return;
	}

	status = socket_recvfrom(kdc_socket->sock, blob.data, blob.length, &nread, 0,
				 &src_addr, &src_port);
	if (!NT_STATUS_IS_OK(status)) {
		talloc_free(tmp_ctx);
		return;
	}
	talloc_steal(tmp_ctx, src_addr);
	blob.length = nread;
	
	DEBUG(2,("Received krb5 UDP packet of length %u from %s:%u\n", 
		 blob.length, src_addr, (uint16_t)src_port));
	
	/* Call krb5 */
	ret = kdc_socket->process(kdc_socket->kdc, 
				  tmp_ctx, 
				  &blob,  
				  &reply,
				  src_addr, src_port);
	if (!ret) {
		talloc_free(tmp_ctx);
		return;
	}

	/* queue a pending reply */
	rep = talloc(kdc_socket, struct kdc_reply);
	if (rep == NULL) {
		talloc_free(tmp_ctx);
		return;
	}
	rep->dest_address = talloc_steal(rep, src_addr);
	rep->dest_port    = src_port;
	rep->packet       = reply;
	talloc_steal(rep, reply.data);

	if (rep->packet.data == NULL) {
		talloc_free(rep);
		talloc_free(tmp_ctx);
		return;
	}

	DLIST_ADD_END(kdc_socket->send_queue, rep, struct kdc_reply *);
	EVENT_FD_WRITEABLE(kdc_socket->fde);
	talloc_free(tmp_ctx);
}

/*
  handle fd events on a KDC socket
*/
static void kdc_socket_handler(struct event_context *ev, struct fd_event *fde,
			       uint16_t flags, void *private)
{
	struct kdc_socket *kdc_socket = talloc_get_type(private, struct kdc_socket);
	if (flags & EVENT_FD_WRITE) {
		kdc_send_handler(kdc_socket);
	} 
	if (flags & EVENT_FD_READ) {
		kdc_recv_handler(kdc_socket);
	}
}

static void kdc_tcp_terminate_connection(struct kdc_tcp_connection *kdcconn, const char *reason)
{
	stream_terminate_connection(kdcconn->conn, reason);
}


/*
  work out if a tcp packet is complete
*/
NTSTATUS kdc_tcp_is_complete(void *private, DATA_BLOB blob, size_t *size)
{
	if (blob.length < 4) {
		return STATUS_MORE_ENTRIES;
	}
	*size = 4 + RIVAL(blob.data, 0);
	if (*size > blob.length) {
		return STATUS_MORE_ENTRIES;
	}
	if ((*size) & (1 << 31)) {
		/* NOTE: we should send a 'KRB_ERR_FIELD_TOOLONG' and terminate, 
		   but for now we just terminate */
		return NT_STATUS_PORT_MESSAGE_TOO_LONG;
	}
	return NT_STATUS_OK;
}


/*
  receive a full packet on a KDC connection
*/
static NTSTATUS kdc_tcp_recv(void *private, DATA_BLOB blob)
{
	struct kdc_tcp_connection *kdcconn = talloc_get_type(private, struct kdc_tcp_connection);
	NTSTATUS status = NT_STATUS_UNSUCCESSFUL;
	TALLOC_CTX *tmp_ctx = talloc_new(kdcconn);
	struct data_blob_list_item *rep;
	const char *src_addr;
	int src_port;
	int ret;
	DATA_BLOB input, reply;

	talloc_steal(tmp_ctx, blob.data);

	src_addr = socket_get_peer_addr(kdcconn->conn->socket, tmp_ctx);
	if (!src_addr) goto nomem;
	src_port = socket_get_peer_port(kdcconn->conn->socket);

	DEBUG(2,("Received krb5 TCP packet of length %u from %s:%u\n", 
		 blob.length - 4, src_addr, src_port));

	/* Call krb5 */
	input = data_blob_const(blob.data + 4, blob.length - 4); 

	ret = kdcconn->process(kdcconn->kdc, 
			       tmp_ctx,
			       &input,
			       &reply,
			       src_addr, src_port);
	if (!ret) {
		status = NT_STATUS_INTERNAL_ERROR;
		goto failed;
	}

	/* and now encode the reply */
	rep = talloc(kdcconn, struct data_blob_list_item);
	if (!rep) {
		goto nomem;
	}

	rep->blob = data_blob_talloc(rep, NULL, reply.length + 4);
	if (!rep->blob.data) {
		goto nomem;
	}

	RSIVAL(rep->blob.data, 0, reply.length);
	memcpy(rep->blob.data + 4, reply.data, reply.length);	

	if (!kdcconn->send_queue) {
		EVENT_FD_WRITEABLE(kdcconn->conn->event.fde);
	}
	DLIST_ADD_END(kdcconn->send_queue, rep, struct data_blob_list_item *);

	/* the call isn't needed any more */
	talloc_free(tmp_ctx);
	return NT_STATUS_OK;
nomem:
	status = NT_STATUS_NO_MEMORY;

failed:
	kdc_tcp_terminate_connection(kdcconn, nt_errstr(status));
	return NT_STATUS_OK;
}

/*
  receive some data on a KDC connection
*/
static void kdc_tcp_recv_handler(struct stream_connection *conn, uint16_t flags)
{
	struct kdc_tcp_connection *kdcconn = talloc_get_type(conn->private, 
							     struct kdc_tcp_connection);
	packet_recv(kdcconn->packet);
}

/*
  called on a tcp recv error
*/
static void kdc_tcp_recv_error(void *private, NTSTATUS status)
{
	struct kdc_tcp_connection *kdcconn = talloc_get_type(private, struct kdc_tcp_connection);
	kdc_tcp_terminate_connection(kdcconn, nt_errstr(status));
}

/*
  called when we can write to a connection
*/
static void kdc_tcp_send(struct stream_connection *conn, uint16_t flags)
{
	struct kdc_tcp_connection *kdcconn = talloc_get_type(conn->private, struct kdc_tcp_connection);
	NTSTATUS status;

	while (kdcconn->send_queue) {
		struct data_blob_list_item *q = kdcconn->send_queue;
		size_t sendlen;

		status = socket_send(conn->socket, &q->blob, &sendlen, 0);
		if (NT_STATUS_IS_ERR(status)) goto failed;
		if (!NT_STATUS_IS_OK(status)) return;

		q->blob.length -= sendlen;
		q->blob.data   += sendlen;

		if (q->blob.length == 0) {
			DLIST_REMOVE(kdcconn->send_queue, q);
			talloc_free(q);
		}
	}

	EVENT_FD_NOT_WRITEABLE(conn->event.fde);
	return;
failed:
	kdc_tcp_terminate_connection(kdcconn, nt_errstr(status));
}

/**
   Wrapper for krb5_kdc_process_krb5_request, converting to/from Samba
   calling conventions
*/

static BOOL kdc_process(struct kdc_server *kdc,
			TALLOC_CTX *mem_ctx, 
			DATA_BLOB *input, 
			DATA_BLOB *reply,
			const char *src_addr,
			int src_port)
{
	int ret;	
	krb5_data k5_reply;
	struct ipv4_addr addr;
	struct sockaddr_in src_sock_addr;

	/* TODO:  This really should be in a utility function somewhere */
	ZERO_STRUCT(src_sock_addr);
#ifdef HAVE_SOCK_SIN_LEN
	src_sock_addr.sin_len		= sizeof(src_sock_addr);
#endif
	addr				= interpret_addr2(src_addr);
	src_sock_addr.sin_addr.s_addr	= addr.addr;
	src_sock_addr.sin_port		= htons(src_port);
	src_sock_addr.sin_family	= PF_INET;

	
	ret = krb5_kdc_process_krb5_request(kdc->smb_krb5_context->krb5_context, 
					    kdc->config,
					    input->data, input->length,
					    &k5_reply,
					    src_addr,
					    (struct sockaddr *)&src_sock_addr);
	if (ret == -1) {
		*reply = data_blob(NULL, 0);
		return False;
	}
	*reply = data_blob_talloc(mem_ctx, k5_reply.data, k5_reply.length);
	krb5_data_free(&k5_reply);
	return True;
}

/*
  called when we get a new connection
*/
static void kdc_tcp_accept(struct stream_connection *conn)
{
	struct kdc_server *kdc = talloc_get_type(conn->private, struct kdc_server);
	struct kdc_tcp_connection *kdcconn;

	kdcconn = talloc_zero(conn, struct kdc_tcp_connection);
	if (!kdcconn) {
		stream_terminate_connection(conn, "kdc_tcp_accept: out of memory");
		return;
	}
	kdcconn->conn	 = conn;
	kdcconn->kdc	 = kdc;
	kdcconn->process = kdc_process;
	conn->private    = kdcconn;

	kdcconn->packet = packet_init(kdcconn);
	if (kdcconn->packet == NULL) {
		stream_terminate_connection(conn, "kdc_tcp_accept: out of memory");