n5ac/smartsdr-dsp
1
0
Fork 0
mirror of https://github.com/n5ac/smartsdr-dsp.git synced 2025-12-06 03:01:59 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Successful Reconnection

Browse source
This commit is contained in:
Hayley 2019-07-26 16:30:10 -05:00
parent 4bc9231a0c
commit 20f99daf93
1 changed files with 25 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
DSP_API/ThumbDV/thumbDV.c
View file

@ -94,7 +94,9 @@ static sem_t _read_sem;
//static void * _thumbDV_readThread( void * param ); //static void * _thumbDV_readThread( void * param );
static BufferDescriptor _thumbDVEncodedList_UnlinkHead( void ) { BOOL allowedToRead = TRUE;
static BufferDescriptor _thumbDVEncodedList_UnlinkHead(void ) {
BufferDescriptor buf_desc = NULL; BufferDescriptor buf_desc = NULL;
pthread_rwlock_wrlock( &_encoded_list_lock ); pthread_rwlock_wrlock( &_encoded_list_lock );
@ -757,9 +759,16 @@ static void * _thumbDV_readThread( void * param )
while ( !_readThreadAbort ) while ( !_readThreadAbort )
{ {
sem_wait(&_read_sem); sem_wait(&_read_sem);
thumbDV_processSerial(handle);
}
if (!allowedToRead)
{
break;
}
else
{
thumbDV_processSerial(handle);
}
}
output( ANSI_YELLOW "thumbDV_readThread has exited\n" ANSI_WHITE ); output( ANSI_YELLOW "thumbDV_readThread has exited\n" ANSI_WHITE );
return 0; return 0;
} }
@ -779,16 +788,24 @@ static void * _thumbDV_connectThread( void * param )
ret = FT_GetStatus(handle, &rx_bytes, &tx_bytes, &event_dword); ret = FT_GetStatus(handle, &rx_bytes, &tx_bytes, &event_dword);
if (ret != FT_OK) { if (ret != FT_OK) {
output("Serial is disconnected\n");
fprintf(stderr, "ThumbDV: error from status, status=%d\n", ret);
/* Set invalid FD in sched_waveform so we don't call write functions */ //clear out read buffer and stop read thread
sem_post(&_read_sem);
allowedToRead = FALSE;
output("Serial is disconnected\n");
//Set invalid FD in sched_waveform so we don't call write functions
handle = NULL; handle = NULL;
sched_waveform_setHandle(&handle); sched_waveform_setHandle(&handle);
/* This function hangs until a new connection is made */ //This function hangs until a new connection is made
_connectSerial(&handle); _connectSerial(&handle);
/* Update the sched_waveform to new valid serial */ //Update the sched_waveform to new valid serial
sched_waveform_setHandle(&handle); sched_waveform_setHandle(&handle);
//Start read thread again
allowedToRead = TRUE;
pthread_create( &_read_thread, NULL, &_thumbDV_readThread, &handle );
} }
} }
} }