Package jetbrains.buildServer.serverSide.impl.persisting

Class PersistTasksStorage

java.lang.Object

jetbrains.buildServer.serverSide.impl.persisting.PersistTasksStorage

All Implemented Interfaces:

AfterBuildsCleanupExtension, ServerExtension, TeamCityExtension

public class PersistTasksStorage
extends Object
implements AfterBuildsCleanupExtension

Constructor Summary

Constructors

Constructor	Description
PersistTasksStorage(SQLRunnerEx sqlRunner, ServerResponsibility serverResponsibility, Heartbeat heartbeat, EventDispatcher<BuildServerListener> eventDispatcher, ServerMetrics serverMetrics)

Method Summary

Modifier and Type	Method	Description
void	afterCleanup(CleanupProcessState cleanupState)	Invoked upon finishing of the main cleanup process.
List<TaskInfo>	getNextReadyForExecutionTasks(String taskType, int maxTasksToReturn)
List<TaskInfo>	getNextReadyForExecutionTasks(TaskType taskType, int maxTasksToReturn)	Searches for the next task with states PersistTaskStage.PREPARE, PersistTaskStage.TASK_WITH_METADATA_READY or PersistTaskStage.TASK_READY and returns its info if such a task should be processed by the current node or null otherwise.
static int	getStageIndex(PersistTaskStage stage)
TaskInfo	getTaskInfo(Long taskId)
Map<Long,TaskInfo>	getTasksInfo(Collection<Long> ids)
List<TaskInfo>	getUnfinishedTasks(TaskType taskType)
void	markAsUpdated(long taskId)
long	newTask(String taskType, String description)
long	newTask(TaskType taskType, String description)
void	recreatePersistTasksStorageMonitor(long delay)
void	setStage(long taskId, PersistTaskStage stage)
void	setTimeService(TimeService timeService)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistTasksStorage

public PersistTasksStorage(@NotNull
                           SQLRunnerEx sqlRunner,
                           @NotNull
                           ServerResponsibility serverResponsibility,
                           @NotNull
                           Heartbeat heartbeat,
                           @NotNull
                           EventDispatcher<BuildServerListener> eventDispatcher,
                           @NotNull
                           ServerMetrics serverMetrics)

Method Detail

recreatePersistTasksStorageMonitor

public void recreatePersistTasksStorageMonitor(long delay)

setTimeService

public void setTimeService(@NotNull
                           TimeService timeService)

newTask

public long newTask(@NotNull
                    TaskType taskType,
                    @NotNull
                    String description)

newTask

public long newTask(@NotNull
                    String taskType,
                    @NotNull
                    String description)

setStage

public void setStage(long taskId,
                     @NotNull
                     PersistTaskStage stage)

markAsUpdated

public void markAsUpdated(long taskId)

getNextReadyForExecutionTasks

@NotNull
public List<TaskInfo> getNextReadyForExecutionTasks(@NotNull
                                                    TaskType taskType,
                                                    int maxTasksToReturn)

Searches for the next task with states PersistTaskStage.PREPARE, PersistTaskStage.TASK_WITH_METADATA_READY or PersistTaskStage.TASK_READY and returns its info if such a task should be processed by the current node or null otherwise.

getNextReadyForExecutionTasks

@NotNull
public List<TaskInfo> getNextReadyForExecutionTasks(@NotNull
                                                    String taskType,
                                                    int maxTasksToReturn)

getUnfinishedTasks

@NotNull
public List<TaskInfo> getUnfinishedTasks(@NotNull
                                         TaskType taskType)

getTasksInfo

@NotNull
public Map<Long,TaskInfo> getTasksInfo(@NotNull
                                             Collection<Long> ids)

getTaskInfo

@Nullable
public TaskInfo getTaskInfo(@NotNull
                            Long taskId)

afterCleanup

public void afterCleanup(@NotNull
                         CleanupProcessState cleanupState)

Description copied from interface: AfterBuildsCleanupExtension

Invoked upon finishing of the main cleanup process. At this point all data for specific builds is deleted.
Note: This extension might not be called for every cleanup run as cleanup process can be interrupted earlier. Extension must check cleanup process state and if it is interrupted, complete its operations and return as quick as possible.

Specified by:

afterCleanup in interface AfterBuildsCleanupExtension

Parameters:

cleanupState - cleanup process state

getStageIndex

public static int getStageIndex(@NotNull
                                PersistTaskStage stage)