import com.subgraph.orchid.circuits.cells.RelayCellImpl; //导入依赖的package包/类
public RelayCell receiveRelayResponse(int expectedCommand, Router extendTarget) {
	final RelayCell cell = circuit.receiveRelayCell();
	if(cell == null) {
		throw new TorException("Timeout building circuit");
	}
	final int command = cell.getRelayCommand();
	if(command == RelayCell.RELAY_TRUNCATED) {
		final int code = cell.getByte() & 0xFF;
		final String msg = CellImpl.errorToDescription(code);
		final String source = nodeToName(cell.getCircuitNode());
		if(code == Cell.ERROR_PROTOCOL) {
			logProtocolViolation(source, extendTarget);
		}
		throw new TorException("Error from ("+ source +") while extending to ("+ extendTarget.getNickname() + "): "+ msg);
	} else if(command != expectedCommand) {
		final String expected = RelayCellImpl.commandToDescription(expectedCommand);
		final String received = RelayCellImpl.commandToDescription(command);
		throw new TorException("Received incorrect extend response, expecting "+ expected + " but received "+ received);
	} else {
		return cell;
	}
}
 

import com.subgraph.orchid.circuits.cells.RelayCellImpl; //导入依赖的package包/类
public void close() {
	if(isClosed)
		return;
	
	logger.fine("Closing stream "+ this);
	
	isClosed = true;
	inputStream.close();
	outputStream.close();
	circuit.removeStream(this);
	if(autoclose) {
		circuit.markForClose();
	}
	
	if(!relayEndReceived) {
		final RelayCell cell = new RelayCellImpl(circuit.getFinalCircuitNode(), circuit.getCircuitId(), streamId, RelayCell.RELAY_END);
		cell.putByte(RelayCell.REASON_DONE);
		circuit.sendRelayCellToFinalNode(cell);
	}
}
 

import com.subgraph.orchid.circuits.cells.RelayCellImpl; //导入依赖的package包/类
private RelayCell decryptRelayCell(Cell cell) {
	for(CircuitNode node: circuit.getNodeList()) {
		if(node.decryptBackwardCell(cell)) {
			return RelayCellImpl.createFromCell(node, cell);
		}
	}
	destroyCircuit();
	throw new TorException("Could not decrypt relay cell");
}
 

import com.subgraph.orchid.circuits.cells.RelayCellImpl; //导入依赖的package包/类
void openExit(String target, int port, long timeout) throws InterruptedException, TimeoutException, StreamConnectFailedException {
	streamTarget = target + ":"+ port;
	final RelayCell cell = new RelayCellImpl(circuit.getFinalCircuitNode(), circuit.getCircuitId(), streamId, RelayCell.RELAY_BEGIN);
	cell.putString(target + ":"+ port);
	circuit.sendRelayCellToFinalNode(cell);
	waitForRelayConnected(timeout);
}
 

import com.subgraph.orchid.circuits.cells.RelayCellImpl; //导入依赖的package包/类
public RelayCell createRelayCell(int command) {
	return new RelayCellImpl(circuit.getFinalCircuitNode(), circuit.getCircuitId(), 0, command, true);
}
 

import com.subgraph.orchid.circuits.cells.RelayCellImpl; //导入依赖的package包/类
RelayCell createRelayCell(int relayCommand, int streamId, CircuitNode targetNode) {
	return new RelayCellImpl(targetNode, circuitId, streamId, relayCommand);
}
 

import com.subgraph.orchid.circuits.cells.RelayCellImpl; //导入依赖的package包/类
public void openDirectory(long timeout) throws InterruptedException, TimeoutException, StreamConnectFailedException {
	streamTarget = "[Directory]";
	final RelayCell cell = new RelayCellImpl(circuit.getFinalCircuitNode(), circuit.getCircuitId(), streamId, RelayCell.RELAY_BEGIN_DIR);
	circuit.sendRelayCellToFinalNode(cell);
	waitForRelayConnected(timeout);
}