diff options
| author | lordjaxom <lordjaxom> | 2005-02-09 19:47:09 +0000 |
|---|---|---|
| committer | lordjaxom <lordjaxom> | 2005-02-09 19:47:09 +0000 |
| commit | c1cb77c3f8c7c0b3469e1d110f4e9a96bac16178 (patch) | |
| tree | b2b6d13dd67f4b4d30faf404c5feb059dd7487df /server/streamer.c | |
| parent | 78b9b7c6ba30158f97a9f6c34a16ac3047d5f4e3 (diff) | |
| download | vdr-plugin-streamdev-c1cb77c3f8c7c0b3469e1d110f4e9a96bac16178.tar.gz vdr-plugin-streamdev-c1cb77c3f8c7c0b3469e1d110f4e9a96bac16178.tar.bz2 | |
- transfer
Diffstat (limited to 'server/streamer.c')
| -rw-r--r-- | server/streamer.c | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/server/streamer.c b/server/streamer.c index 00ac6cb..eee3d63 100644 --- a/server/streamer.c +++ b/server/streamer.c @@ -1,5 +1,5 @@ /* - * $Id: streamer.c,v 1.4 2005/02/08 19:54:52 lordjaxom Exp $ + * $Id: streamer.c,v 1.5 2005/02/09 19:47:09 lordjaxom Exp $ */ #include <vdr/ringbuffer.h> @@ -35,11 +35,15 @@ void cStreamdevWriter::Action(void) int count; uchar *block = m_Streamer->Get(count); - if (!m_Socket->SafeWrite(block, count)) { - esyslog("ERROR: streamdev-server: couldn't send data: %m"); - break; + if (block) { + if (!m_Socket->TimedWrite(block, count, 2000)) { + esyslog("ERROR: streamdev-server: couldn't send data: %m"); + break; + } + if (count > max) + max = count; + m_Streamer->Del(count); } - m_Streamer->Del(count); } m_Active = false; Dprintf("Max. Transmit Blocksize was: %d\n", max); @@ -112,7 +116,7 @@ void cStreamdevStreamer::Action(void) int got; uchar *block = m_RingBuffer->Get(got); - if (block && got > 0) { + if (block) { int count = Put(block, got); if (count) m_RingBuffer->Del(count); |