1 /*
2 * Copyright (c) 2000, 2011, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation. Oracle designates this
8 * particular file as subject to the "Classpath" exception as provided
9 * by Oracle in the LICENSE file that accompanied this code.
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 #include "jni.h"
27 #include "jni_util.h"
28 #include "jvm.h"
29 #include "jvm_md.h"
30 #include "jlong.h"
31 #include <sys/mman.h>
32 #include <sys/stat.h>
33 #include <fcntl.h>
34 #include "sun_nio_ch_FileChannelImpl.h"
35 #include "nio.h"
36 #include "nio_util.h"
37 #include <dlfcn.h>
38 #include <nativehelper/JNIHelp.h>
39
40 #define NATIVE_METHOD(className, functionName, signature) \
41 { #functionName, signature, (void*)(className ## _ ## functionName) }
42
43 #if defined(__linux__) || defined(__solaris__)
44 #include <sys/sendfile.h>
45 #elif defined(_AIX)
46 #include <sys/socket.h>
47 #elif defined(_ALLBSD_SOURCE)
48 #include <sys/types.h>
49 #include <sys/socket.h>
50 #include <sys/uio.h>
51
52 #define lseek64 lseek
53 #define mmap64 mmap
54 #endif
55
56 static jfieldID chan_fd; /* jobject 'fd' in sun.io.FileChannelImpl */
57
58 JNIEXPORT jlong JNICALL
FileChannelImpl_initIDs(JNIEnv * env,jclass clazz)59 FileChannelImpl_initIDs(JNIEnv *env, jclass clazz)
60 {
61 jlong pageSize = sysconf(_SC_PAGESIZE);
62 chan_fd = (*env)->GetFieldID(env, clazz, "fd", "Ljava/io/FileDescriptor;");
63 return pageSize;
64 }
65
66 static jlong
handle(JNIEnv * env,jlong rv,char * msg)67 handle(JNIEnv *env, jlong rv, char *msg)
68 {
69 if (rv >= 0)
70 return rv;
71 if (errno == EINTR)
72 return IOS_INTERRUPTED;
73 JNU_ThrowIOExceptionWithLastError(env, msg);
74 return IOS_THROWN;
75 }
76
77
78 JNIEXPORT jlong JNICALL
FileChannelImpl_map0(JNIEnv * env,jobject this,jint prot,jlong off,jlong len)79 FileChannelImpl_map0(JNIEnv *env, jobject this,
80 jint prot, jlong off, jlong len)
81 {
82 void *mapAddress = 0;
83 jobject fdo = (*env)->GetObjectField(env, this, chan_fd);
84 jint fd = fdval(env, fdo);
85 int protections = 0;
86 int flags = 0;
87
88 if (prot == sun_nio_ch_FileChannelImpl_MAP_RO) {
89 protections = PROT_READ;
90 flags = MAP_SHARED;
91 } else if (prot == sun_nio_ch_FileChannelImpl_MAP_RW) {
92 protections = PROT_WRITE | PROT_READ;
93 flags = MAP_SHARED;
94 } else if (prot == sun_nio_ch_FileChannelImpl_MAP_PV) {
95 protections = PROT_WRITE | PROT_READ;
96 flags = MAP_PRIVATE;
97 }
98
99 mapAddress = mmap64(
100 0, /* Let OS decide location */
101 len, /* Number of bytes to map */
102 protections, /* File permissions */
103 flags, /* Changes are shared */
104 fd, /* File descriptor of mapped file */
105 off); /* Offset into file */
106
107 if (mapAddress == MAP_FAILED) {
108 if (errno == ENOMEM) {
109 JNU_ThrowOutOfMemoryError(env, "Map failed");
110 return IOS_THROWN;
111 }
112 return handle(env, -1, "Map failed");
113 }
114
115 return ((jlong) (unsigned long) mapAddress);
116 }
117
118
119 JNIEXPORT jint JNICALL
FileChannelImpl_unmap0(JNIEnv * env,jobject this,jlong address,jlong len)120 FileChannelImpl_unmap0(JNIEnv *env, jobject this,
121 jlong address, jlong len)
122 {
123 void *a = (void *)jlong_to_ptr(address);
124 return handle(env,
125 munmap(a, (size_t)len),
126 "Unmap failed");
127 }
128
129
130 JNIEXPORT jlong JNICALL
FileChannelImpl_position0(JNIEnv * env,jobject this,jobject fdo,jlong offset)131 FileChannelImpl_position0(JNIEnv *env, jobject this,
132 jobject fdo, jlong offset)
133 {
134 jint fd = fdval(env, fdo);
135 jlong result = 0;
136
137 if (offset < 0) {
138 result = lseek64(fd, 0, SEEK_CUR);
139 } else {
140 result = lseek64(fd, offset, SEEK_SET);
141 }
142 return handle(env, result, "Position failed");
143 }
144
145
146 JNIEXPORT void JNICALL
FileChannelImpl_close0(JNIEnv * env,jobject this,jobject fdo)147 FileChannelImpl_close0(JNIEnv *env, jobject this, jobject fdo)
148 {
149 jint fd = fdval(env, fdo);
150 if (fd != -1) {
151 jlong result = close(fd);
152 if (result < 0) {
153 JNU_ThrowIOExceptionWithLastError(env, "Close failed");
154 }
155 }
156 }
157
158 JNIEXPORT jlong JNICALL
FileChannelImpl_transferTo0(JNIEnv * env,jobject this,jobject srcFDO,jlong position,jlong count,jobject dstFDO)159 FileChannelImpl_transferTo0(JNIEnv *env, jobject this,
160 jobject srcFDO,
161 jlong position, jlong count,
162 jobject dstFDO)
163 {
164 jint srcFD = fdval(env, srcFDO);
165 jint dstFD = fdval(env, dstFDO);
166
167 #if defined(__linux__)
168 off64_t offset = (off64_t)position;
169 jlong n = sendfile64(dstFD, srcFD, &offset, (size_t)count);
170 if (n < 0) {
171 if (errno == EAGAIN)
172 return IOS_UNAVAILABLE;
173 if ((errno == EINVAL) && ((ssize_t)count >= 0))
174 return IOS_UNSUPPORTED_CASE;
175 if (errno == EINTR) {
176 return IOS_INTERRUPTED;
177 }
178 JNU_ThrowIOExceptionWithLastError(env, "Transfer failed");
179 return IOS_THROWN;
180 }
181 return n;
182 #elif defined (__solaris__)
183 sendfilevec64_t sfv;
184 size_t numBytes = 0;
185 jlong result;
186
187 sfv.sfv_fd = srcFD;
188 sfv.sfv_flag = 0;
189 sfv.sfv_off = (off64_t)position;
190 sfv.sfv_len = count;
191
192 result = sendfilev64(dstFD, &sfv, 1, &numBytes);
193
194 /* Solaris sendfilev() will return -1 even if some bytes have been
195 * transferred, so we check numBytes first.
196 */
197 if (numBytes > 0)
198 return numBytes;
199 if (result < 0) {
200 if (errno == EAGAIN)
201 return IOS_UNAVAILABLE;
202 if (errno == EOPNOTSUPP)
203 return IOS_UNSUPPORTED_CASE;
204 if ((errno == EINVAL) && ((ssize_t)count >= 0))
205 return IOS_UNSUPPORTED_CASE;
206 if (errno == EINTR)
207 return IOS_INTERRUPTED;
208 JNU_ThrowIOExceptionWithLastError(env, "Transfer failed");
209 return IOS_THROWN;
210 }
211 return result;
212 #elif defined(__APPLE__)
213 off_t numBytes;
214 int result;
215
216 numBytes = count;
217
218 result = sendfile(srcFD, dstFD, position, &numBytes, NULL, 0);
219
220 if (numBytes > 0)
221 return numBytes;
222
223 if (result == -1) {
224 if (errno == EAGAIN)
225 return IOS_UNAVAILABLE;
226 if (errno == EOPNOTSUPP || errno == ENOTSOCK || errno == ENOTCONN)
227 return IOS_UNSUPPORTED_CASE;
228 if ((errno == EINVAL) && ((ssize_t)count >= 0))
229 return IOS_UNSUPPORTED_CASE;
230 if (errno == EINTR)
231 return IOS_INTERRUPTED;
232 JNU_ThrowIOExceptionWithLastError(env, "Transfer failed");
233 return IOS_THROWN;
234 }
235
236 return result;
237
238 #elif defined(_AIX)
239 jlong max = (jlong)java_lang_Integer_MAX_VALUE;
240 struct sf_parms sf_iobuf;
241 jlong result;
242
243 if (position > max)
244 return IOS_UNSUPPORTED_CASE;
245
246 if (count > max)
247 count = max;
248
249 memset(&sf_iobuf, 0, sizeof(sf_iobuf));
250 sf_iobuf.file_descriptor = srcFD;
251 sf_iobuf.file_offset = (off_t)position;
252 sf_iobuf.file_bytes = count;
253
254 result = send_file(&dstFD, &sf_iobuf, SF_SYNC_CACHE);
255
256 /* AIX send_file() will return 0 when this operation complete successfully,
257 * return 1 when partial bytes transfered and return -1 when an error has
258 * Occured.
259 */
260 if (result == -1) {
261 if (errno == EWOULDBLOCK)
262 return IOS_UNAVAILABLE;
263 if ((errno == EINVAL) && ((ssize_t)count >= 0))
264 return IOS_UNSUPPORTED_CASE;
265 if (errno == EINTR)
266 return IOS_INTERRUPTED;
267 if (errno == ENOTSOCK)
268 return IOS_UNSUPPORTED;
269 JNU_ThrowIOExceptionWithLastError(env, "Transfer failed");
270 return IOS_THROWN;
271 }
272
273 if (sf_iobuf.bytes_sent > 0)
274 return (jlong)sf_iobuf.bytes_sent;
275
276 return IOS_UNSUPPORTED_CASE;
277 #else
278 return IOS_UNSUPPORTED_CASE;
279 #endif
280 }
281
282 static JNINativeMethod gMethods[] = {
283 NATIVE_METHOD(FileChannelImpl, initIDs, "()J"),
284 NATIVE_METHOD(FileChannelImpl, map0, "(IJJ)J"),
285 NATIVE_METHOD(FileChannelImpl, unmap0, "(JJ)I"),
286 NATIVE_METHOD(FileChannelImpl, position0, "(Ljava/io/FileDescriptor;J)J"),
287 NATIVE_METHOD(FileChannelImpl, transferTo0, "(Ljava/io/FileDescriptor;JJLjava/io/FileDescriptor;)J"),
288 };
289
register_sun_nio_ch_FileChannelImpl(JNIEnv * env)290 void register_sun_nio_ch_FileChannelImpl(JNIEnv* env) {
291 jniRegisterNativeMethods(env, "sun/nio/ch/FileChannelImpl", gMethods, NELEM(gMethods));
292 }
293