com.sleepycat.je.log

Class FSyncManager.FSyncGroup

java.lang.Object

com.sleepycat.je.log.FSyncManager.FSyncGroup

Enclosing class:

FSyncManager

static class FSyncManager.FSyncGroup
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static int	DO_LEADER_FSYNC
(package private) static int	DO_TIMEOUT_FSYNC
(package private) static int	NO_FSYNC_NEEDED

Constructor Summary

Constructors

Constructor and Description
FSyncManager.FSyncGroup(long fsyncTimeout, EnvironmentImpl envImpl)

Method Summary

Methods

Modifier and Type	Method and Description
(package private) boolean	getLeader()
(package private) int	waitForFsync() Wait for either a turn to execute a fsync, or to find out that a fsync was done on your behalf.
(package private) void	wakeupAll()
(package private) void	wakeupOne()

Methods inherited from class java.lang.Object

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

Field Detail

DO_TIMEOUT_FSYNC

static int DO_TIMEOUT_FSYNC

DO_LEADER_FSYNC

static int DO_LEADER_FSYNC

NO_FSYNC_NEEDED

static int NO_FSYNC_NEEDED

Constructor Detail

FSyncManager.FSyncGroup

FSyncManager.FSyncGroup(long fsyncTimeout,
                       EnvironmentImpl envImpl)

Method Detail

getLeader

boolean getLeader()

waitForFsync

int waitForFsync()
           throws ThreadInterruptedException

Wait for either a turn to execute a fsync, or to find out that a fsync was done on your behalf.

Returns:

true if the fsync wasn't done, and this thread needs to execute a fsync when it wakes up. This may be true because it's the leader of its group, or because the wait timed out.

Throws:

ThreadInterruptedException

wakeupAll

void wakeupAll()

wakeupOne

void wakeupOne()