GitHub/sdrtrunk
1
0
Fork 0
mirror of https://github.com/DSheirer/sdrtrunk.git synced 2026-11-13 09:07:27 -05:00
Code Issues Packages Projects Releases 2 Wiki Activity

Resolved issue with delayed event log writing ... added forced flushing

Browse Source 
after each event write.
This commit is contained in:
denny
2015-09-19 20:02:26 -04:00
parent f070510acc
commit 95c38df812
4 changed files with 7 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/audio/AudioModule.java
View File

@@ -98,13 +98,12 @@ public class AudioModule extends Module implements IAudioPacketProvider,
@Override
public void stop()
{
// /* Issue an end audio packet in case a recorder is still rolling */
// if( mAudioPacketListener != null )
// {
// mLog.debug( "Sending end audio packet - stop() invoked" );
// mAudioPacketListener.receive( new AudioPacket( AudioPacket.Type.END,
// mAudioMetadata.copyOf() ) );
// }
/* Issue an end audio packet in case a recorder is still rolling */
if( mAudioPacketListener != null )
{
mAudioPacketListener.receive( new AudioPacket( AudioPacket.Type.END,
mAudioMetadata.copyOf() ) );
}
}
/**
@@ -201,8 +200,6 @@ public class AudioModule extends Module implements IAudioPacketProvider,
@Override
public void receive( SquelchState state )
{
mLog.debug( "Squelch State:" + state );
if( state == SquelchState.SQUELCH && mAudioPacketListener != null )
{
mAudioPacketListener.receive( new AudioPacket( AudioPacket.Type.END,

1
src/instrument/gui/DecoderSelectionFrame.java
View File

@@ -7,7 +7,6 @@ import java.awt.event.ActionListener;
import javax.swing.JButton;
import javax.swing.JDesktopPane;
import javax.swing.JInternalFrame;
import javax.swing.JPanel;
import module.decode.DecodeComponentEditor;
import module.decode.config.DecodeConfiguration;

9
src/module/decode/state/ChannelState.java
View File

@@ -230,13 +230,9 @@ public class ChannelState extends Module implements ICallEventProvider,
( mChannelType == ChannelType.STANDARD ? FADE_TIMEOUT_DELAY :
mTrafficChannelTimeout );
mLog.debug( "Updating Fade Timeout - previous [" + mFadeTimeout + "] new [" + timeout + "] current [" + current + "] delay [" + ( mChannelType == ChannelType.STANDARD ? FADE_TIMEOUT_DELAY :
mTrafficChannelTimeout ) + "]" );
if( timeout > mFadeTimeout )
{
mFadeTimeout = timeout;
mLog.debug( "Timeout updated to: " + mFadeTimeout );
}
}
@@ -307,7 +303,6 @@ public class ChannelState extends Module implements ICallEventProvider,
case CONTROL:
case DATA:
case ENCRYPTED:
mLog.debug( "Squelching for [" + state + "]" );
broadcast( SquelchState.SQUELCH );
updateFadeTimeout();
startMonitor();
@@ -318,19 +313,16 @@ public class ChannelState extends Module implements ICallEventProvider,
startMonitor();
break;
case FADE:
mLog.debug( "Squelching for [" + state + "]" );
broadcast( SquelchState.SQUELCH );
updateResetTimeout();
startMonitor();
break;
case END:
mLog.debug( "Squelching for [" + state + "]" );
broadcast( SquelchState.SQUELCH );
broadcast( new DecoderStateEvent( this, Event.RESET, State.IDLE ) );
broadcast( new MetadataReset() );
break;
case IDLE:
mLog.debug( "Squelching for [" + state + "]" );
broadcast( SquelchState.SQUELCH );
stopMonitor();
@@ -381,7 +373,6 @@ public class ChannelState extends Module implements ICallEventProvider,
{
if( mFadeTimeout <= System.currentTimeMillis() )
{
mLog.debug( "Fading for timeout [" + mFadeTimeout + "] current [" + System.currentTimeMillis() + "]" );
setState( State.FADE );
}
}

1
src/module/log/EventLogger.java
View File

@@ -130,6 +130,7 @@ public abstract class EventLogger extends Module
try
{
mLogFile.write( eventLogEntry + "\n" );
mLogFile.flush();
}
catch ( IOException e )
{