34 lines
897 B
Java
34 lines
897 B
Java
/*
|
|
* Decompiled with CFR 0.152.
|
|
*/
|
|
package com.tridium.fox.session;
|
|
|
|
import com.tridium.fox.session.FoxFrame;
|
|
import com.tridium.fox.session.FoxSession;
|
|
import com.tridium.fox.session.SessionReceiver;
|
|
|
|
public class TunnelReceiver
|
|
extends SessionReceiver {
|
|
public TunnelReceiver(FoxSession foxSession) {
|
|
super(foxSession);
|
|
this.name = "Fox:TunnelReceiver:" + foxSession.getId();
|
|
}
|
|
|
|
public void run() {
|
|
while (this.isAlive && !this.session.isClosed()) {
|
|
try {
|
|
FoxFrame foxFrame = this.session.readTunnelFrame();
|
|
if (this.session.isClosed()) break;
|
|
this.session.writeFrame(foxFrame);
|
|
}
|
|
catch (Throwable throwable) {
|
|
if (this.isAlive) {
|
|
this.session.close(throwable);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|