summaryrefslogtreecommitdiff
path: root/libjava/classpath/gnu/java/nio/channels/FileChannelImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'libjava/classpath/gnu/java/nio/channels/FileChannelImpl.java')
-rw-r--r--libjava/classpath/gnu/java/nio/channels/FileChannelImpl.java553
1 files changed, 0 insertions, 553 deletions
diff --git a/libjava/classpath/gnu/java/nio/channels/FileChannelImpl.java b/libjava/classpath/gnu/java/nio/channels/FileChannelImpl.java
deleted file mode 100644
index ed439e141ef..00000000000
--- a/libjava/classpath/gnu/java/nio/channels/FileChannelImpl.java
+++ /dev/null
@@ -1,553 +0,0 @@
-/* FileChannelImpl.java --
- Copyright (C) 2002, 2004, 2005, 2006 Free Software Foundation, Inc.
-
-This file is part of GNU Classpath.
-
-GNU Classpath is free software; you can redistribute it and/or modify
-it under the terms of the GNU General Public License as published by
-the Free Software Foundation; either version 2, or (at your option)
-any later version.
-
-GNU Classpath is distributed in the hope that it will be useful, but
-WITHOUT ANY WARRANTY; without even the implied warranty of
-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-General Public License for more details.
-
-You should have received a copy of the GNU General Public License
-along with GNU Classpath; see the file COPYING. If not, write to the
-Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
-02110-1301 USA.
-
-Linking this library statically or dynamically with other modules is
-making a combined work based on this library. Thus, the terms and
-conditions of the GNU General Public License cover the whole
-combination.
-
-As a special exception, the copyright holders of this library give you
-permission to link this library with independent modules to produce an
-executable, regardless of the license terms of these independent
-modules, and to copy and distribute the resulting executable under
-terms of your choice, provided that you also meet, for each linked
-independent module, the terms and conditions of the license of that
-module. An independent module is a module which is not derived from
-or based on this library. If you modify this library, you may extend
-this exception to your version of the library, but you are not
-obligated to do so. If you do not wish to do so, delete this
-exception statement from your version. */
-
-
-package gnu.java.nio.channels;
-
-import gnu.classpath.Configuration;
-import gnu.java.nio.FileLockImpl;
-import gnu.java.nio.VMChannel;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.nio.MappedByteBuffer;
-import java.nio.channels.ClosedChannelException;
-import java.nio.channels.FileChannel;
-import java.nio.channels.FileLock;
-import java.nio.channels.NonReadableChannelException;
-import java.nio.channels.NonWritableChannelException;
-import java.nio.channels.ReadableByteChannel;
-import java.nio.channels.WritableByteChannel;
-
-/**
- * This file is not user visible !
- * But alas, Java does not have a concept of friendly packages
- * so this class is public.
- * Instances of this class are created by invoking getChannel
- * Upon a Input/Output/RandomAccessFile object.
- */
-public final class FileChannelImpl extends FileChannel
-{
- // These are mode values for open().
- public static final int READ = 1;
- public static final int WRITE = 2;
- public static final int APPEND = 4;
-
- // EXCL is used only when making a temp file.
- public static final int EXCL = 8;
- public static final int SYNC = 16;
- public static final int DSYNC = 32;
-
- public static FileChannelImpl in;
- public static FileChannelImpl out;
- public static FileChannelImpl err;
-
- private static native void init();
-
- static
- {
- if (Configuration.INIT_LOAD_LIBRARY)
- {
- System.loadLibrary("javanio");
- }
-
- init();
-
- in = new FileChannelImpl(0, READ);
- out = new FileChannelImpl(1, WRITE);
- err = new FileChannelImpl(2, WRITE);
- }
-
- /**
- * This is the actual native file descriptor value
- */
- // System's notion of file descriptor. It might seem redundant to
- // initialize this given that it is reassigned in the constructors.
- // However, this is necessary because if open() throws an exception
- // we want to make sure this has the value -1. This is the most
- // efficient way to accomplish that.
- private int fd = -1;
- private VMChannel ch;
-
- private int mode;
-
- final String description;
-
- /* Open a file. MODE is a combination of the above mode flags. */
- /* This is a static factory method, so that VM implementors can decide
- * substitute subclasses of FileChannelImpl. */
- public static FileChannelImpl create(File file, int mode)
- throws FileNotFoundException
- {
- return new FileChannelImpl(file, mode);
- }
-
- private FileChannelImpl(File file, int mode)
- throws FileNotFoundException
- {
- String path = file.getPath();
- description = path;
- fd = open (path, mode);
- this.mode = mode;
- this.ch = VMChannel.getVMChannel(this);
-
- // First open the file and then check if it is a a directory
- // to avoid race condition.
- if (file.isDirectory())
- {
- try
- {
- close();
- }
- catch (IOException e)
- {
- /* ignore it */
- }
-
- throw new FileNotFoundException(description + " is a directory");
- }
- }
-
- /**
- * Constructor for default channels in, out and err.
- *
- * Used by init() (native code).
- *
- * @param fd the file descriptor (0, 1, 2 for stdin, stdout, stderr).
- *
- * @param mode READ or WRITE
- */
- FileChannelImpl (int fd, int mode)
- {
- this.fd = fd;
- this.mode = mode;
- this.description = "descriptor(" + fd + ")";
- this.ch = VMChannel.getVMChannel(this);
- }
-
- private native int open (String path, int mode) throws FileNotFoundException;
-
- public native int available () throws IOException;
- private native long implPosition () throws IOException;
- private native void seek (long newPosition) throws IOException;
- private native void implTruncate (long size) throws IOException;
-
- public native void unlock (long pos, long len) throws IOException;
-
- public native long size () throws IOException;
-
- protected native void implCloseChannel() throws IOException;
-
- /**
- * Makes sure the Channel is properly closed.
- */
- protected void finalize() throws IOException
- {
- if (fd != -1)
- close();
- }
-
- public int read (ByteBuffer dst) throws IOException
- {
- /*
- int result;
- byte[] buffer = new byte [dst.remaining ()];
-
- result = read (buffer, 0, buffer.length);
-
- if (result > 0)
- dst.put (buffer, 0, result);
-
- return result;
- */
- return ch.read(dst);
- }
-
- public int read (ByteBuffer dst, long position)
- throws IOException
- {
- if (position < 0)
- throw new IllegalArgumentException ("position: " + position);
- long oldPosition = implPosition ();
- position (position);
- int result = read(dst);
- position (oldPosition);
-
- return result;
- }
-
- public native int read ()
- throws IOException;
-
- public native int read (byte[] buffer, int offset, int length)
- throws IOException;
-
- public long read (ByteBuffer[] dsts, int offset, int length)
- throws IOException
- {
- return ch.readScattering(dsts, offset, length);
- }
-
- public int write (ByteBuffer src) throws IOException
- {
- return ch.write(src);
- }
-
- public int write (ByteBuffer src, long position)
- throws IOException
- {
- if (position < 0)
- throw new IllegalArgumentException ("position: " + position);
-
- if (!isOpen ())
- throw new ClosedChannelException ();
-
- if ((mode & WRITE) == 0)
- throw new NonWritableChannelException ();
-
- int result;
- long oldPosition;
-
- oldPosition = implPosition ();
- seek (position);
- result = write(src);
- seek (oldPosition);
-
- return result;
- }
-
- public native void write (byte[] buffer, int offset, int length)
- throws IOException;
-
- public native void write (int b) throws IOException;
-
- public long write(ByteBuffer[] srcs, int offset, int length)
- throws IOException
- {
- return ch.writeGathering(srcs, offset, length);
- }
-
- public native MappedByteBuffer mapImpl (char mode, long position, int size)
- throws IOException;
-
- public MappedByteBuffer map (FileChannel.MapMode mode,
- long position, long size)
- throws IOException
- {
- char nmode = 0;
- if (mode == MapMode.READ_ONLY)
- {
- nmode = 'r';
- if ((this.mode & READ) == 0)
- throw new NonReadableChannelException();
- }
- else if (mode == MapMode.READ_WRITE || mode == MapMode.PRIVATE)
- {
- nmode = mode == MapMode.READ_WRITE ? '+' : 'c';
- if ((this.mode & WRITE) != WRITE)
- throw new NonWritableChannelException();
- if ((this.mode & READ) != READ)
- throw new NonReadableChannelException();
- }
- else
- throw new IllegalArgumentException ("mode: " + mode);
-
- if (position < 0 || size < 0 || size > Integer.MAX_VALUE)
- throw new IllegalArgumentException ("position: " + position
- + ", size: " + size);
- return mapImpl(nmode, position, (int) size);
- }
-
- /**
- * msync with the disk
- */
- public void force (boolean metaData) throws IOException
- {
- if (!isOpen ())
- throw new ClosedChannelException ();
-
- force ();
- }
-
- private native void force ();
-
- // like transferTo, but with a count of less than 2Gbytes
- private int smallTransferTo (long position, int count,
- WritableByteChannel target)
- throws IOException
- {
- ByteBuffer buffer;
- try
- {
- // Try to use a mapped buffer if we can. If this fails for
- // any reason we'll fall back to using a ByteBuffer.
- buffer = map (MapMode.READ_ONLY, position, count);
- }
- catch (IOException e)
- {
- buffer = ByteBuffer.allocate (count);
- read (buffer, position);
- buffer.flip();
- }
-
- return target.write (buffer);
- }
-
- public long transferTo (long position, long count,
- WritableByteChannel target)
- throws IOException
- {
- if (position < 0
- || count < 0)
- throw new IllegalArgumentException ("position: " + position
- + ", count: " + count);
-
- if (!isOpen ())
- throw new ClosedChannelException ();
-
- if ((mode & READ) == 0)
- throw new NonReadableChannelException ();
-
- final int pageSize = 65536;
- long total = 0;
-
- while (count > 0)
- {
- int transferred
- = smallTransferTo (position, (int)Math.min (count, pageSize),
- target);
- if (transferred < 0)
- break;
- total += transferred;
- position += transferred;
- count -= transferred;
- }
-
- return total;
- }
-
- // like transferFrom, but with a count of less than 2Gbytes
- private int smallTransferFrom (ReadableByteChannel src, long position,
- int count)
- throws IOException
- {
- ByteBuffer buffer = null;
-
- if (src instanceof FileChannel)
- {
- try
- {
- // Try to use a mapped buffer if we can. If this fails
- // for any reason we'll fall back to using a ByteBuffer.
- buffer = ((FileChannel)src).map (MapMode.READ_ONLY, position,
- count);
- }
- catch (IOException e)
- {
- }
- }
-
- if (buffer == null)
- {
- buffer = ByteBuffer.allocate ((int) count);
- src.read (buffer);
- buffer.flip();
- }
-
- return write (buffer, position);
- }
-
- public long transferFrom (ReadableByteChannel src, long position,
- long count)
- throws IOException
- {
- if (position < 0
- || count < 0)
- throw new IllegalArgumentException ("position: " + position
- + ", count: " + count);
-
- if (!isOpen ())
- throw new ClosedChannelException ();
-
- if ((mode & WRITE) == 0)
- throw new NonWritableChannelException ();
-
- final int pageSize = 65536;
- long total = 0;
-
- while (count > 0)
- {
- int transferred = smallTransferFrom (src, position,
- (int)Math.min (count, pageSize));
- if (transferred < 0)
- break;
- total += transferred;
- position += transferred;
- count -= transferred;
- }
-
- return total;
- }
-
- // Shared sanity checks between lock and tryLock methods.
- private void lockCheck(long position, long size, boolean shared)
- throws IOException
- {
- if (position < 0
- || size < 0)
- throw new IllegalArgumentException ("position: " + position
- + ", size: " + size);
-
- if (!isOpen ())
- throw new ClosedChannelException();
-
- if (shared && ((mode & READ) == 0))
- throw new NonReadableChannelException();
-
- if (!shared && ((mode & WRITE) == 0))
- throw new NonWritableChannelException();
- }
-
- public FileLock tryLock (long position, long size, boolean shared)
- throws IOException
- {
- lockCheck(position, size, shared);
-
- boolean completed = false;
- try
- {
- begin();
- boolean lockable = lock(position, size, shared, false);
- completed = true;
- return (lockable
- ? new FileLockImpl(this, position, size, shared)
- : null);
- }
- finally
- {
- end(completed);
- }
- }
-
- /** Try to acquire a lock at the given position and size.
- * On success return true.
- * If wait as specified, block until we can get it.
- * Otherwise return false.
- */
- private native boolean lock(long position, long size,
- boolean shared, boolean wait) throws IOException;
-
- public FileLock lock (long position, long size, boolean shared)
- throws IOException
- {
- lockCheck(position, size, shared);
-
- boolean completed = false;
- try
- {
- boolean lockable = lock(position, size, shared, true);
- completed = true;
- return (lockable
- ? new FileLockImpl(this, position, size, shared)
- : null);
- }
- finally
- {
- end(completed);
- }
- }
-
- public long position ()
- throws IOException
- {
- if (!isOpen ())
- throw new ClosedChannelException ();
-
- return implPosition ();
- }
-
- public FileChannel position (long newPosition)
- throws IOException
- {
- if (newPosition < 0)
- throw new IllegalArgumentException ("newPosition: " + newPosition);
-
- if (!isOpen ())
- throw new ClosedChannelException ();
-
- // FIXME note semantics if seeking beyond eof.
- // We should seek lazily - only on a write.
- seek (newPosition);
- return this;
- }
-
- public FileChannel truncate (long size)
- throws IOException
- {
- if (size < 0)
- throw new IllegalArgumentException ("size: " + size);
-
- if (!isOpen ())
- throw new ClosedChannelException ();
-
- if ((mode & WRITE) == 0)
- throw new NonWritableChannelException ();
-
- if (size < size ())
- implTruncate (size);
-
- return this;
- }
-
- public String toString()
- {
- return (this.getClass()
- + "[fd=" + fd
- + ",mode=" + mode + ","
- + description + "]");
- }
-
- /**
- * @return The native file descriptor.
- */
- public int getNativeFD()
- {
- return fd;
- }
-}