FileChannelImpl.java, [...]: Removed.
2003-07-13 Michael Koch <konqueror@gmx.de> * gnu/java/nio/FileChannelImpl.java, gnu/java/nio/natFileChannelImpl.cc: Removed. * java/io/FileInputStream.java, java/io/FileOutputStream.java, java/io/RandomAccessFile.java, java/nio/MappedByteBufferImpl.java: Import java.nio.channels.FileChannelImpl instead of gnu.java.nio.FileChannelImpl. * java/nio/channels/FileChannelImpl.java, java/nio/channels/natFileChannelImpl.cc: New files. * Makefile.am (ordinary_java_source_files): Removed gnu/java/nio/FileChannelImpl.java and added java/nio/channels/FileChannelImpl.java. (nat source_files): Removed gnu/java/nio/natFileChannelImpl.cc and added java/nio/channels/natFileChannelImpl.cc. * Makefile.in: Regenerated. From-SVN: r69296
This commit is contained in:
Michael Koch
Michael Koch
parent
46db61e733
commit
ae26c8e25f
9 changed files with 60 additions and 46 deletions
|
|
@ -1,399 +0,0 @@
|
|||
/* FileChannelImpl.java --
|
||||
Copyright (C) 2002 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., 59 Temple Place, Suite 330, Boston, MA
|
||||
02111-1307 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;
|
||||
|
||||
import java.io.EOFException;
|
||||
import java.io.FileDescriptor;
|
||||
import java.io.FileInputStream;
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.RandomAccessFile;
|
||||
import java.nio.ByteBuffer;
|
||||
import java.nio.MappedByteBuffer;
|
||||
import java.nio.MappedByteBufferImpl;
|
||||
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;
|
||||
import gnu.gcj.RawData;
|
||||
|
||||
/**
|
||||
* 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 class FileChannelImpl extends FileChannel
|
||||
{
|
||||
public RawData map_address;
|
||||
|
||||
int length;
|
||||
FileDescriptor fd;
|
||||
MappedByteBuffer buf;
|
||||
Object file_obj; // just to keep it live...
|
||||
|
||||
public FileChannelImpl (FileDescriptor fd, boolean write, Object obj)
|
||||
{
|
||||
if (!(obj instanceof RandomAccessFile)
|
||||
&& !(obj instanceof FileInputStream)
|
||||
&& !(obj instanceof FileOutputStream))
|
||||
throw new InternalError ();
|
||||
|
||||
this.fd = fd;
|
||||
this.file_obj = obj;
|
||||
}
|
||||
|
||||
public FileChannelImpl ()
|
||||
{
|
||||
this (new FileDescriptor (), true, null);
|
||||
}
|
||||
|
||||
private native long implPosition ();
|
||||
private native FileChannel implPosition (long newPosition);
|
||||
private native FileChannel implTruncate (long size);
|
||||
|
||||
private native RawData nio_mmap_file (long pos, long size, int mode);
|
||||
private native void nio_unmmap_file (RawData map_address, int size);
|
||||
private native void nio_msync (RawData map_address, int length);
|
||||
|
||||
public native long size () throws IOException;
|
||||
|
||||
protected void implCloseChannel() throws IOException
|
||||
{
|
||||
if (map_address != null)
|
||||
{
|
||||
nio_unmmap_file (map_address, (int) length);
|
||||
map_address = null;
|
||||
}
|
||||
|
||||
if (file_obj instanceof RandomAccessFile)
|
||||
{
|
||||
RandomAccessFile o = (RandomAccessFile) file_obj;
|
||||
o.close();
|
||||
}
|
||||
else if (file_obj instanceof FileInputStream)
|
||||
{
|
||||
FileInputStream o = (FileInputStream) file_obj;
|
||||
o.close();
|
||||
}
|
||||
else if (file_obj instanceof FileOutputStream)
|
||||
{
|
||||
FileOutputStream o = (FileOutputStream) file_obj;
|
||||
o.close();
|
||||
}
|
||||
}
|
||||
|
||||
public int read (ByteBuffer dst) throws IOException
|
||||
{
|
||||
// Check if file is mapped into memory.
|
||||
if (buf != null)
|
||||
{
|
||||
// FIXME: implement this
|
||||
throw new Error ("Accessing mapped buffers not implemented.");
|
||||
}
|
||||
|
||||
// File not mapped, access it directly.
|
||||
return implRead (dst);
|
||||
}
|
||||
|
||||
public int read (ByteBuffer dst, long position)
|
||||
throws IOException
|
||||
{
|
||||
if (position < 0)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
if (file_obj instanceof FileOutputStream)
|
||||
throw new NonReadableChannelException ();
|
||||
|
||||
int result;
|
||||
long oldPosition;
|
||||
|
||||
oldPosition = implPosition ();
|
||||
result = implRead (dst);
|
||||
implPosition (oldPosition);
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
private int implRead (ByteBuffer dst) throws IOException
|
||||
{
|
||||
int result;
|
||||
byte[] buffer = new byte [dst.remaining ()];
|
||||
|
||||
result = implRead (buffer, 0, buffer.length);
|
||||
dst.put (buffer, 0, result);
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
private native int implRead (byte[] buffer, int offset, int length)
|
||||
throws IOException;
|
||||
|
||||
public long read (ByteBuffer[] dsts, int offset, int length)
|
||||
throws IOException
|
||||
{
|
||||
long result = 0;
|
||||
|
||||
for (int i = offset; i < offset + length; i++)
|
||||
{
|
||||
result += read (dsts [i]);
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
public int write (ByteBuffer src) throws IOException
|
||||
{
|
||||
// Check if file is mapped into memory.
|
||||
if (buf != null)
|
||||
{
|
||||
// FIXME: implement this
|
||||
throw new Error ("Accessing mapped buffers not implemented.");
|
||||
}
|
||||
|
||||
// File not mapped, access it directly.
|
||||
return implWrite (src);
|
||||
}
|
||||
|
||||
public int write (ByteBuffer src, long position)
|
||||
throws IOException
|
||||
{
|
||||
if (position < 0)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
if (file_obj instanceof FileInputStream)
|
||||
throw new NonWritableChannelException ();
|
||||
|
||||
int result;
|
||||
long oldPosition;
|
||||
|
||||
oldPosition = implPosition ();
|
||||
result = implWrite (src);
|
||||
implPosition (oldPosition);
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
private int implWrite (ByteBuffer src) throws IOException
|
||||
{
|
||||
byte[] buffer = new byte [src.remaining ()];
|
||||
|
||||
src.get (buffer, 0, buffer.length);
|
||||
return implWrite (buffer, 0, buffer.length);
|
||||
}
|
||||
|
||||
private native int implWrite (byte[] buffer, int offset, int length)
|
||||
throws IOException;
|
||||
|
||||
public long write(ByteBuffer[] srcs, int offset, int length)
|
||||
throws IOException
|
||||
{
|
||||
long result = 0;
|
||||
|
||||
for (int i = offset;i < offset + length;i++)
|
||||
{
|
||||
result += write (srcs[i]);
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
public MappedByteBuffer map (FileChannel.MapMode mode, long position,
|
||||
long size)
|
||||
throws IOException
|
||||
{
|
||||
if ((mode != MapMode.READ_ONLY
|
||||
&& mode != MapMode.READ_WRITE
|
||||
&& mode != MapMode.PRIVATE)
|
||||
|| position < 0
|
||||
|| size < 0
|
||||
|| size > Integer.MAX_VALUE)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
// FIXME: Make this working.
|
||||
int cmode = mode.m;
|
||||
map_address = nio_mmap_file (position, size, cmode);
|
||||
length = (int) size;
|
||||
buf = new MappedByteBufferImpl (this);
|
||||
return buf;
|
||||
}
|
||||
|
||||
static MappedByteBuffer create_direct_mapped_buffer (RawData map_address,
|
||||
long length)
|
||||
throws IOException
|
||||
{
|
||||
FileChannelImpl ch = new FileChannelImpl ();
|
||||
ch.map_address = map_address;
|
||||
ch.length = (int) length;
|
||||
ch.buf = new MappedByteBufferImpl (ch);
|
||||
return ch.buf;
|
||||
}
|
||||
|
||||
/**
|
||||
* msync with the disk
|
||||
*/
|
||||
public void force (boolean metaData) throws IOException
|
||||
{
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
// FIXME: What to do with metaData ?
|
||||
|
||||
nio_msync (map_address, length);
|
||||
}
|
||||
|
||||
public long transferTo (long position, long count, WritableByteChannel target)
|
||||
throws IOException
|
||||
{
|
||||
if (position < 0
|
||||
|| count < 0)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
if (file_obj instanceof FileOutputStream)
|
||||
throw new NonReadableChannelException ();
|
||||
|
||||
// XXX: count needs to be casted from long to int. Dataloss ?
|
||||
ByteBuffer buffer = ByteBuffer.allocate ((int) count);
|
||||
read (buffer, position);
|
||||
return target.write (buffer);
|
||||
}
|
||||
|
||||
public long transferFrom (ReadableByteChannel src, long position, long count)
|
||||
throws IOException
|
||||
{
|
||||
if (position < 0
|
||||
|| count < 0)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
if (file_obj instanceof FileInputStream)
|
||||
throw new NonWritableChannelException ();
|
||||
|
||||
// XXX: count needs to be casted from long to int. Dataloss ?
|
||||
ByteBuffer buffer = ByteBuffer.allocate ((int) count);
|
||||
src.read (buffer);
|
||||
return write (buffer, position);
|
||||
}
|
||||
|
||||
public FileLock lock (long position, long size, boolean shared)
|
||||
throws IOException
|
||||
{
|
||||
if (position < 0
|
||||
|| size < 0)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
if (shared &&
|
||||
file_obj instanceof FileOutputStream)
|
||||
throw new NonReadableChannelException ();
|
||||
|
||||
if (!shared &&
|
||||
file_obj instanceof FileInputStream)
|
||||
throw new NonWritableChannelException ();
|
||||
|
||||
throw new Error ("Not implemented");
|
||||
}
|
||||
|
||||
public FileLock tryLock (long position, long size, boolean shared)
|
||||
throws IOException
|
||||
{
|
||||
if (position < 0
|
||||
|| size < 0)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
throw new Error ("Not implemented");
|
||||
}
|
||||
|
||||
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 ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
return implPosition (newPosition);
|
||||
}
|
||||
|
||||
public FileChannel truncate (long size)
|
||||
throws IOException
|
||||
{
|
||||
if (size < 0)
|
||||
throw new IllegalArgumentException ();
|
||||
|
||||
if (!isOpen ())
|
||||
throw new ClosedChannelException ();
|
||||
|
||||
if (file_obj instanceof FileInputStream)
|
||||
throw new NonWritableChannelException ();
|
||||
|
||||
return implTruncate (size);
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue