aboutsummaryrefslogtreecommitdiff
path: root/libjava/gnu/java/nio/natSelectorImplPosix.cc
diff options
context:
space:
mode:
Diffstat (limited to 'libjava/gnu/java/nio/natSelectorImplPosix.cc')
-rw-r--r--libjava/gnu/java/nio/natSelectorImplPosix.cc127
1 files changed, 0 insertions, 127 deletions
diff --git a/libjava/gnu/java/nio/natSelectorImplPosix.cc b/libjava/gnu/java/nio/natSelectorImplPosix.cc
deleted file mode 100644
index b433900..0000000
--- a/libjava/gnu/java/nio/natSelectorImplPosix.cc
+++ /dev/null
@@ -1,127 +0,0 @@
-// natSelectorImplPosix.cc
-
-/* Copyright (C) 2002, 2003, 2004 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 <platform.h>
-
-#include <errno.h>
-#include <string.h>
-
-#include <gnu/java/nio/VMSelector.h>
-#include <java/io/InterruptedIOException.h>
-#include <java/io/IOException.h>
-#include <java/lang/Thread.h>
-
-static void
-helper_put_filedescriptors (jintArray fdArray, fd_set& fds, int& max_fd)
-{
- jint* tmpFDArray = elements (fdArray);
-
- for (int index = 0; index < JvGetArrayLength (fdArray); index++)
- {
- int fd = tmpFDArray [index];
- if (fd > 0)
- {
- FD_SET (tmpFDArray [index], &fds);
-
- if (tmpFDArray [index] > max_fd)
- max_fd = tmpFDArray [index];
- }
- }
-}
-
-static void
-helper_get_filedescriptors (jintArray& fdArray, fd_set fds)
-{
- jint* tmpFDArray = elements (fdArray);
-
- for (int index = 0; index < JvGetArrayLength (fdArray); index++)
- {
- int fd = tmpFDArray [index];
- if (fd < 0 || !FD_ISSET (fd, &fds))
- tmpFDArray [index] = 0;
- }
-}
-
-static void
-helper_reset (jintArray& fdArray)
-{
- jint* tmpFDArray = elements (fdArray);
-
- for (int index = 0; index < JvGetArrayLength (fdArray); index++)
- tmpFDArray [index] = 0;
-}
-
-jint
-gnu::java::nio::VMSelector::select (jintArray read, jintArray write,
- jintArray except, jlong timeout)
-{
- jint result;
- int max_fd = 0;
- fd_set read_fds;
- fd_set write_fds;
- fd_set except_fds;
- struct timeval real_time_data;
- struct timeval *time_data = NULL;
-
- // If a legal timeout value isn't given, use NULL.
- // This means an infinite timeout. The specification
- // also says that a zero timeout should be treated
- // as infinite. Otherwise (if the timeout value is legal),
- // fill our timeval struct and use it for the select.
- if (timeout > 0)
- {
- real_time_data.tv_sec = timeout / 1000;
- real_time_data.tv_usec = (timeout % 1000) * 1000;
- time_data = &real_time_data;
- }
-
- // Reset all fd_set structures
- FD_ZERO (&read_fds);
- FD_ZERO (&write_fds);
- FD_ZERO (&except_fds);
-
- // Fill the fd_set data structures for the _Jv_select() call.
- helper_put_filedescriptors (read, read_fds, max_fd);
- helper_put_filedescriptors (write, write_fds, max_fd);
- helper_put_filedescriptors (except, except_fds, max_fd);
-
- // Actually do the select
- try
- {
- result = _Jv_select (max_fd + 1, &read_fds, &write_fds,
- &except_fds, time_data);
- }
- catch (::java::io::InterruptedIOException *e)
- {
- // The behavior of JRE 1.4.1 is that no exception is thrown
- // when the thread is interrupted, but the thread's interrupt
- // status is set. Clear all of our select sets and return 0,
- // indicating that nothing was selected.
- ::java::lang::Thread::currentThread ()->interrupt ();
- helper_reset (read);
- helper_reset (write);
- helper_reset (except);
- return 0;
- }
-
- if (result < 0)
- {
- char* strerr = strerror (errno);
- throw new ::java::io::IOException (JvNewStringUTF (strerr));
- }
-
- // Set the file descriptors according to the values returned from select().
- helper_get_filedescriptors (read, read_fds);
- helper_get_filedescriptors (write, write_fds);
- helper_get_filedescriptors (except, except_fds);
-
- return result;
-}