pl.edu.agh.age.compute.stream.logging

Class DefaultLoggingService

java.lang.Object

pl.edu.agh.age.compute.stream.logging.DefaultLoggingService

All Implemented Interfaces:

LoggingService

public final class DefaultLoggingService
extends java.lang.Object
implements LoggingService

Default implementation of the logging service for stream agents. It logs the data to the SLF4J logger named “stream”.

Each log file entry consists of an entry type tag and entry values, each separated with a semicolon delimiter (**;**).

The supported log entry types are as follows: - [PD] - log entry with a one-line problem definition string - [WH] - log entry with a one-line definition of properties used in the workplace entries - [SH] - log entry with a one-line definition of properties used in the tick summary entries - [BH] - log entry with a one-line definition of properties used in best solution entries - [W] - log entry for a particular workplace in a tick (each tick consist of n such entries, if n is the number of all workplaces) - [S] - log entry with a tick summary (each tick consists of exactly one entry of this type) - [B] - log entry with the best solution (there might be more than one entry of this type in a log, if multiple agents can have the same evaluation)

Log entries appear in the log file in the order same as defined above. There is only one log entry for each of types {[PD], [WH], [SH], [BH]} and one or more entries for the rest of the types.

See Also:

Columns, Tags

Field Summary

Fields

Modifier and Type	Field and Description
private AgentsRegistry<? extends Agent>	agentsRegistry
static java.lang.String	DELIMITER
private EvaluatorCounter	evaluatorCounter
private boolean	headerLogged
private static org.slf4j.Logger	logger
private @Nullable ListenableScheduledFuture<?>	loggerFuture
private LoggingParameters	parameters
private long	startTime
private static org.slf4j.Logger	stream_logger

Constructor Summary

Constructors

Constructor and Description
DefaultLoggingService(LoggingParameters parameters, EvaluatorCounter evaluatorCounter, AgentsRegistry<? extends Agent> agentsRegistry)

Method Summary

Modifier and Type	Method and Description
private static void	logBestSolutionHeader()
private static void	logBestSolutions(io.vavr.collection.Map<java.lang.String,io.vavr.Tuple3<java.lang.Long,java.lang.Long,java.lang.Long>> solutionsMap)
private void	logHeaders(io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> statistics)
private void	logProblemDefinition(ProblemDefinition problemDefinition)
private void	logStatistics(io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> statistics, int workplacesCount)
private static void	logSummaryHeader()
private void	logSummaryStatistics(java.lang.Long time)
private static void	logWorkplaceHeader(io.vavr.collection.Map<java.lang.Object,java.lang.Object> workplaceStats)
private void	logWorkplaceStatistics(java.lang.Long time, java.lang.Long workplaceId, int workplacesCount, io.vavr.collection.Map<java.lang.Object,java.lang.Object> workplaceStats)
void	schedule(Manager statisticsManager, ThreadPool threadPool) Schedules and starts this service in the provided ThreadPool
void	stop() Stops this service

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

stream_logger

private static final org.slf4j.Logger stream_logger

DELIMITER

public static final java.lang.String DELIMITER

See Also:

Constant Field Values

parameters

private final LoggingParameters parameters

evaluatorCounter

private final EvaluatorCounter evaluatorCounter

agentsRegistry

private final AgentsRegistry<? extends Agent> agentsRegistry

headerLogged

private boolean headerLogged

startTime

private long startTime

loggerFuture

private @Nullable ListenableScheduledFuture<?> loggerFuture

Constructor Detail

DefaultLoggingService

@Inject
public DefaultLoggingService(LoggingParameters parameters,
                                     EvaluatorCounter evaluatorCounter,
                                     AgentsRegistry<? extends Agent> agentsRegistry)

Method Detail

schedule

public void schedule(Manager statisticsManager,
                     ThreadPool threadPool)

Description copied from interface: LoggingService

Schedules and starts this service in the provided ThreadPool

Statistics will be obtained by this service from the passes Manager.

Specified by:

schedule in interface LoggingService

Parameters:

statisticsManager - provider of the statistics

threadPool - thread pool used to schedule the service

Throws:

java.lang.IllegalStateException - if this service was already scheduled

Implementation Note:

If the passed `loggingInterval` was zero, then this service will not be scheduled.

stop

public void stop()

Description copied from interface: LoggingService

Stops this service

This operations does not have to be synchronous. Service may be stopped some time in the future after this call.

Specified by:

stop in interface LoggingService

Throws:

java.lang.IllegalStateException - if this service was not yet scheduled

logProblemDefinition

private void logProblemDefinition(ProblemDefinition problemDefinition)

logStatistics

private void logStatistics(io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> statistics,
                           int workplacesCount)

logWorkplaceStatistics

private void logWorkplaceStatistics(java.lang.Long time,
                                    java.lang.Long workplaceId,
                                    int workplacesCount,
                                    io.vavr.collection.Map<java.lang.Object,java.lang.Object> workplaceStats)

logSummaryStatistics

private void logSummaryStatistics(java.lang.Long time)

logBestSolutions

private static void logBestSolutions(io.vavr.collection.Map<java.lang.String,io.vavr.Tuple3<java.lang.Long,java.lang.Long,java.lang.Long>> solutionsMap)

logHeaders

private void logHeaders(io.vavr.collection.Map<java.lang.Long,io.vavr.collection.Map<java.lang.Object,java.lang.Object>> statistics)

logWorkplaceHeader

private static void logWorkplaceHeader(io.vavr.collection.Map<java.lang.Object,java.lang.Object> workplaceStats)

logSummaryHeader

private static void logSummaryHeader()

logBestSolutionHeader

private static void logBestSolutionHeader()