Package org.apache.hadoop.fs.impl

Class LeakReporter

java.lang.Object

org.apache.hadoop.fs.impl.LeakReporter

All Implemented Interfaces:

Closeable, AutoCloseable

public class LeakReporter
extends Object
implements Closeable

A class to report leaks of streams.

It is created during object creation, and closed during finalization. Predicates should be supplied for the isOpen probe check if the resource is still open, and an operation to actually close the target.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	RESOURCE_LEAKS_LOG_NAME	Name of logger used to report leaks: "org.apache.hadoop.fs.resource.leaks".

Constructor Summary

Constructors

Constructor	Description
LeakReporter(String message, BooleanSupplier isOpen, RunnableRaisingIOE closeAction)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the resource.
IOException	getLeakException()
boolean	isClosed()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

RESOURCE_LEAKS_LOG_NAME

public static final String RESOURCE_LEAKS_LOG_NAME

Name of logger used to report leaks: "org.apache.hadoop.fs.resource.leaks".

See Also:

• Constant Field Values

Constructor Details

LeakReporter

public LeakReporter(String message,
 BooleanSupplier isOpen,
 RunnableRaisingIOE closeAction)

Constructor.

Validates the parameters and builds the stack; append "; thread: " + thread name.

Parameters:

message - error message

isOpen - open predicate

closeAction - action to close

Method Details

close

public void close()

Close the resource.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getLeakException

public IOException getLeakException()

isClosed

public boolean isClosed()

toString

public String toString()

Overrides:

toString in class Object