10 *
11 * This code is distributed in the hope that it will be useful, but WITHOUT
12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 * version 2 for more details (a copy is included in the LICENSE file that
15 * accompanied this code).
16 *
17 * You should have received a copy of the GNU General Public License version
18 * 2 along with this work; if not, write to the Free Software Foundation,
19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
20 *
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
22 * or visit www.oracle.com if you need additional information or have any
23 * questions.
24 */
25
26 package sun.nio.ch;
27
28 import java.io.FileDescriptor;
29 import java.io.IOException;
30 import jdk.internal.access.JavaIOFileDescriptorAccess;
31 import jdk.internal.access.SharedSecrets;
32
33 /**
34 * Allows different platforms to call different native methods
35 * for read and write operations.
36 */
37
38 abstract class NativeDispatcher {
39 private static final JavaIOFileDescriptorAccess JIOFDA = SharedSecrets.getJavaIOFileDescriptorAccess();
40
41 abstract int read(FileDescriptor fd, long address, int len)
42 throws IOException;
43
44 /**
45 * Returns {@code true} if pread/pwrite needs to be synchronized with
46 * position sensitive methods.
47 */
48 boolean needsPositionLock() {
49 return false;
50 }
51
52 int pread(FileDescriptor fd, long address, int len, long position)
53 throws IOException
54 {
55 throw new IOException("Operation Unsupported");
56 }
57
58 abstract long readv(FileDescriptor fd, long address, int len)
59 throws IOException;
61 abstract int write(FileDescriptor fd, long address, int len)
62 throws IOException;
63
64 int pwrite(FileDescriptor fd, long address, int len, long position)
65 throws IOException
66 {
67 throw new IOException("Operation Unsupported");
68 }
69
70 abstract long writev(FileDescriptor fd, long address, int len)
71 throws IOException;
72
73 abstract void close(FileDescriptor fd) throws IOException;
74
75 /**
76 * Prepare the given file descriptor for closing. If a virtual thread is blocked
77 * on the file descriptor then it is unparked so that it stops polling. On Unix systems,
78 * if a platform thread is blocked on the file descriptor then the file descriptor is
79 * dup'ed to a special fd and the thread signalled so that the syscall fails with EINTR.
80 */
81 final void preClose(FileDescriptor fd, long reader, long writer) throws IOException {
82 if (NativeThread.isVirtualThread(reader) || NativeThread.isVirtualThread(writer)) {
83 int fdVal = JIOFDA.get(fd);
84 Poller.stopPoll(fdVal);
85 }
86 if (NativeThread.isNativeThread(reader) || NativeThread.isNativeThread(writer)) {
87 implPreClose(fd, reader, writer);
88 }
89 }
90
91 /**
92 * This method does nothing by default. On Unix systems the file descriptor is dup'ed
93 * to a special fd and native threads signalled.
94 */
95
96 void implPreClose(FileDescriptor fd, long reader, long writer) throws IOException {
97 // Do nothing by default; this is only needed on Unix
98 }
99
100 /**
101 * Duplicates a file descriptor.
102 * @param fd1 the file descriptor to duplicate
103 * @param fd2 the new file descriptor, the socket or file that it is connected
104 * to will be closed by this method
105 */
106 void dup(FileDescriptor fd1, FileDescriptor fd2) throws IOException {
107 throw new UnsupportedOperationException();
108 }
109 }
|
10 *
11 * This code is distributed in the hope that it will be useful, but WITHOUT
12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14 * version 2 for more details (a copy is included in the LICENSE file that
15 * accompanied this code).
16 *
17 * You should have received a copy of the GNU General Public License version
18 * 2 along with this work; if not, write to the Free Software Foundation,
19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
20 *
21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
22 * or visit www.oracle.com if you need additional information or have any
23 * questions.
24 */
25
26 package sun.nio.ch;
27
28 import java.io.FileDescriptor;
29 import java.io.IOException;
30
31 /**
32 * Allows different platforms to call different native methods
33 * for read and write operations.
34 */
35
36 abstract class NativeDispatcher {
37
38 abstract int read(FileDescriptor fd, long address, int len)
39 throws IOException;
40
41 /**
42 * Returns {@code true} if pread/pwrite needs to be synchronized with
43 * position sensitive methods.
44 */
45 boolean needsPositionLock() {
46 return false;
47 }
48
49 int pread(FileDescriptor fd, long address, int len, long position)
50 throws IOException
51 {
52 throw new IOException("Operation Unsupported");
53 }
54
55 abstract long readv(FileDescriptor fd, long address, int len)
56 throws IOException;
58 abstract int write(FileDescriptor fd, long address, int len)
59 throws IOException;
60
61 int pwrite(FileDescriptor fd, long address, int len, long position)
62 throws IOException
63 {
64 throw new IOException("Operation Unsupported");
65 }
66
67 abstract long writev(FileDescriptor fd, long address, int len)
68 throws IOException;
69
70 abstract void close(FileDescriptor fd) throws IOException;
71
72 /**
73 * Prepare the given file descriptor for closing. If a virtual thread is blocked
74 * on the file descriptor then it is unparked so that it stops polling. On Unix systems,
75 * if a platform thread is blocked on the file descriptor then the file descriptor is
76 * dup'ed to a special fd and the thread signalled so that the syscall fails with EINTR.
77 */
78 final void preClose(FileDescriptor fd, NativeThread reader, NativeThread writer) throws IOException {
79 if (NativeThread.isVirtualThread(reader)) {
80 Poller.stopPoll(reader.thread());
81 }
82 if (NativeThread.isVirtualThread(writer)) {
83 Poller.stopPoll(writer.thread());
84 }
85 if (NativeThread.isNativeThread(reader) || NativeThread.isNativeThread(writer)) {
86 implPreClose(fd, reader, writer);
87 }
88 }
89
90 /**
91 * This method does nothing by default. On Unix systems the file descriptor is dup'ed
92 * to a special fd and native threads signalled.
93 */
94 void implPreClose(FileDescriptor fd, NativeThread reader, NativeThread writer) throws IOException {
95 // Do nothing by default; this is only needed on Unix
96 }
97
98 /**
99 * Duplicates a file descriptor.
100 * @param fd1 the file descriptor to duplicate
101 * @param fd2 the new file descriptor, the socket or file that it is connected
102 * to will be closed by this method
103 */
104 void dup(FileDescriptor fd1, FileDescriptor fd2) throws IOException {
105 throw new UnsupportedOperationException();
106 }
107 }
|