private < T > void addAsyncBufferEntry ( StreamElementQueueEntry < T > streamElementQueueEntry ) throws InterruptedException { assert ( Thread . holdsLock ( checkpointingLock ) ) ; pendingStreamElementQueueEntry = streamElementQueueEntry ; while ( ! queue . tryPut ( streamElementQueueEntry ) ) { // we wait for the emitter to notify us if the queue has space left again checkpointingLock . wait ( ) ; } pendingStreamElementQueueEntry = null ; }
Add the given stream element queue entry to the operator s stream element queue . This operation blocks until the element has been added .