import com.subgraph.orchid.HiddenServiceCircuit; //导入依赖的package包/类
HiddenServiceCircuit processRendezvous2(TorTapKeyAgreement kex) {
	final RelayCell cell = circuit.receiveRelayCell();
	if(cell == null) {
		logger.info("Timeout waiting for RENDEZVOUS2");
		return null;
	} else if (cell.getRelayCommand() != RelayCell.RELAY_COMMAND_RENDEZVOUS2) {
		logger.info("Unexpected Relay cell type received while waiting for RENDEZVOUS2: "+ cell.getRelayCommand());
		return null;
	}
	final BigInteger peerPublic = readPeerPublic(cell);
	final HexDigest handshakeDigest = readHandshakeDigest(cell);
	if(peerPublic == null || handshakeDigest == null) {
		return null;
	}
	final byte[] verifyHash = new byte[TorMessageDigest.TOR_DIGEST_SIZE];
	final byte[] keyMaterial = new byte[CircuitNodeCryptoState.KEY_MATERIAL_SIZE];
	if(!kex.deriveKeysFromDHPublicAndHash(peerPublic, handshakeDigest.getRawBytes(), keyMaterial, verifyHash)) {
		logger.info("Error deriving session keys while extending to hidden service");
		return null;
	}
	return circuit.connectHiddenService(CircuitNodeImpl.createAnonymous(circuit.getFinalCircuitNode(), keyMaterial, verifyHash));
}
 

import com.subgraph.orchid.HiddenServiceCircuit; //导入依赖的package包/类
public HiddenServiceCircuit connectHiddenService(CircuitNode node) {
	if(type != InternalType.UNUSED) {
		throw new IllegalStateException("Cannot connect hidden service from internal circuit type "+ type);
	}
	appendNode(node);
	type = InternalType.HS_CIRCUIT;
	return this;
}
 

import com.subgraph.orchid.HiddenServiceCircuit; //导入依赖的package包/类
public Stream getStreamTo(String onion, int port) throws OpenFailedException, InterruptedException, TimeoutException {
	final HiddenService hs = getHiddenServiceForOnion(onion);
	final HiddenServiceCircuit circuit = getCircuitTo(hs);
	
	try {
		return circuit.openStream(port, HS_STREAM_TIMEOUT);
	} catch (StreamConnectFailedException e) {
		throw new OpenFailedException("Failed to open stream to hidden service "+ hs.getOnionAddressForLogging() + " reason "+ e.getReason());
	}
}
 

import com.subgraph.orchid.HiddenServiceCircuit; //导入依赖的package包/类
private synchronized HiddenServiceCircuit getCircuitTo(HiddenService hs) throws OpenFailedException {
	if(hs.getCircuit() == null) {
		final HiddenServiceCircuit c = openCircuitTo(hs);
		if(c == null) {
			throw new OpenFailedException("Failed to open circuit to "+ hs.getOnionAddressForLogging());
		}
		hs.setCircuit(c);
	}
	return hs.getCircuit();
}
 

import com.subgraph.orchid.HiddenServiceCircuit; //导入依赖的package包/类
private HiddenServiceCircuit openCircuitTo(HiddenService hs) throws OpenFailedException {
	HSDescriptor descriptor = getDescriptorFor(hs);
	
	for(int i = 0; i < RENDEZVOUS_RETRY_COUNT; i++) {
		final HiddenServiceCircuit c = openRendezvousCircuit(hs, descriptor);
		if(c != null) {
			return c;
		}
	}
	throw new OpenFailedException("Failed to open circuit to "+ hs.getOnionAddressForLogging());
}
 

import com.subgraph.orchid.HiddenServiceCircuit; //导入依赖的package包/类
private HiddenServiceCircuit openRendezvousCircuit(HiddenService hs, HSDescriptor descriptor) {
	final RendezvousCircuitBuilder builder = new RendezvousCircuitBuilder(directory, circuitManager, hs, descriptor);
	try {
		return builder.call();
	} catch (Exception e) {
		return null;
	}
}
 

import com.subgraph.orchid.HiddenServiceCircuit; //导入依赖的package包/类
public HiddenServiceCircuit call() throws Exception {
	
	logger.fine("Opening rendezvous circuit for "+ logServiceName());
	
	final InternalCircuit rendezvous = circuitManager.getCleanInternalCircuit();
	logger.fine("Establishing rendezvous for "+ logServiceName());
	RendezvousProcessor rp = new RendezvousProcessor(rendezvous);
	if(!rp.establishRendezvous()) {
		rendezvous.markForClose();
		return null;
	}
	logger.fine("Opening introduction circuit for "+ logServiceName());
	final IntroductionProcessor introductionProcessor = openIntroduction();
	if(introductionProcessor == null) {
		logger.info("Failed to open connection to any introduction point");
		rendezvous.markForClose();
		return null;
	}
	logger.fine("Sending introduce cell for "+ logServiceName());
	final TorTapKeyAgreement kex = new TorTapKeyAgreement();
	final boolean icResult = introductionProcessor.sendIntroduce(introductionProcessor.getServiceKey(), kex.getPublicKeyBytes(), rp.getCookie(), rp.getRendezvousRouter());
	introductionProcessor.markCircuitForClose();
	if(!icResult) {
		rendezvous.markForClose();
		return null;
	}
	logger.fine("Processing RV2 for "+ logServiceName());
	HiddenServiceCircuit hsc = rp.processRendezvous2(kex);
	if(hsc == null) {
		rendezvous.markForClose();
	}

	logger.fine("Rendezvous circuit opened for "+ logServiceName());
	
	return hsc;
}