test_class.file: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
test_class.identifier: RemoteInputChannelTest
test_case.body: @Test(expected = IllegalStateException.class)
  	public void testRetriggerWithoutPartitionRequest() throws Exception {
  		Tuple2<Integer, Integer> backoff = new Tuple2<Integer, Integer>(500, 3000);
  		PartitionRequestClient connClient = mock(PartitionRequestClient.class);
  		SingleInputGate inputGate = mock(SingleInputGate.class);
  
  		RemoteInputChannel ch = createRemoteInputChannel(inputGate, connClient, backoff);
  
  		ch.retriggerSubpartitionRequest(0);
  	}
test_case.class_method_signature: RemoteInputChannelTest.testRetriggerWithoutPartitionRequest()
test_case.full_signature: @Test(expected = IllegalStateException.class) public void testRetriggerWithoutPartitionRequest()
test_case.identifier: testRetriggerWithoutPartitionRequest
test_case.invocations: mock mock createRemoteInputChannel retriggerSubpartitionRequest
test_case.modifiers: @Test(expected = IllegalStateException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testRetriggerWithoutPartitionRequest()
focal_class.declarator: LOG = LoggerFactory.getLogger(RemoteInputChannel.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(RemoteInputChannel.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: id = new InputChannelID()
focal_class.modifier: private final
focal_class.original_string: private final InputChannelID id = new InputChannelID();
focal_class.type: InputChannelID
focal_class.var_name: id
focal_class.declarator: connectionId
focal_class.modifier: private final
focal_class.original_string: private final ConnectionID connectionId;
focal_class.type: ConnectionID
focal_class.var_name: connectionId
focal_class.declarator: connectionManager
focal_class.modifier: private final
focal_class.original_string: private final ConnectionManager connectionManager;
focal_class.type: ConnectionManager
focal_class.var_name: connectionManager
focal_class.declarator: receivedBuffers = new ArrayDeque<Buffer>()
focal_class.modifier: private final
focal_class.original_string: private final Queue<Buffer> receivedBuffers = new ArrayDeque<Buffer>();
focal_class.type: Queue<Buffer>
focal_class.var_name: receivedBuffers
focal_class.declarator: isReleased = new AtomicBoolean()
focal_class.modifier: private final
focal_class.original_string: private final AtomicBoolean isReleased = new AtomicBoolean();
focal_class.type: AtomicBoolean
focal_class.var_name: isReleased
focal_class.declarator: partitionRequestClient
focal_class.modifier: private volatile
focal_class.original_string: private volatile PartitionRequestClient partitionRequestClient;
focal_class.type: PartitionRequestClient
focal_class.var_name: partitionRequestClient
focal_class.declarator: expectedSequenceNumber = 0
focal_class.modifier: private
focal_class.original_string: private int expectedSequenceNumber = 0;
focal_class.type: int
focal_class.var_name: expectedSequenceNumber
focal_class.file: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
focal_class.identifier: RemoteInputChannel
focal_class.class_method_signature: RemoteInputChannel.RemoteInputChannel(
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager)
focal_class.full_signature: public  RemoteInputChannel(
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager)
focal_class.identifier: RemoteInputChannel
focal_class.modifiers: public
focal_class.parameters: (
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager)
focal_class.signature:  RemoteInputChannel(
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager)
focal_class.class_method_signature: RemoteInputChannel.RemoteInputChannel(
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager,
  			Tuple2<Integer, Integer> initialAndMaxBackoff)
focal_class.full_signature: public  RemoteInputChannel(
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager,
  			Tuple2<Integer, Integer> initialAndMaxBackoff)
focal_class.identifier: RemoteInputChannel
focal_class.modifiers: public
focal_class.parameters: (
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager,
  			Tuple2<Integer, Integer> initialAndMaxBackoff)
focal_class.signature:  RemoteInputChannel(
  			SingleInputGate inputGate,
  			int channelIndex,
  			ResultPartitionID partitionId,
  			ConnectionID connectionId,
  			ConnectionManager connectionManager,
  			Tuple2<Integer, Integer> initialAndMaxBackoff)
focal_class.class_method_signature: RemoteInputChannel.requestSubpartition(int subpartitionIndex)
focal_class.full_signature: @Override void requestSubpartition(int subpartitionIndex)
focal_class.identifier: requestSubpartition
focal_class.modifiers: @Override
focal_class.parameters: (int subpartitionIndex)
focal_class.return: void
focal_class.signature: void requestSubpartition(int subpartitionIndex)
focal_class.class_method_signature: RemoteInputChannel.retriggerSubpartitionRequest(int subpartitionIndex)
focal_class.full_signature:  void retriggerSubpartitionRequest(int subpartitionIndex)
focal_class.identifier: retriggerSubpartitionRequest
focal_class.parameters: (int subpartitionIndex)
focal_class.return: void
focal_class.signature: void retriggerSubpartitionRequest(int subpartitionIndex)
focal_class.class_method_signature: RemoteInputChannel.getNextBuffer()
focal_class.full_signature: @Override Buffer getNextBuffer()
focal_class.identifier: getNextBuffer
focal_class.modifiers: @Override
focal_class.parameters: ()
focal_class.return: Buffer
focal_class.signature: Buffer getNextBuffer()
focal_class.class_method_signature: RemoteInputChannel.sendTaskEvent(TaskEvent event)
focal_class.full_signature: @Override void sendTaskEvent(TaskEvent event)
focal_class.identifier: sendTaskEvent
focal_class.modifiers: @Override
focal_class.parameters: (TaskEvent event)
focal_class.return: void
focal_class.signature: void sendTaskEvent(TaskEvent event)
focal_class.class_method_signature: RemoteInputChannel.isReleased()
focal_class.full_signature: @Override boolean isReleased()
focal_class.identifier: isReleased
focal_class.modifiers: @Override
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isReleased()
focal_class.class_method_signature: RemoteInputChannel.notifySubpartitionConsumed()
focal_class.full_signature: @Override void notifySubpartitionConsumed()
focal_class.identifier: notifySubpartitionConsumed
focal_class.modifiers: @Override
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void notifySubpartitionConsumed()
focal_class.class_method_signature: RemoteInputChannel.releaseAllResources()
focal_class.full_signature: @Override void releaseAllResources()
focal_class.identifier: releaseAllResources
focal_class.modifiers: @Override
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void releaseAllResources()
focal_class.class_method_signature: RemoteInputChannel.failPartitionRequest()
focal_class.full_signature: public void failPartitionRequest()
focal_class.identifier: failPartitionRequest
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void failPartitionRequest()
focal_class.class_method_signature: RemoteInputChannel.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.class_method_signature: RemoteInputChannel.getNumberOfQueuedBuffers()
focal_class.full_signature: public int getNumberOfQueuedBuffers()
focal_class.identifier: getNumberOfQueuedBuffers
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getNumberOfQueuedBuffers()
focal_class.class_method_signature: RemoteInputChannel.getInputChannelId()
focal_class.full_signature: public InputChannelID getInputChannelId()
focal_class.identifier: getInputChannelId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: InputChannelID
focal_class.signature: InputChannelID getInputChannelId()
focal_class.class_method_signature: RemoteInputChannel.getBufferProvider()
focal_class.full_signature: public BufferProvider getBufferProvider()
focal_class.identifier: getBufferProvider
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: BufferProvider
focal_class.signature: BufferProvider getBufferProvider()
focal_class.class_method_signature: RemoteInputChannel.onBuffer(Buffer buffer, int sequenceNumber)
focal_class.full_signature: public void onBuffer(Buffer buffer, int sequenceNumber)
focal_class.identifier: onBuffer
focal_class.modifiers: public
focal_class.parameters: (Buffer buffer, int sequenceNumber)
focal_class.return: void
focal_class.signature: void onBuffer(Buffer buffer, int sequenceNumber)
focal_class.class_method_signature: RemoteInputChannel.onEmptyBuffer(int sequenceNumber)
focal_class.full_signature: public void onEmptyBuffer(int sequenceNumber)
focal_class.identifier: onEmptyBuffer
focal_class.modifiers: public
focal_class.parameters: (int sequenceNumber)
focal_class.return: void
focal_class.signature: void onEmptyBuffer(int sequenceNumber)
focal_class.class_method_signature: RemoteInputChannel.onFailedPartitionRequest()
focal_class.full_signature: public void onFailedPartitionRequest()
focal_class.identifier: onFailedPartitionRequest
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void onFailedPartitionRequest()
focal_class.class_method_signature: RemoteInputChannel.onError(Throwable cause)
focal_class.full_signature: public void onError(Throwable cause)
focal_class.identifier: onError
focal_class.modifiers: public
focal_class.parameters: (Throwable cause)
focal_class.return: void
focal_class.signature: void onError(Throwable cause)
focal_class.superclass: extends InputChannel
focal_method.body: void retriggerSubpartitionRequest(int subpartitionIndex) throws IOException, InterruptedException {
  		checkState(partitionRequestClient != null, "Missing initial subpartition request.");
  
  		if (increaseBackoff()) {
  			partitionRequestClient.requestSubpartition(
  					partitionId, subpartitionIndex, this, getCurrentBackoff());
  		}
  		else {
  			failPartitionRequest();
  		}
  	}
focal_method.class_method_signature: RemoteInputChannel.retriggerSubpartitionRequest(int subpartitionIndex)
focal_method.full_signature:  void retriggerSubpartitionRequest(int subpartitionIndex)
focal_method.identifier: retriggerSubpartitionRequest
focal_method.invocations: checkState increaseBackoff requestSubpartition getCurrentBackoff failPartitionRequest
focal_method.parameters: (int subpartitionIndex)
focal_method.return: void
focal_method.signature: void retriggerSubpartitionRequest(int subpartitionIndex)