gst-libs/gst/rtsp/gstrtspconnection.c

   1 /* GStreamer
   2  * Copyright (C) <2005-2009> Wim Taymans <wim.taymans@gmail.com>
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Library General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Library General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Library General Public
  15  * License along with this library; if not, write to the
  16  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  17  * Boston, MA 02111-1307, USA.
  18  */
  19 /*
  20  * Unless otherwise indicated, Source Code is licensed under MIT license.
  21  * See further explanation attached in License Statement (distributed in the file
  22  * LICENSE).
  23  *
  24  * Permission is hereby granted, free of charge, to any person obtaining a copy of
  25  * this software and associated documentation files (the "Software"), to deal in
  26  * the Software without restriction, including without limitation the rights to
  27  * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies
  28  * of the Software, and to permit persons to whom the Software is furnished to do
  29  * so, subject to the following conditions:
  30  *
  31  * The above copyright notice and this permission notice shall be included in all
  32  * copies or substantial portions of the Software.
  33  *
  34  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  35  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  36  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  37  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  38  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  39  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  40  * SOFTWARE.
  41  */
  42
  43 /**
  44  * SECTION:gstrtspconnection
  45  * @short_description: manage RTSP connections
  46  * @see_also: gstrtspurl
  47  *
  48  * <refsect2>
  49  * <para>
  50  * This object manages the RTSP connection to the server. It provides function
  51  * to receive and send bytes and messages.
  52  * </para>
  53  * </refsect2>
  54  *
  55  * Last reviewed on 2007-07-24 (0.10.14)
  56  */
  57
  58 #ifdef HAVE_CONFIG_H
  59 #  include <config.h>
  60 #endif
  61
  62 #include <stdio.h>
  63 #include <errno.h>
  64 #include <stdlib.h>
  65 #include <string.h>
  66 #include <time.h>
  67
  68 #ifdef HAVE_UNISTD_H
  69 #include <unistd.h>
  70 #endif
  71
  72 /* we include this here to get the G_OS_* defines */
  73 #include <glib.h>
  74 #include <gst/gst.h>
  75
  76 #ifdef G_OS_WIN32
  77 /* ws2_32.dll has getaddrinfo and freeaddrinfo on Windows XP and later.
  78  * minwg32 headers check WINVER before allowing the use of these */
  79 #ifndef WINVER
  80 #define WINVER 0x0501
  81 #endif
  82 #include <winsock2.h>
  83 #include <ws2tcpip.h>
  84 #define EINPROGRESS WSAEINPROGRESS
  85 #else
  86 #include <sys/ioctl.h>
  87 #include <netdb.h>
  88 #include <sys/socket.h>
  89 #include <fcntl.h>
  90 #include <netinet/in.h>
  91 #endif
  92
  93 #ifdef HAVE_FIONREAD_IN_SYS_FILIO
  94 #include <sys/filio.h>
  95 #endif
  96
  97 #include "gstrtspconnection.h"
  98 #include "gstrtspbase64.h"
  99
 100 union gst_sockaddr
 101 {
 102   struct sockaddr sa;
 103   struct sockaddr_in sa_in;
 104   struct sockaddr_in6 sa_in6;
 105   struct sockaddr_storage sa_stor;
 106 };
 107
 108 typedef struct
 109 {
 110   gint state;
 111   guint save;
 112   guchar out[3];                /* the size must be evenly divisible by 3 */
 113   guint cout;
 114   guint coutl;
 115 } DecodeCtx;
 116
 117 static GstRTSPResult read_line (GstRTSPConnection * conn, guint8 * buffer,
 118     guint * idx, guint size);
 119 static GstRTSPResult parse_key_value (guint8 * buffer, gchar * key,
 120     guint keysize, gchar ** value);
 121 static GstRTSPResult parse_string (gchar * dest, gint size, gchar ** src);
 122
 123 #ifdef G_OS_WIN32
 124 #define READ_SOCKET(fd, buf, len) recv (fd, (char *)buf, len, 0)
 125 #define WRITE_SOCKET(fd, buf, len) send (fd, (const char *)buf, len, 0)
 126 #define SETSOCKOPT(sock, level, name, val, len) setsockopt (sock, level, name, (const char *)val, len)
 127 #define CLOSE_SOCKET(sock) closesocket (sock)
 128 #define ERRNO_IS_EAGAIN (WSAGetLastError () == WSAEWOULDBLOCK)
 129 #define ERRNO_IS_EINTR (WSAGetLastError () == WSAEINTR)
 130 /* According to Microsoft's connect() documentation this one returns
 131  * WSAEWOULDBLOCK and not WSAEINPROGRESS. */
 132 #define ERRNO_IS_EINPROGRESS (WSAGetLastError () == WSAEWOULDBLOCK)
 133 #else
 134 #define READ_SOCKET(fd, buf, len) read (fd, buf, len)
 135 #define WRITE_SOCKET(fd, buf, len) write (fd, buf, len)
 136 #define SETSOCKOPT(sock, level, name, val, len) setsockopt (sock, level, name, val, len)
 137 #define CLOSE_SOCKET(sock) close (sock)
 138 #define ERRNO_IS_EAGAIN (errno == EAGAIN)
 139 #define ERRNO_IS_EINTR (errno == EINTR)
 140 #define ERRNO_IS_EINPROGRESS (errno == EINPROGRESS)
 141 #endif
 142
 143 #define ADD_POLLFD(fdset, pfd, fd)        \
 144 G_STMT_START {                            \
 145   (pfd)->fd = fd;                         \
 146   gst_poll_add_fd (fdset, pfd);           \
 147 } G_STMT_END
 148
 149 #define REMOVE_POLLFD(fdset, pfd)          \
 150 G_STMT_START {                             \
 151   if ((pfd)->fd != -1) {                   \
 152     GST_DEBUG ("remove fd %d", (pfd)->fd); \
 153     gst_poll_remove_fd (fdset, pfd);       \
 154     CLOSE_SOCKET ((pfd)->fd);              \
 155     (pfd)->fd = -1;                        \
 156   }                                        \
 157 } G_STMT_END
 158
 159 typedef enum
 160 {
 161   TUNNEL_STATE_NONE,
 162   TUNNEL_STATE_GET,
 163   TUNNEL_STATE_POST,
 164   TUNNEL_STATE_COMPLETE
 165 } GstRTSPTunnelState;
 166
 167 #define TUNNELID_LEN   24
 168
 169 struct _GstRTSPConnection
 170 {
 171   /*< private > */
 172   /* URL for the connection */
 173   GstRTSPUrl *url;
 174
 175   /* connection state */
 176   GstPollFD fd0;
 177   GstPollFD fd1;
 178
 179   GstPollFD *readfd;
 180   GstPollFD *writefd;
 181
 182   gchar tunnelid[TUNNELID_LEN];
 183   gboolean tunneled;
 184   GstRTSPTunnelState tstate;
 185
 186   GstPoll *fdset;
 187   gchar *ip;
 188
 189   gchar *initial_buffer;
 190   gsize initial_buffer_offset;
 191
 192   /* Session state */
 193   gint cseq;                    /* sequence number */
 194   gchar session_id[512];        /* session id */
 195   gint timeout;                 /* session timeout in seconds */
 196   GTimer *timer;                /* timeout timer */
 197
 198   /* Authentication */
 199   GstRTSPAuthMethod auth_method;
 200   gchar *username;
 201   gchar *passwd;
 202   GHashTable *auth_params;
 203
 204   DecodeCtx ctx;
 205   DecodeCtx *ctxp;
 206
 207   gchar *proxy_host;
 208   guint proxy_port;
 209 };
 210
 211 enum
 212 {
 213   STATE_START = 0,
 214   STATE_DATA_HEADER,
 215   STATE_DATA_BODY,
 216   STATE_READ_LINES,
 217   STATE_END,
 218   STATE_LAST
 219 };
 220
 221 /* a structure for constructing RTSPMessages */
 222 typedef struct
 223 {
 224   gint state;
 225   GstRTSPResult status;
 226   guint8 buffer[4096];
 227   guint offset;
 228
 229   guint line;
 230   guint8 *body_data;
 231   glong body_len;
 232 } GstRTSPBuilder;
 233
 234 static void
 235 build_reset (GstRTSPBuilder * builder)
 236 {
 237   g_free (builder->body_data);
 238   memset (builder, 0, sizeof (GstRTSPBuilder));
 239 }
 240
 241 /**
 242  * gst_rtsp_connection_create:
 243  * @url: a #GstRTSPUrl
 244  * @conn: storage for a #GstRTSPConnection
 245  *
 246  * Create a newly allocated #GstRTSPConnection from @url and store it in @conn.
 247  * The connection will not yet attempt to connect to @url, use
 248  * gst_rtsp_connection_connect().
 249  *
 250  * A copy of @url will be made.
 251  *
 252  * Returns: #GST_RTSP_OK when @conn contains a valid connection.
 253  */
 254 GstRTSPResult
 255 gst_rtsp_connection_create (const GstRTSPUrl * url, GstRTSPConnection ** conn)
 256 {
 257   GstRTSPConnection *newconn;
 258 #ifdef G_OS_WIN32
 259   WSADATA w;
 260   int error;
 261 #endif
 262
 263   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
 264
 265 #ifdef G_OS_WIN32
 266   error = WSAStartup (0x0202, &w);
 267
 268   if (error)
 269     goto startup_error;
 270
 271   if (w.wVersion != 0x0202)
 272     goto version_error;
 273 #endif
 274
 275   newconn = g_new0 (GstRTSPConnection, 1);
 276
 277   if ((newconn->fdset = gst_poll_new (TRUE)) == NULL)
 278     goto no_fdset;
 279
 280   newconn->url = gst_rtsp_url_copy (url);
 281   newconn->fd0.fd = -1;
 282   newconn->fd1.fd = -1;
 283   newconn->timer = g_timer_new ();
 284   newconn->timeout = 60;
 285   newconn->cseq = 1;
 286
 287   newconn->auth_method = GST_RTSP_AUTH_NONE;
 288   newconn->username = NULL;
 289   newconn->passwd = NULL;
 290   newconn->auth_params = NULL;
 291
 292   *conn = newconn;
 293
 294   return GST_RTSP_OK;
 295
 296   /* ERRORS */
 297 #ifdef G_OS_WIN32
 298 startup_error:
 299   {
 300     g_warning ("Error %d on WSAStartup", error);
 301     return GST_RTSP_EWSASTART;
 302   }
 303 version_error:
 304   {
 305     g_warning ("Windows sockets are not version 0x202 (current 0x%x)",
 306         w.wVersion);
 307     WSACleanup ();
 308     return GST_RTSP_EWSAVERSION;
 309   }
 310 #endif
 311 no_fdset:
 312   {
 313     g_free (newconn);
 314 #ifdef G_OS_WIN32
 315     WSACleanup ();
 316 #endif
 317     return GST_RTSP_ESYS;
 318   }
 319 }
 320
 321 /**
 322  * gst_rtsp_connection_create_from_fd:
 323  * @fd: a file descriptor
 324  * @ip: the IP address of the other end
 325  * @port: the port used by the other end
 326  * @initial_buffer: data already read from @fd
 327  * @conn: storage for a #GstRTSPConnection
 328  *
 329  * Create a new #GstRTSPConnection for handling communication on the existing
 330  * file descriptor @fd. The @initial_buffer contains any data already read from
 331  * @fd which should be used before starting to read new data.
 332  *
 333  * Returns: #GST_RTSP_OK when @conn contains a valid connection.
 334  *
 335  * Since: 0.10.25
 336  */
 337 GstRTSPResult
 338 gst_rtsp_connection_create_from_fd (gint fd, const gchar * ip, guint16 port,
 339     const gchar * initial_buffer, GstRTSPConnection ** conn)
 340 {
 341   GstRTSPConnection *newconn = NULL;
 342   GstRTSPUrl *url;
 343 #ifdef G_OS_WIN32
 344   gulong flags = 1;
 345 #endif
 346   GstRTSPResult res;
 347
 348   g_return_val_if_fail (fd >= 0, GST_RTSP_EINVAL);
 349   g_return_val_if_fail (ip != NULL, GST_RTSP_EINVAL);
 350   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
 351
 352   /* set to non-blocking mode so that we can cancel the communication */
 353 #ifndef G_OS_WIN32
 354   fcntl (fd, F_SETFL, O_NONBLOCK);
 355 #else
 356   ioctlsocket (fd, FIONBIO, &flags);
 357 #endif /* G_OS_WIN32 */
 358
 359   /* create a url for the client address */
 360   url = g_new0 (GstRTSPUrl, 1);
 361   url->host = g_strdup (ip);
 362   url->port = port;
 363
 364   /* now create the connection object */
 365   GST_RTSP_CHECK (gst_rtsp_connection_create (url, &newconn), newconn_failed);
 366   gst_rtsp_url_free (url);
 367
 368   ADD_POLLFD (newconn->fdset, &newconn->fd0, fd);
 369
 370   /* both read and write initially */
 371   newconn->readfd = &newconn->fd0;
 372   newconn->writefd = &newconn->fd0;
 373
 374   newconn->ip = g_strdup (ip);
 375
 376   newconn->initial_buffer = g_strdup (initial_buffer);
 377
 378   *conn = newconn;
 379
 380   return GST_RTSP_OK;
 381
 382   /* ERRORS */
 383 newconn_failed:
 384   {
 385     gst_rtsp_url_free (url);
 386     return res;
 387   }
 388 }
 389
 390 /**
 391  * gst_rtsp_connection_accept:
 392  * @sock: a socket
 393  * @conn: storage for a #GstRTSPConnection
 394  *
 395  * Accept a new connection on @sock and create a new #GstRTSPConnection for
 396  * handling communication on new socket.
 397  *
 398  * Returns: #GST_RTSP_OK when @conn contains a valid connection.
 399  *
 400  * Since: 0.10.23
 401  */
 402 GstRTSPResult
 403 gst_rtsp_connection_accept (gint sock, GstRTSPConnection ** conn)
 404 {
 405   int fd;
 406   union gst_sockaddr sa;
 407   socklen_t slen = sizeof (sa);
 408   gchar ip[INET6_ADDRSTRLEN];
 409   guint16 port;
 410
 411   g_return_val_if_fail (sock >= 0, GST_RTSP_EINVAL);
 412   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
 413
 414   memset (&sa, 0, slen);
 415
 416 #ifndef G_OS_WIN32
 417   fd = accept (sock, &sa.sa, &slen);
 418 #else
 419   fd = accept (sock, &sa.sa, (gint *) & slen);
 420 #endif /* G_OS_WIN32 */
 421   if (fd == -1)
 422     goto accept_failed;
 423
 424   if (getnameinfo (&sa.sa, slen, ip, sizeof (ip), NULL, 0, NI_NUMERICHOST) != 0)
 425     goto getnameinfo_failed;
 426
 427   if (sa.sa.sa_family == AF_INET)
 428     port = sa.sa_in.sin_port;
 429   else if (sa.sa.sa_family == AF_INET6)
 430     port = sa.sa_in6.sin6_port;
 431   else
 432     goto wrong_family;
 433
 434   return gst_rtsp_connection_create_from_fd (fd, ip, port, NULL, conn);
 435
 436   /* ERRORS */
 437 accept_failed:
 438   {
 439     return GST_RTSP_ESYS;
 440   }
 441 getnameinfo_failed:
 442 wrong_family:
 443   {
 444     close (fd);
 445     return GST_RTSP_ERROR;
 446   }
 447 }
 448
 449 static gchar *
 450 do_resolve (const gchar * host)
 451 {
 452   static gchar ip[INET6_ADDRSTRLEN];
 453   struct addrinfo *aires;
 454   struct addrinfo *ai;
 455   gint aierr;
 456
 457   aierr = getaddrinfo (host, NULL, NULL, &aires);
 458   if (aierr != 0)
 459     goto no_addrinfo;
 460
 461   for (ai = aires; ai; ai = ai->ai_next) {
 462     if (ai->ai_family == AF_INET || ai->ai_family == AF_INET6) {
 463       break;
 464     }
 465   }
 466   if (ai == NULL)
 467     goto no_family;
 468
 469   aierr = getnameinfo (ai->ai_addr, ai->ai_addrlen, ip, sizeof (ip), NULL, 0,
 470       NI_NUMERICHOST | NI_NUMERICSERV);
 471   if (aierr != 0)
 472     goto no_address;
 473
 474   freeaddrinfo (aires);
 475
 476   return g_strdup (ip);
 477
 478   /* ERRORS */
 479 no_addrinfo:
 480   {
 481     GST_ERROR ("no addrinfo found for %s: %s", host, gai_strerror (aierr));
 482     return NULL;
 483   }
 484 no_family:
 485   {
 486     GST_ERROR ("no family found for %s", host);
 487     freeaddrinfo (aires);
 488     return NULL;
 489   }
 490 no_address:
 491   {
 492     GST_ERROR ("no address found for %s: %s", host, gai_strerror (aierr));
 493     freeaddrinfo (aires);
 494     return NULL;
 495   }
 496 }
 497
 498 static GstRTSPResult
 499 do_connect (const gchar * ip, guint16 port, GstPollFD * fdout,
 500     GstPoll * fdset, GTimeVal * timeout)
 501 {
 502   gint fd;
 503   struct addrinfo hints;
 504   struct addrinfo *aires;
 505   struct addrinfo *ai;
 506   gint aierr;
 507   gchar service[NI_MAXSERV];
 508   gint ret;
 509 #ifdef G_OS_WIN32
 510   unsigned long flags = 1;
 511 #endif /* G_OS_WIN32 */
 512   GstClockTime to;
 513   gint retval;
 514
 515   memset (&hints, 0, sizeof hints);
 516   hints.ai_flags = AI_NUMERICHOST;
 517   hints.ai_family = AF_UNSPEC;
 518   hints.ai_socktype = SOCK_STREAM;
 519   g_snprintf (service, sizeof (service) - 1, "%hu", port);
 520   service[sizeof (service) - 1] = '\0';
 521
 522   aierr = getaddrinfo (ip, service, &hints, &aires);
 523   if (aierr != 0)
 524     goto no_addrinfo;
 525
 526   for (ai = aires; ai; ai = ai->ai_next) {
 527     if (ai->ai_family == AF_INET || ai->ai_family == AF_INET6) {
 528       break;
 529     }
 530   }
 531   if (ai == NULL)
 532     goto no_family;
 533
 534   fd = socket (ai->ai_family, SOCK_STREAM, 0);
 535   if (fd == -1)
 536     goto no_socket;
 537
 538   /* set to non-blocking mode so that we can cancel the connect */
 539 #ifndef G_OS_WIN32
 540   fcntl (fd, F_SETFL, O_NONBLOCK);
 541 #else
 542   ioctlsocket (fd, FIONBIO, &flags);
 543 #endif /* G_OS_WIN32 */
 544
 545   /* add the socket to our fdset */
 546   ADD_POLLFD (fdset, fdout, fd);
 547
 548   /* we are going to connect ASYNC now */
 549   ret = connect (fd, ai->ai_addr, ai->ai_addrlen);
 550   if (ret == 0)
 551     goto done;
 552   if (!ERRNO_IS_EINPROGRESS)
 553     goto sys_error;
 554
 555   /* wait for connect to complete up to the specified timeout or until we got
 556    * interrupted. */
 557   gst_poll_fd_ctl_write (fdset, fdout, TRUE);
 558
 559   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
 560
 561   do {
 562     retval = gst_poll_wait (fdset, to);
 563   } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
 564
 565   if (retval == 0)
 566     goto timeout;
 567   else if (retval == -1)
 568     goto sys_error;
 569
 570   /* we can still have an error connecting on windows */
 571   if (gst_poll_fd_has_error (fdset, fdout)) {
 572     socklen_t len = sizeof (errno);
 573 #ifndef G_OS_WIN32
 574     getsockopt (fd, SOL_SOCKET, SO_ERROR, &errno, &len);
 575 #else
 576     getsockopt (fd, SOL_SOCKET, SO_ERROR, (char *) &errno, &len);
 577 #endif
 578     goto sys_error;
 579   }
 580
 581   gst_poll_fd_ignored (fdset, fdout);
 582
 583 done:
 584   freeaddrinfo (aires);
 585
 586   return GST_RTSP_OK;
 587
 588   /* ERRORS */
 589 no_addrinfo:
 590   {
 591     GST_ERROR ("no addrinfo found for %s: %s", ip, gai_strerror (aierr));
 592     return GST_RTSP_ERROR;
 593   }
 594 no_family:
 595   {
 596     GST_ERROR ("no family found for %s", ip);
 597     freeaddrinfo (aires);
 598     return GST_RTSP_ERROR;
 599   }
 600 no_socket:
 601   {
 602     GST_ERROR ("no socket %d (%s)", errno, g_strerror (errno));
 603     freeaddrinfo (aires);
 604     return GST_RTSP_ESYS;
 605   }
 606 sys_error:
 607   {
 608     GST_ERROR ("system error %d (%s)", errno, g_strerror (errno));
 609     REMOVE_POLLFD (fdset, fdout);
 610     freeaddrinfo (aires);
 611     return GST_RTSP_ESYS;
 612   }
 613 timeout:
 614   {
 615     GST_ERROR ("timeout");
 616     REMOVE_POLLFD (fdset, fdout);
 617     freeaddrinfo (aires);
 618     return GST_RTSP_ETIMEOUT;
 619   }
 620 }
 621
 622 static GstRTSPResult
 623 setup_tunneling (GstRTSPConnection * conn, GTimeVal * timeout)
 624 {
 625   gint i;
 626   GstRTSPResult res;
 627   gchar *str;
 628   guint idx, line;
 629   gint retval;
 630   GstClockTime to;
 631   gchar *ip, *url_port_str;
 632   guint16 port, url_port;
 633   gchar codestr[4], *resultstr;
 634   gint code;
 635   GstRTSPUrl *url;
 636   gchar *hostparam;
 637
 638   /* create a random sessionid */
 639   for (i = 0; i < TUNNELID_LEN; i++)
 640     conn->tunnelid[i] = g_random_int_range ('a', 'z');
 641   conn->tunnelid[TUNNELID_LEN - 1] = '\0';
 642
 643   url = conn->url;
 644   /* get the port from the url */
 645   gst_rtsp_url_get_port (url, &url_port);
 646
 647   if (conn->proxy_host) {
 648     hostparam = g_strdup_printf ("Host: %s:%d\r\n", url->host, url_port);
 649     url_port_str = g_strdup_printf (":%d", url_port);
 650     ip = conn->proxy_host;
 651     port = conn->proxy_port;
 652   } else {
 653     hostparam = NULL;
 654     url_port_str = NULL;
 655     ip = conn->ip;
 656     port = url_port;
 657   }
 658
 659   /* */
 660   str = g_strdup_printf ("GET %s%s%s%s%s%s HTTP/1.0\r\n"
 661       "%s"
 662       "x-sessioncookie: %s\r\n"
 663       "Accept: application/x-rtsp-tunnelled\r\n"
 664       "Pragma: no-cache\r\n"
 665       "Cache-Control: no-cache\r\n" "\r\n",
 666       conn->proxy_host ? "http://" : "",
 667       conn->proxy_host ? url->host : "",
 668       conn->proxy_host ? url_port_str : "",
 669       url->abspath, url->query ? "?" : "", url->query ? url->query : "",
 670       hostparam ? hostparam : "", conn->tunnelid);
 671
 672   /* we start by writing to this fd */
 673   conn->writefd = &conn->fd0;
 674
 675   res = gst_rtsp_connection_write (conn, (guint8 *) str, strlen (str), timeout);
 676   g_free (str);
 677   if (res != GST_RTSP_OK)
 678     goto write_failed;
 679
 680   gst_poll_fd_ctl_write (conn->fdset, &conn->fd0, FALSE);
 681   gst_poll_fd_ctl_read (conn->fdset, &conn->fd0, TRUE);
 682
 683   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
 684
 685   line = 0;
 686   while (TRUE) {
 687     guint8 buffer[4096];
 688
 689     idx = 0;
 690     while (TRUE) {
 691       res = read_line (conn, buffer, &idx, sizeof (buffer));
 692       if (res == GST_RTSP_EEOF)
 693         goto eof;
 694       if (res == GST_RTSP_OK)
 695         break;
 696       if (res != GST_RTSP_EINTR)
 697         goto read_error;
 698
 699       do {
 700         retval = gst_poll_wait (conn->fdset, to);
 701       } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
 702
 703       /* check for timeout */
 704       if (retval == 0)
 705         goto timeout;
 706
 707       if (retval == -1) {
 708         if (errno == EBUSY)
 709           goto stopped;
 710         else
 711           goto select_error;
 712       }
 713     }
 714
 715     /* check for last line */
 716     if (buffer[0] == '\r')
 717       buffer[0] = '\0';
 718     if (buffer[0] == '\0')
 719       break;
 720
 721     if (line == 0) {
 722       /* first line, parse response */
 723       gchar versionstr[20];
 724       gchar *bptr;
 725
 726       bptr = (gchar *) buffer;
 727
 728       parse_string (versionstr, sizeof (versionstr), &bptr);
 729       parse_string (codestr, sizeof (codestr), &bptr);
 730       code = atoi (codestr);
 731
 732       while (g_ascii_isspace (*bptr))
 733         bptr++;
 734
 735       resultstr = bptr;
 736
 737       if (code != GST_RTSP_STS_OK)
 738         goto wrong_result;
 739     } else {
 740       gchar key[32];
 741       gchar *value;
 742
 743       /* other lines, parse key/value */
 744       res = parse_key_value (buffer, key, sizeof (key), &value);
 745       if (res == GST_RTSP_OK) {
 746         /* we got a new ip address */
 747         if (g_ascii_strcasecmp (key, "x-server-ip-address") == 0) {
 748           if (conn->proxy_host) {
 749             /* if we use a proxy we need to change the destination url */
 750             g_free (url->host);
 751             url->host = g_strdup (value);
 752             g_free (hostparam);
 753             g_free (url_port_str);
 754             hostparam =
 755                 g_strdup_printf ("Host: %s:%d\r\n", url->host, url_port);
 756             url_port_str = g_strdup_printf (":%d", url_port);
 757           } else {
 758             /* and resolve the new ip address */
 759             if (!(ip = do_resolve (conn->ip)))
 760               goto not_resolved;
 761             g_free (conn->ip);
 762             conn->ip = ip;
 763           }
 764         }
 765       }
 766     }
 767     line++;
 768   }
 769
 770   /* connect to the host/port */
 771   res = do_connect (ip, port, &conn->fd1, conn->fdset, timeout);
 772   if (res != GST_RTSP_OK)
 773     goto connect_failed;
 774
 775   /* this is now our writing socket */
 776   conn->writefd = &conn->fd1;
 777
 778   /* */
 779   str = g_strdup_printf ("POST %s%s%s%s%s%s HTTP/1.0\r\n"
 780       "%s"
 781       "x-sessioncookie: %s\r\n"
 782       "Content-Type: application/x-rtsp-tunnelled\r\n"
 783       "Pragma: no-cache\r\n"
 784       "Cache-Control: no-cache\r\n"
 785       "Content-Length: 32767\r\n"
 786       "Expires: Sun, 9 Jan 1972 00:00:00 GMT\r\n"
 787       "\r\n",
 788       conn->proxy_host ? "http://" : "",
 789       conn->proxy_host ? url->host : "",
 790       conn->proxy_host ? url_port_str : "",
 791       url->abspath, url->query ? "?" : "", url->query ? url->query : "",
 792       hostparam ? hostparam : "", conn->tunnelid);
 793
 794   res = gst_rtsp_connection_write (conn, (guint8 *) str, strlen (str), timeout);
 795   g_free (str);
 796   if (res != GST_RTSP_OK)
 797     goto write_failed;
 798
 799 exit:
 800   g_free (hostparam);
 801   g_free (url_port_str);
 802
 803   return res;
 804
 805   /* ERRORS */
 806 write_failed:
 807   {
 808     GST_ERROR ("write failed (%d)", res);
 809     goto exit;
 810   }
 811 eof:
 812   {
 813     res = GST_RTSP_EEOF;
 814     goto exit;
 815   }
 816 read_error:
 817   {
 818     goto exit;
 819   }
 820 timeout:
 821   {
 822     res = GST_RTSP_ETIMEOUT;
 823     goto exit;
 824   }
 825 select_error:
 826   {
 827     res = GST_RTSP_ESYS;
 828     goto exit;
 829   }
 830 stopped:
 831   {
 832     res = GST_RTSP_EINTR;
 833     goto exit;
 834   }
 835 wrong_result:
 836   {
 837     GST_ERROR ("got failure response %d %s", code, resultstr);
 838     res = GST_RTSP_ERROR;
 839     goto exit;
 840   }
 841 not_resolved:
 842   {
 843     GST_ERROR ("could not resolve %s", conn->ip);
 844     res = GST_RTSP_ENET;
 845     goto exit;
 846   }
 847 connect_failed:
 848   {
 849     GST_ERROR ("failed to connect");
 850     goto exit;
 851   }
 852 }
 853
 854 /**
 855  * gst_rtsp_connection_connect:
 856  * @conn: a #GstRTSPConnection
 857  * @timeout: a #GTimeVal timeout
 858  *
 859  * Attempt to connect to the url of @conn made with
 860  * gst_rtsp_connection_create(). If @timeout is #NULL this function can block
 861  * forever. If @timeout contains a valid timeout, this function will return
 862  * #GST_RTSP_ETIMEOUT after the timeout expired.
 863  *
 864  * This function can be cancelled with gst_rtsp_connection_flush().
 865  *
 866  * Returns: #GST_RTSP_OK when a connection could be made.
 867  */
 868 GstRTSPResult
 869 gst_rtsp_connection_connect (GstRTSPConnection * conn, GTimeVal * timeout)
 870 {
 871   GstRTSPResult res;
 872   gchar *ip;
 873   guint16 port;
 874   GstRTSPUrl *url;
 875
 876   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
 877   g_return_val_if_fail (conn->url != NULL, GST_RTSP_EINVAL);
 878   g_return_val_if_fail (conn->fd0.fd < 0, GST_RTSP_EINVAL);
 879
 880   url = conn->url;
 881
 882   if (conn->proxy_host && conn->tunneled) {
 883     if (!(ip = do_resolve (conn->proxy_host))) {
 884       GST_ERROR ("could not resolve %s", conn->proxy_host);
 885       goto not_resolved;
 886     }
 887     port = conn->proxy_port;
 888     g_free (conn->proxy_host);
 889     conn->proxy_host = ip;
 890   } else {
 891     if (!(ip = do_resolve (url->host))) {
 892       GST_ERROR ("could not resolve %s", url->host);
 893       goto not_resolved;
 894     }
 895     /* get the port from the url */
 896     gst_rtsp_url_get_port (url, &port);
 897
 898     g_free (conn->ip);
 899     conn->ip = ip;
 900   }
 901
 902   /* connect to the host/port */
 903   res = do_connect (ip, port, &conn->fd0, conn->fdset, timeout);
 904   if (res != GST_RTSP_OK)
 905     goto connect_failed;
 906
 907   /* this is our read URL */
 908   conn->readfd = &conn->fd0;
 909
 910   if (conn->tunneled) {
 911     res = setup_tunneling (conn, timeout);
 912     if (res != GST_RTSP_OK)
 913       goto tunneling_failed;
 914   } else {
 915     conn->writefd = &conn->fd0;
 916   }
 917
 918   return GST_RTSP_OK;
 919
 920 not_resolved:
 921   {
 922     return GST_RTSP_ENET;
 923   }
 924 connect_failed:
 925   {
 926     GST_ERROR ("failed to connect");
 927     return res;
 928   }
 929 tunneling_failed:
 930   {
 931     GST_ERROR ("failed to setup tunneling");
 932     return res;
 933   }
 934 }
 935
 936 static void
 937 auth_digest_compute_hex_urp (const gchar * username,
 938     const gchar * realm, const gchar * password, gchar hex_urp[33])
 939 {
 940   GChecksum *md5_context = g_checksum_new (G_CHECKSUM_MD5);
 941   const gchar *digest_string;
 942
 943   g_checksum_update (md5_context, (const guchar *) username, strlen (username));
 944   g_checksum_update (md5_context, (const guchar *) ":", 1);
 945   g_checksum_update (md5_context, (const guchar *) realm, strlen (realm));
 946   g_checksum_update (md5_context, (const guchar *) ":", 1);
 947   g_checksum_update (md5_context, (const guchar *) password, strlen (password));
 948   digest_string = g_checksum_get_string (md5_context);
 949
 950   memset (hex_urp, 0, 33);
 951   memcpy (hex_urp, digest_string, strlen (digest_string));
 952
 953   g_checksum_free (md5_context);
 954 }
 955
 956 static void
 957 auth_digest_compute_response (const gchar * method,
 958     const gchar * uri, const gchar * hex_a1, const gchar * nonce,
 959     gchar response[33])
 960 {
 961   char hex_a2[33] = { 0, };
 962   GChecksum *md5_context = g_checksum_new (G_CHECKSUM_MD5);
 963   const gchar *digest_string;
 964
 965   /* compute A2 */
 966   g_checksum_update (md5_context, (const guchar *) method, strlen (method));
 967   g_checksum_update (md5_context, (const guchar *) ":", 1);
 968   g_checksum_update (md5_context, (const guchar *) uri, strlen (uri));
 969   digest_string = g_checksum_get_string (md5_context);
 970   memcpy (hex_a2, digest_string, strlen (digest_string));
 971
 972   /* compute KD */
 973 #if GLIB_CHECK_VERSION (2, 18, 0)
 974   g_checksum_reset (md5_context);
 975 #else
 976   g_checksum_free (md5_context);
 977   md5_context = g_checksum_new (G_CHECKSUM_MD5);
 978 #endif
 979   g_checksum_update (md5_context, (const guchar *) hex_a1, strlen (hex_a1));
 980   g_checksum_update (md5_context, (const guchar *) ":", 1);
 981   g_checksum_update (md5_context, (const guchar *) nonce, strlen (nonce));
 982   g_checksum_update (md5_context, (const guchar *) ":", 1);
 983
 984   g_checksum_update (md5_context, (const guchar *) hex_a2, 32);
 985   digest_string = g_checksum_get_string (md5_context);
 986   memset (response, 0, 33);
 987   memcpy (response, digest_string, strlen (digest_string));
 988
 989   g_checksum_free (md5_context);
 990 }
 991
 992 static void
 993 add_auth_header (GstRTSPConnection * conn, GstRTSPMessage * message)
 994 {
 995   switch (conn->auth_method) {
 996     case GST_RTSP_AUTH_BASIC:{
 997       gchar *user_pass;
 998       gchar *user_pass64;
 999       gchar *auth_string;
1000
1001       user_pass = g_strdup_printf ("%s:%s", conn->username, conn->passwd);
1002       user_pass64 = g_base64_encode ((guchar *) user_pass, strlen (user_pass));
1003       auth_string = g_strdup_printf ("Basic %s", user_pass64);
1004
1005       gst_rtsp_message_take_header (message, GST_RTSP_HDR_AUTHORIZATION,
1006           auth_string);
1007
1008       g_free (user_pass);
1009       g_free (user_pass64);
1010       break;
1011     }
1012     case GST_RTSP_AUTH_DIGEST:{
1013       gchar response[33], hex_urp[33];
1014       gchar *auth_string, *auth_string2;
1015       gchar *realm;
1016       gchar *nonce;
1017       gchar *opaque;
1018       const gchar *uri;
1019       const gchar *method;
1020
1021       /* we need to have some params set */
1022       if (conn->auth_params == NULL)
1023         break;
1024
1025       /* we need the realm and nonce */
1026       realm = (gchar *) g_hash_table_lookup (conn->auth_params, "realm");
1027       nonce = (gchar *) g_hash_table_lookup (conn->auth_params, "nonce");
1028       if (realm == NULL || nonce == NULL)
1029         break;
1030
1031       auth_digest_compute_hex_urp (conn->username, realm, conn->passwd,
1032           hex_urp);
1033
1034       method = gst_rtsp_method_as_text (message->type_data.request.method);
1035       uri = message->type_data.request.uri;
1036
1037       /* Assume no qop, algorithm=md5, stale=false */
1038       /* For algorithm MD5, a1 = urp. */
1039       auth_digest_compute_response (method, uri, hex_urp, nonce, response);
1040       auth_string = g_strdup_printf ("Digest username=\"%s\", "
1041           "realm=\"%s\", nonce=\"%s\", uri=\"%s\", response=\"%s\"",
1042           conn->username, realm, nonce, uri, response);
1043
1044       opaque = (gchar *) g_hash_table_lookup (conn->auth_params, "opaque");
1045       if (opaque) {
1046         auth_string2 = g_strdup_printf ("%s, opaque=\"%s\"", auth_string,
1047             opaque);
1048         g_free (auth_string);
1049         auth_string = auth_string2;
1050       }
1051       gst_rtsp_message_take_header (message, GST_RTSP_HDR_AUTHORIZATION,
1052           auth_string);
1053       break;
1054     }
1055     default:
1056       /* Nothing to do */
1057       break;
1058   }
1059 }
1060
1061 static void
1062 gen_date_string (gchar * date_string, guint len)
1063 {
1064   GTimeVal tv;
1065   time_t t;
1066 #ifdef HAVE_GMTIME_R
1067   struct tm tm_;
1068 #endif
1069
1070   g_get_current_time (&tv);
1071   t = (time_t) tv.tv_sec;
1072
1073 #ifdef HAVE_GMTIME_R
1074   strftime (date_string, len, "%a, %d %b %Y %H:%M:%S GMT", gmtime_r (&t, &tm_));
1075 #else
1076   strftime (date_string, len, "%a, %d %b %Y %H:%M:%S GMT", gmtime (&t));
1077 #endif
1078 }
1079
1080 static GstRTSPResult
1081 write_bytes (gint fd, const guint8 * buffer, guint * idx, guint size)
1082 {
1083   guint left;
1084
1085   if (G_UNLIKELY (*idx > size))
1086     return GST_RTSP_ERROR;
1087
1088   left = size - *idx;
1089
1090   while (left) {
1091     gint r;
1092
1093     r = WRITE_SOCKET (fd, &buffer[*idx], left);
1094     if (G_UNLIKELY (r == 0)) {
1095       return GST_RTSP_EINTR;
1096     } else if (G_UNLIKELY (r < 0)) {
1097       if (ERRNO_IS_EAGAIN)
1098         return GST_RTSP_EINTR;
1099       if (!ERRNO_IS_EINTR)
1100         return GST_RTSP_ESYS;
1101     } else {
1102       left -= r;
1103       *idx += r;
1104     }
1105   }
1106   return GST_RTSP_OK;
1107 }
1108
1109 static gint
1110 fill_raw_bytes (GstRTSPConnection * conn, guint8 * buffer, guint size)
1111 {
1112   gint out = 0;
1113
1114   if (G_UNLIKELY (conn->initial_buffer != NULL)) {
1115     gsize left = strlen (&conn->initial_buffer[conn->initial_buffer_offset]);
1116
1117     out = MIN (left, size);
1118     memcpy (buffer, &conn->initial_buffer[conn->initial_buffer_offset], out);
1119
1120     if (left == (gsize) out) {
1121       g_free (conn->initial_buffer);
1122       conn->initial_buffer = NULL;
1123       conn->initial_buffer_offset = 0;
1124     } else
1125       conn->initial_buffer_offset += out;
1126   }
1127
1128   if (G_LIKELY (size > (guint) out)) {
1129     gint r;
1130
1131     r = READ_SOCKET (conn->readfd->fd, &buffer[out], size - out);
1132     if (r <= 0) {
1133       if (out == 0)
1134         out = r;
1135     } else
1136       out += r;
1137   }
1138
1139   return out;
1140 }
1141
1142 static gint
1143 fill_bytes (GstRTSPConnection * conn, guint8 * buffer, guint size)
1144 {
1145   DecodeCtx *ctx = conn->ctxp;
1146   gint out = 0;
1147
1148   if (ctx) {
1149     while (size > 0) {
1150       guint8 in[sizeof (ctx->out) * 4 / 3];
1151       gint r;
1152
1153       while (size > 0 && ctx->cout < ctx->coutl) {
1154         /* we have some leftover bytes */
1155         *buffer++ = ctx->out[ctx->cout++];
1156         size--;
1157         out++;
1158       }
1159
1160       /* got what we needed? */
1161       if (size == 0)
1162         break;
1163
1164       /* try to read more bytes */
1165       r = fill_raw_bytes (conn, in, sizeof (in));
1166       if (r <= 0) {
1167         if (out == 0)
1168           out = r;
1169         break;
1170       }
1171
1172       ctx->cout = 0;
1173       ctx->coutl =
1174           g_base64_decode_step ((gchar *) in, r, ctx->out, &ctx->state,
1175           &ctx->save);
1176     }
1177   } else {
1178     out = fill_raw_bytes (conn, buffer, size);
1179   }
1180
1181   return out;
1182 }
1183
1184 static GstRTSPResult
1185 read_bytes (GstRTSPConnection * conn, guint8 * buffer, guint * idx, guint size)
1186 {
1187   guint left;
1188
1189   if (G_UNLIKELY (*idx > size))
1190     return GST_RTSP_ERROR;
1191
1192   left = size - *idx;
1193
1194   while (left) {
1195     gint r;
1196
1197     r = fill_bytes (conn, &buffer[*idx], left);
1198     if (G_UNLIKELY (r == 0)) {
1199       return GST_RTSP_EEOF;
1200     } else if (G_UNLIKELY (r < 0)) {
1201       if (ERRNO_IS_EAGAIN)
1202         return GST_RTSP_EINTR;
1203       if (!ERRNO_IS_EINTR)
1204         return GST_RTSP_ESYS;
1205     } else {
1206       left -= r;
1207       *idx += r;
1208     }
1209   }
1210   return GST_RTSP_OK;
1211 }
1212
1213 static GstRTSPResult
1214 read_line (GstRTSPConnection * conn, guint8 * buffer, guint * idx, guint size)
1215 {
1216   while (TRUE) {
1217     guint8 c;
1218     gint r;
1219
1220     r = fill_bytes (conn, &c, 1);
1221     if (G_UNLIKELY (r == 0)) {
1222       return GST_RTSP_EEOF;
1223     } else if (G_UNLIKELY (r < 0)) {
1224       if (ERRNO_IS_EAGAIN)
1225         return GST_RTSP_EINTR;
1226       if (!ERRNO_IS_EINTR)
1227         return GST_RTSP_ESYS;
1228     } else {
1229       if (c == '\n')            /* end on \n */
1230         break;
1231       if (c == '\r')            /* ignore \r */
1232         continue;
1233
1234       if (G_LIKELY (*idx < size - 1))
1235         buffer[(*idx)++] = c;
1236     }
1237   }
1238   buffer[*idx] = '\0';
1239
1240   return GST_RTSP_OK;
1241 }
1242
1243 /**
1244  * gst_rtsp_connection_write:
1245  * @conn: a #GstRTSPConnection
1246  * @data: the data to write
1247  * @size: the size of @data
1248  * @timeout: a timeout value or #NULL
1249  *
1250  * Attempt to write @size bytes of @data to the connected @conn, blocking up to
1251  * the specified @timeout. @timeout can be #NULL, in which case this function
1252  * might block forever.
1253  *
1254  * This function can be cancelled with gst_rtsp_connection_flush().
1255  *
1256  * Returns: #GST_RTSP_OK on success.
1257  */
1258 GstRTSPResult
1259 gst_rtsp_connection_write (GstRTSPConnection * conn, const guint8 * data,
1260     guint size, GTimeVal * timeout)
1261 {
1262   guint offset;
1263   gint retval;
1264   GstClockTime to;
1265   GstRTSPResult res;
1266
1267   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
1268   g_return_val_if_fail (data != NULL || size == 0, GST_RTSP_EINVAL);
1269   g_return_val_if_fail (conn->writefd != NULL, GST_RTSP_EINVAL);
1270
1271   gst_poll_set_controllable (conn->fdset, TRUE);
1272   gst_poll_fd_ctl_write (conn->fdset, conn->writefd, TRUE);
1273   gst_poll_fd_ctl_read (conn->fdset, conn->readfd, FALSE);
1274   /* clear all previous poll results */
1275   gst_poll_fd_ignored (conn->fdset, conn->writefd);
1276   gst_poll_fd_ignored (conn->fdset, conn->readfd);
1277
1278   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
1279
1280   offset = 0;
1281
1282   while (TRUE) {
1283     /* try to write */
1284     res = write_bytes (conn->writefd->fd, data, &offset, size);
1285     if (G_LIKELY (res == GST_RTSP_OK))
1286       break;
1287     if (G_UNLIKELY (res != GST_RTSP_EINTR))
1288       goto write_error;
1289
1290     /* not all is written, wait until we can write more */
1291     do {
1292       retval = gst_poll_wait (conn->fdset, to);
1293     } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
1294
1295     if (G_UNLIKELY (retval == 0))
1296       goto timeout;
1297
1298     if (G_UNLIKELY (retval == -1)) {
1299       if (errno == EBUSY)
1300         goto stopped;
1301       else
1302         goto select_error;
1303     }
1304   }
1305   return GST_RTSP_OK;
1306
1307   /* ERRORS */
1308 timeout:
1309   {
1310     return GST_RTSP_ETIMEOUT;
1311   }
1312 select_error:
1313   {
1314     return GST_RTSP_ESYS;
1315   }
1316 stopped:
1317   {
1318     return GST_RTSP_EINTR;
1319   }
1320 write_error:
1321   {
1322     return res;
1323   }
1324 }
1325
1326 static GString *
1327 message_to_string (GstRTSPConnection * conn, GstRTSPMessage * message)
1328 {
1329   GString *str = NULL;
1330
1331   str = g_string_new ("");
1332
1333   switch (message->type) {
1334     case GST_RTSP_MESSAGE_REQUEST:
1335       /* create request string, add CSeq */
1336       g_string_append_printf (str, "%s %s RTSP/1.0\r\n"
1337           "CSeq: %d\r\n",
1338           gst_rtsp_method_as_text (message->type_data.request.method),
1339           message->type_data.request.uri, conn->cseq++);
1340       /* add session id if we have one */
1341       if (conn->session_id[0] != '\0') {
1342         gst_rtsp_message_remove_header (message, GST_RTSP_HDR_SESSION, -1);
1343         gst_rtsp_message_add_header (message, GST_RTSP_HDR_SESSION,
1344             conn->session_id);
1345       }
1346       /* add any authentication headers */
1347       add_auth_header (conn, message);
1348       break;
1349     case GST_RTSP_MESSAGE_RESPONSE:
1350       /* create response string */
1351       g_string_append_printf (str, "RTSP/1.0 %d %s\r\n",
1352           message->type_data.response.code, message->type_data.response.reason);
1353       break;
1354     case GST_RTSP_MESSAGE_HTTP_REQUEST:
1355       /* create request string */
1356       g_string_append_printf (str, "%s %s HTTP/%s\r\n",
1357           gst_rtsp_method_as_text (message->type_data.request.method),
1358           message->type_data.request.uri,
1359           gst_rtsp_version_as_text (message->type_data.request.version));
1360       /* add any authentication headers */
1361       add_auth_header (conn, message);
1362       break;
1363     case GST_RTSP_MESSAGE_HTTP_RESPONSE:
1364       /* create response string */
1365       g_string_append_printf (str, "HTTP/%s %d %s\r\n",
1366           gst_rtsp_version_as_text (message->type_data.request.version),
1367           message->type_data.response.code, message->type_data.response.reason);
1368       break;
1369     case GST_RTSP_MESSAGE_DATA:
1370     {
1371       guint8 data_header[4];
1372
1373       /* prepare data header */
1374       data_header[0] = '$';
1375       data_header[1] = message->type_data.data.channel;
1376       data_header[2] = (message->body_size >> 8) & 0xff;
1377       data_header[3] = message->body_size & 0xff;
1378
1379       /* create string with header and data */
1380       str = g_string_append_len (str, (gchar *) data_header, 4);
1381       str =
1382           g_string_append_len (str, (gchar *) message->body,
1383           message->body_size);
1384       break;
1385     }
1386     default:
1387       g_string_free (str, TRUE);
1388       g_return_val_if_reached (NULL);
1389       break;
1390   }
1391
1392   /* append headers and body */
1393   if (message->type != GST_RTSP_MESSAGE_DATA) {
1394     gchar date_string[100];
1395
1396     gen_date_string (date_string, sizeof (date_string));
1397
1398     /* add date header */
1399     gst_rtsp_message_remove_header (message, GST_RTSP_HDR_DATE, -1);
1400     gst_rtsp_message_add_header (message, GST_RTSP_HDR_DATE, date_string);
1401
1402     /* append headers */
1403     gst_rtsp_message_append_headers (message, str);
1404
1405     /* append Content-Length and body if needed */
1406     if (message->body != NULL && message->body_size > 0) {
1407       gchar *len;
1408
1409       len = g_strdup_printf ("%d", message->body_size);
1410       g_string_append_printf (str, "%s: %s\r\n",
1411           gst_rtsp_header_as_text (GST_RTSP_HDR_CONTENT_LENGTH), len);
1412       g_free (len);
1413       /* header ends here */
1414       g_string_append (str, "\r\n");
1415       str =
1416           g_string_append_len (str, (gchar *) message->body,
1417           message->body_size);
1418     } else {
1419       /* just end headers */
1420       g_string_append (str, "\r\n");
1421     }
1422   }
1423
1424   return str;
1425 }
1426
1427 /**
1428  * gst_rtsp_connection_send:
1429  * @conn: a #GstRTSPConnection
1430  * @message: the message to send
1431  * @timeout: a timeout value or #NULL
1432  *
1433  * Attempt to send @message to the connected @conn, blocking up to
1434  * the specified @timeout. @timeout can be #NULL, in which case this function
1435  * might block forever.
1436  *
1437  * This function can be cancelled with gst_rtsp_connection_flush().
1438  *
1439  * Returns: #GST_RTSP_OK on success.
1440  */
1441 GstRTSPResult
1442 gst_rtsp_connection_send (GstRTSPConnection * conn, GstRTSPMessage * message,
1443     GTimeVal * timeout)
1444 {
1445   GString *string = NULL;
1446   GstRTSPResult res;
1447   gchar *str;
1448   gsize len;
1449
1450   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
1451   g_return_val_if_fail (message != NULL, GST_RTSP_EINVAL);
1452
1453   if (G_UNLIKELY (!(string = message_to_string (conn, message))))
1454     goto no_message;
1455
1456   if (conn->tunneled) {
1457     str = g_base64_encode ((const guchar *) string->str, string->len);
1458     g_string_free (string, TRUE);
1459     len = strlen (str);
1460   } else {
1461     str = string->str;
1462     len = string->len;
1463     g_string_free (string, FALSE);
1464   }
1465
1466   /* write request */
1467   res = gst_rtsp_connection_write (conn, (guint8 *) str, len, timeout);
1468
1469   g_free (str);
1470
1471   return res;
1472
1473 no_message:
1474   {
1475     g_warning ("Wrong message");
1476     return GST_RTSP_EINVAL;
1477   }
1478 }
1479
1480 static GstRTSPResult
1481 parse_string (gchar * dest, gint size, gchar ** src)
1482 {
1483   GstRTSPResult res = GST_RTSP_OK;
1484   gint idx;
1485
1486   idx = 0;
1487   /* skip spaces */
1488   while (g_ascii_isspace (**src))
1489     (*src)++;
1490
1491   while (!g_ascii_isspace (**src) && **src != '\0') {
1492     if (idx < size - 1)
1493       dest[idx++] = **src;
1494     else
1495       res = GST_RTSP_EPARSE;
1496     (*src)++;
1497   }
1498   if (size > 0)
1499     dest[idx] = '\0';
1500
1501   return res;
1502 }
1503
1504 static void
1505 parse_key (gchar * dest, gint size, gchar ** src)
1506 {
1507   gint idx;
1508
1509   idx = 0;
1510   while (**src != ':' && **src != '\0') {
1511     if (idx < size - 1)
1512       dest[idx++] = **src;
1513     (*src)++;
1514   }
1515   if (size > 0)
1516     dest[idx] = '\0';
1517 }
1518
1519 static GstRTSPResult
1520 parse_protocol_version (gchar * protocol, GstRTSPMsgType * type,
1521     GstRTSPVersion * version)
1522 {
1523   GstRTSPResult res = GST_RTSP_OK;
1524   gchar *ver;
1525
1526   if (G_LIKELY ((ver = strchr (protocol, '/')) != NULL)) {
1527     guint major;
1528     guint minor;
1529     gchar dummychar;
1530
1531     *ver++ = '\0';
1532
1533     /* the version number must be formatted as X.Y with nothing following */
1534     if (sscanf (ver, "%u.%u%c", &major, &minor, &dummychar) != 2)
1535       res = GST_RTSP_EPARSE;
1536
1537     if (g_ascii_strcasecmp (protocol, "RTSP") == 0) {
1538       if (major != 1 || minor != 0) {
1539         *version = GST_RTSP_VERSION_INVALID;
1540         res = GST_RTSP_ERROR;
1541       }
1542     } else if (g_ascii_strcasecmp (protocol, "HTTP") == 0) {
1543       if (*type == GST_RTSP_MESSAGE_REQUEST)
1544         *type = GST_RTSP_MESSAGE_HTTP_REQUEST;
1545       else if (*type == GST_RTSP_MESSAGE_RESPONSE)
1546         *type = GST_RTSP_MESSAGE_HTTP_RESPONSE;
1547
1548       if (major == 1 && minor == 1) {
1549         *version = GST_RTSP_VERSION_1_1;
1550       } else if (major != 1 || minor != 0) {
1551         *version = GST_RTSP_VERSION_INVALID;
1552         res = GST_RTSP_ERROR;
1553       }
1554     } else
1555       res = GST_RTSP_EPARSE;
1556   } else
1557     res = GST_RTSP_EPARSE;
1558
1559   return res;
1560 }
1561
1562 static GstRTSPResult
1563 parse_response_status (guint8 * buffer, GstRTSPMessage * msg)
1564 {
1565   GstRTSPResult res = GST_RTSP_OK;
1566   GstRTSPResult res2;
1567   gchar versionstr[20];
1568   gchar codestr[4];
1569   gint code;
1570   gchar *bptr;
1571
1572   bptr = (gchar *) buffer;
1573
1574   if (parse_string (versionstr, sizeof (versionstr), &bptr) != GST_RTSP_OK)
1575     res = GST_RTSP_EPARSE;
1576
1577   if (parse_string (codestr, sizeof (codestr), &bptr) != GST_RTSP_OK)
1578     res = GST_RTSP_EPARSE;
1579   code = atoi (codestr);
1580   if (G_UNLIKELY (*codestr == '\0' || code < 0 || code >= 600))
1581     res = GST_RTSP_EPARSE;
1582
1583   while (g_ascii_isspace (*bptr))
1584     bptr++;
1585
1586   if (G_UNLIKELY (gst_rtsp_message_init_response (msg, code, bptr,
1587               NULL) != GST_RTSP_OK))
1588     res = GST_RTSP_EPARSE;
1589
1590   res2 = parse_protocol_version (versionstr, &msg->type,
1591       &msg->type_data.response.version);
1592   if (G_LIKELY (res == GST_RTSP_OK))
1593     res = res2;
1594
1595   return res;
1596 }
1597
1598 static GstRTSPResult
1599 parse_request_line (guint8 * buffer, GstRTSPMessage * msg)
1600 {
1601   GstRTSPResult res = GST_RTSP_OK;
1602   GstRTSPResult res2;
1603   gchar versionstr[20];
1604   gchar methodstr[20];
1605   gchar urlstr[4096];
1606   gchar *bptr;
1607   GstRTSPMethod method;
1608
1609   bptr = (gchar *) buffer;
1610
1611   if (parse_string (methodstr, sizeof (methodstr), &bptr) != GST_RTSP_OK)
1612     res = GST_RTSP_EPARSE;
1613   method = gst_rtsp_find_method (methodstr);
1614
1615   if (parse_string (urlstr, sizeof (urlstr), &bptr) != GST_RTSP_OK)
1616     res = GST_RTSP_EPARSE;
1617   if (G_UNLIKELY (*urlstr == '\0'))
1618     res = GST_RTSP_EPARSE;
1619
1620   if (parse_string (versionstr, sizeof (versionstr), &bptr) != GST_RTSP_OK)
1621     res = GST_RTSP_EPARSE;
1622
1623   if (G_UNLIKELY (*bptr != '\0'))
1624     res = GST_RTSP_EPARSE;
1625
1626   if (G_UNLIKELY (gst_rtsp_message_init_request (msg, method,
1627               urlstr) != GST_RTSP_OK))
1628     res = GST_RTSP_EPARSE;
1629
1630   res2 = parse_protocol_version (versionstr, &msg->type,
1631       &msg->type_data.request.version);
1632   if (G_LIKELY (res == GST_RTSP_OK))
1633     res = res2;
1634
1635   if (G_LIKELY (msg->type == GST_RTSP_MESSAGE_REQUEST)) {
1636     /* GET and POST are not allowed as RTSP methods */
1637     if (msg->type_data.request.method == GST_RTSP_GET ||
1638         msg->type_data.request.method == GST_RTSP_POST) {
1639       msg->type_data.request.method = GST_RTSP_INVALID;
1640       if (res == GST_RTSP_OK)
1641         res = GST_RTSP_ERROR;
1642     }
1643   } else if (msg->type == GST_RTSP_MESSAGE_HTTP_REQUEST) {
1644     /* only GET and POST are allowed as HTTP methods */
1645     if (msg->type_data.request.method != GST_RTSP_GET &&
1646         msg->type_data.request.method != GST_RTSP_POST) {
1647       msg->type_data.request.method = GST_RTSP_INVALID;
1648       if (res == GST_RTSP_OK)
1649         res = GST_RTSP_ERROR;
1650     }
1651   }
1652
1653   return res;
1654 }
1655
1656 static GstRTSPResult
1657 parse_key_value (guint8 * buffer, gchar * key, guint keysize, gchar ** value)
1658 {
1659   gchar *bptr;
1660
1661   bptr = (gchar *) buffer;
1662
1663   /* read key */
1664   parse_key (key, keysize, &bptr);
1665   if (G_UNLIKELY (*bptr != ':'))
1666     goto no_column;
1667
1668   bptr++;
1669   while (g_ascii_isspace (*bptr))
1670     bptr++;
1671
1672   *value = bptr;
1673
1674   return GST_RTSP_OK;
1675
1676   /* ERRORS */
1677 no_column:
1678   {
1679     return GST_RTSP_EPARSE;
1680   }
1681 }
1682
1683 /* parsing lines means reading a Key: Value pair */
1684 static GstRTSPResult
1685 parse_line (guint8 * buffer, GstRTSPMessage * msg)
1686 {
1687   GstRTSPResult res;
1688   gchar key[32];
1689   gchar *value;
1690   GstRTSPHeaderField field;
1691
1692   res = parse_key_value (buffer, key, sizeof (key), &value);
1693   if (G_UNLIKELY (res != GST_RTSP_OK))
1694     goto parse_error;
1695
1696   field = gst_rtsp_find_header_field (key);
1697   if (field != GST_RTSP_HDR_INVALID)
1698     gst_rtsp_message_add_header (msg, field, value);
1699
1700   return GST_RTSP_OK;
1701
1702   /* ERRORS */
1703 parse_error:
1704   {
1705     return res;
1706   }
1707 }
1708
1709 /* returns:
1710  *  GST_RTSP_OK when a complete message was read.
1711  *  GST_RTSP_EEOF: when the socket is closed
1712  *  GST_RTSP_EINTR: when more data is needed.
1713  *  GST_RTSP_..: some other error occured.
1714  */
1715 static GstRTSPResult
1716 build_next (GstRTSPBuilder * builder, GstRTSPMessage * message,
1717     GstRTSPConnection * conn)
1718 {
1719   GstRTSPResult res;
1720
1721   while (TRUE) {
1722     switch (builder->state) {
1723       case STATE_START:
1724         builder->offset = 0;
1725         res =
1726             read_bytes (conn, (guint8 *) builder->buffer, &builder->offset, 1);
1727         if (res != GST_RTSP_OK)
1728           goto done;
1729
1730         /* we have 1 bytes now and we can see if this is a data message or
1731          * not */
1732         if (builder->buffer[0] == '$') {
1733           /* data message, prepare for the header */
1734           builder->state = STATE_DATA_HEADER;
1735         } else {
1736           builder->line = 0;
1737           builder->state = STATE_READ_LINES;
1738         }
1739         break;
1740       case STATE_DATA_HEADER:
1741       {
1742         res =
1743             read_bytes (conn, (guint8 *) builder->buffer, &builder->offset, 4);
1744         if (res != GST_RTSP_OK)
1745           goto done;
1746
1747         gst_rtsp_message_init_data (message, builder->buffer[1]);
1748
1749         builder->body_len = (builder->buffer[2] << 8) | builder->buffer[3];
1750         builder->body_data = g_malloc (builder->body_len + 1);
1751         builder->body_data[builder->body_len] = '\0';
1752         builder->offset = 0;
1753         builder->state = STATE_DATA_BODY;
1754         break;
1755       }
1756       case STATE_DATA_BODY:
1757       {
1758         res =
1759             read_bytes (conn, builder->body_data, &builder->offset,
1760             builder->body_len);
1761         if (res != GST_RTSP_OK)
1762           goto done;
1763
1764         /* we have the complete body now, store in the message adjusting the
1765          * length to include the traling '\0' */
1766         gst_rtsp_message_take_body (message,
1767             (guint8 *) builder->body_data, builder->body_len + 1);
1768         builder->body_data = NULL;
1769         builder->body_len = 0;
1770
1771         builder->state = STATE_END;
1772         break;
1773       }
1774       case STATE_READ_LINES:
1775       {
1776         res = read_line (conn, builder->buffer, &builder->offset,
1777             sizeof (builder->buffer));
1778         if (res != GST_RTSP_OK)
1779           goto done;
1780
1781         /* we have a regular response */
1782         if (builder->buffer[0] == '\r') {
1783           builder->buffer[0] = '\0';
1784         }
1785
1786         if (builder->buffer[0] == '\0') {
1787           gchar *hdrval;
1788
1789           /* empty line, end of message header */
1790           /* see if there is a Content-Length header */
1791           if (gst_rtsp_message_get_header (message,
1792                   GST_RTSP_HDR_CONTENT_LENGTH, &hdrval, 0) == GST_RTSP_OK) {
1793             /* there is, prepare to read the body */
1794             builder->body_len = atol (hdrval);
1795             builder->body_data = g_malloc (builder->body_len + 1);
1796             builder->body_data[builder->body_len] = '\0';
1797             builder->offset = 0;
1798             builder->state = STATE_DATA_BODY;
1799           } else {
1800             builder->state = STATE_END;
1801           }
1802           break;
1803         }
1804
1805         /* we have a line */
1806         if (builder->line == 0) {
1807           /* first line, check for response status */
1808           if (memcmp (builder->buffer, "RTSP", 4) == 0 ||
1809               memcmp (builder->buffer, "HTTP", 4) == 0) {
1810             builder->status = parse_response_status (builder->buffer, message);
1811           } else {
1812             builder->status = parse_request_line (builder->buffer, message);
1813           }
1814         } else {
1815           /* else just parse the line */
1816           res = parse_line (builder->buffer, message);
1817           if (res != GST_RTSP_OK)
1818             builder->status = res;
1819         }
1820         builder->line++;
1821         builder->offset = 0;
1822         break;
1823       }
1824       case STATE_END:
1825       {
1826         gchar *session_cookie;
1827         gchar *session_id;
1828
1829         if (message->type == GST_RTSP_MESSAGE_DATA) {
1830           /* data messages don't have headers */
1831           res = GST_RTSP_OK;
1832           goto done;
1833         }
1834
1835         /* save the tunnel session in the connection */
1836         if (message->type == GST_RTSP_MESSAGE_HTTP_REQUEST &&
1837             !conn->manual_http &&
1838             conn->tstate == TUNNEL_STATE_NONE &&
1839             gst_rtsp_message_get_header (message, GST_RTSP_HDR_X_SESSIONCOOKIE,
1840                 &session_cookie, 0) == GST_RTSP_OK) {
1841           strncpy (conn->tunnelid, session_cookie, TUNNELID_LEN);
1842           conn->tunnelid[TUNNELID_LEN - 1] = '\0';
1843           conn->tunneled = TRUE;
1844         }
1845
1846         /* save session id in the connection for further use */
1847         if (message->type == GST_RTSP_MESSAGE_RESPONSE &&
1848             gst_rtsp_message_get_header (message, GST_RTSP_HDR_SESSION,
1849                 &session_id, 0) == GST_RTSP_OK) {
1850           gint maxlen, i;
1851
1852           maxlen = sizeof (conn->session_id) - 1;
1853           /* the sessionid can have attributes marked with ;
1854            * Make sure we strip them */
1855           for (i = 0; session_id[i] != '\0'; i++) {
1856             if (session_id[i] == ';') {
1857               maxlen = i;
1858               /* parse timeout */
1859               do {
1860                 i++;
1861               } while (g_ascii_isspace (session_id[i]));
1862               if (g_str_has_prefix (&session_id[i], "timeout=")) {
1863                 gint to;
1864
1865                 /* if we parsed something valid, configure */
1866                 if ((to = atoi (&session_id[i + 8])) > 0)
1867                   conn->timeout = to;
1868               }
1869               break;
1870             }
1871           }
1872
1873           /* make sure to not overflow */
1874           strncpy (conn->session_id, session_id, maxlen);
1875           conn->session_id[maxlen] = '\0';
1876         }
1877         res = builder->status;
1878         goto done;
1879       }
1880       default:
1881         res = GST_RTSP_ERROR;
1882         break;
1883     }
1884   }
1885 done:
1886   return res;
1887 }
1888
1889 /**
1890  * gst_rtsp_connection_read:
1891  * @conn: a #GstRTSPConnection
1892  * @data: the data to read
1893  * @size: the size of @data
1894  * @timeout: a timeout value or #NULL
1895  *
1896  * Attempt to read @size bytes into @data from the connected @conn, blocking up to
1897  * the specified @timeout. @timeout can be #NULL, in which case this function
1898  * might block forever.
1899  *
1900  * This function can be cancelled with gst_rtsp_connection_flush().
1901  *
1902  * Returns: #GST_RTSP_OK on success.
1903  */
1904 GstRTSPResult
1905 gst_rtsp_connection_read (GstRTSPConnection * conn, guint8 * data, guint size,
1906     GTimeVal * timeout)
1907 {
1908   guint offset;
1909   gint retval;
1910   GstClockTime to;
1911   GstRTSPResult res;
1912
1913   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
1914   g_return_val_if_fail (data != NULL, GST_RTSP_EINVAL);
1915   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
1916
1917   if (G_UNLIKELY (size == 0))
1918     return GST_RTSP_OK;
1919
1920   offset = 0;
1921
1922   /* configure timeout if any */
1923   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
1924
1925   gst_poll_set_controllable (conn->fdset, TRUE);
1926   gst_poll_fd_ctl_write (conn->fdset, conn->writefd, FALSE);
1927   gst_poll_fd_ctl_read (conn->fdset, conn->readfd, TRUE);
1928
1929   while (TRUE) {
1930     res = read_bytes (conn, data, &offset, size);
1931     if (G_UNLIKELY (res == GST_RTSP_EEOF))
1932       goto eof;
1933     if (G_LIKELY (res == GST_RTSP_OK))
1934       break;
1935     if (G_UNLIKELY (res != GST_RTSP_EINTR))
1936       goto read_error;
1937
1938     do {
1939       retval = gst_poll_wait (conn->fdset, to);
1940     } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
1941
1942     /* check for timeout */
1943     if (G_UNLIKELY (retval == 0))
1944       goto select_timeout;
1945
1946     if (G_UNLIKELY (retval == -1)) {
1947       if (errno == EBUSY)
1948         goto stopped;
1949       else
1950         goto select_error;
1951     }
1952     gst_poll_set_controllable (conn->fdset, FALSE);
1953   }
1954   return GST_RTSP_OK;
1955
1956   /* ERRORS */
1957 select_error:
1958   {
1959     return GST_RTSP_ESYS;
1960   }
1961 select_timeout:
1962   {
1963     return GST_RTSP_ETIMEOUT;
1964   }
1965 stopped:
1966   {
1967     return GST_RTSP_EINTR;
1968   }
1969 eof:
1970   {
1971     return GST_RTSP_EEOF;
1972   }
1973 read_error:
1974   {
1975     return res;
1976   }
1977 }
1978
1979 static GString *
1980 gen_tunnel_reply (GstRTSPConnection * conn, GstRTSPStatusCode code)
1981 {
1982   GString *str;
1983   gchar date_string[100];
1984   const gchar *status;
1985
1986   gen_date_string (date_string, sizeof (date_string));
1987
1988   status = gst_rtsp_status_as_text (code);
1989   if (status == NULL) {
1990     code = GST_RTSP_STS_INTERNAL_SERVER_ERROR;
1991     status = "Internal Server Error";
1992   }
1993
1994   str = g_string_new ("");
1995
1996   /* */
1997   g_string_append_printf (str, "HTTP/1.0 %d %s\r\n", code, status);
1998   g_string_append_printf (str,
1999       "Server: GStreamer RTSP Server\r\n"
2000       "Date: %s\r\n"
2001       "Connection: close\r\n"
2002       "Cache-Control: no-store\r\n" "Pragma: no-cache\r\n", date_string);
2003   if (code == GST_RTSP_STS_OK) {
2004     if (conn->ip)
2005       g_string_append_printf (str, "x-server-ip-address: %s\r\n", conn->ip);
2006     g_string_append_printf (str,
2007         "Content-Type: application/x-rtsp-tunnelled\r\n");
2008   }
2009   g_string_append_printf (str, "\r\n");
2010   return str;
2011 }
2012
2013 /**
2014  * gst_rtsp_connection_receive:
2015  * @conn: a #GstRTSPConnection
2016  * @message: the message to read
2017  * @timeout: a timeout value or #NULL
2018  *
2019  * Attempt to read into @message from the connected @conn, blocking up to
2020  * the specified @timeout. @timeout can be #NULL, in which case this function
2021  * might block forever.
2022  *
2023  * This function can be cancelled with gst_rtsp_connection_flush().
2024  *
2025  * Returns: #GST_RTSP_OK on success.
2026  */
2027 GstRTSPResult
2028 gst_rtsp_connection_receive (GstRTSPConnection * conn, GstRTSPMessage * message,
2029     GTimeVal * timeout)
2030 {
2031   GstRTSPResult res;
2032   GstRTSPBuilder builder;
2033   gint retval;
2034   GstClockTime to;
2035
2036   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2037   g_return_val_if_fail (message != NULL, GST_RTSP_EINVAL);
2038   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
2039
2040   /* configure timeout if any */
2041   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
2042
2043   gst_poll_set_controllable (conn->fdset, TRUE);
2044   gst_poll_fd_ctl_write (conn->fdset, conn->writefd, FALSE);
2045   gst_poll_fd_ctl_read (conn->fdset, conn->readfd, TRUE);
2046
2047   memset (&builder, 0, sizeof (GstRTSPBuilder));
2048   while (TRUE) {
2049     res = build_next (&builder, message, conn);
2050     if (G_UNLIKELY (res == GST_RTSP_EEOF))
2051       goto eof;
2052     else if (G_LIKELY (res == GST_RTSP_OK)) {
2053       if (message->type == GST_RTSP_MESSAGE_HTTP_REQUEST) {
2054         if (conn->tstate == TUNNEL_STATE_NONE &&
2055             message->type_data.request.method == GST_RTSP_GET) {
2056           GString *str;
2057
2058           conn->tstate = TUNNEL_STATE_GET;
2059
2060           /* tunnel GET request, we can reply now */
2061           str = gen_tunnel_reply (conn, GST_RTSP_STS_OK);
2062           res =
2063               gst_rtsp_connection_write (conn, (guint8 *) str->str, str->len,
2064               timeout);
2065           g_string_free (str, TRUE);
2066           res = GST_RTSP_ETGET;
2067           goto cleanup;
2068         } else if (conn->tstate == TUNNEL_STATE_NONE &&
2069             message->type_data.request.method == GST_RTSP_POST) {
2070           conn->tstate = TUNNEL_STATE_POST;
2071
2072           /* tunnel POST request, the caller now has to link the two
2073            * connections. */
2074           res = GST_RTSP_ETPOST;
2075           goto cleanup;
2076         } else {
2077           res = GST_RTSP_EPARSE;
2078           goto cleanup;
2079         }
2080       }
2081
2082       break;
2083     } else if (G_UNLIKELY (res != GST_RTSP_EINTR))
2084       goto read_error;
2085
2086     do {
2087       retval = gst_poll_wait (conn->fdset, to);
2088     } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
2089
2090     /* check for timeout */
2091     if (G_UNLIKELY (retval == 0))
2092       goto select_timeout;
2093
2094     if (G_UNLIKELY (retval == -1)) {
2095       if (errno == EBUSY)
2096         goto stopped;
2097       else
2098         goto select_error;
2099     }
2100     gst_poll_set_controllable (conn->fdset, FALSE);
2101   }
2102
2103   /* we have a message here */
2104   build_reset (&builder);
2105
2106   return GST_RTSP_OK;
2107
2108   /* ERRORS */
2109 select_error:
2110   {
2111     res = GST_RTSP_ESYS;
2112     goto cleanup;
2113   }
2114 select_timeout:
2115   {
2116     res = GST_RTSP_ETIMEOUT;
2117     goto cleanup;
2118   }
2119 stopped:
2120   {
2121     res = GST_RTSP_EINTR;
2122     goto cleanup;
2123   }
2124 eof:
2125   {
2126     res = GST_RTSP_EEOF;
2127     goto cleanup;
2128   }
2129 read_error:
2130 cleanup:
2131   {
2132     build_reset (&builder);
2133     gst_rtsp_message_unset (message);
2134     return res;
2135   }
2136 }
2137
2138 /**
2139  * gst_rtsp_connection_close:
2140  * @conn: a #GstRTSPConnection
2141  *
2142  * Close the connected @conn. After this call, the connection is in the same
2143  * state as when it was first created.
2144  *
2145  * Returns: #GST_RTSP_OK on success.
2146  */
2147 GstRTSPResult
2148 gst_rtsp_connection_close (GstRTSPConnection * conn)
2149 {
2150   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2151
2152   g_free (conn->ip);
2153   conn->ip = NULL;
2154
2155   g_free (conn->initial_buffer);
2156   conn->initial_buffer = NULL;
2157   conn->initial_buffer_offset = 0;
2158
2159   REMOVE_POLLFD (conn->fdset, &conn->fd0);
2160   REMOVE_POLLFD (conn->fdset, &conn->fd1);
2161   conn->writefd = NULL;
2162   conn->readfd = NULL;
2163   conn->tunneled = FALSE;
2164   conn->tstate = TUNNEL_STATE_NONE;
2165   conn->ctxp = NULL;
2166   g_free (conn->username);
2167   conn->username = NULL;
2168   g_free (conn->passwd);
2169   conn->passwd = NULL;
2170   gst_rtsp_connection_clear_auth_params (conn);
2171   conn->timeout = 60;
2172   conn->cseq = 0;
2173   conn->session_id[0] = '\0';
2174
2175   return GST_RTSP_OK;
2176 }
2177
2178 /**
2179  * gst_rtsp_connection_free:
2180  * @conn: a #GstRTSPConnection
2181  *
2182  * Close and free @conn.
2183  *
2184  * Returns: #GST_RTSP_OK on success.
2185  */
2186 GstRTSPResult
2187 gst_rtsp_connection_free (GstRTSPConnection * conn)
2188 {
2189   GstRTSPResult res;
2190
2191   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2192
2193   res = gst_rtsp_connection_close (conn);
2194   gst_poll_free (conn->fdset);
2195   g_timer_destroy (conn->timer);
2196   gst_rtsp_url_free (conn->url);
2197   g_free (conn->proxy_host);
2198   g_free (conn);
2199 #ifdef G_OS_WIN32
2200   WSACleanup ();
2201 #endif
2202
2203   return res;
2204 }
2205
2206 /**
2207  * gst_rtsp_connection_poll:
2208  * @conn: a #GstRTSPConnection
2209  * @events: a bitmask of #GstRTSPEvent flags to check
2210  * @revents: location for result flags
2211  * @timeout: a timeout
2212  *
2213  * Wait up to the specified @timeout for the connection to become available for
2214  * at least one of the operations specified in @events. When the function returns
2215  * with #GST_RTSP_OK, @revents will contain a bitmask of available operations on
2216  * @conn.
2217  *
2218  * @timeout can be #NULL, in which case this function might block forever.
2219  *
2220  * This function can be cancelled with gst_rtsp_connection_flush().
2221  *
2222  * Returns: #GST_RTSP_OK on success.
2223  *
2224  * Since: 0.10.15
2225  */
2226 GstRTSPResult
2227 gst_rtsp_connection_poll (GstRTSPConnection * conn, GstRTSPEvent events,
2228     GstRTSPEvent * revents, GTimeVal * timeout)
2229 {
2230   GstClockTime to;
2231   gint retval;
2232
2233   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2234   g_return_val_if_fail (events != 0, GST_RTSP_EINVAL);
2235   g_return_val_if_fail (revents != NULL, GST_RTSP_EINVAL);
2236   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
2237   g_return_val_if_fail (conn->writefd != NULL, GST_RTSP_EINVAL);
2238
2239   gst_poll_set_controllable (conn->fdset, TRUE);
2240
2241   /* add fd to writer set when asked to */
2242   gst_poll_fd_ctl_write (conn->fdset, conn->writefd,
2243       events & GST_RTSP_EV_WRITE);
2244
2245   /* add fd to reader set when asked to */
2246   gst_poll_fd_ctl_read (conn->fdset, conn->readfd, events & GST_RTSP_EV_READ);
2247
2248   /* configure timeout if any */
2249   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
2250
2251   do {
2252     retval = gst_poll_wait (conn->fdset, to);
2253   } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
2254
2255   if (G_UNLIKELY (retval == 0))
2256     goto select_timeout;
2257
2258   if (G_UNLIKELY (retval == -1)) {
2259     if (errno == EBUSY)
2260       goto stopped;
2261     else
2262       goto select_error;
2263   }
2264
2265   *revents = 0;
2266   if (events & GST_RTSP_EV_READ) {
2267     if (gst_poll_fd_can_read (conn->fdset, conn->readfd))
2268       *revents |= GST_RTSP_EV_READ;
2269   }
2270   if (events & GST_RTSP_EV_WRITE) {
2271     if (gst_poll_fd_can_write (conn->fdset, conn->writefd))
2272       *revents |= GST_RTSP_EV_WRITE;
2273   }
2274   return GST_RTSP_OK;
2275
2276   /* ERRORS */
2277 select_timeout:
2278   {
2279     return GST_RTSP_ETIMEOUT;
2280   }
2281 select_error:
2282   {
2283     return GST_RTSP_ESYS;
2284   }
2285 stopped:
2286   {
2287     return GST_RTSP_EINTR;
2288   }
2289 }
2290
2291 /**
2292  * gst_rtsp_connection_next_timeout:
2293  * @conn: a #GstRTSPConnection
2294  * @timeout: a timeout
2295  *
2296  * Calculate the next timeout for @conn, storing the result in @timeout.
2297  *
2298  * Returns: #GST_RTSP_OK.
2299  */
2300 GstRTSPResult
2301 gst_rtsp_connection_next_timeout (GstRTSPConnection * conn, GTimeVal * timeout)
2302 {
2303   gdouble elapsed;
2304   glong sec;
2305   gulong usec;
2306
2307   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2308   g_return_val_if_fail (timeout != NULL, GST_RTSP_EINVAL);
2309
2310   elapsed = g_timer_elapsed (conn->timer, &usec);
2311   if (elapsed >= conn->timeout) {
2312     sec = 0;
2313     usec = 0;
2314   } else {
2315     sec = conn->timeout - elapsed;
2316   }
2317
2318   timeout->tv_sec = sec;
2319   timeout->tv_usec = usec;
2320
2321   return GST_RTSP_OK;
2322 }
2323
2324 /**
2325  * gst_rtsp_connection_reset_timeout:
2326  * @conn: a #GstRTSPConnection
2327  *
2328  * Reset the timeout of @conn.
2329  *
2330  * Returns: #GST_RTSP_OK.
2331  */
2332 GstRTSPResult
2333 gst_rtsp_connection_reset_timeout (GstRTSPConnection * conn)
2334 {
2335   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2336
2337   g_timer_start (conn->timer);
2338
2339   return GST_RTSP_OK;
2340 }
2341
2342 /**
2343  * gst_rtsp_connection_flush:
2344  * @conn: a #GstRTSPConnection
2345  * @flush: start or stop the flush
2346  *
2347  * Start or stop the flushing action on @conn. When flushing, all current
2348  * and future actions on @conn will return #GST_RTSP_EINTR until the connection
2349  * is set to non-flushing mode again.
2350  *
2351  * Returns: #GST_RTSP_OK.
2352  */
2353 GstRTSPResult
2354 gst_rtsp_connection_flush (GstRTSPConnection * conn, gboolean flush)
2355 {
2356   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2357
2358   gst_poll_set_flushing (conn->fdset, flush);
2359
2360   return GST_RTSP_OK;
2361 }
2362
2363 /**
2364  * gst_rtsp_connection_set_proxy:
2365  * @conn: a #GstRTSPConnection
2366  * @host: the proxy host
2367  * @port: the proxy port
2368  *
2369  * Set the proxy host and port.
2370  *
2371  * Returns: #GST_RTSP_OK.
2372  *
2373  * Since: 0.10.23
2374  */
2375 GstRTSPResult
2376 gst_rtsp_connection_set_proxy (GstRTSPConnection * conn,
2377     const gchar * host, guint port)
2378 {
2379   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2380
2381   g_free (conn->proxy_host);
2382   conn->proxy_host = g_strdup (host);
2383   conn->proxy_port = port;
2384
2385   return GST_RTSP_OK;
2386 }
2387
2388 /**
2389  * gst_rtsp_connection_set_auth:
2390  * @conn: a #GstRTSPConnection
2391  * @method: authentication method
2392  * @user: the user
2393  * @pass: the password
2394  *
2395  * Configure @conn for authentication mode @method with @user and @pass as the
2396  * user and password respectively.
2397  *
2398  * Returns: #GST_RTSP_OK.
2399  */
2400 GstRTSPResult
2401 gst_rtsp_connection_set_auth (GstRTSPConnection * conn,
2402     GstRTSPAuthMethod method, const gchar * user, const gchar * pass)
2403 {
2404   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2405
2406   if (method == GST_RTSP_AUTH_DIGEST && ((user == NULL || pass == NULL)
2407           || g_strrstr (user, ":") != NULL))
2408     return GST_RTSP_EINVAL;
2409
2410   /* Make sure the username and passwd are being set for authentication */
2411   if (method == GST_RTSP_AUTH_NONE && (user == NULL || pass == NULL))
2412     return GST_RTSP_EINVAL;
2413
2414   /* ":" chars are not allowed in usernames for basic auth */
2415   if (method == GST_RTSP_AUTH_BASIC && g_strrstr (user, ":") != NULL)
2416     return GST_RTSP_EINVAL;
2417
2418   g_free (conn->username);
2419   g_free (conn->passwd);
2420
2421   conn->auth_method = method;
2422   conn->username = g_strdup (user);
2423   conn->passwd = g_strdup (pass);
2424
2425   return GST_RTSP_OK;
2426 }
2427
2428 /**
2429  * str_case_hash:
2430  * @key: ASCII string to hash
2431  *
2432  * Hashes @key in a case-insensitive manner.
2433  *
2434  * Returns: the hash code.
2435  **/
2436 static guint
2437 str_case_hash (gconstpointer key)
2438 {
2439   const char *p = key;
2440   guint h = g_ascii_toupper (*p);
2441
2442   if (h)
2443     for (p += 1; *p != '\0'; p++)
2444       h = (h << 5) - h + g_ascii_toupper (*p);
2445
2446   return h;
2447 }
2448
2449 /**
2450  * str_case_equal:
2451  * @v1: an ASCII string
2452  * @v2: another ASCII string
2453  *
2454  * Compares @v1 and @v2 in a case-insensitive manner
2455  *
2456  * Returns: %TRUE if they are equal (modulo case)
2457  **/
2458 static gboolean
2459 str_case_equal (gconstpointer v1, gconstpointer v2)
2460 {
2461   const char *string1 = v1;
2462   const char *string2 = v2;
2463
2464   return g_ascii_strcasecmp (string1, string2) == 0;
2465 }
2466
2467 /**
2468  * gst_rtsp_connection_set_auth_param:
2469  * @conn: a #GstRTSPConnection
2470  * @param: authentication directive
2471  * @value: value
2472  *
2473  * Setup @conn with authentication directives. This is not necesary for
2474  * methods #GST_RTSP_AUTH_NONE and #GST_RTSP_AUTH_BASIC. For
2475  * #GST_RTSP_AUTH_DIGEST, directives should be taken from the digest challenge
2476  * in the WWW-Authenticate response header and can include realm, domain,
2477  * nonce, opaque, stale, algorithm, qop as per RFC2617.
2478  *
2479  * Since: 0.10.20
2480  */
2481 void
2482 gst_rtsp_connection_set_auth_param (GstRTSPConnection * conn,
2483     const gchar * param, const gchar * value)
2484 {
2485   g_return_if_fail (conn != NULL);
2486   g_return_if_fail (param != NULL);
2487
2488   if (conn->auth_params == NULL) {
2489     conn->auth_params =
2490         g_hash_table_new_full (str_case_hash, str_case_equal, g_free, g_free);
2491   }
2492   g_hash_table_insert (conn->auth_params, g_strdup (param), g_strdup (value));
2493 }
2494
2495 /**
2496  * gst_rtsp_connection_clear_auth_params:
2497  * @conn: a #GstRTSPConnection
2498  *
2499  * Clear the list of authentication directives stored in @conn.
2500  *
2501  * Since: 0.10.20
2502  */
2503 void
2504 gst_rtsp_connection_clear_auth_params (GstRTSPConnection * conn)
2505 {
2506   g_return_if_fail (conn != NULL);
2507
2508   if (conn->auth_params != NULL) {
2509     g_hash_table_destroy (conn->auth_params);
2510     conn->auth_params = NULL;
2511   }
2512 }
2513
2514 static GstRTSPResult
2515 set_qos_dscp (gint fd, guint qos_dscp)
2516 {
2517   union gst_sockaddr sa;
2518   socklen_t slen = sizeof (sa);
2519   gint af;
2520   gint tos;
2521
2522   if (fd == -1)
2523     return GST_RTSP_OK;
2524
2525   if (getsockname (fd, &sa.sa, &slen) < 0)
2526     goto no_getsockname;
2527
2528   af = sa.sa.sa_family;
2529
2530   /* if this is an IPv4-mapped address then do IPv4 QoS */
2531   if (af == AF_INET6) {
2532     if (IN6_IS_ADDR_V4MAPPED (&sa.sa_in6.sin6_addr))
2533       af = AF_INET;
2534   }
2535
2536   /* extract and shift 6 bits of the DSCP */
2537   tos = (qos_dscp & 0x3f) << 2;
2538
2539   switch (af) {
2540     case AF_INET:
2541       if (SETSOCKOPT (fd, IPPROTO_IP, IP_TOS, &tos, sizeof (tos)) < 0)
2542         goto no_setsockopt;
2543       break;
2544     case AF_INET6:
2545 #ifdef IPV6_TCLASS
2546       if (SETSOCKOPT (fd, IPPROTO_IPV6, IPV6_TCLASS, &tos, sizeof (tos)) < 0)
2547         goto no_setsockopt;
2548       break;
2549 #endif
2550     default:
2551       goto wrong_family;
2552   }
2553
2554   return GST_RTSP_OK;
2555
2556   /* ERRORS */
2557 no_getsockname:
2558 no_setsockopt:
2559   {
2560     return GST_RTSP_ESYS;
2561   }
2562
2563 wrong_family:
2564   {
2565     return GST_RTSP_ERROR;
2566   }
2567 }
2568
2569 /**
2570  * gst_rtsp_connection_set_qos_dscp:
2571  * @conn: a #GstRTSPConnection
2572  * @qos_dscp: DSCP value
2573  *
2574  * Configure @conn to use the specified DSCP value.
2575  *
2576  * Returns: #GST_RTSP_OK on success.
2577  *
2578  * Since: 0.10.20
2579  */
2580 GstRTSPResult
2581 gst_rtsp_connection_set_qos_dscp (GstRTSPConnection * conn, guint qos_dscp)
2582 {
2583   GstRTSPResult res;
2584
2585   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2586   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
2587   g_return_val_if_fail (conn->writefd != NULL, GST_RTSP_EINVAL);
2588
2589   res = set_qos_dscp (conn->fd0.fd, qos_dscp);
2590   if (res == GST_RTSP_OK)
2591     res = set_qos_dscp (conn->fd1.fd, qos_dscp);
2592
2593   return res;
2594 }
2595
2596
2597 /**
2598  * gst_rtsp_connection_get_url:
2599  * @conn: a #GstRTSPConnection
2600  *
2601  * Retrieve the URL of the other end of @conn.
2602  *
2603  * Returns: The URL. This value remains valid until the
2604  * connection is freed.
2605  *
2606  * Since: 0.10.23
2607  */
2608 GstRTSPUrl *
2609 gst_rtsp_connection_get_url (const GstRTSPConnection * conn)
2610 {
2611   g_return_val_if_fail (conn != NULL, NULL);
2612
2613   return conn->url;
2614 }
2615
2616 /**
2617  * gst_rtsp_connection_get_ip:
2618  * @conn: a #GstRTSPConnection
2619  *
2620  * Retrieve the IP address of the other end of @conn.
2621  *
2622  * Returns: The IP address as a string. this value remains valid until the
2623  * connection is closed.
2624  *
2625  * Since: 0.10.20
2626  */
2627 const gchar *
2628 gst_rtsp_connection_get_ip (const GstRTSPConnection * conn)
2629 {
2630   g_return_val_if_fail (conn != NULL, NULL);
2631
2632   return conn->ip;
2633 }
2634
2635 /**
2636  * gst_rtsp_connection_set_ip:
2637  * @conn: a #GstRTSPConnection
2638  * @ip: an ip address
2639  *
2640  * Set the IP address of the server.
2641  *
2642  * Since: 0.10.23
2643  */
2644 void
2645 gst_rtsp_connection_set_ip (GstRTSPConnection * conn, const gchar * ip)
2646 {
2647   g_return_if_fail (conn != NULL);
2648
2649   g_free (conn->ip);
2650   conn->ip = g_strdup (ip);
2651 }
2652
2653 /**
2654  * gst_rtsp_connection_get_readfd:
2655  * @conn: a #GstRTSPConnection
2656  *
2657  * Get the file descriptor for reading.
2658  *
2659  * Returns: the file descriptor used for reading or -1 on error. The file
2660  * descriptor remains valid until the connection is closed.
2661  *
2662  * Since: 0.10.23
2663  */
2664 gint
2665 gst_rtsp_connection_get_readfd (const GstRTSPConnection * conn)
2666 {
2667   g_return_val_if_fail (conn != NULL, -1);
2668   g_return_val_if_fail (conn->readfd != NULL, -1);
2669
2670   return conn->readfd->fd;
2671 }
2672
2673 /**
2674  * gst_rtsp_connection_get_writefd:
2675  * @conn: a #GstRTSPConnection
2676  *
2677  * Get the file descriptor for writing.
2678  *
2679  * Returns: the file descriptor used for writing or -1 on error. The file
2680  * descriptor remains valid until the connection is closed.
2681  *
2682  * Since: 0.10.23
2683  */
2684 gint
2685 gst_rtsp_connection_get_writefd (const GstRTSPConnection * conn)
2686 {
2687   g_return_val_if_fail (conn != NULL, -1);
2688   g_return_val_if_fail (conn->writefd != NULL, -1);
2689
2690   return conn->writefd->fd;
2691 }
2692
2693
2694 /**
2695  * gst_rtsp_connection_set_tunneled:
2696  * @conn: a #GstRTSPConnection
2697  * @tunneled: the new state
2698  *
2699  * Set the HTTP tunneling state of the connection. This must be configured before
2700  * the @conn is connected.
2701  *
2702  * Since: 0.10.23
2703  */
2704 void
2705 gst_rtsp_connection_set_tunneled (GstRTSPConnection * conn, gboolean tunneled)
2706 {
2707   g_return_if_fail (conn != NULL);
2708   g_return_if_fail (conn->readfd == NULL);
2709   g_return_if_fail (conn->writefd == NULL);
2710
2711   conn->tunneled = tunneled;
2712 }
2713
2714 /**
2715  * gst_rtsp_connection_is_tunneled:
2716  * @conn: a #GstRTSPConnection
2717  *
2718  * Get the tunneling state of the connection.
2719  *
2720  * Returns: if @conn is using HTTP tunneling.
2721  *
2722  * Since: 0.10.23
2723  */
2724 gboolean
2725 gst_rtsp_connection_is_tunneled (const GstRTSPConnection * conn)
2726 {
2727   g_return_val_if_fail (conn != NULL, FALSE);
2728
2729   return conn->tunneled;
2730 }
2731
2732 /**
2733  * gst_rtsp_connection_get_tunnelid:
2734  * @conn: a #GstRTSPConnection
2735  *
2736  * Get the tunnel session id the connection.
2737  *
2738  * Returns: returns a non-empty string if @conn is being tunneled over HTTP.
2739  *
2740  * Since: 0.10.23
2741  */
2742 const gchar *
2743 gst_rtsp_connection_get_tunnelid (const GstRTSPConnection * conn)
2744 {
2745   g_return_val_if_fail (conn != NULL, NULL);
2746
2747   if (!conn->tunneled)
2748     return NULL;
2749
2750   return conn->tunnelid;
2751 }
2752
2753 /**
2754  * gst_rtsp_connection_do_tunnel:
2755  * @conn: a #GstRTSPConnection
2756  * @conn2: a #GstRTSPConnection
2757  *
2758  * If @conn received the first tunnel connection and @conn2 received
2759  * the second tunnel connection, link the two connections together so that
2760  * @conn manages the tunneled connection.
2761  *
2762  * After this call, @conn2 cannot be used anymore and must be freed with
2763  * gst_rtsp_connection_free().
2764  *
2765  * Returns: return GST_RTSP_OK on success.
2766  *
2767  * Since: 0.10.23
2768  */
2769 GstRTSPResult
2770 gst_rtsp_connection_do_tunnel (GstRTSPConnection * conn,
2771     GstRTSPConnection * conn2)
2772 {
2773   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2774   g_return_val_if_fail (conn2 != NULL, GST_RTSP_EINVAL);
2775   g_return_val_if_fail (conn->tstate == TUNNEL_STATE_GET, GST_RTSP_EINVAL);
2776   g_return_val_if_fail (conn2->tstate == TUNNEL_STATE_POST, GST_RTSP_EINVAL);
2777   g_return_val_if_fail (!memcmp (conn2->tunnelid, conn->tunnelid, TUNNELID_LEN),
2778       GST_RTSP_EINVAL);
2779
2780   /* both connections have fd0 as the read/write socket. start by taking the
2781    * socket from conn2 and set it as the socket in conn */
2782   conn->fd1 = conn2->fd0;
2783
2784   /* clean up some of the state of conn2 */
2785   gst_poll_remove_fd (conn2->fdset, &conn2->fd0);
2786   conn2->fd0.fd = -1;
2787   conn2->readfd = conn2->writefd = NULL;
2788
2789   /* We make fd0 the write socket and fd1 the read socket. */
2790   conn->writefd = &conn->fd0;
2791   conn->readfd = &conn->fd1;
2792
2793   conn->tstate = TUNNEL_STATE_COMPLETE;
2794
2795   /* we need base64 decoding for the readfd */
2796   conn->ctx.state = 0;
2797   conn->ctx.save = 0;
2798   conn->ctx.cout = 0;
2799   conn->ctx.coutl = 0;
2800   conn->ctxp = &conn->ctx;
2801
2802   return GST_RTSP_OK;
2803 }
2804
2805 #define READ_COND   (G_IO_IN | G_IO_HUP | G_IO_ERR)
2806 #define WRITE_COND  (G_IO_OUT | G_IO_ERR)
2807
2808 typedef struct
2809 {
2810   guint8 *data;
2811   guint size;
2812   guint id;
2813 } GstRTSPRec;
2814
2815 /* async functions */
2816 struct _GstRTSPWatch
2817 {
2818   GSource source;
2819
2820   GstRTSPConnection *conn;
2821
2822   GstRTSPBuilder builder;
2823   GstRTSPMessage message;
2824
2825   GPollFD readfd;
2826   GPollFD writefd;
2827   gboolean write_added;
2828
2829   /* queued message for transmission */
2830   guint id;
2831   GAsyncQueue *messages;
2832   guint8 *write_data;
2833   guint write_off;
2834   guint write_size;
2835   guint write_id;
2836
2837   GstRTSPWatchFuncs funcs;
2838
2839   gpointer user_data;
2840   GDestroyNotify notify;
2841 };
2842
2843 static gboolean
2844 gst_rtsp_source_prepare (GSource * source, gint * timeout)
2845 {
2846   GstRTSPWatch *watch = (GstRTSPWatch *) source;
2847
2848   if (watch->conn->initial_buffer != NULL)
2849     return TRUE;
2850
2851   *timeout = (watch->conn->timeout * 1000);
2852
2853   return FALSE;
2854 }
2855
2856 static gboolean
2857 gst_rtsp_source_check (GSource * source)
2858 {
2859   GstRTSPWatch *watch = (GstRTSPWatch *) source;
2860
2861   if (watch->readfd.revents & READ_COND)
2862     return TRUE;
2863
2864   if (watch->writefd.revents & WRITE_COND)
2865     return TRUE;
2866
2867   return FALSE;
2868 }
2869
2870 static gboolean
2871 gst_rtsp_source_dispatch (GSource * source, GSourceFunc callback G_GNUC_UNUSED,
2872     gpointer user_data G_GNUC_UNUSED)
2873 {
2874   GstRTSPWatch *watch = (GstRTSPWatch *) source;
2875   GstRTSPResult res;
2876
2877   /* first read as much as we can */
2878   if (watch->readfd.revents & READ_COND || watch->conn->initial_buffer != NULL) {
2879     do {
2880       res = build_next (&watch->builder, &watch->message, watch->conn);
2881       if (res == GST_RTSP_EINTR)
2882         break;
2883       else if (G_UNLIKELY (res == GST_RTSP_EEOF))
2884         goto eof;
2885       else if (G_LIKELY (res == GST_RTSP_OK)) {
2886         if (watch->message.type == GST_RTSP_MESSAGE_HTTP_REQUEST) {
2887           if (watch->conn->tstate == TUNNEL_STATE_NONE &&
2888               watch->message.type_data.request.method == GST_RTSP_GET) {
2889             GString *str;
2890             GstRTSPStatusCode code;
2891             guint size;
2892
2893             watch->conn->tstate = TUNNEL_STATE_GET;
2894
2895             if (watch->funcs.tunnel_start)
2896               code = watch->funcs.tunnel_start (watch, watch->user_data);
2897             else
2898               code = GST_RTSP_STS_OK;
2899
2900             /* queue the response string */
2901             str = gen_tunnel_reply (watch->conn, code);
2902             size = str->len;
2903             gst_rtsp_watch_queue_data (watch, (guint8 *) g_string_free (str,
2904                     FALSE), size);
2905             goto read_done;
2906           } else if (watch->conn->tstate == TUNNEL_STATE_NONE &&
2907               watch->message.type_data.request.method == GST_RTSP_POST) {
2908             watch->conn->tstate = TUNNEL_STATE_POST;
2909
2910             /* in the callback the connection should be tunneled with the
2911              * GET connection */
2912             if (watch->funcs.tunnel_complete)
2913               watch->funcs.tunnel_complete (watch, watch->user_data);
2914             goto read_done;
2915           } else {
2916             res = GST_RTSP_ERROR;
2917           }
2918         }
2919       }
2920
2921       if (G_LIKELY (res == GST_RTSP_OK)) {
2922         if (watch->funcs.message_received)
2923           watch->funcs.message_received (watch, &watch->message,
2924               watch->user_data);
2925       } else
2926         goto error;
2927
2928     read_done:
2929       gst_rtsp_message_unset (&watch->message);
2930       build_reset (&watch->builder);
2931     } while (FALSE);
2932   }
2933
2934   if (watch->writefd.revents & WRITE_COND) {
2935     do {
2936       if (watch->write_data == NULL) {
2937         GstRTSPRec *rec;
2938
2939         /* get a new message from the queue */
2940         rec = g_async_queue_try_pop (watch->messages);
2941         if (rec == NULL)
2942           goto done;
2943
2944         watch->write_off = 0;
2945         watch->write_data = rec->data;
2946         watch->write_size = rec->size;
2947         watch->write_id = rec->id;
2948
2949         g_slice_free (GstRTSPRec, rec);
2950       }
2951
2952       res = write_bytes (watch->writefd.fd, watch->write_data,
2953           &watch->write_off, watch->write_size);
2954       if (res == GST_RTSP_EINTR)
2955         break;
2956       if (G_UNLIKELY (res != GST_RTSP_OK))
2957         goto error;
2958
2959       if (watch->funcs.message_sent)
2960         watch->funcs.message_sent (watch, watch->write_id, watch->user_data);
2961
2962     done:
2963       if (g_async_queue_length (watch->messages) == 0 && watch->write_added) {
2964         g_source_remove_poll ((GSource *) watch, &watch->writefd);
2965         watch->write_added = FALSE;
2966         watch->writefd.revents = 0;
2967       }
2968       g_free (watch->write_data);
2969       watch->write_data = NULL;
2970     } while (FALSE);
2971   }
2972
2973   return TRUE;
2974
2975   /* ERRORS */
2976 eof:
2977   {
2978     if (watch->funcs.closed)
2979       watch->funcs.closed (watch, watch->user_data);
2980     return FALSE;
2981   }
2982 error:
2983   {
2984     if (watch->funcs.error)
2985       watch->funcs.error (watch, res, watch->user_data);
2986     return FALSE;
2987   }
2988 }
2989
2990 static void
2991 gst_rtsp_rec_free (gpointer data)
2992 {
2993   GstRTSPRec *rec = data;
2994
2995   g_free (rec->data);
2996   g_slice_free (GstRTSPRec, rec);
2997 }
2998
2999 static void
3000 gst_rtsp_source_finalize (GSource * source)
3001 {
3002   GstRTSPWatch *watch = (GstRTSPWatch *) source;
3003
3004   build_reset (&watch->builder);
3005   gst_rtsp_message_unset (&watch->message);
3006
3007   g_async_queue_unref (watch->messages);
3008   watch->messages = NULL;
3009
3010   g_free (watch->write_data);
3011
3012   if (watch->notify)
3013     watch->notify (watch->user_data);
3014 }
3015
3016 static GSourceFuncs gst_rtsp_source_funcs = {
3017   gst_rtsp_source_prepare,
3018   gst_rtsp_source_check,
3019   gst_rtsp_source_dispatch,
3020   gst_rtsp_source_finalize,
3021   NULL,
3022   NULL
3023 };
3024
3025 /**
3026  * gst_rtsp_watch_new:
3027  * @conn: a #GstRTSPConnection
3028  * @funcs: watch functions
3029  * @user_data: user data to pass to @funcs
3030  * @notify: notify when @user_data is not referenced anymore
3031  *
3032  * Create a watch object for @conn. The functions provided in @funcs will be
3033  * called with @user_data when activity happened on the watch.
3034  *
3035  * The new watch is usually created so that it can be attached to a
3036  * maincontext with gst_rtsp_watch_attach().
3037  *
3038  * @conn must exist for the entire lifetime of the watch.
3039  *
3040  * Returns: a #GstRTSPWatch that can be used for asynchronous RTSP
3041  * communication. Free with gst_rtsp_watch_unref () after usage.
3042  *
3043  * Since: 0.10.23
3044  */
3045 GstRTSPWatch *
3046 gst_rtsp_watch_new (GstRTSPConnection * conn,
3047     GstRTSPWatchFuncs * funcs, gpointer user_data, GDestroyNotify notify)
3048 {
3049   GstRTSPWatch *result;
3050
3051   g_return_val_if_fail (conn != NULL, NULL);
3052   g_return_val_if_fail (funcs != NULL, NULL);
3053   g_return_val_if_fail (conn->readfd != NULL, NULL);
3054   g_return_val_if_fail (conn->writefd != NULL, NULL);
3055
3056   result = (GstRTSPWatch *) g_source_new (&gst_rtsp_source_funcs,
3057       sizeof (GstRTSPWatch));
3058
3059   result->conn = conn;
3060   result->builder.state = STATE_START;
3061
3062   result->messages = g_async_queue_new_full (gst_rtsp_rec_free);
3063
3064   result->readfd.fd = -1;
3065   result->writefd.fd = -1;
3066
3067   gst_rtsp_watch_reset (result);
3068
3069   result->funcs = *funcs;
3070   result->user_data = user_data;
3071   result->notify = notify;
3072
3073   /* only add the read fd, the write fd is only added when we have data
3074    * to send. */
3075   g_source_add_poll ((GSource *) result, &result->readfd);
3076
3077   return result;
3078 }
3079
3080 /**
3081  * gst_rtsp_watch_reset:
3082  * @watch: a #GstRTSPWatch
3083  *
3084  * Reset @watch, this is usually called after gst_rtsp_connection_do_tunnel()
3085  * when the file descriptors of the connection might have changed.
3086  *
3087  * Since: 0.10.23
3088  */
3089 void
3090 gst_rtsp_watch_reset (GstRTSPWatch * watch)
3091 {
3092   if (watch->readfd.fd != -1)
3093     g_source_remove_poll ((GSource *) watch, &watch->readfd);
3094   if (watch->writefd.fd != -1)
3095     g_source_remove_poll ((GSource *) watch, &watch->writefd);
3096
3097   watch->readfd.fd = watch->conn->readfd->fd;
3098   watch->readfd.events = READ_COND;
3099   watch->readfd.revents = 0;
3100
3101   watch->writefd.fd = watch->conn->writefd->fd;
3102   watch->writefd.events = WRITE_COND;
3103   watch->writefd.revents = 0;
3104   watch->write_added = FALSE;
3105
3106   g_source_add_poll ((GSource *) watch, &watch->readfd);
3107 }
3108
3109 /**
3110  * gst_rtsp_watch_attach:
3111  * @watch: a #GstRTSPWatch
3112  * @context: a GMainContext (if NULL, the default context will be used)
3113  *
3114  * Adds a #GstRTSPWatch to a context so that it will be executed within that context.
3115  *
3116  * Returns: the ID (greater than 0) for the watch within the GMainContext.
3117  *
3118  * Since: 0.10.23
3119  */
3120 guint
3121 gst_rtsp_watch_attach (GstRTSPWatch * watch, GMainContext * context)
3122 {
3123   g_return_val_if_fail (watch != NULL, 0);
3124
3125   return g_source_attach ((GSource *) watch, context);
3126 }
3127
3128 /**
3129  * gst_rtsp_watch_unref:
3130  * @watch: a #GstRTSPWatch
3131  *
3132  * Decreases the reference count of @watch by one. If the resulting reference
3133  * count is zero the watch and associated memory will be destroyed.
3134  *
3135  * Since: 0.10.23
3136  */
3137 void
3138 gst_rtsp_watch_unref (GstRTSPWatch * watch)
3139 {
3140   g_return_if_fail (watch != NULL);
3141
3142   g_source_unref ((GSource *) watch);
3143 }
3144
3145 /**
3146  * gst_rtsp_watch_queue_data:
3147  * @watch: a #GstRTSPWatch
3148  * @data: the data to queue
3149  * @size: the size of @data
3150  *
3151  * Queue @data for transmission in @watch. It will be transmitted when the
3152  * connection of the @watch becomes writable.
3153  *
3154  * This function will take ownership of @data and g_free() it after use.
3155  *
3156  * The return value of this function will be used as the id argument in the
3157  * message_sent callback.
3158  *
3159  * Returns: an id.
3160  *
3161  * Since: 0.10.24
3162  */
3163 guint
3164 gst_rtsp_watch_queue_data (GstRTSPWatch * watch, const guint8 * data,
3165     guint size)
3166 {
3167   GstRTSPRec *rec;
3168
3169   g_return_val_if_fail (watch != NULL, GST_RTSP_EINVAL);
3170   g_return_val_if_fail (data != NULL, GST_RTSP_EINVAL);
3171   g_return_val_if_fail (size != 0, GST_RTSP_EINVAL);
3172
3173   /* make a record with the data and id */
3174   rec = g_slice_new (GstRTSPRec);
3175   rec->data = (guint8 *) data;
3176   rec->size = size;
3177   do {
3178     /* make sure rec->id is never 0 */
3179     rec->id = ++watch->id;
3180   } while (G_UNLIKELY (rec->id == 0));
3181
3182   /* add the record to a queue. FIXME we would like to have an upper limit here */
3183   g_async_queue_push (watch->messages, rec);
3184
3185   /* FIXME: does the following need to be made thread-safe? (this might be
3186    * called from a streaming thread, like appsink's render function) */
3187   /* make sure the main context will now also check for writability on the
3188    * socket */
3189   if (!watch->write_added) {
3190     g_source_add_poll ((GSource *) watch, &watch->writefd);
3191     watch->write_added = TRUE;
3192   }
3193
3194   return rec->id;
3195 }
3196
3197 /**
3198  * gst_rtsp_watch_queue_message:
3199  * @watch: a #GstRTSPWatch
3200  * @message: a #GstRTSPMessage
3201  *
3202  * Queue a @message for transmission in @watch. The contents of this
3203  * message will be serialized and transmitted when the connection of the
3204  * @watch becomes writable.
3205  *
3206  * The return value of this function will be used as the id argument in the
3207  * message_sent callback.
3208  *
3209  * Returns: an id.
3210  *
3211  * Since: 0.10.23
3212  */
3213 guint
3214 gst_rtsp_watch_queue_message (GstRTSPWatch * watch, GstRTSPMessage * message)
3215 {
3216   GString *str;
3217   guint size;
3218
3219   g_return_val_if_fail (watch != NULL, GST_RTSP_EINVAL);
3220   g_return_val_if_fail (message != NULL, GST_RTSP_EINVAL);
3221
3222   /* make a record with the message as a string and id */
3223   str = message_to_string (watch->conn, message);
3224   size = str->len;
3225   return gst_rtsp_watch_queue_data (watch,
3226       (guint8 *) g_string_free (str, FALSE), size);
3227 }