/*  eXosip - This is the eXtended osip library.  Copyright (C) 2002,2003,2004,2005,2006,2007  Aymeric MOIZARD  - jack@atosc.org    eXosip 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.    eXosip 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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA*/#ifdef ENABLE_MPATROL#include <mpatrol.h>#endif#ifdef OSIP_MT#include "jpipe.h"#if !defined(WIN32) && !defined(__arc__)#include <fcntl.h>jpipe_t *jpipe (){  jpipe_t *my_pipe = (jpipe_t *) osip_malloc (sizeof (jpipe_t));  if (my_pipe == NULL)    return NULL;  if (0 != pipe (my_pipe->pipes))    {      osip_free (my_pipe);      return NULL;    }    if (fcntl(my_pipe->pipes[1], F_SETFL, O_NONBLOCK) == -1)    {      /* failed for some reason... */      OSIP_TRACE (osip_trace                  (__FILE__, __LINE__, OSIP_ERROR, NULL,                   "cannot set O_NONBLOCK to the pipe[1]!\n"));    }    return my_pipe;}intjpipe_close (jpipe_t * apipe){  if (apipe == NULL)    return -1;  close (apipe->pipes[0]);  close (apipe->pipes[1]);  osip_free (apipe);  return 0;}/** * Write in a pipe. */intjpipe_write (jpipe_t * apipe, const void *buf, int count){  if (apipe == NULL)    return -1;  return write (apipe->pipes[1], buf, count);}/** * Read in a pipe. */intjpipe_read (jpipe_t * apipe, void *buf, int count){  if (apipe == NULL)    return -1;  return read (apipe->pipes[0], buf, count);}/** * Get descriptor of reading pipe. */intjpipe_get_read_descr (jpipe_t * apipe){  if (apipe == NULL)    return -1;  return apipe->pipes[0];}#elsejpipe_t *jpipe (){  int s = 0;  int timeout = 0;  static int aport = 10500;  struct sockaddr_in raddr;  int j;  jpipe_t *my_pipe = (jpipe_t *) osip_malloc (sizeof (jpipe_t));  if (my_pipe == NULL)    return NULL;  s = (int) socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);  if (0 > s)    {      osip_free (my_pipe);      return NULL;    }  my_pipe->pipes[1] = (int) socket (PF_INET, SOCK_STREAM, IPPROTO_TCP);  if (0 > my_pipe->pipes[1])    {#if defined(__arc__)      close (s);#else      closesocket (s);#endif      osip_free (my_pipe);      return NULL;    }  raddr.sin_addr.s_addr = inet_addr ("127.0.0.1");  raddr.sin_family = AF_INET;  j = 50;  while (aport++ && j-- > 0)    {      raddr.sin_port = htons ((short) aport);      if (bind (s, (struct sockaddr *) &raddr, sizeof (raddr)) < 0)        {          OSIP_TRACE (osip_trace (__FILE__, __LINE__, OSIP_WARNING, NULL,                                  "Failed to bind one local socket %i!\n", aport));      } else        break;    }  if (j == 0)    {      OSIP_TRACE (osip_trace (__FILE__, __LINE__, OSIP_ERROR, NULL,                              "Failed to bind a local socket, aborting!\n"));#if defined(__arc__)      close (s);      close (my_pipe->pipes[1]);#else      closesocket (s);      closesocket (my_pipe->pipes[1]);#endif      osip_free (my_pipe);      return NULL;    }  j = listen (s, 1);  if (j != 0)    {      OSIP_TRACE (osip_trace (__FILE__, __LINE__, OSIP_ERROR, NULL,                              "Failed to listen on a local socket, aborting!\n"));#if defined(__arc__)      close (s);      close (my_pipe->pipes[1]);#else      closesocket (s);      closesocket (my_pipe->pipes[1]);#endif      osip_free (my_pipe);      return NULL;    }  j = setsockopt (my_pipe->pipes[1],                  SOL_SOCKET,                  SO_RCVTIMEO, (const char *) &timeout, sizeof (timeout));#if defined(__arc__)  if (j != 0)    {      /* failed for some reason... */      OSIP_TRACE (osip_trace                  (__FILE__, __LINE__, OSIP_ERROR, NULL,                   "udp plugin; cannot set O_NONBLOCK to the file desciptor!\n"));      close (s);      close (my_pipe->pipes[1]);      osip_free (my_pipe);      return NULL;    }#elif !defined(_WIN32_WCE)  if (j != NO_ERROR)    {      /* failed for some reason... */      OSIP_TRACE (osip_trace                  (__FILE__, __LINE__, OSIP_ERROR, NULL,                   "udp plugin; cannot set O_NONBLOCK to the file desciptor!\n"));      closesocket (s);      closesocket (my_pipe->pipes[1]);      osip_free (my_pipe);      return NULL;    }#endif  connect (my_pipe->pipes[1], (struct sockaddr *) &raddr, sizeof (raddr));  my_pipe->pipes[0] = accept (s, NULL, NULL);  if (my_pipe->pipes[0] <= 0)    {      OSIP_TRACE (osip_trace                  (__FILE__, __LINE__, OSIP_ERROR, NULL,                   "udp plugin; Failed to call accept!\n"));#if defined(__arc__)      close (s);      close (my_pipe->pipes[1]);#else      closesocket (s);      closesocket (my_pipe->pipes[1]);#endif      osip_free (my_pipe);      return NULL;    }  return my_pipe;}intjpipe_close (jpipe_t * apipe){  if (apipe == NULL)    return -1;#if defined(__arc__)  close (apipe->pipes[0]);  close (apipe->pipes[1]);#else  closesocket (apipe->pipes[0]);  closesocket (apipe->pipes[1]);#endif  osip_free (apipe);  return 0;}/** * Write in a pipe. */intjpipe_write (jpipe_t * apipe, const void *buf, int count){  if (apipe == NULL)    return -1;  return send (apipe->pipes[1], buf, count, 0);}/** * Read in a pipe. */intjpipe_read (jpipe_t * apipe, void *buf, int count){  if (apipe == NULL)    return -1;  return recv (apipe->pipes[0], buf, count, 0 /* MSG_DONTWAIT */ );     /* BUG?? */}/** * Get descriptor of reading pipe. */intjpipe_get_read_descr (jpipe_t * apipe){  if (apipe == NULL)    return -1;  return apipe->pipes[0];}#endif#endif