diff options
Diffstat (limited to 'libjava/java/io/natFileDescriptorPosix.cc')
| -rw-r--r-- | libjava/java/io/natFileDescriptorPosix.cc | 467 |
1 files changed, 0 insertions, 467 deletions
diff --git a/libjava/java/io/natFileDescriptorPosix.cc b/libjava/java/io/natFileDescriptorPosix.cc deleted file mode 100644 index 7c36669d27f..00000000000 --- a/libjava/java/io/natFileDescriptorPosix.cc +++ /dev/null @@ -1,467 +0,0 @@ -// natFileDescriptor.cc - Native part of FileDescriptor class. - -/* Copyright (C) 1998, 1999, 2000, 2001, 2002, 2003 Free Software Foundation - - This file is part of libgcj. - -This software is copyrighted work licensed under the terms of the -Libgcj License. Please consult the file "LIBGCJ_LICENSE" for -details. */ - -#include <config.h> - -#include "posix.h" - -#include <errno.h> -#include <fcntl.h> -#include <stdio.h> -#include <string.h> -#include <sys/stat.h> -#include <sys/param.h> - -#ifdef HAVE_SYS_IOCTL_H -#define BSD_COMP /* Get FIONREAD on Solaris2. */ -#include <sys/ioctl.h> -#endif - -// Pick up FIONREAD on Solaris 2.5. -#ifdef HAVE_SYS_FILIO_H -#include <sys/filio.h> -#endif - -#include <gcj/cni.h> -#include <jvm.h> -#include <java/io/FileDescriptor.h> -#include <java/io/SyncFailedException.h> -#include <java/io/IOException.h> -#include <java/io/InterruptedIOException.h> -#include <java/io/EOFException.h> -#include <java/lang/ArrayIndexOutOfBoundsException.h> -#include <java/lang/NullPointerException.h> -#include <java/lang/System.h> -#include <java/lang/String.h> -#include <java/lang/Thread.h> -#include <java/io/FileNotFoundException.h> - -#define NO_FSYNC_MESSAGE "sync unsupported" - -void -java::io::FileDescriptor::init (void) -{ - in = new java::io::FileDescriptor(0); - out = new java::io::FileDescriptor(1); - err = new java::io::FileDescriptor(2); -} - -jboolean -java::io::FileDescriptor::valid (void) -{ - struct stat sb; - return fd >= 0 && ::fstat (fd, &sb) == 0; -} - -void -java::io::FileDescriptor::sync (void) -{ - // Some files don't support fsync. We don't bother reporting these - // as errors. -#ifdef HAVE_FSYNC - if (::fsync (fd) && errno != EROFS && errno != EINVAL) - throw new SyncFailedException (JvNewStringLatin1 (strerror (errno))); -#else - throw new SyncFailedException (JvNewStringLatin1 (NO_FSYNC_MESSAGE)); -#endif -} - -jint -java::io::FileDescriptor::open (jstring path, jint jflags) -{ - char *buf = (char *) _Jv_AllocBytes (_Jv_GetStringUTFLength (path) + 1); - jsize total = JvGetStringUTFRegion (path, 0, path->length(), buf); - buf[total] = '\0'; - int flags = 0; -#ifdef O_BINARY - flags |= O_BINARY; -#endif - - JvAssert ((jflags & READ) || (jflags & WRITE)); - int mode = 0666; - if ((jflags & READ) && (jflags & WRITE)) - flags |= O_RDWR | O_CREAT; - else if ((jflags & READ)) - flags |= O_RDONLY; - else - { - flags |= O_WRONLY | O_CREAT; - if ((jflags & APPEND)) - flags |= O_APPEND; - else - flags |= O_TRUNC; - - if ((jflags & EXCL)) - { - flags |= O_EXCL; - // In this case we are making a temp file. - mode = 0600; - } - } - - if ((jflags & SYNC)) - flags |= O_SYNC; - - if ((jflags & DSYNC)) - flags |= O_DSYNC; - - int fd = ::open (buf, flags, mode); - if (fd == -1 && errno == EMFILE) - { - // Because finalize () calls close () we might be able to continue. - java::lang::System::gc (); - java::lang::System::runFinalization (); - fd = ::open (buf, flags, mode); - } - if (fd == -1) - { - char msg[MAXPATHLEN + 200]; - // We choose the formatting here for JDK compatibility, believe - // it or not. - sprintf (msg, "%s (%s)", buf, strerror (errno)); - throw new FileNotFoundException (JvNewStringLatin1 (msg)); - } - - _Jv_platform_close_on_exec (fd); - - return fd; -} - -void -java::io::FileDescriptor::write (jint b) -{ - jbyte d = (jbyte) b; - int r = 0; - while (r != 1) - { - r = ::write (fd, &d, 1); - if (r == -1) - { - if (java::lang::Thread::interrupted()) - { - InterruptedIOException *iioe - = new InterruptedIOException (JvNewStringLatin1 (strerror (errno))); - iioe->bytesTransferred = r == -1 ? 0 : r; - throw iioe; - } - if (errno != EINTR) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - } - } - position++; -} - -void -java::io::FileDescriptor::write (jbyteArray b, jint offset, jint len) -{ - if (! b) - throw new java::lang::NullPointerException; - if (offset < 0 || len < 0 || offset + len > JvGetArrayLength (b)) - throw new java::lang::ArrayIndexOutOfBoundsException; - jbyte *bytes = elements (b) + offset; - - int written = 0; - while (len > 0) - { - int r = ::write (fd, bytes, len); - if (r == -1) - { - if (java::lang::Thread::interrupted()) - { - InterruptedIOException *iioe - = new InterruptedIOException (JvNewStringLatin1 (strerror (errno))); - iioe->bytesTransferred = written; - throw iioe; - } - if (errno != EINTR) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - } - - written += r; - len -= r; - bytes += r; - position += r; - } -} - -void -java::io::FileDescriptor::close (void) -{ - jint save = fd; - fd = -1; - if (::close (save)) - throw new IOException (JvNewStringLatin1 (strerror (errno))); -} - -void -java::io::FileDescriptor::setLength (jlong pos) -{ - struct stat sb; - -#ifdef HAVE_FTRUNCATE - if (::fstat (fd, &sb)) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - - if ((jlong) sb.st_size == pos) - return; - - // If the file is too short, we extend it. We can't rely on - // ftruncate() extending the file. So we lseek() to 1 byte less - // than we want, and then we write a single byte at the end. - if ((jlong) sb.st_size < pos) - { - if (::lseek (fd, (off_t) (pos - 1), SEEK_SET) == -1) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - char out = '\0'; - int r = ::write (fd, &out, 1); - if (r <= 0 || ::lseek (fd, position, SEEK_SET) == -1) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - } - else - { - if (::ftruncate (fd, (off_t) pos)) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - position = pos; - } -#else /* HAVE_FTRUNCATE */ - throw new IOException (JvNewStringLatin1 ("FileDescriptor.setLength not implemented")); -#endif /* HAVE_FTRUNCATE */ -} - -jint -java::io::FileDescriptor::seek (jlong pos, jint whence, jboolean eof_trunc) -{ - JvAssert (whence == SET || whence == CUR); - - if (eof_trunc) - { - jlong len = getLength (); - if (whence == SET) - { - if (pos > len) - pos = len; - } - else - { - jlong here = getFilePointer (); - if (here + pos > len) - { - pos = len; - whence = SET; - } - } - } - - off_t r = ::lseek (fd, (off_t) pos, whence == SET ? SEEK_SET : SEEK_CUR); - if (r == -1) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - position = r; - return r; -} - -jlong -java::io::FileDescriptor::getLength (void) -{ - struct stat sb; - if (::fstat (fd, &sb)) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - return sb.st_size; -} - -jlong -java::io::FileDescriptor::getFilePointer (void) -{ - return position; -} - -jint -java::io::FileDescriptor::read (void) -{ - jbyte b; - int r; - do - { - r = ::read (fd, &b, 1); - if (r == 0) - return -1; - if (r == -1) - { - if (java::lang::Thread::interrupted()) - { - InterruptedIOException *iioe - = new InterruptedIOException (JvNewStringLatin1 (strerror (errno))); - iioe->bytesTransferred = r == -1 ? 0 : r; - throw iioe; - } - if (errno != EINTR) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - } - } - while (r != 1); - position++; - return b & 0xFF; -} - -jint -java::io::FileDescriptor::read (jbyteArray buffer, jint offset, jint count) -{ - if (! buffer) - throw new java::lang::NullPointerException; - jsize bsize = JvGetArrayLength (buffer); - if (offset < 0 || count < 0 || offset + count > bsize) - throw new java::lang::ArrayIndexOutOfBoundsException; - - // Must return 0 if an attempt is made to read 0 bytes. - if (count == 0) - return 0; - - jbyte *bytes = elements (buffer) + offset; - int r; - do - { - r = ::read (fd, bytes, count); - if (r == 0) - return -1; - if (r == -1) - { - if (java::lang::Thread::interrupted()) - { - InterruptedIOException *iioe - = new InterruptedIOException (JvNewStringLatin1 (strerror (errno))); - iioe->bytesTransferred = r == -1 ? 0 : r; - throw iioe; - } - if (errno != EINTR) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - } - } - while (r <= 0); - position += r; - return r; -} - -jint -java::io::FileDescriptor::available (void) -{ -#if defined (FIONREAD) || defined (HAVE_SELECT) || defined (HAVE_FSTAT) - long num = 0; - int r = 0; - bool num_set = false; - -#if defined (FIONREAD) - r = ::ioctl (fd, FIONREAD, &num); - if (r == -1 && errno == ENOTTY) - { - // If the ioctl doesn't work, we don't care. - r = 0; - num = 0; - } - else - num_set = true; -#elif defined (HAVE_SELECT) - if (fd < 0) - { - errno = EBADF; - r = -1; - } -#endif - - if (r == -1) - { - posix_error: - throw new IOException (JvNewStringLatin1 (strerror (errno))); - } - - // If we didn't get anything, and we have fstat, then see if see if - // we're reading a regular file. On many systems, FIONREAD does not - // work on regular files; select() likewise returns a useless - // result. This is run incorrectly when FIONREAD does work on - // regular files and we are at the end of the file. However, this - // case probably isn't very important. -#if defined (HAVE_FSTAT) - if (! num_set) - { - struct stat sb; - off_t where = 0; - if (fstat (fd, &sb) != -1 - && S_ISREG (sb.st_mode) - && (where = lseek (fd, 0, SEEK_CUR)) != (off_t) -1) - { - num = (long) (sb.st_size - where); - num_set = true; - } - } -#endif /* HAVE_FSTAT */ - -#if defined (HAVE_SELECT) - if (! num_set) - { - fd_set rd; - FD_ZERO (&rd); - FD_SET (fd, &rd); - struct timeval tv; - tv.tv_sec = 0; - tv.tv_usec = 0; - r = _Jv_select (fd + 1, &rd, NULL, NULL, &tv); - if (r == -1) - goto posix_error; - num = r == 0 ? 0 : 1; - } -#endif /* HAVE_SELECT */ - - return (jint) num; -#else - return 0; -#endif -} - -void -java::io::FileDescriptor::lock (jlong pos, jint len, jboolean shared) -{ - struct flock lockdata; - - lockdata.l_type = shared ? F_WRLCK : F_RDLCK; - lockdata.l_whence = SEEK_SET; - lockdata.l_start = pos; - lockdata.l_len = len; - - if (::fcntl (fd, F_SETLK, &lockdata) == -1) - throw new IOException (JvNewStringLatin1 (strerror (errno))); -} - -jboolean -java::io::FileDescriptor::tryLock (jlong pos, jint len, jboolean shared) -{ - struct flock lockdata; - - lockdata.l_type = shared ? F_WRLCK : F_RDLCK; - lockdata.l_whence = SEEK_SET; - lockdata.l_start = pos; - lockdata.l_len = len; - - if (::fcntl (fd, F_GETLK, &lockdata) == -1) - throw new IOException (JvNewStringLatin1 (strerror (errno))); - - return lockdata.l_type == F_UNLCK; -} - -void -java::io::FileDescriptor::unlock (jlong pos, jint len) -{ - struct flock lockdata; - - lockdata.l_type = F_UNLCK; - lockdata.l_whence = SEEK_SET; - lockdata.l_start = pos; - lockdata.l_len = len; - - if (::fcntl (fd, F_SETLK, &lockdata) == -1) - throw new IOException (JvNewStringLatin1 (strerror (errno))); -} |
