com.hazelcast.nio

Class IOUtil

java.lang.Object

com.hazelcast.nio.IOUtil

@PrivateApi
public final class IOUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static byte	PRIMITIVE_TYPE_BOOLEAN
static byte	PRIMITIVE_TYPE_BYTE
static byte	PRIMITIVE_TYPE_DOUBLE
static byte	PRIMITIVE_TYPE_FLOAT
static byte	PRIMITIVE_TYPE_INTEGER
static byte	PRIMITIVE_TYPE_LONG
static byte	PRIMITIVE_TYPE_SHORT
static byte	PRIMITIVE_TYPE_UTF

Method Summary

Methods

Modifier and Type	Method and Description
static void	closeResource(Closeable closeable) Quietly attempts to close a Closeable resource, swallowing any exception.
static byte[]	compress(byte[] input)
static int	copyToHeapBuffer(ByteBuffer src, ByteBuffer dst)
static byte[]	decompress(byte[] compressedData)
static void	delete(File f) Ensures that the file described by the supplied parameter does not exist after the method returns.
static long	extractOperationCallId(Data data, InternalSerializationService serializationService) This method has a direct dependency on how objects are serialized in DataSerializableSerializer.
static ByteBuffer	newByteBuffer(int bufferSize, boolean direct)
static InputStream	newInputStream(ByteBuffer src)
static ObjectInputStream	newObjectInputStream(ClassLoader classLoader, InputStream in)
static OutputStream	newOutputStream(ByteBuffer dst)
static Object	readAttributeValue(ObjectDataInput in)
static byte[]	readByteArray(ObjectDataInput in)
static <T> T	readObject(ObjectDataInput in)
static void	rename(File fileNow, File fileToBe) Ensures that the file described by fileNow is renamed to file described by fileToBe.
static String	toFileName(String name)
static void	writeAttributeValue(Object value, ObjectDataOutput out)
static void	writeByteArray(ObjectDataOutput out, byte[] value)
static void	writeObject(ObjectDataOutput out, Object object)

Methods inherited from class java.lang.Object

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

Field Detail

PRIMITIVE_TYPE_BOOLEAN

public static final byte PRIMITIVE_TYPE_BOOLEAN

See Also:

Constant Field Values

PRIMITIVE_TYPE_BYTE

public static final byte PRIMITIVE_TYPE_BYTE

See Also:

Constant Field Values

PRIMITIVE_TYPE_SHORT

public static final byte PRIMITIVE_TYPE_SHORT

See Also:

Constant Field Values

PRIMITIVE_TYPE_INTEGER

public static final byte PRIMITIVE_TYPE_INTEGER

See Also:

Constant Field Values

PRIMITIVE_TYPE_LONG

public static final byte PRIMITIVE_TYPE_LONG

See Also:

Constant Field Values

PRIMITIVE_TYPE_FLOAT

public static final byte PRIMITIVE_TYPE_FLOAT

See Also:

Constant Field Values

PRIMITIVE_TYPE_DOUBLE

public static final byte PRIMITIVE_TYPE_DOUBLE

See Also:

Constant Field Values

PRIMITIVE_TYPE_UTF

public static final byte PRIMITIVE_TYPE_UTF

See Also:

Constant Field Values

Method Detail

newByteBuffer

public static ByteBuffer newByteBuffer(int bufferSize,
                       boolean direct)

extractOperationCallId

public static long extractOperationCallId(Data data,
                          InternalSerializationService serializationService)
                                   throws IOException

This method has a direct dependency on how objects are serialized in DataSerializableSerializer. If the stream format is changed, this extraction method must be changed as well.

Throws:

IOException

writeByteArray

public static void writeByteArray(ObjectDataOutput out,
                  byte[] value)
                           throws IOException

Throws:

IOException

readByteArray

public static byte[] readByteArray(ObjectDataInput in)
                            throws IOException

Throws:

IOException

writeObject

public static void writeObject(ObjectDataOutput out,
               Object object)
                        throws IOException

Throws:

IOException

readObject

public static <T> T readObject(ObjectDataInput in)
                    throws IOException

Throws:

IOException

newObjectInputStream

public static ObjectInputStream newObjectInputStream(ClassLoader classLoader,
                                     InputStream in)
                                              throws IOException

Throws:

IOException

newOutputStream

public static OutputStream newOutputStream(ByteBuffer dst)

newInputStream

public static InputStream newInputStream(ByteBuffer src)

copyToHeapBuffer

public static int copyToHeapBuffer(ByteBuffer src,
                   ByteBuffer dst)

compress

public static byte[] compress(byte[] input)
                       throws IOException

Throws:

IOException

decompress

public static byte[] decompress(byte[] compressedData)
                         throws IOException

Throws:

IOException

writeAttributeValue

public static void writeAttributeValue(Object value,
                       ObjectDataOutput out)
                                throws IOException

Throws:

IOException

readAttributeValue

public static Object readAttributeValue(ObjectDataInput in)
                                 throws IOException

Throws:

IOException

closeResource

public static void closeResource(Closeable closeable)

Quietly attempts to close a Closeable resource, swallowing any exception.

Parameters:

closeable - the resource to close. If null, no action is taken.

delete

public static void delete(File f)

Ensures that the file described by the supplied parameter does not exist after the method returns. If the file didn't exist, returns silently. If the file could not be deleted, fails with an exception. If the file is a directory, its children are recursively deleted.

rename

public static void rename(File fileNow,
          File fileToBe)

Ensures that the file described by fileNow is renamed to file described by fileToBe. First attempts to perform a direct, atomic rename; if that fails, checks whether the target exists, deletes it, and retries. Throws an exception in each case where the rename failed.

Parameters:

fileNow - describes an existing file

fileToBe - describes the desired pathname for the file

toFileName

public static String toFileName(String name)