1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
// natSelectorImpl.cc
/* Copyright (C) 2002 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>
#if HAVE_BSTRING_H
// Needed for bzero, implicitly used by FD_ZERO on IRIX 5.2
#include <bstring.h>
#endif
//#include <gcj/cni.h>
#include <gnu/java/nio/SelectorImpl.h>
#include <java/io/IOException.h>
void
helper_put_filedescriptors (jintArray java_fd_array, fd_set& fds, int& max_fd)
{
int counter;
jint* java_fds;
java_fds = elements (java_fd_array);
for (counter = 0; counter < JvGetArrayLength (java_fd_array); counter++)
{
FD_SET (java_fds [counter], &fds);
if (java_fds [counter] > max_fd)
{
max_fd = java_fds [counter];
}
}
}
void
helper_get_filedescriptors (jintArray& java_fd_array, fd_set fds)
{
int counter;
int counter_fds;
jint* java_fds;
jintArray new_array_fds;
jint* new_data_fds;
counter_fds = 0;
java_fds = elements (java_fd_array);
for (counter = 0; counter < JvGetArrayLength (java_fd_array); counter++)
{
if (FD_ISSET (java_fds[counter], &fds))
{
counter_fds++;
}
}
new_array_fds = JvNewIntArray (counter_fds);
new_data_fds = elements (new_array_fds);
for (counter = 0; counter < JvGetArrayLength (java_fd_array); counter++)
{
if (FD_ISSET (java_fds[counter], &fds))
{
new_data_fds[counter] = java_fds[counter];
}
}
java_fd_array = new_array_fds;
}
jint
gnu::java::nio::SelectorImpl::java_do_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;
real_time_data.tv_sec = 0;
real_time_data.tv_usec = timeout;
// If not legal timeout value is given, use NULL.
// This means an infinite timeout.
if (timeout >= 0)
{
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
result = _Jv_select (max_fd + 1, &read_fds, &write_fds, &except_fds, time_data);
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;
}
|
