adam
/
darkice
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

added fault tolerance in case a server connection is dropped

This commit is contained in:
darkeye 2002-07-20 16:37:06 +00:00
parent e043b8784f
commit 229095cb7e
5 changed files with 34 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
darkice/trunk/ChangeLog
View File

@ -4,6 +4,8 @@ DarkIce 0.10
encoding modes with specifying encoding quality as well.
thanks to Nicu Pavel <npavel@ituner.com>
o added support for Ogg Vorbis 1.0 final, removed support for rc2
o added fault tolerance: if one of several server connection drops,
DarkIce carries on with the rest of the servers still connected
09-04-2002: DarkIce 0.9.1 released

31
darkice/trunk/src/Connector.cpp
View File

@ -283,20 +283,24 @@ Connector :: transfer ( unsigned long bytes,
for ( u = 0; u < numSinks; ++u ) {
if ( sinks[u]->canWrite( sec, usec) ) {
e = sinks[u]->write( buf, d);
} else {
sinks[u]->close();
detach( sinks[u].get() );
/* with the call to detach, numSinks gets 1 lower,
* and the next sink comes to sinks[u] */
--u;
try {
e = sinks[u]->write( buf, d);
} catch ( Exception & e ) {
sinks[u]->close();
detach( sinks[u].get() );
/* with the call to detach, numSinks gets 1 lower,
* and the next sink comes to sinks[u] */
--u;
reportEvent( 5,
"Connector :: transfer, sink removed, remaining", u);
reportEvent( 4,
"Connector :: transfer, sink removed, remaining",
numSinks);
if ( numSinks == 0 ) {
reportEvent( 4, "Connector :: transfer, no more sinks");
break;
if ( numSinks == 0 ) {
reportEvent( 4,
"Connector :: transfer, no more sinks");
break;
}
}
}
}
@ -334,6 +338,9 @@ Connector :: close ( void ) throw ( Exception )
$Source$
$Log$
Revision 1.8 2002/07/20 16:37:06 darkeye
added fault tolerance in case a server connection is dropped
Revision 1.7 2002/05/28 12:35:41 darkeye
code cleanup: compiles under gcc-c++ 3.1, using -pedantic option

5
darkice/trunk/src/TcpSocket.cpp
View File

@ -313,7 +313,7 @@ TcpSocket :: write ( const void * buf,
}
// ret = send( sockfd, buf, len, MSG_DONTWAIT);
ret = send( sockfd, buf, len, 0);
ret = send( sockfd, buf, len, MSG_NOSIGNAL);
if ( ret == -1 ) {
if ( errno == EAGAIN ) {
@ -349,6 +349,9 @@ TcpSocket :: close ( void ) throw ( Exception )
$Source$
$Log$
Revision 1.7 2002/07/20 16:37:06 darkeye
added fault tolerance in case a server connection is dropped
Revision 1.6 2001/09/18 16:44:10 darkeye
TcpSocket did not report closed state when could not connect()

5
darkice/trunk/src/VorbisLibEncoder.cpp
View File

@ -257,7 +257,7 @@ VorbisLibEncoder :: flush ( void )
* Send pending Vorbis blocks to the underlying stream
*----------------------------------------------------------------------------*/
void
VorbisLibEncoder :: vorbisBlocksOut ( void ) throw ()
VorbisLibEncoder :: vorbisBlocksOut ( void ) throw ( Exception )
{
while ( 1 == vorbis_analysis_blockout( &vorbisDspState, &vorbisBlock) ) {
ogg_packet oggPacket;
@ -316,6 +316,9 @@ VorbisLibEncoder :: close ( void ) throw ( Exception )
$Source$
$Log$
Revision 1.11 2002/07/20 16:37:06 darkeye
added fault tolerance in case a server connection is dropped
Revision 1.10 2002/07/20 10:59:00 darkeye
added support for Ogg Vorbis 1.0, removed support for rc2

5
darkice/trunk/src/VorbisLibEncoder.h
View File

@ -171,7 +171,7 @@ class VorbisLibEncoder : public AudioEncoder, public virtual Reporter
* Send pending Vorbis blocks to the underlying stream
*/
void
vorbisBlocksOut( void ) throw ();
vorbisBlocksOut( void ) throw ( Exception );
protected:
@ -445,6 +445,9 @@ class VorbisLibEncoder : public AudioEncoder, public virtual Reporter
$Source$
$Log$
Revision 1.6 2002/07/20 16:37:06 darkeye
added fault tolerance in case a server connection is dropped
Revision 1.5 2002/04/13 11:26:00 darkeye
added cbr, abr and vbr setting feature with encoding quality