mirror of
https://github.com/alibaba/arthas.git
synced 2024-04-21 10:21:39 +00:00
Replace JobControllerImpl with interface JobController
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
package com.taobao.arthas.core.shell.session;
|
||||
|
||||
import com.taobao.arthas.core.shell.system.JobController;
|
||||
import com.taobao.arthas.core.shell.system.impl.InternalCommandManager;
|
||||
import com.taobao.arthas.core.shell.system.impl.JobControllerImpl;
|
||||
|
||||
import java.lang.instrument.Instrumentation;
|
||||
|
||||
@@ -25,5 +25,5 @@ public interface SessionManager {
|
||||
|
||||
Instrumentation getInstrumentation();
|
||||
|
||||
JobControllerImpl getJobController();
|
||||
JobController getJobController();
|
||||
}
|
||||
|
||||
+4
-4
@@ -11,8 +11,8 @@ import com.taobao.arthas.core.shell.ShellServerOptions;
|
||||
import com.taobao.arthas.core.shell.session.Session;
|
||||
import com.taobao.arthas.core.shell.session.SessionManager;
|
||||
import com.taobao.arthas.core.shell.system.Job;
|
||||
import com.taobao.arthas.core.shell.system.JobController;
|
||||
import com.taobao.arthas.core.shell.system.impl.InternalCommandManager;
|
||||
import com.taobao.arthas.core.shell.system.impl.JobControllerImpl;
|
||||
|
||||
import java.lang.instrument.Instrumentation;
|
||||
import java.util.*;
|
||||
@@ -28,7 +28,7 @@ public class SessionManagerImpl implements SessionManager {
|
||||
private final ArthasBootstrap bootstrap;
|
||||
private final InternalCommandManager commandManager;
|
||||
private final Instrumentation instrumentation;
|
||||
private final JobControllerImpl jobController;
|
||||
private final JobController jobController;
|
||||
private final long timeoutMillis;
|
||||
private final long reaperInterval;
|
||||
private final Map<String, Session> sessions;
|
||||
@@ -37,7 +37,7 @@ public class SessionManagerImpl implements SessionManager {
|
||||
private ScheduledExecutorService scheduledExecutorService;
|
||||
|
||||
public SessionManagerImpl(ShellServerOptions options, ArthasBootstrap bootstrap, InternalCommandManager commandManager,
|
||||
JobControllerImpl jobController) {
|
||||
JobController jobController) {
|
||||
this.bootstrap = bootstrap;
|
||||
this.commandManager = commandManager;
|
||||
this.jobController = jobController;
|
||||
@@ -187,7 +187,7 @@ public class SessionManagerImpl implements SessionManager {
|
||||
}
|
||||
|
||||
@Override
|
||||
public JobControllerImpl getJobController() {
|
||||
public JobController getJobController() {
|
||||
return jobController;
|
||||
}
|
||||
}
|
||||
|
||||
+2
-2
@@ -20,9 +20,9 @@ import com.taobao.arthas.core.shell.history.impl.HistoryManagerImpl;
|
||||
import com.taobao.arthas.core.shell.session.Session;
|
||||
import com.taobao.arthas.core.shell.session.SessionManager;
|
||||
import com.taobao.arthas.core.shell.system.Job;
|
||||
import com.taobao.arthas.core.shell.system.JobController;
|
||||
import com.taobao.arthas.core.shell.system.JobListener;
|
||||
import com.taobao.arthas.core.shell.system.impl.InternalCommandManager;
|
||||
import com.taobao.arthas.core.shell.system.impl.JobControllerImpl;
|
||||
import com.taobao.arthas.core.shell.term.SignalHandler;
|
||||
import com.taobao.arthas.core.shell.term.Term;
|
||||
import com.taobao.arthas.core.util.ArthasBanner;
|
||||
@@ -58,7 +58,7 @@ public class HttpApiHandler {
|
||||
private final AtomicInteger requestIdGenerator = new AtomicInteger(0);
|
||||
private static HttpApiHandler instance;
|
||||
private final InternalCommandManager commandManager;
|
||||
private final JobControllerImpl jobController;
|
||||
private final JobController jobController;
|
||||
private final HistoryManager historyManager;
|
||||
|
||||
private int jsonBufferSize = 1024 * 256;
|
||||
|
||||
Reference in New Issue
Block a user