home *** CD-ROM | disk | FTP | other *** search
- package sun.tools.debug;
-
- import java.io.DataInputStream;
-
- class AgentIn implements Runnable, AgentConstants {
- RemoteAgent agent;
- DebuggerCallback client;
- // $FF: renamed from: in java.io.DataInputStream
- DataInputStream field_0;
-
- AgentIn(RemoteAgent var1, DataInputStream var2, DebuggerCallback var3, boolean var4) {
- this.agent = var1;
- this.client = var3;
- this.field_0 = var2;
- }
-
- public void run() {
- Agent.addSystemThread(Thread.currentThread());
- Thread.currentThread().setPriority(10);
- boolean var1 = false;
-
- try {
- while(true) {
- int var9 = this.field_0.read();
- switch (var9) {
- case -1:
- if (!var1) {
- this.client.printToConsole("\nThe communications channel closed.\n");
- this.agent.closeRemoteInterpreter = false;
- this.agent.close();
- this.client.quitEvent();
- return;
- }
- case 33:
- int var12 = this.field_0.read();
- byte[] var13 = new byte[var12];
- this.field_0.readFully(var13, 0, var12);
- String var5 = new String(var13, 0);
- this.client.printToConsole(var5);
- break;
- case 46:
- RemoteThread var11 = (RemoteThread)this.agent.readValue(this.field_0);
- this.client.breakpointEvent(var11);
- break;
- case 52:
- this.agent.message("AgentIn: exceptionEvent!");
- RemoteThread var10 = (RemoteThread)this.agent.readValue(this.field_0);
- String var4 = this.field_0.readUTF();
- this.agent.message("text=" + var4);
- this.client.exceptionEvent(var10, var4);
- break;
- case 66:
- RemoteThread var3 = (RemoteThread)this.agent.readValue(this.field_0);
- this.agent.message("AgentIn: threadDeath in " + var3.getName());
- this.client.threadDeathEvent(var3);
- break;
- case 67:
- var1 = true;
- this.client.quitEvent();
- this.agent.closeRemoteInterpreter = false;
- this.agent.close();
- return;
- }
- }
- } catch (Exception var7) {
- Exception var2 = var7;
-
- try {
- if (!var1) {
- this.client.printToConsole("\nFatal exception: " + var2 + "\n");
- ((Throwable)var2).printStackTrace();
- this.agent.closeRemoteInterpreter = false;
- this.agent.close();
- this.client.quitEvent();
- }
- } catch (Exception var6) {
- }
- }
- }
- }
-