/********************************************************************* *                 * Filename:      obex_transport.c * Version:        * Description:   Code to handle different types of transports * Status:        Experimental. * Author:        Dag Brattli <dagb@cs.uit.no> * Created at:    Sat May  1 20:15:04 1999 * CVS ID:        $Id: obex_transport.c,v 1.28 2006/01/03 18:36:15 holtmann Exp $ *  *     Copyright (c) 1999, 2000 Pontus Fuchs, All Rights Reserved. *     Copyright (c) 1999, 2000 Dag Brattli, All Rights Reserved. *      *     This library is free software; you can redistribute it and/or *     modify it under the terms of the GNU Lesser General Public *     License as published by the Free Software Foundation; either *     version 2 of the License, or (at your option) any later version. * *     This library 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 *     Lesser General Public License for more details. * *     You should have received a copy of the GNU Lesser General Public *     License along with this library; if not, write to the Free Software *     Foundation, Inc., 59 Temple Place, Suite 330, Boston,  *     MA  02111-1307  USA *      ********************************************************************/#ifdef HAVE_CONFIG_H#include <config.h>#endif#include <string.h>#include <stdio.h>#include "obex_main.h"#ifdef HAVE_IRDA#include "irobex.h"#endif /*HAVE_IRDA*/#include "inobex.h"#ifdef HAVE_BLUETOOTH#include "btobex.h"#endif /*HAVE_BLUETOOTH*/#ifdef HAVE_USB #include "usbobex.h"#endif /*HAVE_USB*/#include "obex_transport.h"/* * Function obex_transport_handle_input(self, timeout) * *    Used when working in synchronous mode. * */int obex_transport_handle_input(obex_t *self, int timeout){	int ret;		if(self->trans.type == OBEX_TRANS_CUSTOM) {		if(self->ctrans.handleinput)			ret = self->ctrans.handleinput(self, self->ctrans.customdata, timeout);		else {			DEBUG(4, "No handleinput-callback exist!\n");			ret = -1;		}	}	else if (self->trans.type == OBEX_TRANS_USB) {		ret = obex_data_indication(self, NULL, 0);	}	else {		struct timeval time;		fd_set fdset;		int highestfd = 0;			DEBUG(4, "\n");		obex_return_val_if_fail(self != NULL, -1);		/* Check of we have any fd's to do select on. */		if(self->fd < 0 && self->serverfd < 0) {			DEBUG(0, "No valid socket is open\n");			return -1;		}		time.tv_sec = timeout;		time.tv_usec = 0;		/* Add the fd's to the set. */		FD_ZERO(&fdset);		if(self->fd >= 0) {			FD_SET(self->fd, &fdset);				highestfd = self->fd;		}		if(self->serverfd >= 0) {			FD_SET(self->serverfd, &fdset);			if(self->serverfd > highestfd)				highestfd = self->serverfd;		}		/* Wait for input */		ret = select(highestfd+1, &fdset, NULL, NULL, &time);			/* Check if this is a timeout (0) or error (-1) */		if (ret < 1)			return ret;			if( (self->fd >= 0) && FD_ISSET(self->fd, &fdset)) {			DEBUG(4, "Data available on client socket\n");			ret = obex_data_indication(self, NULL, 0);		}		else if( (self->serverfd >= 0) && FD_ISSET(self->serverfd, &fdset)) {			DEBUG(4, "Data available on server socket\n");			/* Accept : create the connected socket */			ret = obex_transport_accept(self);			/* Tell the app to perform the OBEX_Accept() */			if(self->keepserver)				obex_deliver_event(self, OBEX_EV_ACCEPTHINT,						   0, 0, FALSE);			/* Otherwise, just disconnect the server */			if((ret >= 0) && (! self->keepserver)) {				obex_transport_disconnect_server(self);			}		}		else			ret = -1;	}	return ret;}/* * Function obex_transport_accept(self) * *    Accept an incoming connection. * */int obex_transport_accept(obex_t *self){	int ret = -1;	DEBUG(4, "\n");	switch (self->trans.type) {#ifdef HAVE_IRDA	case OBEX_TRANS_IRDA:		ret = irobex_accept(self);		break;#endif /*HAVE_IRDA*/	case OBEX_TRANS_INET:		ret = inobex_accept(self);		break;#ifdef HAVE_BLUETOOTH	case OBEX_TRANS_BLUETOOTH:		ret = btobex_accept(self);		break;#endif /*HAVE_BLUETOOTH*/	case OBEX_TRANS_FD:		/* no real accept on a file */		ret = 0;		break;	default:		DEBUG(4, "domain not implemented!\n");		break;	}	return ret;}/* * Function obex_transport_connect_request (self, service) * *    Try to connect transport * */int obex_transport_connect_request(obex_t *self){	int ret = -1;	if(self->trans.connected)		return 1;	switch (self->trans.type) {#ifdef HAVE_IRDA	case OBEX_TRANS_IRDA:		ret = irobex_connect_request(self);		break;#endif /*HAVE_IRDA*/	case OBEX_TRANS_INET:		ret = inobex_connect_request(self);		break;	case OBEX_TRANS_CUSTOM:		DEBUG(4, "Custom connect\n");		if(self->ctrans.connect)			ret = self->ctrans.connect(self, self->ctrans.customdata);		else			DEBUG(4, "No connect-callback exist!\n");		DEBUG(4, "ret=%d\n", ret);		break;#ifdef HAVE_BLUETOOTH	case OBEX_TRANS_BLUETOOTH:		ret = btobex_connect_request(self);		break;#endif /*HAVE_BLUETOOTH*/	case OBEX_TRANS_FD:		/* no real connect on the file */		if (self->fd >= 0 && self->writefd >= 0)			ret = 0;		break;#ifdef HAVE_USB 	case OBEX_TRANS_USB:		ret = usbobex_connect_request(self);		break;#endif /*HAVE_USB*/ 	default:		DEBUG(4, "Transport not implemented!\n");		break;	}	if (ret >= 0)		self->trans.connected = TRUE;	return ret;}/* * Function obex_transport_disconnect_request (self) * *    Disconnect transport * */void obex_transport_disconnect_request(obex_t *self){	switch (self->trans.type) {#ifdef HAVE_IRDA	case OBEX_TRANS_IRDA:		irobex_disconnect_request(self);		break;#endif /*HAVE_IRDA*/	case OBEX_TRANS_INET:		inobex_disconnect_request(self);		break;		case OBEX_TRANS_CUSTOM:		DEBUG(4, "Custom disconnect\n");		if(self->ctrans.disconnect)			self->ctrans.disconnect(self, self->ctrans.customdata);		else			DEBUG(4, "No disconnect-callback exist!\n");		break;#ifdef HAVE_BLUETOOTH	case OBEX_TRANS_BLUETOOTH:		btobex_disconnect_request(self);		break;#endif /*HAVE_BLUETOOTH*/	case OBEX_TRANS_FD:		/* no real disconnect on a file */		self->fd = self->writefd = -1;		break;#ifdef HAVE_USB 	case OBEX_TRANS_USB:		usbobex_disconnect_request(self);		break;#endif /*HAVE_USB*/ 	default:		DEBUG(4, "Transport not implemented!\n");		break;	}	self->trans.connected = FALSE;}/* * Function obex_transport_listen (self) * *    Prepare for incomming connections * */int obex_transport_listen(obex_t *self){	int ret = -1;	switch (self->trans.type) {#ifdef HAVE_IRDA	case OBEX_TRANS_IRDA:		ret = irobex_listen(self);		break;#endif /*HAVE_IRDA*/	case OBEX_TRANS_INET:		ret = inobex_listen(self);		break;	case OBEX_TRANS_CUSTOM:		DEBUG(4, "Custom listen\n");		if(self->ctrans.listen)			ret = self->ctrans.listen(self, self->ctrans.customdata);		else			DEBUG(4, "No listen-callback exist!\n");		break;#ifdef HAVE_BLUETOOTH	case OBEX_TRANS_BLUETOOTH:		ret = btobex_listen(self);		break;#endif /*HAVE_BLUETOOTH*/	case OBEX_TRANS_FD:	case OBEX_TRANS_USB:		/* no real listen on the file or USB */		ret = 0;		break;	default:		DEBUG(4, "Transport %d not implemented!\n",			  self->trans.type);		break;	}	return ret;}	/* * Function obex_transport_disconnect_server (self) * *    Disconnect the listening server * * Used either after an accept, or directly at client request (app. exits) * Note : obex_delete_socket() will catch the case when the socket * doesn't exist (-1)... */void obex_transport_disconnect_server(obex_t *self){	switch (self->trans.type) {#ifdef HAVE_IRDA	case OBEX_TRANS_IRDA:		irobex_disconnect_server(self);		break;#endif /*HAVE_IRDA*/	case OBEX_TRANS_INET:		inobex_disconnect_server(self);		break;		case OBEX_TRANS_CUSTOM:		DEBUG(4, "Custom disconnect\n");		break;#ifdef HAVE_BLUETOOTH	case OBEX_TRANS_BLUETOOTH:		btobex_disconnect_server(self);		break;#endif /*HAVE_BLUETOOTH*/	case OBEX_TRANS_FD:	case OBEX_TRANS_USB:		/* no real server on a file or USB */;		break;	default:		DEBUG(4, "Transport not implemented!\n");		break;	}}/* * does fragmented write */static int do_write(int fd, GNetBuf *msg, int mtu){	int actual = -1;	int size;	/* Send and fragment if necessary  */	while (msg->len) {		if (msg->len > mtu)			size = mtu;		else			size = msg->len;		DEBUG(1, "sending %d bytes\n", size);		actual = write(fd, msg->data, size);		if (actual <= 0)			return actual;					/* Hide sent data */		g_netbuf_pull(msg, actual);	}	return actual;}/* * Function obex_transport_write () * *    Do the writing * */int obex_transport_write(obex_t *self, GNetBuf *msg){	int actual = -1;	DEBUG(4, "\n");	switch(self->trans.type)	{#ifdef HAVE_IRDA	case OBEX_TRANS_IRDA:#endif /*HAVE_IRDA*/#ifdef HAVE_BLUETOOTH	case OBEX_TRANS_BLUETOOTH:#endif /*HAVE_BLUETOOTH*/	case OBEX_TRANS_INET:		actual = do_write(self->fd, msg, self->trans.mtu);		break;	case OBEX_TRANS_FD:		actual = do_write(self->writefd, msg, self->trans.mtu);		break;#ifdef HAVE_USB 	case OBEX_TRANS_USB:		if (self->trans.connected != TRUE)			break;		DEBUG(4, "Endpoint %d\n", self->trans.self.usb.data_endpoint_write);		actual = usb_bulk_write(self->trans.self.usb.dev_data, 		    self->trans.self.usb.data_endpoint_write,		    (char *) msg->data, msg->len, USB_OBEX_TIMEOUT);		break;#endif /*HAVE_USB*/ 	case OBEX_TRANS_CUSTOM:		DEBUG(4, "Custom write\n");		if(self->ctrans.write)			actual = self->ctrans.write(self, self->ctrans.customdata, msg->data, msg->len);		else			DEBUG(4, "No write-callback exist!\n");		break;	default:		DEBUG(4, "Transport not implemented!\n");		break;	}		return actual;}/* * Function obex_transport_read () * *    Do the reading * */int obex_transport_read(obex_t *self, int max, uint8_t *buf, int buflen){	int actual = -1;	GNetBuf *msg = self->rx_msg;	DEBUG(4, "Request to read max %d bytes\n", max);	switch(self->trans.type)	{#ifdef HAVE_IRDA	case OBEX_TRANS_IRDA:#endif /*HAVE_IRDA*/#ifdef HAVE_BLUETOOTH	case OBEX_TRANS_BLUETOOTH:#endif /*HAVE_BLUETOOTH*/	case OBEX_TRANS_INET:	case OBEX_TRANS_FD:		actual = read(self->fd, msg->tail, max);		break;#ifdef HAVE_USB 	case OBEX_TRANS_USB:		if (self->trans.connected != TRUE)			break;		DEBUG(4, "Endpoint %d\n", self->trans.self.usb.data_endpoint_read);		actual = usb_bulk_read(self->trans.self.usb.dev_data, 		    self->trans.self.usb.data_endpoint_read,		    (char *) msg->tail, self->mtu_rx, USB_OBEX_TIMEOUT);		break;#endif /*HAVE_USB*/ 	case OBEX_TRANS_CUSTOM:		if(buflen > max) {			memcpy(msg->tail, buf, max);			actual = max;		}		else {			memcpy(msg->tail, buf, buflen);			actual = buflen;		}		break;	default:		DEBUG(4, "Transport not implemented!\n");		break;	}		return actual;}