import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
public synchronized void addDescriptors(List<T> descriptors) {
	final List<T> journalDescriptors = new ArrayList<T>();
	int duplicateCount = 0;
	for(T d: descriptors) {
		if(data.addDescriptor(d)) {
			if(d.getCacheLocation() == Descriptor.CacheLocation.NOT_CACHED) {
				journalLength += d.getBodyLength();
				journalDescriptors.add(d);
			}
		} else {
			duplicateCount += 1;
		}
	}

	if(!journalDescriptors.isEmpty()) {
		store.appendDocumentList(journalFile, journalDescriptors);
	}
	if(duplicateCount > 0) {
		logger.info("Duplicate descriptors added to journal, count = "+ duplicateCount);
	}
}
 

import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
private void loadJournalFileBuffer(ByteBuffer buffer) {
	journalLength = buffer.limit();
	if(journalLength == 0) {
		return;
	}
	final DocumentParser<T> parser = createDocumentParser(buffer);
	final DocumentParsingResult<T> result = parser.parse();
	if(result.isOkay()) {
		int duplicateCount = 0;
		logger.fine("Loaded "+ result.getParsedDocuments().size() + " descriptors from journal");
		for(T d: result.getParsedDocuments()) {
			d.setCacheLocation(Descriptor.CacheLocation.CACHED_JOURNAL);
			if(!data.addDescriptor(d)) {
				duplicateCount += 1;
			}
		} 
		if(duplicateCount > 0) {
			logger.info("Found "+ duplicateCount + " duplicate descriptors in journal file");
		}
	} else if(result.isInvalid()) {
		logger.warning("Invalid descriptor data parsing from journal file : "+ result.getMessage());
	} else if(result.isError()) {
		logger.warning("Error parsing descriptors from journal file : "+ result.getMessage());			
	}
}
 

import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
private Descriptor getDescriptorForRouterStatus(RouterStatus rs, boolean isMicrodescriptor) {
	if(isMicrodescriptor) {
		return microdescriptorCache.getDescriptor(rs.getMicrodescriptorDigest());
	} else {
		return basicDescriptorCache.getDescriptor(rs.getDescriptorDigest());
	}
}
 

import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
private <T extends Descriptor> List<T> removeUnrequestedDescriptors(Set<HexDigest> requested, List<T> received) {
	final List<T> result = new ArrayList<T>();
	int unrequestedCount = 0;
	for(T d: received) {
		if(requested.contains(d.getDescriptorDigest())) {
			result.add(d);
		} else {
			unrequestedCount += 1;
		}
	}
	if(unrequestedCount > 0) {
		logger.warning("Discarding "+ unrequestedCount + " received descriptor(s) with fingerprints that did not match requested descriptors");
	}
	return result;
}
 

import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
private void loadCacheFileBuffer(ByteBuffer buffer) {
	cacheLength = buffer.limit();
	if(cacheLength == 0) {
		return;
	}
	final DocumentParser<T> parser = createDocumentParser(buffer);
	final DocumentParsingResult<T> result = parser.parse();
	if(result.isOkay()) {
		for(T d: result.getParsedDocuments()) {
			d.setCacheLocation(Descriptor.CacheLocation.CACHED_CACHEFILE);
			data.addDescriptor(d);
		}
	}

}
 

import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
public synchronized void addConsensusDocument(ConsensusDocument consensus, boolean fromCache) {
	if(consensus.equals(currentConsensus))
		return;

	if(currentConsensus != null && consensus.getValidAfterTime().isBefore(currentConsensus.getValidAfterTime())) {
		logger.warning("New consensus document is older than current consensus document");
		return;
	}

	synchronized(TrustedAuthorities.getInstance()) {
		switch(consensus.verifySignatures()) {
		case STATUS_FAILED:
			logger.warning("Unable to verify signatures on consensus document, discarding...");
			return;
			
		case STATUS_NEED_CERTS:
			consensusWaitingForCertificates = consensus;
			requiredCertificates.addAll(consensus.getRequiredCertificates());
			return;

		case STATUS_VERIFIED:
			break;
		}
		requiredCertificates.addAll(consensus.getRequiredCertificates());
	
	}
	final Map<HexDigest, RouterImpl> oldRouterByIdentity = new HashMap<HexDigest, RouterImpl>(routersByIdentity);

	clearAll();

	for(RouterStatus status: consensus.getRouterStatusEntries()) {
		if(status.hasFlag("Running") && status.hasFlag("Valid")) {
			final RouterImpl router = updateOrCreateRouter(status, oldRouterByIdentity);
			addRouter(router);
			classifyRouter(router);
		}
		final Descriptor d = getDescriptorForRouterStatus(status, consensus.getFlavor() == ConsensusFlavor.MICRODESC);
		if(d != null) {
			d.setLastListed(consensus.getValidAfterTime().getTime());
		}
	}
	
	logger.fine("Loaded "+ routersByIdentity.size() +" routers from consensus document");
	currentConsensus = consensus;
	
	if(!fromCache) {
		storeCurrentConsensus();
	}
	consensusChangedManager.fireEvent(new Event() {});
}
 

import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
public Descriptor getCurrentDescriptor() {
	refreshDescriptor();
	return descriptor;
}
 

import com.subgraph.orchid.Descriptor; //导入依赖的package包/类
public Descriptor getCurrentDescriptor() {
	return descriptor;
}