eeva/jamulus
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

bug fix

Browse source
This commit is contained in:
Volker Fischer 2006-03-08 21:18:20 +00:00
parent bf678d5c2a
commit 30b6fcdf3d
3 changed files with 9 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/channel.cpp
View file

@ -338,15 +338,18 @@ for (int i = 0; i < BLOCK_SIZE_SAMPLES; i++)
} }
Mutex.unlock (); /* put mutex unlock */ Mutex.unlock (); /* put mutex unlock */
// if channel was not connected, emit signal to inform that new // check if channel was not connected
// connection was established const bool bChanWasNotConnected = !IsConnected();
if ( iConTimeOut == 0 )
{
emit NewConnection();
}
// reset time-out counter // reset time-out counter
iConTimeOut = CON_TIME_OUT_CNT_MAX; iConTimeOut = CON_TIME_OUT_CNT_MAX;
// if channel was not connected, emit signal to inform that new
// connection was established
if ( bChanWasNotConnected )
{
emit NewConnection();
}
} }
else else
{ {

3
src/client.cpp
View file

@ -51,8 +51,7 @@ for ( int i = 0; i < vecMessage.Size (); i++ ) {
// the protocol queries me to call the function to send the message // the protocol queries me to call the function to send the message
// send it through the network // send it through the network
Socket.SendPacket ( vecbyDataConv, Socket.SendPacket ( vecbyDataConv, Channel.GetAddress () );
Channel.GetAddress () );
} }
bool CClient::SetServerAddr(QString strNAddr) bool CClient::SetServerAddr(QString strNAddr)

3
src/server.cpp
View file

@ -60,8 +60,7 @@ for ( int i = 0; i < vecMessage.Size (); i++ ) {
// the protocol queries me to call the function to send the message // the protocol queries me to call the function to send the message
// send it through the network // send it through the network
Socket.SendPacket ( vecbyDataConv, Socket.SendPacket ( vecbyDataConv, ChannelSet.GetAddress ( iChID ) );
ChannelSet.GetAddress ( iChID ) );
} }
void CServer::Start () void CServer::Start ()