mirror of
https://github.com/Qortal/altcoinj.git
synced 2025-11-03 05:57:21 +00:00
@@ -289,29 +289,33 @@ public class ConnectionImpl implements Connection, DashboardRenderable {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void processRelayCell(Cell cell) {
|
private void processRelayCell(Cell cell) {
|
||||||
|
Circuit circuit;
|
||||||
circuitsLock.lock();
|
circuitsLock.lock();
|
||||||
try {
|
try {
|
||||||
final Circuit circuit = circuitMap.get(cell.getCircuitId());
|
circuit = circuitMap.get(cell.getCircuitId());
|
||||||
if(circuit == null) {
|
if(circuit == null) {
|
||||||
logger.warning("Could not deliver relay cell for circuit id = "+ cell.getCircuitId() +" on connection "+ this +". Circuit not found");
|
logger.warning("Could not deliver relay cell for circuit id = "+ cell.getCircuitId() +" on connection "+ this +". Circuit not found");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
circuit.deliverRelayCell(cell);
|
|
||||||
} finally {
|
} finally {
|
||||||
circuitsLock.unlock();
|
circuitsLock.unlock();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
circuit.deliverRelayCell(cell);
|
||||||
}
|
}
|
||||||
|
|
||||||
private void processControlCell(Cell cell) {
|
private void processControlCell(Cell cell) {
|
||||||
|
Circuit circuit;
|
||||||
circuitsLock.lock();
|
circuitsLock.lock();
|
||||||
try {
|
try {
|
||||||
final Circuit circuit = circuitMap.get(cell.getCircuitId());
|
circuit = circuitMap.get(cell.getCircuitId());
|
||||||
if(circuit != null) {
|
|
||||||
circuit.deliverControlCell(cell);
|
|
||||||
}
|
|
||||||
} finally {
|
} finally {
|
||||||
circuitsLock.unlock();
|
circuitsLock.unlock();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if(circuit != null) {
|
||||||
|
circuit.deliverControlCell(cell);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void idleCloseCheck() {
|
void idleCloseCheck() {
|
||||||
|
|||||||
Reference in New Issue
Block a user