Package jetbrains.buildServer.serverSide.impl

Class MultiNodeTasksDbImpl

java.lang.Object

jetbrains.buildServer.serverSide.impl.MultiNodeTasksDbImpl

All Implemented Interfaces:

MultiNodeTasks

public class MultiNodeTasksDbImpl
extends Object
implements MultiNodeTasks

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	MultiNodeTasksDbImpl.PerformingTaskImpl

Nested classes/interfaces inherited from interface jetbrains.buildServer.serverSide.MultiNodeTasks

MultiNodeTasks.PerformingTask, MultiNodeTasks.PersistedTask, MultiNodeTasks.SubmittedTask, MultiNodeTasks.Task, MultiNodeTasks.TaskConsumer, MultiNodeTasks.TaskData

Field Summary

Fields

Modifier and Type	Field	Description
static int	IDENTITY_MAX_LENGTH
static String	PACKED_LONG_VALUE_PREFIX
static String	PLAIN_LONG_VALUE_PREFIX
static String	PROCESS_TASKS_DELAY_MILLIS
static String	TASK_COMPLETION_POLL_INTERVAL
static String	TASKS_BACKGROUND_PROCESSING_PAUSED
static String	TASKS_PROCESSING_PACK_SIZE
static String	TEAMCITY_OFFLINE_NODE_TASK_TIMEOUT_MILLIS

Constructor Summary

Constructors

Constructor	Description
MultiNodeTasksDbImpl(SQLRunnerEx sqlRunner, EventDispatcher<BuildServerListener> eventDispatcher, TeamCityNodes teamCityNodes, ExecutorServices executors, ServerResponsibility serverResponsibility, ServerMetrics serverMetrics, SecurityContextEx securityContext, NumericIdSequences idSequences)

Method Summary

Modifier and Type	Method	Description
void	addListener(MultiNodeTasksListener listener)
protected void	cleanupOldTasks()
List<MultiNodeTasks.SubmittedTask>	findFinishedTasks(Collection<String> taskTypes, long finishTimeThresholdMs)
List<MultiNodeTasks.SubmittedTask>	findInProgressTasks()
List<MultiNodeTasks.SubmittedTask>	findInProgressTasks(Collection<String> taskTypes)
List<MultiNodeTasks.SubmittedTask>	findPendingTasks(Collection<String> taskTypes)
MultiNodeTasks.SubmittedTask	findTask(String taskType, String taskIdentity)
MultiNodeTasks.SubmittedTask	findTaskById(int id)
List<MultiNodeTasks.SubmittedTask>	findTasks(Collection<String> taskTypes)
void	finishWithNodeInaccessibleState(MultiNodeTasks.SubmittedTask task)
long	getLastTaskId()
List<MultiNodeTasks.SubmittedTask>	getUnfinishedTasks()	Returns currently known pending and in-progress tasks.
void	removeListener(MultiNodeTasksListener listener)
void	setBeforeTaskInterceptor(Function<MultiNodeTasks.PerformingTask,Boolean> beforeTaskInterceptor)
protected void	start()
protected void	stop()
MultiNodeTasks.SubmittedTask	submit(MultiNodeTasks.Task task)
void	subscribe(String taskType, MultiNodeTasks.TaskConsumer consumer)	Subscribes a consumer for the task of the specified type.
void	subscribeOnSingletonTask(String taskType, MultiNodeTasks.TaskConsumer consumer)	Subscribe for a task that is guaranteed to be executed only once per identity: when the second task with the same identity is found it's marked as finished immediately, without calling subscribers.
void	unsubscribe(String taskType)	Unsubscribes a consumer for the task of the specified type.

Methods inherited from class java.lang.Object

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

Field Detail

IDENTITY_MAX_LENGTH

public static final int IDENTITY_MAX_LENGTH

See Also:

Constant Field Values

TASK_COMPLETION_POLL_INTERVAL

public static final String TASK_COMPLETION_POLL_INTERVAL

See Also:

Constant Field Values

TEAMCITY_OFFLINE_NODE_TASK_TIMEOUT_MILLIS

public static final String TEAMCITY_OFFLINE_NODE_TASK_TIMEOUT_MILLIS

See Also:

Constant Field Values

PROCESS_TASKS_DELAY_MILLIS

public static final String PROCESS_TASKS_DELAY_MILLIS

See Also:

Constant Field Values

PLAIN_LONG_VALUE_PREFIX

public static final String PLAIN_LONG_VALUE_PREFIX

See Also:

Constant Field Values

PACKED_LONG_VALUE_PREFIX

public static final String PACKED_LONG_VALUE_PREFIX

See Also:

Constant Field Values

TASKS_PROCESSING_PACK_SIZE

public static final String TASKS_PROCESSING_PACK_SIZE

See Also:

Constant Field Values

TASKS_BACKGROUND_PROCESSING_PAUSED

public static final String TASKS_BACKGROUND_PROCESSING_PAUSED

See Also:

Constant Field Values

Constructor Detail

MultiNodeTasksDbImpl

@Autowired
public MultiNodeTasksDbImpl(@NotNull
                            SQLRunnerEx sqlRunner,
                            @NotNull
                            EventDispatcher<BuildServerListener> eventDispatcher,
                            @NotNull
                            TeamCityNodes teamCityNodes,
                            @NotNull
                            ExecutorServices executors,
                            @NotNull
                            ServerResponsibility serverResponsibility,
                            @NotNull
                            ServerMetrics serverMetrics,
                            @NotNull
                            SecurityContextEx securityContext,
                            @NotNull
                            NumericIdSequences idSequences)

Method Detail

start

protected void start()

stop

protected void stop()

submit

@NotNull
public MultiNodeTasks.SubmittedTask submit(@NotNull
                                           MultiNodeTasks.Task task)

Specified by:

submit in interface MultiNodeTasks

subscribe

public void subscribe(@NotNull
                      String taskType,
                      @NotNull
                      MultiNodeTasks.TaskConsumer consumer)

Description copied from interface: MultiNodeTasks

Subscribes a consumer for the task of the specified type. The task may not be accepted by the consumer, in this case it should throw CannotAcceptTaskException.

Specified by:

subscribe in interface MultiNodeTasks

unsubscribe

public void unsubscribe(@NotNull
                        String taskType)

Description copied from interface: MultiNodeTasks

Unsubscribes a consumer for the task of the specified type.

Specified by:

unsubscribe in interface MultiNodeTasks

subscribeOnSingletonTask

public void subscribeOnSingletonTask(@NotNull
                                     String taskType,
                                     @NotNull
                                     MultiNodeTasks.TaskConsumer consumer)

Description copied from interface: MultiNodeTasks

Subscribe for a task that is guaranteed to be executed only once per identity: when the second task with the same identity is found it's marked as finished immediately, without calling subscribers.

Specified by:

subscribeOnSingletonTask in interface MultiNodeTasks

findTasks

@NotNull
public List<MultiNodeTasks.SubmittedTask> findTasks(@NotNull
                                                    Collection<String> taskTypes)

Specified by:

findTasks in interface MultiNodeTasks

findTaskById

@Nullable
public MultiNodeTasks.SubmittedTask findTaskById(int id)

Specified by:

findTaskById in interface MultiNodeTasks

findInProgressTasks

@NotNull
public List<MultiNodeTasks.SubmittedTask> findInProgressTasks(@NotNull
                                                              Collection<String> taskTypes)

Specified by:

findInProgressTasks in interface MultiNodeTasks

findInProgressTasks

@NotNull
public List<MultiNodeTasks.SubmittedTask> findInProgressTasks()

Specified by:

findInProgressTasks in interface MultiNodeTasks

Returns:

all currently in progress tasks

findPendingTasks

@NotNull
public List<MultiNodeTasks.SubmittedTask> findPendingTasks(@NotNull
                                                           Collection<String> taskTypes)

Specified by:

findPendingTasks in interface MultiNodeTasks

findTask

@Nullable
public MultiNodeTasks.SubmittedTask findTask(@NotNull
                                             String taskType,
                                             @NotNull
                                             String taskIdentity)

Specified by:

findTask in interface MultiNodeTasks

getUnfinishedTasks

@NotNull
public List<MultiNodeTasks.SubmittedTask> getUnfinishedTasks()

Description copied from interface: MultiNodeTasks

Returns currently known pending and in-progress tasks.

The list includes tasks created by the current and by other nodes.

Note: contrary to various find* methods, this method does not fetch the data from the database, instead it returns the list which is updated periodically and may not contain the most up-to-date information.

The tasks are sorted by their creation time, the oldest comes first.

Specified by:

getUnfinishedTasks in interface MultiNodeTasks

Returns:

the currently known list of pending and in progress tasks

findFinishedTasks

@NotNull
public List<MultiNodeTasks.SubmittedTask> findFinishedTasks(@NotNull
                                                            Collection<String> taskTypes,
                                                            long finishTimeThresholdMs)

Specified by:

findFinishedTasks in interface MultiNodeTasks

addListener

public void addListener(@NotNull
                        MultiNodeTasksListener listener)

Specified by:

addListener in interface MultiNodeTasks

removeListener

public void removeListener(@NotNull
                           MultiNodeTasksListener listener)

Specified by:

removeListener in interface MultiNodeTasks

finishWithNodeInaccessibleState

public void finishWithNodeInaccessibleState(@NotNull
                                            MultiNodeTasks.SubmittedTask task)

cleanupOldTasks

protected void cleanupOldTasks()

setBeforeTaskInterceptor

@TestOnly
public void setBeforeTaskInterceptor(Function<MultiNodeTasks.PerformingTask,Boolean> beforeTaskInterceptor)

getLastTaskId

public long getLastTaskId()

Specified by:

getLastTaskId in interface MultiNodeTasks

Returns:

the id of the last created task