import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
@BeforeMethod
  @Override
  protected void setUp() throws Exception {
    super.setUp();
//    setPartialMessagesChecker();
    new TeamCityProperties() {{
      setModel(new BasePropertiesModel() {
        @NotNull
        @Override
        public Map<String, String> getUserDefinedProperties() {
          return CollectionsUtil.asMap("teamcity.agent.build.messages.translators.enabled", "true");
        }
      });
    }};
    myEventDispatcher = EventDispatcher.create(AgentLifeCycleListener.class);
    myCurrentBuildTracker = new CurrentBuildTrackerImpl(myEventDispatcher);
    myTranslatorsRegistry = new TranslatorsRegistryImpl();
    myParserLoader = new ParserLoaderImpl(myCurrentBuildTracker);
    myParsersRegistry = new ParsersRegistryImpl(myTranslatorsRegistry, myParserLoader);
  }
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public UserUIDAndGIDImpl(@NotNull final EventDispatcher<AgentLifeCycleListener> events) {

    events.addListener(new AgentLifeCycleAdapter(){
      @Override
      public void afterAgentConfigurationLoaded(@NotNull final BuildAgent agent) {
        final BuildAgentConfiguration configuration = agent.getConfiguration();

        if (configuration.getConfigurationParameters().get(VMConstants.DOCKER_PROPERTY) == null) return;
        if (!configuration.getSystemInfo().isUnix()) return;
        if (configuration.getSystemInfo().isWindows()) return;
        if (configuration.getSystemInfo().isMac()) return;

        detectSidAndGid();
      }
    });
  }
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public PowerShellInfoProvider(@NotNull final BuildAgentConfiguration config,
                              @NotNull final EventDispatcher<AgentLifeCycleListener> events,
                              @NotNull final List<PowerShellDetector> detectors) {
  myConfig = config;
  events.addListener(new AgentLifeCycleAdapter(){

    @Override
    public void afterAgentConfigurationLoaded(@NotNull BuildAgent agent) {
      registerDetectedPowerShells(detectors, new DetectionContext(agent.getConfiguration()));
    }
  });
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public HelmAgentConfigurationProvider(@NotNull EventDispatcher<AgentLifeCycleListener> agentEvents) {
    agentEvents.addListener(new AgentLifeCycleAdapter(){
        @Override
        public void beforeAgentConfigurationLoaded(@NotNull BuildAgent agent) {
            File defaultHelmLocation = new File("/usr/local/bin/helm");
            if(defaultHelmLocation.exists()){
                agent.getConfiguration().addConfigurationParameter(HELM_PATH_CONFIG_PARAM, defaultHelmLocation.getAbsolutePath());
            }
            super.beforeAgentConfigurationLoaded(agent);
        }
    });
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public KubeAgentConfigurationProvider(@NotNull EventDispatcher<AgentLifeCycleListener> agentEvents,
                                      @NotNull BuildAgentConfigurationEx agentConfigurationEx) {
    myAgentConfigurationEx = agentConfigurationEx;
    agentEvents.addListener(new AgentLifeCycleAdapter(){
        @Override
        public void afterAgentConfigurationLoaded(@NotNull BuildAgent agent) {
            super.afterAgentConfigurationLoaded(agent);
            appendKubeSpecificConfiguration();
        }
    });
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public ContainerCloudAgentPropertiesSetter(final BuildAgentConfigurationEx agentConfiguration,
                                           @NotNull EventDispatcher<AgentLifeCycleListener> events) {
    LOG.info("Created ContainerCloudAgentPropertiesSetter");
    this.agentConfiguration = agentConfiguration;
    this.events = events;

    events.addListener(new AgentLifeCycleAdapter() {
        @Override
        public void afterAgentConfigurationLoaded(@NotNull BuildAgent buildAgent) {
            LOG.info("ContainerCloudAgentPropertiesSetter: Setting terminate after build flag");
            agentConfiguration.addConfigurationParameter(CloudConstants.AGENT_TERMINATE_AFTER_BUILD, "true");
        }
    });
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
@BeforeMethod
public void setUp() throws Exception {
  super.setUp();
  EventDispatcher<AgentLifeCycleListener> dispatcher = EventDispatcher.create(AgentLifeCycleListener.class);

  BuildAgentConfiguration agentConfiguration = myAgentConfigurationFixture.setUp();
  final TorrentConfiguration trackerConfiguration = new FakeTorrentConfiguration();

  Mockery m = new Mockery();
  final LeechSettings leechSettings = m.mock(LeechSettings.class);
  final SeedSettings seedingSettings = m.mock(SeedSettings.class);
  final ArtifactCacheProvider cacheProvider = m.mock(ArtifactCacheProvider.class);
  m.checking(new Expectations() {{
    allowing(cacheProvider).addListener(with(any(TorrentArtifactCacheListener.class)));
    allowing(leechSettings).isDownloadEnabled(); will(returnValue(true));
    allowing(seedingSettings).isSeedingEnabled(); will(returnValue(true));
  }});
  final ArtifactsWatcher artifactsWatcher = m.mock(ArtifactsWatcher.class);

  AgentTorrentsSeeder seeder = new AgentTorrentsSeeder(agentConfiguration, trackerConfiguration);
  TorrentFilesFactoryImpl tff = new TorrentFilesFactoryImpl(agentConfiguration, trackerConfiguration, new FakeAgentIdleTasks(), seeder);

  myTorrentsDownloadStatistic = new TorrentsDownloadStatistic();
  myTorrentsManager = new AgentTorrentsManager(dispatcher,
          cacheProvider,
          new CurrentBuildTrackerImpl(dispatcher),
          trackerConfiguration,
          seeder,
          tff,
          artifactsWatcher,
          myTorrentsDownloadStatistic, leechSettings, agentConfiguration, seedingSettings);
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public RuntestToolProvider(@NotNull final ToolProvidersRegistry toolProvidersRegistry, @NotNull final EventDispatcher<AgentLifeCycleListener> eventDispatcher, @NotNull final String toolName, @NotNull final String versionArg) {
  super(toolProvidersRegistry, eventDispatcher, toolName, versionArg);
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public WinDbgToolsDetector(@NotNull final EventDispatcher<AgentLifeCycleListener> events,
                           @NotNull final Win32RegistryAccessor registryAccessor) {
  myRegistryAccessor = registryAccessor;
  events.addListener(this);
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public AppAgent(@NotNull EventDispatcher<AgentLifeCycleListener> dispatcher) {
    s = new StringBuilder();
    dispatcher.addListener(this);
}
 

import jetbrains.buildServer.agent.AgentLifeCycleListener; //导入依赖的package包/类
public AnsibleReportArtifatcsProvider(
        @NotNull ArtifactsWatcher artifactsWatcher,
        @NotNull EventDispatcher<AgentLifeCycleListener> agentDispatcher) {
    agentDispatcher.addListener(this);
    this.artifactsWatcher = artifactsWatcher;
}