question: notifies the view about an error . concode_field_sep ResultSubpartition parent concode_elem_sep int readBatchSize concode_elem_sep BufferFileReader asyncFileReader concode_elem_sep boolean hasReachedEndOfFile concode_elem_sep AtomicInteger currentBatchSize concode_elem_sep BufferProviderCallback bufferAvailabilityListener concode_elem_sep BufferProvider bufferProvider concode_elem_sep SpilledSubpartitionViewAsyncIO subpartitionView concode_elem_sep IOException errorInIOThread concode_elem_sep NotificationListener registeredListener concode_elem_sep int DEFAULT_READ_BATCH_SIZE concode_elem_sep ConcurrentLinkedQueue<Buffer> returnedBuffers concode_elem_sep boolean isReleased concode_elem_sep Object lock concode_field_sep void notifySubpartitionConsumed concode_elem_sep void releaseAllResources concode_elem_sep void requestFailed concode_elem_sep Buffer getNextBuffer concode_elem_sep void checkError concode_elem_sep boolean registerListener concode_elem_sep Throwable getFailureCause concode_elem_sep void onAvailableBuffer concode_elem_sep void returnBufferFromIOThread concode_elem_sep void requestSuccessful concode_elem_sep void onEvent concode_elem_sep void readNextBatchAsync concode_elem_sep boolean isReleased
target: void function ( IOException arg0 ) { if ( errorInIOThread == null ) { errorInIOThread = arg0 ; } final NotificationListener loc0 ; synchronized ( lock ) { loc0 = registeredListener ; registeredListener = null ; } if ( loc0 != null ) { loc0 . onNotification ( ) ; } }