private void setCatchingUp ( ) throws IOException { try { if ( inputEditStream != null && inputEditStream . isInProgress ( ) ) { catchingUp = ( inputEditStream . length ( ) - inputEditStream . getPosition ( ) > catchUpLag ) ; } else { catchingUp = true ; } } catch ( Exception e ) { catchingUp = true ; } }
Checks if the ingest is catching up . If the ingest is consuming finalized segment it s assumed to be behind . Otherwise catching up is based on the position of the input stream .