import com.subgraph.orchid.crypto.TorTapKeyAgreement; //导入依赖的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.crypto.TorTapKeyAgreement; //导入依赖的package包/类
private CircuitNode processExtendResponse(RelayCell response) {
	final byte[] handshakeResponse = new byte[TorTapKeyAgreement.DH_LEN + TorMessageDigest.TOR_DIGEST_SIZE];
	response.getByteArray(handshakeResponse);
	
	final byte[] keyMaterial = new byte[CircuitNodeCryptoState.KEY_MATERIAL_SIZE];
	final byte[] verifyDigest = new byte[TorMessageDigest.TOR_DIGEST_SIZE];
	if(!kex.deriveKeysFromHandshakeResponse(handshakeResponse, keyMaterial, verifyDigest)) {
		return null;
	}
	return extender.createNewNode(router, keyMaterial, verifyDigest);
}
 

import com.subgraph.orchid.crypto.TorTapKeyAgreement; //导入依赖的package包/类
private BigInteger readPeerPublic(Cell cell) {
	final byte[] dhPublic = new byte[TorTapKeyAgreement.DH_LEN];
	cell.getByteArray(dhPublic);
	final BigInteger peerPublic = new BigInteger(1, dhPublic);
	if(!TorTapKeyAgreement.isValidPublicValue(peerPublic)) {
		logger.warning("Illegal DH public value received: "+ peerPublic);
		return null;
	}
	return peerPublic;
}
 

import com.subgraph.orchid.crypto.TorTapKeyAgreement; //导入依赖的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;
}
 

import com.subgraph.orchid.crypto.TorTapKeyAgreement; //导入依赖的package包/类
public TapCircuitExtender(CircuitExtender extender, Router router) {
	this.extender = extender;
	this.router = router;
	this.kex = new TorTapKeyAgreement(router.getOnionKey());
}