/* GStreamer

 *

 * This library is free software; you can redistribute it and/or

 * modify it under the terms of the GNU Library 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

 * Library General Public License for more details.

 *

 * You should have received a copy of the GNU Library 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.

 */

/*

 * Unless otherwise indicated, Source Code is licensed under MIT license.

 * See further explanation attached in License Statement (distributed in the file

 * LICENSE).

 *

 * Permission is hereby granted, free of charge, to any person obtaining a copy of

 * this software and associated documentation files (the "Software"), to deal in

 * the Software without restriction, including without limitation the rights to

 * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies

 * of the Software, and to permit persons to whom the Software is furnished to do

 * so, subject to the following conditions:

 *

 * The above copyright notice and this permission notice shall be included in all

 * copies or substantial portions of the Software.

 *

 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE

 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER

 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,

 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE

 * SOFTWARE.

 */

/**

 * SECTION:gstrtspconnection

 * @short_description: manage RTSP connections

 * @see_also: gstrtspurl

 *  

 * <refsect2>

 * <para>

 * This object manages the RTSP connection to the server. It provides function

 * to receive and send bytes and messages.

 * </para>

 * </refsect2>

 *  

 * Last reviewed on 2007-07-24 (0.10.14)

 */

#ifdef HAVE_CONFIG_H

#  include <config.h>

#endif

#include <stdio.h>

#include <errno.h>

#include <stdlib.h>

#include <string.h>

#include <time.h>

#ifdef HAVE_UNISTD_H

#include <unistd.h>

#endif

/* we include this here to get the G_OS_* defines */

#include <glib.h>

#include <gst/gst.h>

#ifdef G_OS_WIN32

#include <winsock2.h>

#define EINPROGRESS WSAEINPROGRESS

#else

#include <sys/ioctl.h>

#include <netdb.h>

#include <sys/socket.h>

#include <fcntl.h>

#endif

#ifdef HAVE_FIONREAD_IN_SYS_FILIO

#include <sys/filio.h>

#endif

#include "gstrtspconnection.h"

#include "gstrtspbase64.h"

#ifdef G_OS_WIN32

#define CLOSE_SOCKET(sock) closesocket (sock)

/* According to Microsoft's connect() documentation this one returns

 * WSAEWOULDBLOCK and not WSAEINPROGRESS. */

#else

#define READ_SOCKET(fd, buf, len) read (fd, buf, len)

#define WRITE_SOCKET(fd, buf, len) write (fd, buf, len)

#define CLOSE_SOCKET(sock) close (sock)

#endif

{

}

/**

 * gst_rtsp_connection_create:

 * @url: a #GstRTSPUrl 

 *

 * Create a newly allocated #GstRTSPConnection from @url and store it in @conn.

 * The connection will not yet attempt to connect to @url, use

 * gst_rtsp_connection_connect().

 *

 * Returns: #GST_RTSP_OK when @conn contains a valid connection.

 */

GstRTSPResult

{

  GstRTSPConnection *newconn;

  g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);

  newconn = g_new0 (GstRTSPConnection, 1);

  if ((newconn->fdset = gst_poll_new (TRUE)) == NULL)

    goto no_fdset;

  newconn->timer = g_timer_new ();

  newconn->auth_method = GST_RTSP_AUTH_NONE;

  newconn->username = NULL;

  newconn->passwd = NULL;

  *conn = newconn;

  return GST_RTSP_OK;

  /* ERRORS */

  {

  }

}

/**

 * gst_rtsp_connection_connect:

 * @conn: a #GstRTSPConnection 

 * @timeout: a #GTimeVal timeout

 *

 * Attempt to connect to the url of @conn made with

 * gst_rtsp_connection_create(). If @timeout is #NULL this function can block

 * forever. If @timeout contains a valid timeout, this function will return

 * #GST_RTSP_ETIMEOUT after the timeout expired.

 *

 * This function can be cancelled with gst_rtsp_connection_flush().

 *

 * Returns: #GST_RTSP_OK when a connection could be made.

 */

GstRTSPResult

gst_rtsp_connection_connect (GstRTSPConnection * conn, GTimeVal * timeout)

{

  guint16 port;

  GstRTSPUrl *url;

  g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);

  g_return_val_if_fail (conn->url != NULL, GST_RTSP_EINVAL);

  url = conn->url;

  } else {

  }

  return GST_RTSP_OK;

not_resolved:

  {

    return GST_RTSP_ENET;

  }

  {

  }

}

static void

add_auth_header (GstRTSPConnection * conn, GstRTSPMessage * message)

{

  switch (conn->auth_method) {

    case GST_RTSP_AUTH_BASIC:{

          auth_string);

      g_free (user_pass);

      g_free (user_pass64);

      break;

    }

    default:

      /* Nothing to do */

      break;

  }

}

static void

{

  GTimeVal tv;

  time_t t;

#ifdef HAVE_GMTIME_R

  struct tm tm_;

#endif

  g_get_current_time (&tv);

  t = (time_t) tv.tv_sec;

#ifdef HAVE_GMTIME_R

#else

#endif

}

/**

 * gst_rtsp_connection_write:

 * @conn: a #GstRTSPConnection

 * @data: the data to write

 * @size: the size of @data

 * @timeout: a timeout value or #NULL

 *

 * Attempt to write @size bytes of @data to the connected @conn, blocking up to

 * the specified @timeout. @timeout can be #NULL, in which case this function

 * might block forever.

 * 

 * This function can be cancelled with gst_rtsp_connection_flush().

 *

 * Returns: #GST_RTSP_OK on success.

 */

GstRTSPResult

gst_rtsp_connection_write (GstRTSPConnection * conn, const guint8 * data,

    guint size, GTimeVal * timeout)

{

  gint retval;

  GstClockTime to;

  g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);

  g_return_val_if_fail (data != NULL || size == 0, GST_RTSP_EINVAL);

  gst_poll_set_controllable (conn->fdset, TRUE);

  to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;

    do {

      retval = gst_poll_wait (conn->fdset, to);

    } while (retval == -1 && (errno == EINTR || errno == EAGAIN));

      goto timeout;

      if (errno == EBUSY)

        goto stopped;

      else

        goto select_error;

    }

  }

  return GST_RTSP_OK;

  /* ERRORS */

timeout:

  {

    return GST_RTSP_ETIMEOUT;

  }

select_error:

  {

    return GST_RTSP_ESYS;

  }

stopped:

  {

    return GST_RTSP_EINTR;

  }

write_error:

  {

  }

}

{

  GString *str = NULL;

  str = g_string_new ("");

  switch (message->type) {

    case GST_RTSP_MESSAGE_REQUEST:

      /* create request string, add CSeq */

      g_string_append_printf (str, "%s %s RTSP/1.0\r\n"

          "CSeq: %d\r\n",

          gst_rtsp_method_as_text (message->type_data.request.method),

          message->type_data.request.uri, conn->cseq++);

      /* add session id if we have one */

      if (conn->session_id[0] != '\0') {

        gst_rtsp_message_add_header (message, GST_RTSP_HDR_SESSION,

            conn->session_id);

      }

      /* add any authentication headers */