Package jetbrains.buildServer.serverSide.impl

Class BuildAgentMessagesQueue

java.lang.Object

jetbrains.buildServer.serverSide.impl.BuildAgentMessagesQueue

public class BuildAgentMessagesQueue
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	BuildAgentMessagesQueue.BuildMessagesQueue
static class	BuildAgentMessagesQueue.BuildMessagesQueueFullException

Field Summary

Fields

Modifier and Type	Field	Description
static String	ADJUST_THREAD_POOL_INTERVAL_PROP
static String	THREAD_POOL_SIZE_PROP

Constructor Summary

Constructors

Constructor	Description
BuildAgentMessagesQueue(EventDispatcher<BuildServerListener> events, ExtensionHolder extensionsHolder, SQLRunnerEx sqlRunner, BuildMessagesProcessor buildMessagesProcessor, RunningBuildsManager runningBuildsManager, ServerMetrics serverMetrics)

Method Summary

Modifier and Type	Method	Description
void	buildFinished(RunningBuildEx build, Date finishDateOnServer, boolean buildFailedOnAgent)
int	getActiveThreadsNum()
static long	getMessagesQueueFullTimeout()
int	getNumberOfUnprocessedMessagesInAllQueues()
BuildAgentMessagesQueue.BuildMessagesQueue	getQueue(SRunningBuild build)
static int	getWorkerThreadsNum()
boolean	hasMessagesToProcess()
boolean	messagesQueueExists(SRunningBuild build)
void	processMessages(RunningBuildEx build, List<BuildMessage1> messages)
void	removeMessagesQueue(SRunningBuild build)
boolean	waitUntilBuildMessagesProcessed(SRunningBuild build)
boolean	waitUntilBuildMessagesProcessed(SRunningBuild build, long timeoutMillis)	Waits for a specified timeout until build messages are processed.
void	waitUntilBuildMessagesProcessedAndFlushedOnDisk(SRunningBuild build)
boolean	waitUntilBuildMessagesProcessedAndFlushedOnDisk(SRunningBuild build, long timeoutMillis)

Methods inherited from class java.lang.Object

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

Field Detail

ADJUST_THREAD_POOL_INTERVAL_PROP

public static final String ADJUST_THREAD_POOL_INTERVAL_PROP

See Also:

Constant Field Values

THREAD_POOL_SIZE_PROP

public static final String THREAD_POOL_SIZE_PROP

See Also:

Constant Field Values

Constructor Detail

BuildAgentMessagesQueue

public BuildAgentMessagesQueue(@NotNull
                               EventDispatcher<BuildServerListener> events,
                               @NotNull
                               ExtensionHolder extensionsHolder,
                               @NotNull
                               SQLRunnerEx sqlRunner,
                               @NotNull
                               BuildMessagesProcessor buildMessagesProcessor,
                               @NotNull
                               RunningBuildsManager runningBuildsManager,
                               @NotNull
                               ServerMetrics serverMetrics)

Method Detail

processMessages

public void processMessages(@NotNull
                            RunningBuildEx build,
                            @NotNull
                            List<BuildMessage1> messages)
                     throws InterruptedException,
                            BuildAgentMessagesQueue.BuildMessagesQueueFullException

Throws:

InterruptedException

BuildAgentMessagesQueue.BuildMessagesQueueFullException

buildFinished

public void buildFinished(@NotNull
                          RunningBuildEx build,
                          @NotNull
                          Date finishDateOnServer,
                          boolean buildFailedOnAgent)

Parameters:

buildFailedOnAgent - is left for backward compatibility with old agents running old builds, for all the new builds it should always be set to false

getActiveThreadsNum

public int getActiveThreadsNum()

waitUntilBuildMessagesProcessed

public boolean waitUntilBuildMessagesProcessed(@NotNull
                                               SRunningBuild build)

waitUntilBuildMessagesProcessed

public boolean waitUntilBuildMessagesProcessed(@NotNull
                                               SRunningBuild build,
                                               long timeoutMillis)

Waits for a specified timeout until build messages are processed.

Parameters:

build -

timeoutMillis - time to wait

Returns:

true if messages processed (or if there were no messages to process) and false if timeout happened

waitUntilBuildMessagesProcessedAndFlushedOnDisk

public void waitUntilBuildMessagesProcessedAndFlushedOnDisk(@NotNull
                                                            SRunningBuild build)

waitUntilBuildMessagesProcessedAndFlushedOnDisk

public boolean waitUntilBuildMessagesProcessedAndFlushedOnDisk(@NotNull
                                                               SRunningBuild build,
                                                               long timeoutMillis)

removeMessagesQueue

public void removeMessagesQueue(@NotNull
                                SRunningBuild build)

hasMessagesToProcess

public boolean hasMessagesToProcess()

messagesQueueExists

public boolean messagesQueueExists(@NotNull
                                   SRunningBuild build)

getQueue

@Nullable
public BuildAgentMessagesQueue.BuildMessagesQueue getQueue(@NotNull
                                                           SRunningBuild build)

getMessagesQueueFullTimeout

public static long getMessagesQueueFullTimeout()

getWorkerThreadsNum

public static int getWorkerThreadsNum()

getNumberOfUnprocessedMessagesInAllQueues

public int getNumberOfUnprocessedMessagesInAllQueues()