import com.subgraph.orchid.misc.GuardedBy; //导入依赖的package包/类
@GuardedBy("lock")
private void processIncomingCell(RelayCell nextCell) throws IOException {
	if(isClosed || nextCell == CLOSE_SENTINEL) {
		throw new IOException("Input stream closed");
	}
	
	switch(nextCell.getRelayCommand()) {
	case RelayCell.RELAY_DATA:
		currentBuffer = nextCell.getPayloadBuffer();
		break;
	case RelayCell.RELAY_END:
		currentBuffer = EMPTY_BUFFER;
		isEOF = true;
		break;
	default:
		throw new IOException("Unexpected RelayCell command type in TorInputStream queue: "+ nextCell.getRelayCommand());
	}
}
 

import com.subgraph.orchid.misc.GuardedBy; //导入依赖的package包/类
@GuardedBy("lock")
private int readFromCurrentBuffer(byte[] b, int off, int len) {
	final int readLength = (currentBuffer.remaining() >= len) ? (len) : (currentBuffer.remaining());
	currentBuffer.get(b, off, readLength);
	availableBytes -= readLength;
	return readLength;
}
 

import com.subgraph.orchid.misc.GuardedBy; //导入依赖的package包/类
@GuardedBy("lock")
// When this method (or fillBuffer()) returns either isEOF is set or currentBuffer has at least one byte to read
private void refillBufferIfNeeded() throws IOException {
	if(!isEOF) {
		if(currentBuffer.hasRemaining()) {
			return;
		}
		fillBuffer();
	}
}
 

import com.subgraph.orchid.misc.GuardedBy; //导入依赖的package包/类
@GuardedBy("lock")
private void fillBuffer() throws IOException {
	while(true) {
		processIncomingCell(getNextCell());
		if(isEOF || currentBuffer.hasRemaining()) {
			return;
		}
	}
}
 

import com.subgraph.orchid.misc.GuardedBy; //导入依赖的package包/类
@GuardedBy("lock")
private RelayCell getNextCell() throws IOException {
	try {
		while(incomingCells.isEmpty()) {
			lock.wait();
		}
		return incomingCells.remove();
	} catch (InterruptedException e) {
		Thread.currentThread().interrupt();
		throw new IOException("Read interrupted");
	}
}