rtsp.c: converted to C

Trimmed the newlines to be LF-only. Converted the source to plain C, to
use curl style indents, to compile warning-free with picky options and
fixed the minor fprintf() bug on line 245. Added to makefile.

1 files changed, 271 insertions, 253 deletions

diff --git a/docs/examples/rtsp.c b/docs/examples/rtsp.c
index 2fe912c63..42b26cc71 100644
--- a/docs/examples/rtsp.c
+++ b/docs/examples/rtsp.c
@@ -1,253 +1,271 @@
-/*

- * Copyright (c) 2011, Jim Hollinger

- * All rights reserved.

- *

- * Redistribution and use in source and binary forms, with or without

- * modification, are permitted provided that the following conditions

- * are met:

- *   * Redistributions of source code must retain the above copyright

- *     notice, this list of conditions and the following disclaimer.

- *   * Redistributions in binary form must reproduce the above copyright

- *     notice, this list of conditions and the following disclaimer in the

- *     documentation and/or other materials provided with the distribution.

- *   * Neither the name of Jim Hollinger nor the names of its contributors

- *     may be used to endorse or promote products derived from this

- *     software without specific prior written permission.

- *

- * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS

- * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT

- * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR

- * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT

- * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

- * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,

- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY

- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

- * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

- *

- */

-

-#include <stdio.h>

-#include <stdlib.h>

-#include <string.h>

-

-#if defined (WIN32)

-#  include <conio.h>  // _getch()

-#else

-#  include <termios.h>

-#  include <unistd.h>

-

-  int _getch(void) {

-    struct termios oldt, newt;

-    tcgetattr( STDIN_FILENO, &oldt );

-    newt = oldt;

-    newt.c_lflag &= ~( ICANON | ECHO );

-    tcsetattr( STDIN_FILENO, TCSANOW, &newt );

-    int ch = getchar();

-    tcsetattr( STDIN_FILENO, TCSANOW, &oldt );

-    return ch;

-  }

-#endif

-

-#include <curl/curl.h>

-

-#define VERSION_STR  "V1.0"

-

-// error handling macros

-#define my_curl_easy_setopt(A, B, C) \

-  if ((res = curl_easy_setopt((A), (B), (C))) != CURLE_OK) \

-    fprintf(stderr, "curl_easy_setopt(%s, %s, %s) failed: %d\n", #A, #B, #C, res);

-

-#define my_curl_easy_perform(A) \

-  if ((res = curl_easy_perform((A))) != CURLE_OK) \

-    fprintf(stderr, "curl_easy_perform(%s) failed: %d\n", #A, res);

-

-

-// send RTSP OPTIONS request

-void rtsp_options(CURL *curl, const char *uri) {

-    CURLcode res = CURLE_OK;

-    printf("\nRTSP: OPTIONS %s\n", uri);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_STREAM_URI, uri);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_OPTIONS);

-    my_curl_easy_perform(curl);

-}

-

-

-// send RTSP DESCRIBE request and write sdp response to a file

-void rtsp_describe(CURL *curl, const char *uri, const char *sdp_filename) {

-    CURLcode res = CURLE_OK;

-    printf("\nRTSP: DESCRIBE %s\n", uri);

-    FILE *sdp_fp = fopen(sdp_filename, "wt");

-    if (sdp_fp == NULL) {

-        fprintf(stderr, "Could not open '%s' for writing\n", sdp_filename);

-        sdp_fp = stdout;

-    } else {

-        printf("Writing SDP to '%s'\n", sdp_filename);

-    }

-    my_curl_easy_setopt(curl, CURLOPT_WRITEDATA, sdp_fp);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_DESCRIBE);

-    my_curl_easy_perform(curl);

-    my_curl_easy_setopt(curl, CURLOPT_WRITEDATA, stdout);

-    if (sdp_fp != stdout) {

-        fclose(sdp_fp);

-    }

-}

-

-

-// send RTSP SETUP request

-void rtsp_setup(CURL *curl, const char *uri, const char *transport) {

-    CURLcode res = CURLE_OK;

-    printf("\nRTSP: SETUP %s\n", uri);

-    printf("      TRANSPORT %s\n", transport);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_STREAM_URI, uri);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_TRANSPORT, transport);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_SETUP);

-    my_curl_easy_perform(curl);

-}

-

-

-// send RTSP PLAY request

-void rtsp_play(CURL *curl, const char *uri, const char *range) {

-    CURLcode res = CURLE_OK;

-    printf("\nRTSP: PLAY %s\n", uri);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_STREAM_URI, uri);

-    my_curl_easy_setopt(curl, CURLOPT_RANGE, range);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_PLAY);

-    my_curl_easy_perform(curl);

-}

-

-

-// send RTSP TEARDOWN request

-void rtsp_teardown(CURL *curl, const char *uri) {

-    CURLcode res = CURLE_OK;

-    printf("\nRTSP: TEARDOWN %s\n", uri);

-    my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_TEARDOWN);

-    my_curl_easy_perform(curl);

-}

-

-

-// convert url into an sdp filename

-void get_sdp_filename(const char *url, char *sdp_filename) {

-    strcpy(sdp_filename, "video.sdp");

-    const char *s = strrchr(url, '/');

-    if (s != NULL) {

-        s++;

-        if (s[0] != '\0') {

-            sprintf(sdp_filename, "%s.sdp", s);

-        }

-    }

-}

-

-

-// scan sdp file for media control attribute

-void get_media_control_attribute(const char *sdp_filename, char *control) {

-    control[0] = '\0';

-    int max_len = 256;

-    char *s = new char[max_len];

-    FILE *sdp_fp = fopen(sdp_filename, "rt");

-    if (sdp_fp != NULL) {

-        while (fgets(s, max_len - 2, sdp_fp) != NULL) {

-            sscanf(s, " a = control: %s", control);

-        }

-        fclose(sdp_fp);

-    }

-    delete []s;

-}

-

-

-// main app

-int main(int argc, char * const argv[]) {

-    const char *transport = "RTP/AVP;unicast;client_port=1234-1235";  // UDP		

-//    const char *transport = "RTP/AVP/TCP;unicast;client_port=1234-1235";  // TCP

-    const char *range = "0.000-";

-    int rc = EXIT_SUCCESS;

-

-    printf("\nRTSP request %s\n", VERSION_STR);

-    printf("    Project web site: http://code.google.com/p/rtsprequest/\n");

-    printf("    Requires cURL V7.20 or greater\n\n");

-

-    // check command line

-    char *basename = NULL;

-    if ((argc != 2) && (argc != 3)) {

-        basename = strrchr(argv[0], '/');

-        if (basename == NULL) {

-            basename = strrchr(argv[0], '\\');

-        }

-        if (basename == NULL) {

-            basename = argv[0];

-        } else {

-            basename++;

-        }

-        printf("Usage:   %s url [transport]\n", basename);

-        printf("         url of video server\n");

-        printf("         transport (optional) specifier for media stream protocol\n");

-        printf("         default transport: %s\n", transport);

-        printf("Example: %s rtsp://192.168.0.2/media/video1\n\n", basename);

-        rc = EXIT_FAILURE;

-    } else {

-        const char *url = argv[1];

-        char *uri = new char[strlen(url) + 32];

-        char *sdp_filename = new char[strlen(url) + 32];

-        char *control = new char[strlen(url) + 32];

-        get_sdp_filename(url, sdp_filename);

-        if (argc == 3) {

-            transport = argv[2];

-        }

-

-        // initialize curl

-        CURLcode res = CURLE_OK;

-        res = curl_global_init(CURL_GLOBAL_ALL);

-        if (res == CURLE_OK) {

-            curl_version_info_data *data = curl_version_info(CURLVERSION_NOW);

-            fprintf(stderr, "    cURL V%s loaded\n", data->version);

-

-            // initialize this curl session

-            CURL *curl = curl_easy_init();

-            if (curl != NULL) {

-                my_curl_easy_setopt(curl, CURLOPT_VERBOSE, 0L);

-                my_curl_easy_setopt(curl, CURLOPT_NOPROGRESS, 1L);

-                my_curl_easy_setopt(curl, CURLOPT_WRITEHEADER, stdout);

-                my_curl_easy_setopt(curl, CURLOPT_URL, url);

-

-                // request server options

-                sprintf(uri, "%s", url);

-                rtsp_options(curl, uri);

-

-                // request session description and write response to sdp file

-                rtsp_describe(curl, uri, sdp_filename);

-

-                // get media control attribute from sdp file

-                get_media_control_attribute(sdp_filename, control);

-

-                // setup media stream

-                sprintf(uri, "%s/%s", url, control);

-                rtsp_setup(curl, uri, transport);

-

-                // start playing media stream

-                sprintf(uri, "%s/", url);

-                rtsp_play(curl, uri, range);

-                printf("Playing video, press any key to stop ...");

-                _getch();

-                printf("\n");

-

-                // teardown session

-                rtsp_teardown(curl, uri);

-

-                // cleanup

-                curl_easy_cleanup(curl);

-                curl = NULL;

-            } else {

-                fprintf(stderr, "curl_easy_init() failed\n");

-            }

-            curl_global_cleanup();

-        } else {

-            fprintf(stderr, "curl_global_init(%s) failed\n", "CURL_GLOBAL_ALL", res);

-        }

-        delete []control;

-        delete []sdp_filename;

-        delete []uri;

-    }

-

-    return rc;

-}

+/*
+ * Copyright (c) 2011, Jim Hollinger
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *   * Redistributions of source code must retain the above copyright
+ *     notice, this list of conditions and the following disclaimer.
+ *   * Redistributions in binary form must reproduce the above copyright
+ *     notice, this list of conditions and the following disclaimer in the
+ *     documentation and/or other materials provided with the distribution.
+ *   * Neither the name of Jim Hollinger nor the names of its contributors
+ *     may be used to endorse or promote products derived from this
+ *     software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#if defined (WIN32)
+#  include <conio.h>  /* _getch() */
+#else
+#  include <termios.h>
+#  include <unistd.h>
+
+static int _getch(void)
+{
+  struct termios oldt, newt;
+  int ch;
+  tcgetattr( STDIN_FILENO, &oldt );
+  newt = oldt;
+  newt.c_lflag &= ~( ICANON | ECHO );
+  tcsetattr( STDIN_FILENO, TCSANOW, &newt );
+  ch = getchar();
+  tcsetattr( STDIN_FILENO, TCSANOW, &oldt );
+  return ch;
+}
+#endif
+
+#include <curl/curl.h>
+
+#define VERSION_STR  "V1.0"
+
+/* error handling macros */
+#define my_curl_easy_setopt(A, B, C) \
+  if ((res = curl_easy_setopt((A), (B), (C))) != CURLE_OK) \
+    fprintf(stderr, "curl_easy_setopt(%s, %s, %s) failed: %d\n", \
+            #A, #B, #C, res);
+
+#define my_curl_easy_perform(A) \
+  if ((res = curl_easy_perform((A))) != CURLE_OK) \
+    fprintf(stderr, "curl_easy_perform(%s) failed: %d\n", #A, res);
+
+
+/* send RTSP OPTIONS request */
+static void rtsp_options(CURL *curl, const char *uri)
+{
+  CURLcode res = CURLE_OK;
+  printf("\nRTSP: OPTIONS %s\n", uri);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_STREAM_URI, uri);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_OPTIONS);
+  my_curl_easy_perform(curl);
+}
+
+
+/* send RTSP DESCRIBE request and write sdp response to a file */
+static void rtsp_describe(CURL *curl, const char *uri,
+                          const char *sdp_filename)
+{
+  CURLcode res = CURLE_OK;
+  FILE *sdp_fp = fopen(sdp_filename, "wt");
+  printf("\nRTSP: DESCRIBE %s\n", uri);
+  if (sdp_fp == NULL) {
+    fprintf(stderr, "Could not open '%s' for writing\n", sdp_filename);
+    sdp_fp = stdout;
+  }
+  else {
+    printf("Writing SDP to '%s'\n", sdp_filename);
+  }
+  my_curl_easy_setopt(curl, CURLOPT_WRITEDATA, sdp_fp);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_DESCRIBE);
+  my_curl_easy_perform(curl);
+  my_curl_easy_setopt(curl, CURLOPT_WRITEDATA, stdout);
+  if (sdp_fp != stdout) {
+    fclose(sdp_fp);
+  }
+}
+
+/* send RTSP SETUP request */
+static void rtsp_setup(CURL *curl, const char *uri, const char *transport)
+{
+  CURLcode res = CURLE_OK;
+  printf("\nRTSP: SETUP %s\n", uri);
+  printf("      TRANSPORT %s\n", transport);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_STREAM_URI, uri);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_TRANSPORT, transport);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_SETUP);
+  my_curl_easy_perform(curl);
+}
+
+
+/* send RTSP PLAY request */
+static void rtsp_play(CURL *curl, const char *uri, const char *range)
+{
+  CURLcode res = CURLE_OK;
+  printf("\nRTSP: PLAY %s\n", uri);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_STREAM_URI, uri);
+  my_curl_easy_setopt(curl, CURLOPT_RANGE, range);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_PLAY);
+  my_curl_easy_perform(curl);
+}
+
+
+/* send RTSP TEARDOWN request */
+static void rtsp_teardown(CURL *curl, const char *uri)
+{
+  CURLcode res = CURLE_OK;
+  printf("\nRTSP: TEARDOWN %s\n", uri);
+  my_curl_easy_setopt(curl, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_TEARDOWN);
+  my_curl_easy_perform(curl);
+}
+
+
+/* convert url into an sdp filename */
+static void get_sdp_filename(const char *url, char *sdp_filename)
+{
+  const char *s = strrchr(url, '/');
+  strcpy(sdp_filename, "video.sdp");
+  if (s != NULL) {
+    s++;
+    if (s[0] != '\0') {
+      sprintf(sdp_filename, "%s.sdp", s);
+    }
+  }
+}
+
+
+/* scan sdp file for media control attribute */
+static void get_media_control_attribute(const char *sdp_filename,
+                                        char *control)
+{
+  int max_len = 256;
+  char *s = malloc(max_len);
+  FILE *sdp_fp = fopen(sdp_filename, "rt");
+  control[0] = '\0';
+  if (sdp_fp != NULL) {
+    while (fgets(s, max_len - 2, sdp_fp) != NULL) {
+      sscanf(s, " a = control: %s", control);
+    }
+    fclose(sdp_fp);
+  }
+  free(s);
+}
+
+
+/* main app */
+int main(int argc, char * const argv[])
+{
+#if 1
+  const char *transport = "RTP/AVP;unicast;client_port=1234-1235";  /* UDP */
+#else
+  const char *transport = "RTP/AVP/TCP;unicast;client_port=1234-1235";  /* TCP */
+#endif
+  const char *range = "0.000-";
+  int rc = EXIT_SUCCESS;
+  char *basename = NULL;
+
+  printf("\nRTSP request %s\n", VERSION_STR);
+  printf("    Project web site: http://code.google.com/p/rtsprequest/\n");
+  printf("    Requires cURL V7.20 or greater\n\n");
+
+  /* check command line */
+  if ((argc != 2) && (argc != 3)) {
+    basename = strrchr(argv[0], '/');
+    if (basename == NULL) {
+      basename = strrchr(argv[0], '\\');
+    }
+    if (basename == NULL) {
+      basename = argv[0];
+    } else {
+      basename++;
+    }
+    printf("Usage:   %s url [transport]\n", basename);
+    printf("         url of video server\n");
+    printf("         transport (optional) specifier for media stream protocol\n");
+    printf("         default transport: %s\n", transport);
+    printf("Example: %s rtsp://192.168.0.2/media/video1\n\n", basename);
+    rc = EXIT_FAILURE;
+  } else {
+    const char *url = argv[1];
+    char *uri = malloc(strlen(url) + 32);
+    char *sdp_filename = malloc(strlen(url) + 32);
+    char *control = malloc(strlen(url) + 32);
+    CURLcode res;
+    get_sdp_filename(url, sdp_filename);
+    if (argc == 3) {
+      transport = argv[2];
+    }
+
+    /* initialize curl */
+    res = curl_global_init(CURL_GLOBAL_ALL);
+    if (res == CURLE_OK) {
+      curl_version_info_data *data = curl_version_info(CURLVERSION_NOW);
+      CURL *curl;
+      fprintf(stderr, "    cURL V%s loaded\n", data->version);
+
+      /* initialize this curl session */
+      curl = curl_easy_init();
+      if (curl != NULL) {
+        my_curl_easy_setopt(curl, CURLOPT_VERBOSE, 0L);
+        my_curl_easy_setopt(curl, CURLOPT_NOPROGRESS, 1L);
+        my_curl_easy_setopt(curl, CURLOPT_WRITEHEADER, stdout);
+        my_curl_easy_setopt(curl, CURLOPT_URL, url);
+
+        /* request server options */
+        sprintf(uri, "%s", url);
+        rtsp_options(curl, uri);
+
+        /* request session description and write response to sdp file */
+        rtsp_describe(curl, uri, sdp_filename);
+
+        /* get media control attribute from sdp file */
+        get_media_control_attribute(sdp_filename, control);
+
+        /* setup media stream */
+        sprintf(uri, "%s/%s", url, control);
+        rtsp_setup(curl, uri, transport);
+
+        /* start playing media stream */
+        sprintf(uri, "%s/", url);
+        rtsp_play(curl, uri, range);
+        printf("Playing video, press any key to stop ...");
+        _getch();
+        printf("\n");
+
+        /* teardown session */
+        rtsp_teardown(curl, uri);
+
+        /* cleanup */
+        curl_easy_cleanup(curl);
+        curl = NULL;
+      } else {
+        fprintf(stderr, "curl_easy_init() failed\n");
+      }
+      curl_global_cleanup();
+    } else {
+      fprintf(stderr, "curl_global_init(%s) failed: %d\n",
+              "CURL_GLOBAL_ALL", res);
+    }
+    free(control);
+    free(sdp_filename);
+    free(uri);
+  }
+
+  return rc;
+}