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 package jdk.net;
26
27 import java.net.SocketException;
28 import java.security.AccessController;
29 import java.security.PrivilegedAction;
30 import jdk.net.ExtendedSocketOptions.PlatformSocketOptions;
31
32 class LinuxSocketOptions extends PlatformSocketOptions {
33
34 public LinuxSocketOptions() {
35 }
36
37 @Override
38 void setQuickAck(int fd, boolean on) throws SocketException {
39 setQuickAck0(fd, on);
40 }
41
42 @Override
43 boolean getQuickAck(int fd) throws SocketException {
44 return getQuickAck0(fd);
45 }
46
47 @Override
48 public boolean quickAckSupported() {
49 return quickAckSupported0();
50 }
51
52 @Override
53 boolean keepAliveOptionsSupported() {
54 return keepAliveOptionsSupported0();
55 }
56
57 @Override
58 void setTcpkeepAliveProbes(int fd, final int value) throws SocketException {
59 setTcpkeepAliveProbes0(fd, value);
60 }
61
62 @Override
63 void setTcpKeepAliveTime(int fd, final int value) throws SocketException {
64 setTcpKeepAliveTime0(fd, value);
65 }
66
67 @Override
68 void setTcpKeepAliveIntvl(int fd, final int value) throws SocketException {
69 setTcpKeepAliveIntvl0(fd, value);
70 }
71
72 @Override
73 int getTcpkeepAliveProbes(int fd) throws SocketException {
74 return getTcpkeepAliveProbes0(fd);
75 }
76
77 @Override
78 int getTcpKeepAliveTime(int fd) throws SocketException {
79 return getTcpKeepAliveTime0(fd);
80 }
81
82 @Override
83 int getTcpKeepAliveIntvl(int fd) throws SocketException {
84 return getTcpKeepAliveIntvl0(fd);
85 }
86
87 @Override
88 boolean incomingNapiIdSupported() {
89 return incomingNapiIdSupported0();
90 }
91
92 @Override
93 int getIncomingNapiId(int fd) throws SocketException {
94 return getIncomingNapiId0(fd);
95 }
96
97 private static native void setTcpkeepAliveProbes0(int fd, int value) throws SocketException;
98 private static native void setTcpKeepAliveTime0(int fd, int value) throws SocketException;
99 private static native void setTcpKeepAliveIntvl0(int fd, int value) throws SocketException;
100 private static native int getTcpkeepAliveProbes0(int fd) throws SocketException;
101 private static native int getTcpKeepAliveTime0(int fd) throws SocketException;
102 private static native int getTcpKeepAliveIntvl0(int fd) throws SocketException;
103 private static native void setQuickAck0(int fd, boolean on) throws SocketException;
104 private static native boolean getQuickAck0(int fd) throws SocketException;
105 private static native boolean keepAliveOptionsSupported0();
106 private static native boolean quickAckSupported0();
107 private static native boolean incomingNapiIdSupported0();
108 private static native int getIncomingNapiId0(int fd) throws SocketException;
109 static {
110 if (System.getSecurityManager() == null) {
111 System.loadLibrary("extnet");
112 } else {
113 AccessController.doPrivileged((PrivilegedAction<Void>) () -> {
114 System.loadLibrary("extnet");
115 return null;
116 });
117 }
118 }
119 }
120
|
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 package jdk.net;
26
27 import java.net.SocketException;
28 import java.nio.file.attribute.UserPrincipal;
29 import java.nio.file.attribute.GroupPrincipal;
30 import java.security.AccessController;
31 import java.security.PrivilegedAction;
32 import jdk.net.ExtendedSocketOptions.PlatformSocketOptions;
33 import sun.nio.fs.UnixUserGroupUtil;
34
35 class LinuxSocketOptions extends PlatformSocketOptions {
36
37 public LinuxSocketOptions() {
38 }
39
40 @Override
41 void setQuickAck(int fd, boolean on) throws SocketException {
42 setQuickAck0(fd, on);
43 }
44
45 @Override
46 boolean getQuickAck(int fd) throws SocketException {
47 return getQuickAck0(fd);
48 }
49
50 @Override
51 public boolean quickAckSupported() {
52 return quickAckSupported0();
53 }
54
55 @Override
56 boolean keepAliveOptionsSupported() {
57 return keepAliveOptionsSupported0();
58 }
59
60 boolean peerCredentialsSupported() {
61 return true;
62 }
63
64 @Override
65 void setTcpkeepAliveProbes(int fd, final int value) throws SocketException {
66 setTcpkeepAliveProbes0(fd, value);
67 }
68
69 @Override
70 void setTcpKeepAliveTime(int fd, final int value) throws SocketException {
71 setTcpKeepAliveTime0(fd, value);
72 }
73
74 @Override
75 void setTcpKeepAliveIntvl(int fd, final int value) throws SocketException {
76 setTcpKeepAliveIntvl0(fd, value);
77 }
78
79 @Override
80 int getTcpkeepAliveProbes(int fd) throws SocketException {
81 return getTcpkeepAliveProbes0(fd);
82 }
83
84 @Override
85 int getTcpKeepAliveTime(int fd) throws SocketException {
86 return getTcpKeepAliveTime0(fd);
87 }
88
89 @Override
90 int getTcpKeepAliveIntvl(int fd) throws SocketException {
91 return getTcpKeepAliveIntvl0(fd);
92 }
93
94 @Override
95 boolean incomingNapiIdSupported() {
96 return incomingNapiIdSupported0();
97 }
98
99 @Override
100 int getIncomingNapiId(int fd) throws SocketException {
101 return getIncomingNapiId0(fd);
102 }
103
104
105 @Override
106 UnixDomainPrincipal getSoPeerCred(int fd) throws SocketException {
107 int[] result = new int[2];
108
109 getSoPeerCred0(fd, result);
110 UserPrincipal user = UnixUserGroupUtil.fromUid(result[0]);
111 GroupPrincipal group = UnixUserGroupUtil.fromGid(result[1]);
112 return new UnixDomainPrincipal(user, group);
113 }
114
115 private static native void setTcpkeepAliveProbes0(int fd, int value) throws SocketException;
116 private static native void setTcpKeepAliveTime0(int fd, int value) throws SocketException;
117 private static native void setTcpKeepAliveIntvl0(int fd, int value) throws SocketException;
118 private static native int getTcpkeepAliveProbes0(int fd) throws SocketException;
119 private static native int getTcpKeepAliveTime0(int fd) throws SocketException;
120 private static native int getTcpKeepAliveIntvl0(int fd) throws SocketException;
121 private static native void setQuickAck0(int fd, boolean on) throws SocketException;
122 private static native boolean getQuickAck0(int fd) throws SocketException;
123 private static native void getSoPeerCred0(int fd, int[] result) throws SocketException;
124 private static native boolean keepAliveOptionsSupported0();
125 private static native boolean quickAckSupported0();
126 private static native boolean incomingNapiIdSupported0();
127 private static native int getIncomingNapiId0(int fd) throws SocketException;
128 static {
129 if (System.getSecurityManager() == null) {
130 System.loadLibrary("extnet");
131 } else {
132 AccessController.doPrivileged((PrivilegedAction<Void>) () -> {
133 System.loadLibrary("extnet");
134 return null;
135 });
136 }
137 }
138 }
139
|