r783 - in general/xine-lib-vdr/branches/network/debian: . patches

Tobias Grimm pkg-vdr-dvb-changes@lists.alioth.debian.org
Sun, 03 Jul 2005 16:45:00 +0000


Author: tiber-guest
Date: 2005-07-03 16:44:59 +0000 (Sun, 03 Jul 2005)
New Revision: 783

Added:
   general/xine-lib-vdr/branches/network/debian/patches/08_network.dpatch
Modified:
   general/xine-lib-vdr/branches/network/debian/changelog
   general/xine-lib-vdr/branches/network/debian/patches/00list
Log:
xine-lib-vdr-net: added network patch

Modified: general/xine-lib-vdr/branches/network/debian/changelog
===================================================================
--- general/xine-lib-vdr/branches/network/debian/changelog	2005-07-03 16:21:23 UTC (rev 782)
+++ general/xine-lib-vdr/branches/network/debian/changelog	2005-07-03 16:44:59 UTC (rev 783)
@@ -1,3 +1,9 @@
+xine-lib-vdr (1.0.1-1vdr2+net1) unstable; urgency=low
+
+  * Added network patch
+
+ -- Tobias Grimm <tg@e-tobi.net>  Sun,  3 Jul 2005 18:30:18 +0200
+
 xine-lib-vdr (1.0.1-1vdr2) unstable; urgency=low
 
   * Update the vdr-plugin-xine patch (0.7.4) (and disable various printf()s).

Modified: general/xine-lib-vdr/branches/network/debian/patches/00list
===================================================================
--- general/xine-lib-vdr/branches/network/debian/patches/00list	2005-07-03 16:21:23 UTC (rev 782)
+++ general/xine-lib-vdr/branches/network/debian/patches/00list	2005-07-03 16:44:59 UTC (rev 783)
@@ -5,4 +5,5 @@
 05_fpic_asm_fix
 06_-fno-inline-functions
 07_goom_fps_fix
+08_network
 99_autoconf

Added: general/xine-lib-vdr/branches/network/debian/patches/08_network.dpatch
===================================================================
--- general/xine-lib-vdr/branches/network/debian/patches/08_network.dpatch	2005-07-03 16:21:23 UTC (rev 782)
+++ general/xine-lib-vdr/branches/network/debian/patches/08_network.dpatch	2005-07-03 16:44:59 UTC (rev 783)
@@ -0,0 +1,341 @@
+#! /bin/sh /usr/share/dpatch/dpatch-run
+## 08_network.dpatch by  <tg@e-tobi.net>
+##
+## All lines beginning with `## DP:' are a description of the patch.
+## DP: This patch allows to read a vdr stream from the network via
+## DP: sockets provided by the xine plugin for vdr. This patch is
+## DP: based on Peter Webers xine-0-7-4-network. 
+
+@DPATCH@
+diff -urNad xine-lib-vdr-1.0.1/src/vdr/input_vdr.c /tmp/dpep.uJK3qo/xine-lib-vdr-1.0.1/src/vdr/input_vdr.c
+--- xine-lib-vdr-1.0.1/src/vdr/input_vdr.c	2005-06-16 23:50:46.000000000 +0200
++++ /tmp/dpep.uJK3qo/xine-lib-vdr-1.0.1/src/vdr/input_vdr.c	2005-06-16 23:51:46.000000000 +0200
+@@ -34,6 +34,10 @@
+ #include <errno.h>
+ #include <pthread.h>
+ 
++#include <sys/socket.h>
++#include <resolv.h>
++#include <netdb.h>
++
+ #define LOG_MODULE "input_vdr"
+ #define LOG_VERBOSE
+ /*
+@@ -51,8 +55,6 @@
+ #define VDR_MAX_NUM_WINDOWS 16
+ #define VDR_ABS_FIFO_DIR "/tmp/vdr-xine"
+ 
+-
+-
+ #define BUF_SIZE 1024
+ 
+ #define LOG_OSD(x)
+@@ -1394,108 +1396,203 @@
+   return INPUT_OPTIONAL_UNSUPPORTED;
+ }
+ 
+-static int vdr_plugin_open(input_plugin_t *this_gen)
++static int vdr_plugin_open_socket(vdr_input_plugin_t *this, struct hostent *host, unsigned short port)
++{
++	int fd;
++	struct sockaddr_in sain;
++	struct in_addr iaddr;
++
++	if ((fd = socket(PF_INET,SOCK_STREAM,0)) == -1) {
++		xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++				_("vdr: failed to create socket for port %d (%s)\n"),
++					port,strerror(errno));
++		return -1;
++	}
++
++	iaddr.s_addr = * ((unsigned int *) host->h_addr_list[0]);
++
++	sain.sin_port = htons(port);
++	sain.sin_family = AF_INET;
++	sain.sin_addr = iaddr;
++
++	if (connect(fd,(struct sockaddr*) &sain, sizeof(sain)) < 0) {
++		xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++				_("vdr: failed to connect to port %d (%s)\n"),port,
++				strerror(errno));
++		return -1;
++	}
++
++	xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++			"vdr: socket opening successful, fd = %d\n",fd);
++	return fd;
++}    
++
++static int vdr_plugin_open_sockets(vdr_input_plugin_t *this)
++{
++//  struct hostent *host = gethostbyname(VDR_SERVER_ADDRESS);
++  struct hostent *host = gethostbyname(&this->mrl[12]);
++ 
++  xprintf(this->stream->xine, XINE_VERBOSITY_LOG,"vdr: connecting to vdr.\n");
++  if (host == NULL) {
++    xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++            _("vdr: failed to resolve hostname '%s' (%s)\n"),
++			&this->mrl[12],
++			strerror(errno));
++	return 0;
++  }
++
++  if ((this->fh = vdr_plugin_open_socket(this,host,18701)) == -1)
++	  return 0;
++  
++  fcntl(this->fh, F_SETFL, ~O_NONBLOCK & fcntl(this->fh, F_GETFL, 0));
++  
++  if ((this->fh_control = vdr_plugin_open_socket(this,host,18702)) == -1)
++	  return 0;
++
++  if ((this->fh_result = vdr_plugin_open_socket(this,host,18703)) == -1)
++	  return 0;
++
++  if ((this->fh_event = vdr_plugin_open_socket(this,host,18704)) == -1)
++	  return 0;
++  xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++			"vdr: connecting to all sockets was successful.\n");
++  return 1;
++}
++
++static int vdr_plugin_open_vdr(input_plugin_t *this_gen)
+ {
+   vdr_input_plugin_t *this = (vdr_input_plugin_t *)this_gen;
+ 
+-  lprintf("trying to open '%s'...\n", this->mrl);
++  char *filename;
+ 
+-  if (this->fh == -1)
+-  {
+-    char *filename;
+-    int err = 0;
++  filename = (char *)&this->mrl[ 4 ];
++  this->fh = open(filename, O_RDONLY | O_NONBLOCK);
+ 
+-    filename = (char *)&this->mrl[ 4 ];
+-    this->fh = open(filename, O_RDONLY | O_NONBLOCK);
++  lprintf("filename '%s'\n", filename);
+ 
+-    lprintf("filename '%s'\n", filename);
++  if (this->fh == -1)
++  {
++    xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++            _(LOG_MODULE ": failed to open '%s' (%s)\n"),
++            filename,
++            strerror(errno));
++      
++    return 0;
++  }
+ 
+-    if (this->fh == -1)
++  {
++    struct pollfd poll_fh = { this->fh, POLLIN, 0 };
++      
++    int r = poll(&poll_fh, 1, 300);      
++    if (1 != r)
+     {
+       xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
+               _(LOG_MODULE ": failed to open '%s' (%s)\n"),
+               filename,
+-              strerror(errno));
+-      
+-      return 0;
+-    }
+-
+-    {
+-      struct pollfd poll_fh = { this->fh, POLLIN, 0 };
+-      
+-      int r = poll(&poll_fh, 1, 300);      
+-      if (1 != r)
+-      {
+-        xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
+-                _(LOG_MODULE ": failed to open '%s' (%s)\n"),
+-                filename,
+-                _("timeout expired during setup phase"));
++              _("timeout expired during setup phase"));
+         
+-        return 0;
+-      }
++      return 0;
+     }
++  }
+     
+-    fcntl(this->fh, F_SETFL, ~O_NONBLOCK & fcntl(this->fh, F_GETFL, 0));
++  fcntl(this->fh, F_SETFL, ~O_NONBLOCK & fcntl(this->fh, F_GETFL, 0));
+     
+-    {
+-      char *filename_control = 0;
+-      asprintf(&filename_control, "%s.control", filename);
+-
+-      this->fh_control = open(filename_control, O_RDONLY);
+-
+-      if (this->fh_control == -1) {
+-        xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
+-                _(LOG_MODULE ": failed to open '%s' (%s)\n"),
+-                filename_control,
+-                strerror(errno));
++  {
++    char *filename_control = 0;
++    asprintf(&filename_control, "%s.control", filename);
+ 
+-        free(filename_control);
+-        return 0;
+-      }
++    this->fh_control = open(filename_control, O_RDONLY);
+ 
+-      free(filename_control);      
++    if (this->fh_control == -1) {
++      xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++              _(LOG_MODULE ": failed to open '%s' (%s)\n"),
++              filename_control,
++              strerror(errno));
++       free(filename_control);
++      return 0;
+     }
++     free(filename_control);      
++  }
+ 
+-    {
+-      char *filename_result = 0;
+-      asprintf(&filename_result, "%s.result", filename);
++  {
++    char *filename_result = 0;
++    asprintf(&filename_result, "%s.result", filename);
+ 
+-      this->fh_result = open(filename_result, O_WRONLY);
++    this->fh_result = open(filename_result, O_WRONLY);
+ 
+-      if (this->fh_result == -1) {
+-        perror("failed");
++    if (this->fh_result == -1) {
++      perror("failed");
+         
+-        xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
+-                _(LOG_MODULE ": failed to open '%s' (%s)\n"),
+-                filename_result,
+-                strerror(errno));
++      xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++              _(LOG_MODULE ": failed to open '%s' (%s)\n"),
++              filename_result,
++              strerror(errno));
+         
+-        free(filename_result);
+-        return 0;
+-      }
+-
+       free(filename_result);
++      return 0;
+     }
+ 
+-    {
+-      char *filename_event = 0;
+-      asprintf(&filename_event, "%s.event", filename);
++    free(filename_result);
++  }
+ 
+-      this->fh_event = open(filename_event, O_WRONLY);
++  {
++    char *filename_event = 0;
++    asprintf(&filename_event, "%s.event", filename);
+ 
+-      if (this->fh_event == -1) {
+-        perror("failed");
++    this->fh_event = open(filename_event, O_WRONLY);
+ 
+-        xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
+-                _(LOG_MODULE ": failed to open '%s' (%s)\n"),
+-                filename_event,
+-                strerror(errno));
+-        
+-        free(filename_event);
+-        return 0;
+-      }
++    if (this->fh_event == -1) {
++      perror("failed");
+ 
++      xprintf(this->stream->xine, XINE_VERBOSITY_LOG,
++              _(LOG_MODULE ": failed to open '%s' (%s)\n"),
++              filename_event,
++              strerror(errno));
++        
+       free(filename_event);
++      return 0;
++    }
++
++    free(filename_event);
++  }
++
++  return 1;
++}
++
++static int vdr_plugin_open_vdr_socket(input_plugin_t *this_gen)
++{
++  vdr_input_plugin_t *this = (vdr_input_plugin_t *)this_gen;
++
++  lprintf("input_vdr: connecting to vdr-xine-server...\n");
++ 
++  if (!vdr_plugin_open_sockets(this))
++    return 0;
++   
++  return 1;
++}
++
++static int vdr_plugin_open(input_plugin_t *this_gen)
++{
++  vdr_input_plugin_t *this = (vdr_input_plugin_t *)this_gen;
++
++  lprintf("trying to open '%s'...\n", this->mrl);
++
++  if (this->fh == -1) 
++  {
++    int err = 0;
++
++    if (!strncasecmp(&this->mrl[0], "vdr:/", 5))
++    {
++       if (!vdr_plugin_open_vdr(this_gen))
++         return 0;
++    }
++    else
++    {
++      if (!strncasecmp(&this->mrl[0], "vdr-socket:/", 12))
++      {
++         if (!vdr_plugin_open_vdr_socket(this_gen))
++           return 0;
++      }
+     }
+ 
+     this->rpc_thread_shutdown = 0;
+@@ -1510,7 +1607,6 @@
+     }
+   }
+ 
+-
+   /*
+    * mrl accepted and opened successfully at this point
+    *
+@@ -1612,14 +1708,21 @@
+   vdr_input_plugin_t *this;
+   char               *mrl = strdup(data);
+ 
+-  if (!strncasecmp(mrl, "vdr:/", 5))
++  if (!strncasecmp(mrl, "vdr-socket:/", 12))
+   {
+-    lprintf("filename '%s'\n", (char *)&mrl[ 4 ]);
++    lprintf("host '%s'\n", (char *)&mrl[ 12 ]);
+   }
+   else
+   {
+-    free(mrl);
+-    return NULL;
++    if (!strncasecmp(mrl, "vdr:/", 5))
++    {
++      lprintf("filename '%s'\n", (char *)&mrl[ 4 ]);
++    }
++    else
++    {
++      free(mrl);
++      return NULL;
++    }
+   }
+ 
+   /*