Class ProcessServiceLogCache

java.lang.Object

eu.cloudnetservice.node.impl.service.defaults.log.AbstractServiceLogCache

eu.cloudnetservice.node.impl.service.defaults.log.ProcessServiceLogCache

All Implemented Interfaces:

eu.cloudnetservice.node.service.ServiceConsoleLogCache

public class ProcessServiceLogCache
extends AbstractServiceLogCache

Field Summary

Fields

Modifier and Type	Field	Description
private NonBlockingLineReader	errStreamReader
private NonBlockingLineReader	outStreamReader
private final ProcessServiceLogReadScheduler	scheduler
private ProcessHandle	targetProcess

Fields inherited from class AbstractServiceLogCache

alwaysPrintErrorStreamToConsole, ANSI_SEQUENCE_PATTERN, associatedServiceId, cachedLogMessages, handlers, logCacheSize, LOGGER

Constructor Summary

Constructors

Constructor	Description
ProcessServiceLogCache(@NonNull eu.cloudnetservice.node.config.Configuration configuration, @NonNull eu.cloudnetservice.driver.service.ServiceId associatedServiceId, @NonNull ProcessServiceLogReadScheduler scheduler)

Method Summary

Modifier and Type	Method	Description
private void	readLinesFromStream(@NonNull NonBlockingLineReader reader, boolean errStream)
private void	readLinesFromStreams(@NonNull NonBlockingLineReader outReader, @NonNull NonBlockingLineReader errReader)
boolean	readProcessOutputContent()
void	start(@NonNull Process process)
void	stop()

Methods inherited from class AbstractServiceLogCache

addHandler, alwaysPrintErrorStreamToConsole, alwaysPrintErrorStreamToConsole, associatedServiceId, cachedLogMessages, handleItem, handlers, logCacheSize, logCacheSize, removeHandler

Methods inherited from class Object

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

Field Details

scheduler

private final ProcessServiceLogReadScheduler scheduler

targetProcess

private volatile ProcessHandle targetProcess

outStreamReader

private NonBlockingLineReader outStreamReader

errStreamReader

private NonBlockingLineReader errStreamReader

Constructor Details

ProcessServiceLogCache

public ProcessServiceLogCache(@NonNull
 @NonNull eu.cloudnetservice.node.config.Configuration configuration,
 @NonNull
 @NonNull eu.cloudnetservice.driver.service.ServiceId associatedServiceId,
 @NonNull
 @NonNull ProcessServiceLogReadScheduler scheduler)

Method Details

start

public void start(@NonNull
 @NonNull Process process)

stop

public void stop()

readProcessOutputContent

public boolean readProcessOutputContent()

readLinesFromStreams

private void readLinesFromStreams(@NonNull
 @NonNull NonBlockingLineReader outReader,
 @NonNull
 @NonNull NonBlockingLineReader errReader)
                           throws IOException

Throws:

IOException

readLinesFromStream

private void readLinesFromStream(@NonNull
 @NonNull NonBlockingLineReader reader,
 boolean errStream)
                          throws IOException

Throws:

IOException