com.hazelcast.spi.impl
Class BasicBackPressureService

java.lang.Object
  com.hazelcast.spi.impl.BasicBackPressureService

public class BasicBackPressureService
extends Object

A service responsible for figuring out if back pressure needs to be applied to a certain operation.

The current implementation only applies back-pressure on async backup operations of synchronous operation. E.g. the map.put with a async-backup. It does not apply back-pressure for regular async operations or async operations with an async backup. This probably will be added in HZ 3.4.1

For information about the implementation see: https://hazelcast.atlassian.net/wiki/display/EN/Back+Pressure+Design

Constructor Summary

BasicBackPressureService(GroupProperties properties, ILogger logger)

Method Summary

void	cleanup() Cleans up all sync delay administration for dead connections.
boolean	isBackPressureNeeded(Operation op) Checks if back pressure is needed.

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicBackPressureService

public BasicBackPressureService(GroupProperties properties,
                                ILogger logger)

Method Detail

isBackPressureNeeded

public boolean isBackPressureNeeded(Operation op)

Checks if back pressure is needed.

Parameters:

op -

Returns:

cleanup

public void cleanup()

Cleans up all sync delay administration for dead connections. Without this cleanup, eventually the system could run into an OOME.