/* crypto/bio/bio_dgram.c */

 /* 

  * DTLS implementation written by Nagendra Modadugu

  * (nagendra@cs.stanford.edu) for the OpenSSL project 2005.  

  */

 /* ====================================================================

  * Copyright (c) 1999-2005 The OpenSSL Project.  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. All advertising materials mentioning features or use of this

  *    software must display the following acknowledgment:

  *    "This product includes software developed by the OpenSSL Project

  *    for use in the OpenSSL Toolkit. (http://www.OpenSSL.org/)"

  *

  * 4. The names "OpenSSL Toolkit" and "OpenSSL Project" must not be used to

  *    endorse or promote products derived from this software without

  *    prior written permission. For written permission, please contact

  *    openssl-core@OpenSSL.org.

  *

  * 5. Products derived from this software may not be called "OpenSSL"

  *    nor may "OpenSSL" appear in their names without prior written

  *    permission of the OpenSSL Project.

  *

  * 6. Redistributions of any form whatsoever must retain the following

  *    acknowledgment:

  *    "This product includes software developed by the OpenSSL Project

  *    for use in the OpenSSL Toolkit (http://www.OpenSSL.org/)"

  *

  * THIS SOFTWARE IS PROVIDED BY THE OpenSSL PROJECT ``AS IS'' AND ANY

  * EXPRESSED 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 OpenSSL PROJECT OR

  * ITS 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.

  * ====================================================================

  *

  * This product includes cryptographic software written by Eric Young

  * (eay@cryptsoft.com).  This product includes software written by Tim

  * Hudson (tjh@cryptsoft.com).

  *

  */

 /*

  © Portions copyright (c) 2006 Nokia Corporation.  All rights reserved.

  */

 #ifndef OPENSSL_NO_DGRAM

 #include <stdio.h>

 #include <errno.h>

 #define USE_SOCKETS

 #include "cryptlib.h"

 #include <openssl/bio.h>

 #if (defined(SYMBIAN) && (defined(__WINSCW__) || defined(__WINS__)))

 #include "libcrypto_wsd_macros.h"

 #include "libcrypto_wsd.h"

 #endif

 #define IP_MTU      14 /* linux is lame */

 #ifdef WATT32

 #define sock_write SockWrite  /* Watt-32 uses same names */

 #define sock_read  SockRead

 #define sock_puts  SockPuts

 #endif

 static int dgram_write(BIO *h, const char *buf, int num);

 static int dgram_read(BIO *h, char *buf, int size);

 static int dgram_puts(BIO *h, const char *str);

 static long dgram_ctrl(BIO *h, int cmd, long arg1, void *arg2);

 static int dgram_new(BIO *h);

 static int dgram_free(BIO *data);

 static int dgram_clear(BIO *bio);

 int BIO_dgram_should_retry(int s);

 #ifndef EMULATOR

 static BIO_METHOD methods_dgramp=

 	{

 	BIO_TYPE_DGRAM,

 	"datagram socket",

 	dgram_write,

 	dgram_read,

 	dgram_puts,

 	NULL, /* dgram_gets, */

 	dgram_ctrl,

 	dgram_new,

 	dgram_free,

 	NULL,

 	};

 #else

 GET_STATIC_VAR_FROM_TLS(methods_dgramp,bss_dgram,BIO_METHOD)

 #define methods_dgramp (*GET_WSD_VAR_NAME(methods_dgramp,bss_dgram,s)())

 const BIO_METHOD temp_s_methods_dgramp=

 	{

 	BIO_TYPE_DGRAM,

 	"datagram socket",

 	dgram_write,

 	dgram_read,

 	dgram_puts,

 	NULL, /* dgram_gets, */

 	dgram_ctrl,

 	dgram_new,

 	dgram_free,

 	NULL,

 	};

 #endif		

 typedef struct bio_dgram_data_st

 	{

 	struct sockaddr peer;

 	unsigned int connected;

 	unsigned int _errno;

 	unsigned int mtu;

 	} bio_dgram_data;

 EXPORT_C BIO_METHOD *BIO_s_datagram(void)

 	{

 	return(&methods_dgramp);

 	}

 EXPORT_C BIO *BIO_new_dgram(int fd, int close_flag)

 	{

 	BIO *ret;

 	ret=BIO_new(BIO_s_datagram());

 	if (ret == NULL) return(NULL);

 	BIO_set_fd(ret,fd,close_flag);

 	return(ret);

 	}

 static int dgram_new(BIO *bi)

 	{

 	bio_dgram_data *data = NULL;

 	bi->init=0;

 	bi->num=0;

 	data = OPENSSL_malloc(sizeof(bio_dgram_data));

 	if (data == NULL)

 		return 0;

 	memset(data, 0x00, sizeof(bio_dgram_data));

     bi->ptr = data;

 	bi->flags=0;

 	return(1);

 	}

 static int dgram_free(BIO *a)

 	{

 	bio_dgram_data *data;

 	if (a == NULL) return(0);

 	if ( ! dgram_clear(a))

 		return 0;

 	data = (bio_dgram_data *)a->ptr;

 	if(data != NULL) OPENSSL_free(data);

 	return(1);

 	}

 static int dgram_clear(BIO *a)

 	{

 	if (a == NULL) return(0);

 	if (a->shutdown)

 		{

 		if (a->init)

 			{

 			SHUTDOWN2(a->num);

 			}

 		a->init=0;

 		a->flags=0;

 		}

 	return(1);

 	}

 static int dgram_read(BIO *b, char *out, int outl)

 	{

 	int ret=0;

 	bio_dgram_data *data = (bio_dgram_data *)b->ptr;

 	struct sockaddr peer;

 	int peerlen = sizeof(peer);

 	if (out != NULL)

 		{

 		clear_socket_error();

 		memset(&peer, 0x00, peerlen);

 		/* Last arg in recvfrom is signed on some platforms and

 		 * unsigned on others. It is of type socklen_t on some

 		 * but this is not universal. Cast to (void *) to avoid

 		 * compiler warnings.

 		 */

 		ret=recvfrom(b->num,out,outl,0,&peer,(void *)&peerlen);

 		if ( ! data->connected  && ret > 0)

 			BIO_ctrl(b, BIO_CTRL_DGRAM_CONNECT, 0, &peer);

 		BIO_clear_retry_flags(b);

 		if (ret <= 0)

 			{

 			if (BIO_dgram_should_retry(ret))

 				{

 				BIO_set_retry_read(b);

 				data->_errno = get_last_socket_error();

 				}

 			}

 		}

 	return(ret);

 	}

 static int dgram_write(BIO *b, const char *in, int inl)

 	{

 	int ret;

 	bio_dgram_data *data = (bio_dgram_data *)b->ptr;

 	clear_socket_error();

     if ( data->connected )

         ret=send(b->num,in,inl,0);

     else

         ret=sendto(b->num, in, inl, 0, &data->peer, sizeof(data->peer));

 	BIO_clear_retry_flags(b);

 	if (ret <= 0)

 		{

 		if (BIO_sock_should_retry(ret))

 			{

 			BIO_set_retry_write(b);  

 			data->_errno = get_last_socket_error();

 #if 0 /* higher layers are responsible for querying MTU, if necessary */

 			if ( data->_errno == EMSGSIZE)

 				/* retrieve the new MTU */

 				BIO_ctrl(b, BIO_CTRL_DGRAM_QUERY_MTU, 0, NULL);

 #endif

 			}

 		}

 	return(ret);

 	}

 static long dgram_ctrl(BIO *b, int cmd, long num, void *ptr)

 	{

 	long ret=1;

 	int *ip;

 	struct sockaddr *to = NULL;

 	bio_dgram_data *data = NULL;

 	long sockopt_val = 0;

 	unsigned int sockopt_len = 0;

 	data = (bio_dgram_data *)b->ptr;

 	switch (cmd)

 		{

 	case BIO_CTRL_RESET:

 		num=0;

 	case BIO_C_FILE_SEEK:

 		ret=0;

 		break;

 	case BIO_C_FILE_TELL:

 	case BIO_CTRL_INFO:

 		ret=0;

 		break;

 	case BIO_C_SET_FD:

 		dgram_clear(b);

 		b->num= *((int *)ptr);

 		b->shutdown=(int)num;

 		b->init=1;

 		break;

 	case BIO_C_GET_FD:

 		if (b->init)

 			{

 			ip=(int *)ptr;

 			if (ip != NULL) *ip=b->num;

 			ret=b->num;

 			}

 		else

 			ret= -1;

 		break;

 	case BIO_CTRL_GET_CLOSE:

 		ret=b->shutdown;

 		break;

 	case BIO_CTRL_SET_CLOSE:

 		b->shutdown=(int)num;

 		break;

 	case BIO_CTRL_PENDING:

 	case BIO_CTRL_WPENDING:

 		ret=0;

 		break;

 	case BIO_CTRL_DUP:

 	case BIO_CTRL_FLUSH:

 		ret=1;

 		break;

 	case BIO_CTRL_DGRAM_CONNECT:

 		to = (struct sockaddr *)ptr;

 #if 0

 		if (connect(b->num, to, sizeof(struct sockaddr)) < 0)

 			{ perror("connect"); ret = 0; }

 		else

 			{

 #endif

 			memcpy(&(data->peer),to, sizeof(struct sockaddr));

 #if 0

 			}

 #endif

 		break;

 		/* (Linux)kernel sets DF bit on outgoing IP packets */

 #ifdef IP_MTU_DISCOVER

 	case BIO_CTRL_DGRAM_MTU_DISCOVER:

 		sockopt_val = IP_PMTUDISC_DO;

 		if ((ret = setsockopt(b->num, IPPROTO_IP, IP_MTU_DISCOVER,

 			&sockopt_val, sizeof(sockopt_val))) < 0)

 			perror("setsockopt");

 		break;

 #endif

 	case BIO_CTRL_DGRAM_QUERY_MTU:

          sockopt_len = sizeof(sockopt_val);

 		if ((ret = getsockopt(b->num, IPPROTO_IP, IP_MTU, (void *)&sockopt_val,

 			&sockopt_len)) < 0 || sockopt_val < 0)

 			{ ret = 0; }

 		else

 			{

 			data->mtu = sockopt_val;

 			ret = data->mtu;

 			}

 		break;

 	case BIO_CTRL_DGRAM_GET_MTU:

 		return data->mtu;

 		break;

 	case BIO_CTRL_DGRAM_SET_MTU:

 		data->mtu = num;

 		ret = num;

 		break;

 	case BIO_CTRL_DGRAM_SET_CONNECTED:

 		to = (struct sockaddr *)ptr;

 		if ( to != NULL)

 			{

 			data->connected = 1;

 			memcpy(&(data->peer),to, sizeof(struct sockaddr));

 			}

 		else

 			{

 			data->connected = 0;

 			memset(&(data->peer), 0x00, sizeof(struct sockaddr));

 			}

 		break;

     case BIO_CTRL_DGRAM_SET_PEER:

         to = (struct sockaddr *) ptr;

         memcpy(&(data->peer), to, sizeof(struct sockaddr));

         break;

 	case BIO_CTRL_DGRAM_SET_RECV_TIMEOUT:

 		if ( setsockopt(b->num, SOL_SOCKET, SO_RCVTIMEO, ptr,

 			sizeof(struct timeval)) < 0)

 			{ perror("setsockopt");	ret = -1; }

 		break;

 	case BIO_CTRL_DGRAM_GET_RECV_TIMEOUT:

 		if ( getsockopt(b->num, SOL_SOCKET, SO_RCVTIMEO, 

 			ptr, (void *)&ret) < 0)

 			{ perror("getsockopt"); ret = -1; }

 		break;

 	case BIO_CTRL_DGRAM_SET_SEND_TIMEOUT:

 		if ( setsockopt(b->num, SOL_SOCKET, SO_SNDTIMEO, ptr,

 			sizeof(struct timeval)) < 0)

 			{ perror("setsockopt");	ret = -1; }

 		break;

 	case BIO_CTRL_DGRAM_GET_SEND_TIMEOUT:

 		if ( getsockopt(b->num, SOL_SOCKET, SO_SNDTIMEO, 

 			ptr, (void *)&ret) < 0)

 			{ perror("getsockopt"); ret = -1; }

 		break;

 	case BIO_CTRL_DGRAM_GET_SEND_TIMER_EXP:

 		/* fall-through */

 	case BIO_CTRL_DGRAM_GET_RECV_TIMER_EXP:

 		if ( data->_errno == EAGAIN)

 			{

 			ret = 1;

 			data->_errno = 0;

 			}

 		else

 			ret = 0;

 		break;

 #ifdef EMSGSIZE

 	case BIO_CTRL_DGRAM_MTU_EXCEEDED:

 		if ( data->_errno == EMSGSIZE)

 			{

 			ret = 1;

 			data->_errno = 0;

 			}

 		else

 			ret = 0;

 		break;

 #endif

 	default:

 		ret=0;

 		break;

 		}

 	return(ret);

 	}

 static int dgram_puts(BIO *bp, const char *str)

 	{

 	int n,ret;

 	n=strlen(str);

 	ret=dgram_write(bp,str,n);

 	return(ret);

 	}

 int BIO_dgram_should_retry(int i)

 	{

 	int err;

 	if ((i == 0) || (i == -1))

 		{

 		err=get_last_socket_error();

 #if defined(OPENSSL_SYS_WINDOWS) && 0 /* more microsoft stupidity? perhaps not? Ben 4/1/99 */

 		if ((i == -1) && (err == 0))

 			return(1);

 #endif

 		return(BIO_dgram_non_fatal_error(err));

 		}

 	return(0);

 	}

 EXPORT_C int BIO_dgram_non_fatal_error(int err)

 	{

 	switch (err)

 		{

 #if defined(OPENSSL_SYS_WINDOWS)

 # if defined(WSAEWOULDBLOCK)

 	case WSAEWOULDBLOCK:

 # endif

 # if 0 /* This appears to always be an error */

 #  if defined(WSAENOTCONN)

 	case WSAENOTCONN:

 #  endif

 # endif

 #endif

 #ifdef EWOULDBLOCK

 # ifdef WSAEWOULDBLOCK

 #  if WSAEWOULDBLOCK != EWOULDBLOCK

 	case EWOULDBLOCK:

 #  endif

 # else

 	case EWOULDBLOCK:

 # endif

 #endif

 #if defined(ENOTCONN)

 	case ENOTCONN:

 #endif

 #ifdef EINTR

 	case EINTR:

 #endif

 #ifdef EAGAIN

 #if EWOULDBLOCK != EAGAIN

 	case EAGAIN:

 # endif

 #endif

 #ifdef EPROTO

 	case EPROTO:

 #endif

 #ifdef EINPROGRESS

 	case EINPROGRESS:

 #endif

 #ifdef EALREADY

 	case EALREADY:

 #endif

 /* DF bit set, and packet larger than MTU */

 #ifdef EMSGSIZE

 	case EMSGSIZE:

 #endif

 		return(1);

 		/* break; */

 	default:

 		break;

 		}

 	return(0);

 	}

 #endif