rice.pastry.wire
Class Wire

java.lang.Object
  rice.pastry.wire.Wire

public class Wire

extends java.lang.Object

This is the beginning of a process wide authority for Wire. It will be used to maintain the number of file descriptors allowed/being used, as well as any process wide controll necessary for the wire package. As of this release, the vast majority of the methods called are ignored. The only fields of interest are outputDebug, outputStreamLock.

Constructor Summary

Wire()

Method Summary

static void	acquireFileDescriptor()
static void	acquireFileDescriptors(int numFDs)
static void	addWireLimitationListener(WireLimitatioinListener wll)
static void	doneReleaseingFileDescriptor()
static int	getNumFDsUsed() will throw an error on platforms other than Linux/BSD
static void	initialize() Automatic determination of ulimit -n
static void	initialize(float softLimit, float notifyLimit) Automatic determination of ulimit -n
static void	initialize(int fileDescriptorLimit)
static void	initialize(int fileDescriptorLimit, float softLimit, float notifyLimit)
static boolean	needToReleaseFDs()
static void	printStatus()
static void	registerSocketChannel(java.nio.channels.SocketChannel sc, java.lang.String reason)
static void	releaseFileDescriptor()
static void	releaseFileDescriptors(int numFDs)
static void	releaseingFileDescriptor()
static void	removeWireLimitationListener(WireLimitatioinListener wll)

Methods inherited from class java.lang.Object

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

Constructor Detail

Wire

public Wire()

Method Detail

initialize

public static void initialize()

Automatic determination of ulimit -n

initialize

public static void initialize(int fileDescriptorLimit)

initialize

public static void initialize(int fileDescriptorLimit,
                              float softLimit,
                              float notifyLimit)

initialize

public static void initialize(float softLimit,
                              float notifyLimit)

Automatic determination of ulimit -n

Parameters:

softLimit -

notifyLimit -

addWireLimitationListener

public static void addWireLimitationListener(WireLimitatioinListener wll)

removeWireLimitationListener

public static void removeWireLimitationListener(WireLimitatioinListener wll)

acquireFileDescriptor

public static void acquireFileDescriptor()

releaseFileDescriptor

public static void releaseFileDescriptor()

acquireFileDescriptors

public static void acquireFileDescriptors(int numFDs)

releaseFileDescriptors

public static void releaseFileDescriptors(int numFDs)

releaseingFileDescriptor

public static void releaseingFileDescriptor()

doneReleaseingFileDescriptor

public static void doneReleaseingFileDescriptor()

needToReleaseFDs

public static boolean needToReleaseFDs()

getNumFDsUsed

public static int getNumFDsUsed()
                         throws java.io.IOException

will throw an error on platforms other than Linux/BSD

Returns:

Throws:

java.io.IOException

printStatus

public static void printStatus()

registerSocketChannel

public static void registerSocketChannel(java.nio.channels.SocketChannel sc,
                                         java.lang.String reason)