rtsp: Normalize lines (remove extra whitespace) before parsing.
[platform/upstream/gstreamer.git] / 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 /* convert all consecutive whitespace to a single space */
1710 static void
1711 normalize_line (guint8 * buffer)
1712 {
1713   while (*buffer) {
1714     if (g_ascii_isspace (*buffer)) {
1715       guint8 *tmp;
1716
1717       *buffer++ = ' ';
1718       for (tmp = buffer; g_ascii_isspace (*tmp); tmp++) {
1719       }
1720       if (buffer != tmp)
1721         memmove (buffer, tmp, strlen ((gchar *) tmp) + 1);
1722     } else {
1723       buffer++;
1724     }
1725   }
1726 }
1727
1728 /* returns:
1729  *  GST_RTSP_OK when a complete message was read.
1730  *  GST_RTSP_EEOF: when the socket is closed
1731  *  GST_RTSP_EINTR: when more data is needed.
1732  *  GST_RTSP_..: some other error occured.
1733  */
1734 static GstRTSPResult
1735 build_next (GstRTSPBuilder * builder, GstRTSPMessage * message,
1736     GstRTSPConnection * conn)
1737 {
1738   GstRTSPResult res;
1739
1740   while (TRUE) {
1741     switch (builder->state) {
1742       case STATE_START:
1743         builder->offset = 0;
1744         res =
1745             read_bytes (conn, (guint8 *) builder->buffer, &builder->offset, 1);
1746         if (res != GST_RTSP_OK)
1747           goto done;
1748
1749         /* we have 1 bytes now and we can see if this is a data message or
1750          * not */
1751         if (builder->buffer[0] == '$') {
1752           /* data message, prepare for the header */
1753           builder->state = STATE_DATA_HEADER;
1754         } else {
1755           builder->line = 0;
1756           builder->state = STATE_READ_LINES;
1757         }
1758         break;
1759       case STATE_DATA_HEADER:
1760       {
1761         res =
1762             read_bytes (conn, (guint8 *) builder->buffer, &builder->offset, 4);
1763         if (res != GST_RTSP_OK)
1764           goto done;
1765
1766         gst_rtsp_message_init_data (message, builder->buffer[1]);
1767
1768         builder->body_len = (builder->buffer[2] << 8) | builder->buffer[3];
1769         builder->body_data = g_malloc (builder->body_len + 1);
1770         builder->body_data[builder->body_len] = '\0';
1771         builder->offset = 0;
1772         builder->state = STATE_DATA_BODY;
1773         break;
1774       }
1775       case STATE_DATA_BODY:
1776       {
1777         res =
1778             read_bytes (conn, builder->body_data, &builder->offset,
1779             builder->body_len);
1780         if (res != GST_RTSP_OK)
1781           goto done;
1782
1783         /* we have the complete body now, store in the message adjusting the
1784          * length to include the traling '\0' */
1785         gst_rtsp_message_take_body (message,
1786             (guint8 *) builder->body_data, builder->body_len + 1);
1787         builder->body_data = NULL;
1788         builder->body_len = 0;
1789
1790         builder->state = STATE_END;
1791         break;
1792       }
1793       case STATE_READ_LINES:
1794       {
1795         res = read_line (conn, builder->buffer, &builder->offset,
1796             sizeof (builder->buffer));
1797         if (res != GST_RTSP_OK)
1798           goto done;
1799
1800         /* we have a regular response */
1801         if (builder->buffer[0] == '\r') {
1802           builder->buffer[0] = '\0';
1803         }
1804
1805         if (builder->buffer[0] == '\0') {
1806           gchar *hdrval;
1807
1808           /* empty line, end of message header */
1809           /* see if there is a Content-Length header */
1810           if (gst_rtsp_message_get_header (message,
1811                   GST_RTSP_HDR_CONTENT_LENGTH, &hdrval, 0) == GST_RTSP_OK) {
1812             /* there is, prepare to read the body */
1813             builder->body_len = atol (hdrval);
1814             builder->body_data = g_malloc (builder->body_len + 1);
1815             builder->body_data[builder->body_len] = '\0';
1816             builder->offset = 0;
1817             builder->state = STATE_DATA_BODY;
1818           } else {
1819             builder->state = STATE_END;
1820           }
1821           break;
1822         }
1823
1824         /* we have a line */
1825         normalize_line (builder->buffer);
1826         if (builder->line == 0) {
1827           /* first line, check for response status */
1828           if (memcmp (builder->buffer, "RTSP", 4) == 0 ||
1829               memcmp (builder->buffer, "HTTP", 4) == 0) {
1830             builder->status = parse_response_status (builder->buffer, message);
1831           } else {
1832             builder->status = parse_request_line (builder->buffer, message);
1833           }
1834         } else {
1835           /* else just parse the line */
1836           res = parse_line (builder->buffer, message);
1837           if (res != GST_RTSP_OK)
1838             builder->status = res;
1839         }
1840         builder->line++;
1841         builder->offset = 0;
1842         break;
1843       }
1844       case STATE_END:
1845       {
1846         gchar *session_cookie;
1847         gchar *session_id;
1848
1849         if (message->type == GST_RTSP_MESSAGE_DATA) {
1850           /* data messages don't have headers */
1851           res = GST_RTSP_OK;
1852           goto done;
1853         }
1854
1855         /* save the tunnel session in the connection */
1856         if (message->type == GST_RTSP_MESSAGE_HTTP_REQUEST &&
1857             !conn->manual_http &&
1858             conn->tstate == TUNNEL_STATE_NONE &&
1859             gst_rtsp_message_get_header (message, GST_RTSP_HDR_X_SESSIONCOOKIE,
1860                 &session_cookie, 0) == GST_RTSP_OK) {
1861           strncpy (conn->tunnelid, session_cookie, TUNNELID_LEN);
1862           conn->tunnelid[TUNNELID_LEN - 1] = '\0';
1863           conn->tunneled = TRUE;
1864         }
1865
1866         /* save session id in the connection for further use */
1867         if (message->type == GST_RTSP_MESSAGE_RESPONSE &&
1868             gst_rtsp_message_get_header (message, GST_RTSP_HDR_SESSION,
1869                 &session_id, 0) == GST_RTSP_OK) {
1870           gint maxlen, i;
1871
1872           maxlen = sizeof (conn->session_id) - 1;
1873           /* the sessionid can have attributes marked with ;
1874            * Make sure we strip them */
1875           for (i = 0; session_id[i] != '\0'; i++) {
1876             if (session_id[i] == ';') {
1877               maxlen = i;
1878               /* parse timeout */
1879               do {
1880                 i++;
1881               } while (g_ascii_isspace (session_id[i]));
1882               if (g_str_has_prefix (&session_id[i], "timeout=")) {
1883                 gint to;
1884
1885                 /* if we parsed something valid, configure */
1886                 if ((to = atoi (&session_id[i + 8])) > 0)
1887                   conn->timeout = to;
1888               }
1889               break;
1890             }
1891           }
1892
1893           /* make sure to not overflow */
1894           strncpy (conn->session_id, session_id, maxlen);
1895           conn->session_id[maxlen] = '\0';
1896         }
1897         res = builder->status;
1898         goto done;
1899       }
1900       default:
1901         res = GST_RTSP_ERROR;
1902         break;
1903     }
1904   }
1905 done:
1906   return res;
1907 }
1908
1909 /**
1910  * gst_rtsp_connection_read:
1911  * @conn: a #GstRTSPConnection
1912  * @data: the data to read
1913  * @size: the size of @data
1914  * @timeout: a timeout value or #NULL
1915  *
1916  * Attempt to read @size bytes into @data from the connected @conn, blocking up to
1917  * the specified @timeout. @timeout can be #NULL, in which case this function
1918  * might block forever.
1919  *
1920  * This function can be cancelled with gst_rtsp_connection_flush().
1921  *
1922  * Returns: #GST_RTSP_OK on success.
1923  */
1924 GstRTSPResult
1925 gst_rtsp_connection_read (GstRTSPConnection * conn, guint8 * data, guint size,
1926     GTimeVal * timeout)
1927 {
1928   guint offset;
1929   gint retval;
1930   GstClockTime to;
1931   GstRTSPResult res;
1932
1933   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
1934   g_return_val_if_fail (data != NULL, GST_RTSP_EINVAL);
1935   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
1936
1937   if (G_UNLIKELY (size == 0))
1938     return GST_RTSP_OK;
1939
1940   offset = 0;
1941
1942   /* configure timeout if any */
1943   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
1944
1945   gst_poll_set_controllable (conn->fdset, TRUE);
1946   gst_poll_fd_ctl_write (conn->fdset, conn->writefd, FALSE);
1947   gst_poll_fd_ctl_read (conn->fdset, conn->readfd, TRUE);
1948
1949   while (TRUE) {
1950     res = read_bytes (conn, data, &offset, size);
1951     if (G_UNLIKELY (res == GST_RTSP_EEOF))
1952       goto eof;
1953     if (G_LIKELY (res == GST_RTSP_OK))
1954       break;
1955     if (G_UNLIKELY (res != GST_RTSP_EINTR))
1956       goto read_error;
1957
1958     do {
1959       retval = gst_poll_wait (conn->fdset, to);
1960     } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
1961
1962     /* check for timeout */
1963     if (G_UNLIKELY (retval == 0))
1964       goto select_timeout;
1965
1966     if (G_UNLIKELY (retval == -1)) {
1967       if (errno == EBUSY)
1968         goto stopped;
1969       else
1970         goto select_error;
1971     }
1972     gst_poll_set_controllable (conn->fdset, FALSE);
1973   }
1974   return GST_RTSP_OK;
1975
1976   /* ERRORS */
1977 select_error:
1978   {
1979     return GST_RTSP_ESYS;
1980   }
1981 select_timeout:
1982   {
1983     return GST_RTSP_ETIMEOUT;
1984   }
1985 stopped:
1986   {
1987     return GST_RTSP_EINTR;
1988   }
1989 eof:
1990   {
1991     return GST_RTSP_EEOF;
1992   }
1993 read_error:
1994   {
1995     return res;
1996   }
1997 }
1998
1999 static GString *
2000 gen_tunnel_reply (GstRTSPConnection * conn, GstRTSPStatusCode code)
2001 {
2002   GString *str;
2003   gchar date_string[100];
2004   const gchar *status;
2005
2006   gen_date_string (date_string, sizeof (date_string));
2007
2008   status = gst_rtsp_status_as_text (code);
2009   if (status == NULL) {
2010     code = GST_RTSP_STS_INTERNAL_SERVER_ERROR;
2011     status = "Internal Server Error";
2012   }
2013
2014   str = g_string_new ("");
2015
2016   /* */
2017   g_string_append_printf (str, "HTTP/1.0 %d %s\r\n", code, status);
2018   g_string_append_printf (str,
2019       "Server: GStreamer RTSP Server\r\n"
2020       "Date: %s\r\n"
2021       "Connection: close\r\n"
2022       "Cache-Control: no-store\r\n" "Pragma: no-cache\r\n", date_string);
2023   if (code == GST_RTSP_STS_OK) {
2024     if (conn->ip)
2025       g_string_append_printf (str, "x-server-ip-address: %s\r\n", conn->ip);
2026     g_string_append_printf (str,
2027         "Content-Type: application/x-rtsp-tunnelled\r\n");
2028   }
2029   g_string_append_printf (str, "\r\n");
2030   return str;
2031 }
2032
2033 /**
2034  * gst_rtsp_connection_receive:
2035  * @conn: a #GstRTSPConnection
2036  * @message: the message to read
2037  * @timeout: a timeout value or #NULL
2038  *
2039  * Attempt to read into @message from the connected @conn, blocking up to
2040  * the specified @timeout. @timeout can be #NULL, in which case this function
2041  * might block forever.
2042  * 
2043  * This function can be cancelled with gst_rtsp_connection_flush().
2044  *
2045  * Returns: #GST_RTSP_OK on success.
2046  */
2047 GstRTSPResult
2048 gst_rtsp_connection_receive (GstRTSPConnection * conn, GstRTSPMessage * message,
2049     GTimeVal * timeout)
2050 {
2051   GstRTSPResult res;
2052   GstRTSPBuilder builder;
2053   gint retval;
2054   GstClockTime to;
2055
2056   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2057   g_return_val_if_fail (message != NULL, GST_RTSP_EINVAL);
2058   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
2059
2060   /* configure timeout if any */
2061   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
2062
2063   gst_poll_set_controllable (conn->fdset, TRUE);
2064   gst_poll_fd_ctl_write (conn->fdset, conn->writefd, FALSE);
2065   gst_poll_fd_ctl_read (conn->fdset, conn->readfd, TRUE);
2066
2067   memset (&builder, 0, sizeof (GstRTSPBuilder));
2068   while (TRUE) {
2069     res = build_next (&builder, message, conn);
2070     if (G_UNLIKELY (res == GST_RTSP_EEOF))
2071       goto eof;
2072     else if (G_LIKELY (res == GST_RTSP_OK)) {
2073       if (message->type == GST_RTSP_MESSAGE_HTTP_REQUEST) {
2074         if (conn->tstate == TUNNEL_STATE_NONE &&
2075             message->type_data.request.method == GST_RTSP_GET) {
2076           GString *str;
2077
2078           conn->tstate = TUNNEL_STATE_GET;
2079
2080           /* tunnel GET request, we can reply now */
2081           str = gen_tunnel_reply (conn, GST_RTSP_STS_OK);
2082           res =
2083               gst_rtsp_connection_write (conn, (guint8 *) str->str, str->len,
2084               timeout);
2085           g_string_free (str, TRUE);
2086           res = GST_RTSP_ETGET;
2087           goto cleanup;
2088         } else if (conn->tstate == TUNNEL_STATE_NONE &&
2089             message->type_data.request.method == GST_RTSP_POST) {
2090           conn->tstate = TUNNEL_STATE_POST;
2091
2092           /* tunnel POST request, the caller now has to link the two
2093            * connections. */
2094           res = GST_RTSP_ETPOST;
2095           goto cleanup;
2096         } else {
2097           res = GST_RTSP_EPARSE;
2098           goto cleanup;
2099         }
2100       }
2101
2102       break;
2103     } else if (G_UNLIKELY (res != GST_RTSP_EINTR))
2104       goto read_error;
2105
2106     do {
2107       retval = gst_poll_wait (conn->fdset, to);
2108     } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
2109
2110     /* check for timeout */
2111     if (G_UNLIKELY (retval == 0))
2112       goto select_timeout;
2113
2114     if (G_UNLIKELY (retval == -1)) {
2115       if (errno == EBUSY)
2116         goto stopped;
2117       else
2118         goto select_error;
2119     }
2120     gst_poll_set_controllable (conn->fdset, FALSE);
2121   }
2122
2123   /* we have a message here */
2124   build_reset (&builder);
2125
2126   return GST_RTSP_OK;
2127
2128   /* ERRORS */
2129 select_error:
2130   {
2131     res = GST_RTSP_ESYS;
2132     goto cleanup;
2133   }
2134 select_timeout:
2135   {
2136     res = GST_RTSP_ETIMEOUT;
2137     goto cleanup;
2138   }
2139 stopped:
2140   {
2141     res = GST_RTSP_EINTR;
2142     goto cleanup;
2143   }
2144 eof:
2145   {
2146     res = GST_RTSP_EEOF;
2147     goto cleanup;
2148   }
2149 read_error:
2150 cleanup:
2151   {
2152     build_reset (&builder);
2153     gst_rtsp_message_unset (message);
2154     return res;
2155   }
2156 }
2157
2158 /**
2159  * gst_rtsp_connection_close:
2160  * @conn: a #GstRTSPConnection
2161  *
2162  * Close the connected @conn. After this call, the connection is in the same
2163  * state as when it was first created.
2164  * 
2165  * Returns: #GST_RTSP_OK on success.
2166  */
2167 GstRTSPResult
2168 gst_rtsp_connection_close (GstRTSPConnection * conn)
2169 {
2170   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2171
2172   g_free (conn->ip);
2173   conn->ip = NULL;
2174
2175   g_free (conn->initial_buffer);
2176   conn->initial_buffer = NULL;
2177   conn->initial_buffer_offset = 0;
2178
2179   REMOVE_POLLFD (conn->fdset, &conn->fd0);
2180   REMOVE_POLLFD (conn->fdset, &conn->fd1);
2181   conn->writefd = NULL;
2182   conn->readfd = NULL;
2183   conn->tunneled = FALSE;
2184   conn->tstate = TUNNEL_STATE_NONE;
2185   conn->ctxp = NULL;
2186   g_free (conn->username);
2187   conn->username = NULL;
2188   g_free (conn->passwd);
2189   conn->passwd = NULL;
2190   gst_rtsp_connection_clear_auth_params (conn);
2191   conn->timeout = 60;
2192   conn->cseq = 0;
2193   conn->session_id[0] = '\0';
2194
2195   return GST_RTSP_OK;
2196 }
2197
2198 /**
2199  * gst_rtsp_connection_free:
2200  * @conn: a #GstRTSPConnection
2201  *
2202  * Close and free @conn.
2203  * 
2204  * Returns: #GST_RTSP_OK on success.
2205  */
2206 GstRTSPResult
2207 gst_rtsp_connection_free (GstRTSPConnection * conn)
2208 {
2209   GstRTSPResult res;
2210
2211   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2212
2213   res = gst_rtsp_connection_close (conn);
2214   gst_poll_free (conn->fdset);
2215   g_timer_destroy (conn->timer);
2216   gst_rtsp_url_free (conn->url);
2217   g_free (conn->proxy_host);
2218   g_free (conn);
2219 #ifdef G_OS_WIN32
2220   WSACleanup ();
2221 #endif
2222
2223   return res;
2224 }
2225
2226 /**
2227  * gst_rtsp_connection_poll:
2228  * @conn: a #GstRTSPConnection
2229  * @events: a bitmask of #GstRTSPEvent flags to check
2230  * @revents: location for result flags 
2231  * @timeout: a timeout
2232  *
2233  * Wait up to the specified @timeout for the connection to become available for
2234  * at least one of the operations specified in @events. When the function returns
2235  * with #GST_RTSP_OK, @revents will contain a bitmask of available operations on
2236  * @conn.
2237  *
2238  * @timeout can be #NULL, in which case this function might block forever.
2239  *
2240  * This function can be cancelled with gst_rtsp_connection_flush().
2241  * 
2242  * Returns: #GST_RTSP_OK on success.
2243  *
2244  * Since: 0.10.15
2245  */
2246 GstRTSPResult
2247 gst_rtsp_connection_poll (GstRTSPConnection * conn, GstRTSPEvent events,
2248     GstRTSPEvent * revents, GTimeVal * timeout)
2249 {
2250   GstClockTime to;
2251   gint retval;
2252
2253   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2254   g_return_val_if_fail (events != 0, GST_RTSP_EINVAL);
2255   g_return_val_if_fail (revents != NULL, GST_RTSP_EINVAL);
2256   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
2257   g_return_val_if_fail (conn->writefd != NULL, GST_RTSP_EINVAL);
2258
2259   gst_poll_set_controllable (conn->fdset, TRUE);
2260
2261   /* add fd to writer set when asked to */
2262   gst_poll_fd_ctl_write (conn->fdset, conn->writefd,
2263       events & GST_RTSP_EV_WRITE);
2264
2265   /* add fd to reader set when asked to */
2266   gst_poll_fd_ctl_read (conn->fdset, conn->readfd, events & GST_RTSP_EV_READ);
2267
2268   /* configure timeout if any */
2269   to = timeout ? GST_TIMEVAL_TO_TIME (*timeout) : GST_CLOCK_TIME_NONE;
2270
2271   do {
2272     retval = gst_poll_wait (conn->fdset, to);
2273   } while (retval == -1 && (errno == EINTR || errno == EAGAIN));
2274
2275   if (G_UNLIKELY (retval == 0))
2276     goto select_timeout;
2277
2278   if (G_UNLIKELY (retval == -1)) {
2279     if (errno == EBUSY)
2280       goto stopped;
2281     else
2282       goto select_error;
2283   }
2284
2285   *revents = 0;
2286   if (events & GST_RTSP_EV_READ) {
2287     if (gst_poll_fd_can_read (conn->fdset, conn->readfd))
2288       *revents |= GST_RTSP_EV_READ;
2289   }
2290   if (events & GST_RTSP_EV_WRITE) {
2291     if (gst_poll_fd_can_write (conn->fdset, conn->writefd))
2292       *revents |= GST_RTSP_EV_WRITE;
2293   }
2294   return GST_RTSP_OK;
2295
2296   /* ERRORS */
2297 select_timeout:
2298   {
2299     return GST_RTSP_ETIMEOUT;
2300   }
2301 select_error:
2302   {
2303     return GST_RTSP_ESYS;
2304   }
2305 stopped:
2306   {
2307     return GST_RTSP_EINTR;
2308   }
2309 }
2310
2311 /**
2312  * gst_rtsp_connection_next_timeout:
2313  * @conn: a #GstRTSPConnection
2314  * @timeout: a timeout
2315  *
2316  * Calculate the next timeout for @conn, storing the result in @timeout.
2317  * 
2318  * Returns: #GST_RTSP_OK.
2319  */
2320 GstRTSPResult
2321 gst_rtsp_connection_next_timeout (GstRTSPConnection * conn, GTimeVal * timeout)
2322 {
2323   gdouble elapsed;
2324   glong sec;
2325   gulong usec;
2326
2327   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2328   g_return_val_if_fail (timeout != NULL, GST_RTSP_EINVAL);
2329
2330   elapsed = g_timer_elapsed (conn->timer, &usec);
2331   if (elapsed >= conn->timeout) {
2332     sec = 0;
2333     usec = 0;
2334   } else {
2335     sec = conn->timeout - elapsed;
2336   }
2337
2338   timeout->tv_sec = sec;
2339   timeout->tv_usec = usec;
2340
2341   return GST_RTSP_OK;
2342 }
2343
2344 /**
2345  * gst_rtsp_connection_reset_timeout:
2346  * @conn: a #GstRTSPConnection
2347  *
2348  * Reset the timeout of @conn.
2349  * 
2350  * Returns: #GST_RTSP_OK.
2351  */
2352 GstRTSPResult
2353 gst_rtsp_connection_reset_timeout (GstRTSPConnection * conn)
2354 {
2355   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2356
2357   g_timer_start (conn->timer);
2358
2359   return GST_RTSP_OK;
2360 }
2361
2362 /**
2363  * gst_rtsp_connection_flush:
2364  * @conn: a #GstRTSPConnection
2365  * @flush: start or stop the flush
2366  *
2367  * Start or stop the flushing action on @conn. When flushing, all current
2368  * and future actions on @conn will return #GST_RTSP_EINTR until the connection
2369  * is set to non-flushing mode again.
2370  * 
2371  * Returns: #GST_RTSP_OK.
2372  */
2373 GstRTSPResult
2374 gst_rtsp_connection_flush (GstRTSPConnection * conn, gboolean flush)
2375 {
2376   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2377
2378   gst_poll_set_flushing (conn->fdset, flush);
2379
2380   return GST_RTSP_OK;
2381 }
2382
2383 /**
2384  * gst_rtsp_connection_set_proxy:
2385  * @conn: a #GstRTSPConnection
2386  * @host: the proxy host
2387  * @port: the proxy port
2388  *
2389  * Set the proxy host and port.
2390  * 
2391  * Returns: #GST_RTSP_OK.
2392  *
2393  * Since: 0.10.23
2394  */
2395 GstRTSPResult
2396 gst_rtsp_connection_set_proxy (GstRTSPConnection * conn,
2397     const gchar * host, guint port)
2398 {
2399   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2400
2401   g_free (conn->proxy_host);
2402   conn->proxy_host = g_strdup (host);
2403   conn->proxy_port = port;
2404
2405   return GST_RTSP_OK;
2406 }
2407
2408 /**
2409  * gst_rtsp_connection_set_auth:
2410  * @conn: a #GstRTSPConnection
2411  * @method: authentication method
2412  * @user: the user
2413  * @pass: the password
2414  *
2415  * Configure @conn for authentication mode @method with @user and @pass as the
2416  * user and password respectively.
2417  * 
2418  * Returns: #GST_RTSP_OK.
2419  */
2420 GstRTSPResult
2421 gst_rtsp_connection_set_auth (GstRTSPConnection * conn,
2422     GstRTSPAuthMethod method, const gchar * user, const gchar * pass)
2423 {
2424   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2425
2426   if (method == GST_RTSP_AUTH_DIGEST && ((user == NULL || pass == NULL)
2427           || g_strrstr (user, ":") != NULL))
2428     return GST_RTSP_EINVAL;
2429
2430   /* Make sure the username and passwd are being set for authentication */
2431   if (method == GST_RTSP_AUTH_NONE && (user == NULL || pass == NULL))
2432     return GST_RTSP_EINVAL;
2433
2434   /* ":" chars are not allowed in usernames for basic auth */
2435   if (method == GST_RTSP_AUTH_BASIC && g_strrstr (user, ":") != NULL)
2436     return GST_RTSP_EINVAL;
2437
2438   g_free (conn->username);
2439   g_free (conn->passwd);
2440
2441   conn->auth_method = method;
2442   conn->username = g_strdup (user);
2443   conn->passwd = g_strdup (pass);
2444
2445   return GST_RTSP_OK;
2446 }
2447
2448 /**
2449  * str_case_hash:
2450  * @key: ASCII string to hash
2451  *
2452  * Hashes @key in a case-insensitive manner.
2453  *
2454  * Returns: the hash code.
2455  **/
2456 static guint
2457 str_case_hash (gconstpointer key)
2458 {
2459   const char *p = key;
2460   guint h = g_ascii_toupper (*p);
2461
2462   if (h)
2463     for (p += 1; *p != '\0'; p++)
2464       h = (h << 5) - h + g_ascii_toupper (*p);
2465
2466   return h;
2467 }
2468
2469 /**
2470  * str_case_equal:
2471  * @v1: an ASCII string
2472  * @v2: another ASCII string
2473  *
2474  * Compares @v1 and @v2 in a case-insensitive manner
2475  *
2476  * Returns: %TRUE if they are equal (modulo case)
2477  **/
2478 static gboolean
2479 str_case_equal (gconstpointer v1, gconstpointer v2)
2480 {
2481   const char *string1 = v1;
2482   const char *string2 = v2;
2483
2484   return g_ascii_strcasecmp (string1, string2) == 0;
2485 }
2486
2487 /**
2488  * gst_rtsp_connection_set_auth_param:
2489  * @conn: a #GstRTSPConnection
2490  * @param: authentication directive
2491  * @value: value
2492  *
2493  * Setup @conn with authentication directives. This is not necesary for
2494  * methods #GST_RTSP_AUTH_NONE and #GST_RTSP_AUTH_BASIC. For
2495  * #GST_RTSP_AUTH_DIGEST, directives should be taken from the digest challenge
2496  * in the WWW-Authenticate response header and can include realm, domain,
2497  * nonce, opaque, stale, algorithm, qop as per RFC2617.
2498  * 
2499  * Since: 0.10.20
2500  */
2501 void
2502 gst_rtsp_connection_set_auth_param (GstRTSPConnection * conn,
2503     const gchar * param, const gchar * value)
2504 {
2505   g_return_if_fail (conn != NULL);
2506   g_return_if_fail (param != NULL);
2507
2508   if (conn->auth_params == NULL) {
2509     conn->auth_params =
2510         g_hash_table_new_full (str_case_hash, str_case_equal, g_free, g_free);
2511   }
2512   g_hash_table_insert (conn->auth_params, g_strdup (param), g_strdup (value));
2513 }
2514
2515 /**
2516  * gst_rtsp_connection_clear_auth_params:
2517  * @conn: a #GstRTSPConnection
2518  *
2519  * Clear the list of authentication directives stored in @conn.
2520  *
2521  * Since: 0.10.20
2522  */
2523 void
2524 gst_rtsp_connection_clear_auth_params (GstRTSPConnection * conn)
2525 {
2526   g_return_if_fail (conn != NULL);
2527
2528   if (conn->auth_params != NULL) {
2529     g_hash_table_destroy (conn->auth_params);
2530     conn->auth_params = NULL;
2531   }
2532 }
2533
2534 static GstRTSPResult
2535 set_qos_dscp (gint fd, guint qos_dscp)
2536 {
2537   union gst_sockaddr sa;
2538   socklen_t slen = sizeof (sa);
2539   gint af;
2540   gint tos;
2541
2542   if (fd == -1)
2543     return GST_RTSP_OK;
2544
2545   if (getsockname (fd, &sa.sa, &slen) < 0)
2546     goto no_getsockname;
2547
2548   af = sa.sa.sa_family;
2549
2550   /* if this is an IPv4-mapped address then do IPv4 QoS */
2551   if (af == AF_INET6) {
2552     if (IN6_IS_ADDR_V4MAPPED (&sa.sa_in6.sin6_addr))
2553       af = AF_INET;
2554   }
2555
2556   /* extract and shift 6 bits of the DSCP */
2557   tos = (qos_dscp & 0x3f) << 2;
2558
2559   switch (af) {
2560     case AF_INET:
2561       if (SETSOCKOPT (fd, IPPROTO_IP, IP_TOS, &tos, sizeof (tos)) < 0)
2562         goto no_setsockopt;
2563       break;
2564     case AF_INET6:
2565 #ifdef IPV6_TCLASS
2566       if (SETSOCKOPT (fd, IPPROTO_IPV6, IPV6_TCLASS, &tos, sizeof (tos)) < 0)
2567         goto no_setsockopt;
2568       break;
2569 #endif
2570     default:
2571       goto wrong_family;
2572   }
2573
2574   return GST_RTSP_OK;
2575
2576   /* ERRORS */
2577 no_getsockname:
2578 no_setsockopt:
2579   {
2580     return GST_RTSP_ESYS;
2581   }
2582
2583 wrong_family:
2584   {
2585     return GST_RTSP_ERROR;
2586   }
2587 }
2588
2589 /**
2590  * gst_rtsp_connection_set_qos_dscp:
2591  * @conn: a #GstRTSPConnection
2592  * @qos_dscp: DSCP value
2593  *
2594  * Configure @conn to use the specified DSCP value.
2595  *
2596  * Returns: #GST_RTSP_OK on success.
2597  *
2598  * Since: 0.10.20
2599  */
2600 GstRTSPResult
2601 gst_rtsp_connection_set_qos_dscp (GstRTSPConnection * conn, guint qos_dscp)
2602 {
2603   GstRTSPResult res;
2604
2605   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2606   g_return_val_if_fail (conn->readfd != NULL, GST_RTSP_EINVAL);
2607   g_return_val_if_fail (conn->writefd != NULL, GST_RTSP_EINVAL);
2608
2609   res = set_qos_dscp (conn->fd0.fd, qos_dscp);
2610   if (res == GST_RTSP_OK)
2611     res = set_qos_dscp (conn->fd1.fd, qos_dscp);
2612
2613   return res;
2614 }
2615
2616
2617 /**
2618  * gst_rtsp_connection_get_url:
2619  * @conn: a #GstRTSPConnection
2620  *
2621  * Retrieve the URL of the other end of @conn.
2622  *
2623  * Returns: The URL. This value remains valid until the
2624  * connection is freed.
2625  *
2626  * Since: 0.10.23
2627  */
2628 GstRTSPUrl *
2629 gst_rtsp_connection_get_url (const GstRTSPConnection * conn)
2630 {
2631   g_return_val_if_fail (conn != NULL, NULL);
2632
2633   return conn->url;
2634 }
2635
2636 /**
2637  * gst_rtsp_connection_get_ip:
2638  * @conn: a #GstRTSPConnection
2639  *
2640  * Retrieve the IP address of the other end of @conn.
2641  *
2642  * Returns: The IP address as a string. this value remains valid until the
2643  * connection is closed.
2644  *
2645  * Since: 0.10.20
2646  */
2647 const gchar *
2648 gst_rtsp_connection_get_ip (const GstRTSPConnection * conn)
2649 {
2650   g_return_val_if_fail (conn != NULL, NULL);
2651
2652   return conn->ip;
2653 }
2654
2655 /**
2656  * gst_rtsp_connection_set_ip:
2657  * @conn: a #GstRTSPConnection
2658  * @ip: an ip address
2659  *
2660  * Set the IP address of the server.
2661  *
2662  * Since: 0.10.23
2663  */
2664 void
2665 gst_rtsp_connection_set_ip (GstRTSPConnection * conn, const gchar * ip)
2666 {
2667   g_return_if_fail (conn != NULL);
2668
2669   g_free (conn->ip);
2670   conn->ip = g_strdup (ip);
2671 }
2672
2673 /**
2674  * gst_rtsp_connection_get_readfd:
2675  * @conn: a #GstRTSPConnection
2676  *
2677  * Get the file descriptor for reading.
2678  *
2679  * Returns: the file descriptor used for reading 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_readfd (const GstRTSPConnection * conn)
2686 {
2687   g_return_val_if_fail (conn != NULL, -1);
2688   g_return_val_if_fail (conn->readfd != NULL, -1);
2689
2690   return conn->readfd->fd;
2691 }
2692
2693 /**
2694  * gst_rtsp_connection_get_writefd:
2695  * @conn: a #GstRTSPConnection
2696  *
2697  * Get the file descriptor for writing.
2698  *
2699  * Returns: the file descriptor used for writing or -1 on error. The file
2700  * descriptor remains valid until the connection is closed.
2701  *
2702  * Since: 0.10.23
2703  */
2704 gint
2705 gst_rtsp_connection_get_writefd (const GstRTSPConnection * conn)
2706 {
2707   g_return_val_if_fail (conn != NULL, -1);
2708   g_return_val_if_fail (conn->writefd != NULL, -1);
2709
2710   return conn->writefd->fd;
2711 }
2712
2713
2714 /**
2715  * gst_rtsp_connection_set_tunneled:
2716  * @conn: a #GstRTSPConnection
2717  * @tunneled: the new state
2718  *
2719  * Set the HTTP tunneling state of the connection. This must be configured before
2720  * the @conn is connected.
2721  *
2722  * Since: 0.10.23
2723  */
2724 void
2725 gst_rtsp_connection_set_tunneled (GstRTSPConnection * conn, gboolean tunneled)
2726 {
2727   g_return_if_fail (conn != NULL);
2728   g_return_if_fail (conn->readfd == NULL);
2729   g_return_if_fail (conn->writefd == NULL);
2730
2731   conn->tunneled = tunneled;
2732 }
2733
2734 /**
2735  * gst_rtsp_connection_is_tunneled:
2736  * @conn: a #GstRTSPConnection
2737  *
2738  * Get the tunneling state of the connection. 
2739  *
2740  * Returns: if @conn is using HTTP tunneling.
2741  *
2742  * Since: 0.10.23
2743  */
2744 gboolean
2745 gst_rtsp_connection_is_tunneled (const GstRTSPConnection * conn)
2746 {
2747   g_return_val_if_fail (conn != NULL, FALSE);
2748
2749   return conn->tunneled;
2750 }
2751
2752 /**
2753  * gst_rtsp_connection_get_tunnelid:
2754  * @conn: a #GstRTSPConnection
2755  *
2756  * Get the tunnel session id the connection. 
2757  *
2758  * Returns: returns a non-empty string if @conn is being tunneled over HTTP.
2759  *
2760  * Since: 0.10.23
2761  */
2762 const gchar *
2763 gst_rtsp_connection_get_tunnelid (const GstRTSPConnection * conn)
2764 {
2765   g_return_val_if_fail (conn != NULL, NULL);
2766
2767   if (!conn->tunneled)
2768     return NULL;
2769
2770   return conn->tunnelid;
2771 }
2772
2773 /**
2774  * gst_rtsp_connection_do_tunnel:
2775  * @conn: a #GstRTSPConnection
2776  * @conn2: a #GstRTSPConnection
2777  *
2778  * If @conn received the first tunnel connection and @conn2 received
2779  * the second tunnel connection, link the two connections together so that
2780  * @conn manages the tunneled connection.
2781  *
2782  * After this call, @conn2 cannot be used anymore and must be freed with
2783  * gst_rtsp_connection_free().
2784  *
2785  * Returns: return GST_RTSP_OK on success.
2786  *
2787  * Since: 0.10.23
2788  */
2789 GstRTSPResult
2790 gst_rtsp_connection_do_tunnel (GstRTSPConnection * conn,
2791     GstRTSPConnection * conn2)
2792 {
2793   g_return_val_if_fail (conn != NULL, GST_RTSP_EINVAL);
2794   g_return_val_if_fail (conn2 != NULL, GST_RTSP_EINVAL);
2795   g_return_val_if_fail (conn->tstate == TUNNEL_STATE_GET, GST_RTSP_EINVAL);
2796   g_return_val_if_fail (conn2->tstate == TUNNEL_STATE_POST, GST_RTSP_EINVAL);
2797   g_return_val_if_fail (!memcmp (conn2->tunnelid, conn->tunnelid, TUNNELID_LEN),
2798       GST_RTSP_EINVAL);
2799
2800   /* both connections have fd0 as the read/write socket. start by taking the
2801    * socket from conn2 and set it as the socket in conn */
2802   conn->fd1 = conn2->fd0;
2803
2804   /* clean up some of the state of conn2 */
2805   gst_poll_remove_fd (conn2->fdset, &conn2->fd0);
2806   conn2->fd0.fd = -1;
2807   conn2->readfd = conn2->writefd = NULL;
2808
2809   /* We make fd0 the write socket and fd1 the read socket. */
2810   conn->writefd = &conn->fd0;
2811   conn->readfd = &conn->fd1;
2812
2813   conn->tstate = TUNNEL_STATE_COMPLETE;
2814
2815   /* we need base64 decoding for the readfd */
2816   conn->ctx.state = 0;
2817   conn->ctx.save = 0;
2818   conn->ctx.cout = 0;
2819   conn->ctx.coutl = 0;
2820   conn->ctxp = &conn->ctx;
2821
2822   return GST_RTSP_OK;
2823 }
2824
2825 #define READ_COND   (G_IO_IN | G_IO_HUP | G_IO_ERR)
2826 #define WRITE_COND  (G_IO_OUT | G_IO_ERR)
2827
2828 typedef struct
2829 {
2830   guint8 *data;
2831   guint size;
2832   guint id;
2833 } GstRTSPRec;
2834
2835 /* async functions */
2836 struct _GstRTSPWatch
2837 {
2838   GSource source;
2839
2840   GstRTSPConnection *conn;
2841
2842   GstRTSPBuilder builder;
2843   GstRTSPMessage message;
2844
2845   GPollFD readfd;
2846   GPollFD writefd;
2847   gboolean write_added;
2848
2849   /* queued message for transmission */
2850   guint id;
2851   GAsyncQueue *messages;
2852   guint8 *write_data;
2853   guint write_off;
2854   guint write_size;
2855   guint write_id;
2856
2857   GstRTSPWatchFuncs funcs;
2858
2859   gpointer user_data;
2860   GDestroyNotify notify;
2861 };
2862
2863 static gboolean
2864 gst_rtsp_source_prepare (GSource * source, gint * timeout)
2865 {
2866   GstRTSPWatch *watch = (GstRTSPWatch *) source;
2867
2868   if (watch->conn->initial_buffer != NULL)
2869     return TRUE;
2870
2871   *timeout = (watch->conn->timeout * 1000);
2872
2873   return FALSE;
2874 }
2875
2876 static gboolean
2877 gst_rtsp_source_check (GSource * source)
2878 {
2879   GstRTSPWatch *watch = (GstRTSPWatch *) source;
2880
2881   if (watch->readfd.revents & READ_COND)
2882     return TRUE;
2883
2884   if (watch->writefd.revents & WRITE_COND)
2885     return TRUE;
2886
2887   return FALSE;
2888 }
2889
2890 static gboolean
2891 gst_rtsp_source_dispatch (GSource * source, GSourceFunc callback G_GNUC_UNUSED,
2892     gpointer user_data G_GNUC_UNUSED)
2893 {
2894   GstRTSPWatch *watch = (GstRTSPWatch *) source;
2895   GstRTSPResult res;
2896
2897   /* first read as much as we can */
2898   if (watch->readfd.revents & READ_COND || watch->conn->initial_buffer != NULL) {
2899     do {
2900       res = build_next (&watch->builder, &watch->message, watch->conn);
2901       if (res == GST_RTSP_EINTR)
2902         break;
2903       else if (G_UNLIKELY (res == GST_RTSP_EEOF))
2904         goto eof;
2905       else if (G_LIKELY (res == GST_RTSP_OK)) {
2906         if (watch->message.type == GST_RTSP_MESSAGE_HTTP_REQUEST) {
2907           if (watch->conn->tstate == TUNNEL_STATE_NONE &&
2908               watch->message.type_data.request.method == GST_RTSP_GET) {
2909             GString *str;
2910             GstRTSPStatusCode code;
2911             guint size;
2912
2913             watch->conn->tstate = TUNNEL_STATE_GET;
2914
2915             if (watch->funcs.tunnel_start)
2916               code = watch->funcs.tunnel_start (watch, watch->user_data);
2917             else
2918               code = GST_RTSP_STS_OK;
2919
2920             /* queue the response string */
2921             str = gen_tunnel_reply (watch->conn, code);
2922             size = str->len;
2923             gst_rtsp_watch_queue_data (watch, (guint8 *) g_string_free (str,
2924                     FALSE), size);
2925             goto read_done;
2926           } else if (watch->conn->tstate == TUNNEL_STATE_NONE &&
2927               watch->message.type_data.request.method == GST_RTSP_POST) {
2928             watch->conn->tstate = TUNNEL_STATE_POST;
2929
2930             /* in the callback the connection should be tunneled with the
2931              * GET connection */
2932             if (watch->funcs.tunnel_complete)
2933               watch->funcs.tunnel_complete (watch, watch->user_data);
2934             goto read_done;
2935           } else {
2936             res = GST_RTSP_ERROR;
2937           }
2938         }
2939       }
2940
2941       if (G_LIKELY (res == GST_RTSP_OK)) {
2942         if (watch->funcs.message_received)
2943           watch->funcs.message_received (watch, &watch->message,
2944               watch->user_data);
2945       } else
2946         goto error;
2947
2948     read_done:
2949       gst_rtsp_message_unset (&watch->message);
2950       build_reset (&watch->builder);
2951     } while (FALSE);
2952   }
2953
2954   if (watch->writefd.revents & WRITE_COND) {
2955     do {
2956       if (watch->write_data == NULL) {
2957         GstRTSPRec *rec;
2958
2959         /* get a new message from the queue */
2960         rec = g_async_queue_try_pop (watch->messages);
2961         if (rec == NULL)
2962           goto done;
2963
2964         watch->write_off = 0;
2965         watch->write_data = rec->data;
2966         watch->write_size = rec->size;
2967         watch->write_id = rec->id;
2968
2969         g_slice_free (GstRTSPRec, rec);
2970       }
2971
2972       res = write_bytes (watch->writefd.fd, watch->write_data,
2973           &watch->write_off, watch->write_size);
2974       if (res == GST_RTSP_EINTR)
2975         break;
2976       if (G_UNLIKELY (res != GST_RTSP_OK))
2977         goto error;
2978
2979       if (watch->funcs.message_sent)
2980         watch->funcs.message_sent (watch, watch->write_id, watch->user_data);
2981
2982     done:
2983       if (g_async_queue_length (watch->messages) == 0 && watch->write_added) {
2984         g_source_remove_poll ((GSource *) watch, &watch->writefd);
2985         watch->write_added = FALSE;
2986         watch->writefd.revents = 0;
2987       }
2988       g_free (watch->write_data);
2989       watch->write_data = NULL;
2990     } while (FALSE);
2991   }
2992
2993   return TRUE;
2994
2995   /* ERRORS */
2996 eof:
2997   {
2998     if (watch->funcs.closed)
2999       watch->funcs.closed (watch, watch->user_data);
3000     return FALSE;
3001   }
3002 error:
3003   {
3004     if (watch->funcs.error)
3005       watch->funcs.error (watch, res, watch->user_data);
3006     return FALSE;
3007   }
3008 }
3009
3010 static void
3011 gst_rtsp_rec_free (gpointer data)
3012 {
3013   GstRTSPRec *rec = data;
3014
3015   g_free (rec->data);
3016   g_slice_free (GstRTSPRec, rec);
3017 }
3018
3019 static void
3020 gst_rtsp_source_finalize (GSource * source)
3021 {
3022   GstRTSPWatch *watch = (GstRTSPWatch *) source;
3023
3024   build_reset (&watch->builder);
3025   gst_rtsp_message_unset (&watch->message);
3026
3027   g_async_queue_unref (watch->messages);
3028   watch->messages = NULL;
3029
3030   g_free (watch->write_data);
3031
3032   if (watch->notify)
3033     watch->notify (watch->user_data);
3034 }
3035
3036 static GSourceFuncs gst_rtsp_source_funcs = {
3037   gst_rtsp_source_prepare,
3038   gst_rtsp_source_check,
3039   gst_rtsp_source_dispatch,
3040   gst_rtsp_source_finalize,
3041   NULL,
3042   NULL
3043 };
3044
3045 /**
3046  * gst_rtsp_watch_new:
3047  * @conn: a #GstRTSPConnection
3048  * @funcs: watch functions
3049  * @user_data: user data to pass to @funcs
3050  * @notify: notify when @user_data is not referenced anymore
3051  *
3052  * Create a watch object for @conn. The functions provided in @funcs will be
3053  * called with @user_data when activity happened on the watch.
3054  *
3055  * The new watch is usually created so that it can be attached to a
3056  * maincontext with gst_rtsp_watch_attach(). 
3057  *
3058  * @conn must exist for the entire lifetime of the watch.
3059  *
3060  * Returns: a #GstRTSPWatch that can be used for asynchronous RTSP
3061  * communication. Free with gst_rtsp_watch_unref () after usage.
3062  *
3063  * Since: 0.10.23
3064  */
3065 GstRTSPWatch *
3066 gst_rtsp_watch_new (GstRTSPConnection * conn,
3067     GstRTSPWatchFuncs * funcs, gpointer user_data, GDestroyNotify notify)
3068 {
3069   GstRTSPWatch *result;
3070
3071   g_return_val_if_fail (conn != NULL, NULL);
3072   g_return_val_if_fail (funcs != NULL, NULL);
3073   g_return_val_if_fail (conn->readfd != NULL, NULL);
3074   g_return_val_if_fail (conn->writefd != NULL, NULL);
3075
3076   result = (GstRTSPWatch *) g_source_new (&gst_rtsp_source_funcs,
3077       sizeof (GstRTSPWatch));
3078
3079   result->conn = conn;
3080   result->builder.state = STATE_START;
3081
3082   result->messages = g_async_queue_new_full (gst_rtsp_rec_free);
3083
3084   result->readfd.fd = -1;
3085   result->writefd.fd = -1;
3086
3087   gst_rtsp_watch_reset (result);
3088
3089   result->funcs = *funcs;
3090   result->user_data = user_data;
3091   result->notify = notify;
3092
3093   /* only add the read fd, the write fd is only added when we have data
3094    * to send. */
3095   g_source_add_poll ((GSource *) result, &result->readfd);
3096
3097   return result;
3098 }
3099
3100 /**
3101  * gst_rtsp_watch_reset:
3102  * @watch: a #GstRTSPWatch
3103  *
3104  * Reset @watch, this is usually called after gst_rtsp_connection_do_tunnel()
3105  * when the file descriptors of the connection might have changed.
3106  *
3107  * Since: 0.10.23
3108  */
3109 void
3110 gst_rtsp_watch_reset (GstRTSPWatch * watch)
3111 {
3112   if (watch->readfd.fd != -1)
3113     g_source_remove_poll ((GSource *) watch, &watch->readfd);
3114   if (watch->writefd.fd != -1)
3115     g_source_remove_poll ((GSource *) watch, &watch->writefd);
3116
3117   watch->readfd.fd = watch->conn->readfd->fd;
3118   watch->readfd.events = READ_COND;
3119   watch->readfd.revents = 0;
3120
3121   watch->writefd.fd = watch->conn->writefd->fd;
3122   watch->writefd.events = WRITE_COND;
3123   watch->writefd.revents = 0;
3124   watch->write_added = FALSE;
3125
3126   g_source_add_poll ((GSource *) watch, &watch->readfd);
3127 }
3128
3129 /**
3130  * gst_rtsp_watch_attach:
3131  * @watch: a #GstRTSPWatch
3132  * @context: a GMainContext (if NULL, the default context will be used)
3133  *
3134  * Adds a #GstRTSPWatch to a context so that it will be executed within that context.
3135  *
3136  * Returns: the ID (greater than 0) for the watch within the GMainContext. 
3137  *
3138  * Since: 0.10.23
3139  */
3140 guint
3141 gst_rtsp_watch_attach (GstRTSPWatch * watch, GMainContext * context)
3142 {
3143   g_return_val_if_fail (watch != NULL, 0);
3144
3145   return g_source_attach ((GSource *) watch, context);
3146 }
3147
3148 /**
3149  * gst_rtsp_watch_unref:
3150  * @watch: a #GstRTSPWatch
3151  *
3152  * Decreases the reference count of @watch by one. If the resulting reference
3153  * count is zero the watch and associated memory will be destroyed.
3154  *
3155  * Since: 0.10.23
3156  */
3157 void
3158 gst_rtsp_watch_unref (GstRTSPWatch * watch)
3159 {
3160   g_return_if_fail (watch != NULL);
3161
3162   g_source_unref ((GSource *) watch);
3163 }
3164
3165 /**
3166  * gst_rtsp_watch_queue_data:
3167  * @watch: a #GstRTSPWatch
3168  * @data: the data to queue
3169  * @size: the size of @data
3170  *
3171  * Queue @data for transmission in @watch. It will be transmitted when the
3172  * connection of the @watch becomes writable.
3173  *
3174  * This function will take ownership of @data and g_free() it after use.
3175  *
3176  * The return value of this function will be used as the id argument in the
3177  * message_sent callback.
3178  *
3179  * Returns: an id.
3180  *
3181  * Since: 0.10.24
3182  */
3183 guint
3184 gst_rtsp_watch_queue_data (GstRTSPWatch * watch, const guint8 * data,
3185     guint size)
3186 {
3187   GstRTSPRec *rec;
3188
3189   g_return_val_if_fail (watch != NULL, GST_RTSP_EINVAL);
3190   g_return_val_if_fail (data != NULL, GST_RTSP_EINVAL);
3191   g_return_val_if_fail (size != 0, GST_RTSP_EINVAL);
3192
3193   /* make a record with the data and id */
3194   rec = g_slice_new (GstRTSPRec);
3195   rec->data = (guint8 *) data;
3196   rec->size = size;
3197   do {
3198     /* make sure rec->id is never 0 */
3199     rec->id = ++watch->id;
3200   } while (G_UNLIKELY (rec->id == 0));
3201
3202   /* add the record to a queue. FIXME we would like to have an upper limit here */
3203   g_async_queue_push (watch->messages, rec);
3204
3205   /* FIXME: does the following need to be made thread-safe? (this might be
3206    * called from a streaming thread, like appsink's render function) */
3207   /* make sure the main context will now also check for writability on the
3208    * socket */
3209   if (!watch->write_added) {
3210     g_source_add_poll ((GSource *) watch, &watch->writefd);
3211     watch->write_added = TRUE;
3212   }
3213
3214   return rec->id;
3215 }
3216
3217 /**
3218  * gst_rtsp_watch_queue_message:
3219  * @watch: a #GstRTSPWatch
3220  * @message: a #GstRTSPMessage
3221  *
3222  * Queue a @message for transmission in @watch. The contents of this
3223  * message will be serialized and transmitted when the connection of the
3224  * @watch becomes writable.
3225  *
3226  * The return value of this function will be used as the id argument in the
3227  * message_sent callback.
3228  *
3229  * Returns: an id.
3230  *
3231  * Since: 0.10.23
3232  */
3233 guint
3234 gst_rtsp_watch_queue_message (GstRTSPWatch * watch, GstRTSPMessage * message)
3235 {
3236   GString *str;
3237   guint size;
3238
3239   g_return_val_if_fail (watch != NULL, GST_RTSP_EINVAL);
3240   g_return_val_if_fail (message != NULL, GST_RTSP_EINVAL);
3241
3242   /* make a record with the message as a string and id */
3243   str = message_to_string (watch->conn, message);
3244   size = str->len;
3245   return gst_rtsp_watch_queue_data (watch,
3246       (guint8 *) g_string_free (str, FALSE), size);
3247 }