1 /* 2 * Copyright (c) 2014, 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 <errno.h> 27 #include <sys/socket.h> 28 #include <stropts.h> 29 #include <unistd.h> 30 31 #include "jni.h" 32 33 /* Support for restartable system calls on Solaris. */ 34 35 #define RESTARTABLE_RETURN_INT(_cmd) do { \ 36 int _result; \ 37 if (1) { \ 38 do { \ 39 _result = _cmd; \ 40 } while((_result == -1) && (errno == EINTR)); \ 41 return _result; \ 42 } \ 43 } while(0) 44 45 int NET_Read(int s, void* buf, size_t len) { 46 RESTARTABLE_RETURN_INT(recv(s, buf, len, 0)); 47 } 48 49 int NET_RecvFrom(int s, void *buf, int len, unsigned int flags, 50 struct sockaddr *from, socklen_t *fromlen) { 51 RESTARTABLE_RETURN_INT(recvfrom(s, buf, len, flags, from, fromlen)); 52 } 53 54 int NET_ReadV(int s, const struct iovec * vector, int count) { 55 RESTARTABLE_RETURN_INT(readv(s, vector, count)); 56 } 57 58 int NET_WriteV(int s, const struct iovec * vector, int count) { 59 RESTARTABLE_RETURN_INT(writev(s, vector, count)); 60 } 61 62 int NET_Send(int s, void *msg, int len, unsigned int flags) { 63 RESTARTABLE_RETURN_INT(send(s, msg, len, flags)); 64 } 65 66 int NET_SendTo(int s, const void *msg, int len, unsigned int flags, 67 const struct sockaddr *to, int tolen) { 68 RESTARTABLE_RETURN_INT(sendto(s, msg, len, flags, to, tolen)); 69 } 70 71 int NET_Connect(int s, struct sockaddr *addr, int addrlen) { 72 RESTARTABLE_RETURN_INT(connect(s, addr, addrlen)); 73 } 74 75 int NET_Accept(int s, struct sockaddr *addr, socklen_t *addrlen) { 76 RESTARTABLE_RETURN_INT(accept(s, addr, addrlen)); 77 } 78 79 int NET_SocketClose(int fd) { 80 return close(fd); 81 } 82 83 int NET_Dup2(int fd, int fd2) { 84 return dup2(fd, fd2); 85 } 86 87 int NET_Poll(struct pollfd *ufds, unsigned int nfds, int timeout) { 88 RESTARTABLE_RETURN_INT(poll(ufds, nfds, timeout)); 89 } 90 91 int NET_Select(int s, fd_set *readfds, fd_set *writefds, 92 fd_set *exceptfds, struct timeval *timeout) { 93 RESTARTABLE_RETURN_INT(select(s, readfds, writefds, exceptfds, timeout)); 94 } 95 96 int NET_Timeout(JNIEnv *unused, int s, long timeout) { 97 int result; 98 struct timeval t; 99 long prevtime, newtime; 100 struct pollfd pfd; 101 pfd.fd = s; 102 pfd.events = POLLIN; 103 104 if (timeout > 0) { 105 gettimeofday(&t, NULL); 106 prevtime = (t.tv_sec * 1000) + t.tv_usec / 1000; 107 } 108 109 for(;;) { 110 result = poll(&pfd, 1, timeout); 111 if (result < 0 && errno == EINTR) { 112 if (timeout > 0) { 113 gettimeofday(&t, NULL); 114 newtime = (t.tv_sec * 1000) + t.tv_usec /1000; 115 timeout -= newtime - prevtime; 116 if (timeout <= 0) 117 return 0; 118 prevtime = newtime; 119 } 120 } else { 121 return result; 122 } 123 } 124 }