import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
public void sendCell(Cell cell) throws ConnectionIOException  {
	if(!socket.isConnected()) {
		throw new ConnectionIOException("Cannot send cell because connection is not connected");
	}
	updateLastActivity();
	outputLock.lock();
	try {
		try {
			output.write(cell.getCellBytes());
		} catch (IOException e) {
			logger.fine("IOException writing cell to connection "+ e.getMessage());
			closeSocket();
			throw new ConnectionIOException(e.getClass().getName() + " : "+ e.getMessage());
		}
	} finally {
		outputLock.unlock();
	}
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
void runHandshake() throws IOException, InterruptedException, ConnectionIOException {
	// Swap in V1-only ciphers for second handshake as a workaround for:
	//
	//     https://trac.torproject.org/projects/tor/ticket/4591
	// 
	socket.setEnabledCipherSuites(ConnectionSocketFactory.V1_CIPHERS_ONLY);
	
	final HandshakeFinishedMonitor monitor = new HandshakeFinishedMonitor();
	socket.addHandshakeCompletedListener(monitor);
	socket.startHandshake();
	monitor.waitFinished();
	socket.removeHandshakeCompletedListener(monitor);
	
	verifyIdentityKey(getIdentityKey());
	sendVersions(2);
	receiveVersions();
	sendNetinfo();
	recvNetinfo();
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
private void doConnect() throws IOException, InterruptedException, ConnectionIOException {
	connectSocket();
	final ConnectionHandshake handshake = ConnectionHandshake.createHandshake(config, this, socket);
	input = socket.getInputStream();
	output = socket.getOutputStream();
	readCellsThread.start();
	handshake.runHandshake();
	updateLastActivity();
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
Cell readConnectionControlCell() throws ConnectionIOException {
	try {
		return connectionControlCells.take();
	} catch (InterruptedException e) {
		closeSocket();
		throw new ConnectionIOException();
	}
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
void runHandshake() throws IOException, InterruptedException, ConnectionIOException {
	sendVersions(3);
	receiveVersions();
	recvCerts();
	recvAuthChallengeAndNetinfo();
	verifyCertificates();
	sendNetinfo();
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
protected Cell expectCell(Integer... expectedTypes) throws ConnectionHandshakeException {
	try {
		final Cell c = connection.readConnectionControlCell();
		for(int t: expectedTypes) {
			if(c.getCommand() == t) {
				return c;
			}
		}
		final List<Integer> expected = Arrays.asList(expectedTypes);
		throw new ConnectionHandshakeException("Expecting Cell command "+ expected + " and got [ "+ c.getCommand() +" ] instead");
	} catch (ConnectionIOException e) {
		throw new ConnectionHandshakeException("Connection exception while performing handshake "+ e);
	}
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
protected  void sendVersions(int... versions) throws ConnectionIOException {
	final Cell cell = CellImpl.createVarCell(0, Cell.VERSIONS, versions.length * 2);
	for(int v: versions) {
		cell.putShort(v);
	}
	connection.sendCell(cell);
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
protected void sendNetinfo() throws ConnectionIOException {
	final Cell cell = CellImpl.createCell(0, Cell.NETINFO);
	putTimestamp(cell);
	putIPv4Address(cell, connection.getRouter().getAddress());
	putMyAddresses(cell);
	connection.sendCell(cell);
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
void sendCell(Cell cell) {
	final CircuitStatus status = circuit.getStatus();
	if(!(status.isConnected() || status.isBuilding()))
		return;
	try {
		status.updateDirtyTimestamp();
		connection.sendCell(cell);
	} catch (ConnectionIOException e) {
		destroyCircuit();
	}
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
void sendDestroyCell(int reason) {
	Cell destroy = CellImpl.createCell(circuitId, Cell.DESTROY);
	destroy.putByte(reason);
	try {
		connection.sendCell(destroy);
	} catch (ConnectionIOException e) {
		logger.warning("Connection IO error sending DESTROY cell: "+ e.getMessage());
	}
}
 

import com.subgraph.orchid.ConnectionIOException; //导入依赖的package包/类
public void sendCell(Cell cell) throws ConnectionIOException  {
	if(!socket.isConnected()) {
		throw new ConnectionIOException("Cannot send cell because connection is not connected");
	}
	updateLastActivity();
	synchronized(output) {
		try {
			output.write(cell.getCellBytes());
		} catch (IOException e) {
			logger.fine("IOException writing cell to connection "+ e.getMessage());
			closeSocket();
			throw new ConnectionIOException(e.getClass().getName() + " : "+ e.getMessage());
		}
	}
}