package jdk.net;
import java.net.SocketException;
import java.nio.file.attribute.UserPrincipal;
import java.nio.file.attribute.GroupPrincipal;
import java.security.AccessController;
import java.security.PrivilegedAction;
import jdk.net.ExtendedSocketOptions.PlatformSocketOptions;
import sun.nio.fs.UnixUserPrincipals;
class LinuxSocketOptions extends PlatformSocketOptions {
public LinuxSocketOptions() {
}
@Override
void setQuickAck(int fd, boolean on) throws SocketException {
setQuickAck0(fd, on);
}
@Override
boolean getQuickAck(int fd) throws SocketException {
return getQuickAck0(fd);
}
@Override
public boolean quickAckSupported() {
return quickAckSupported0();
}
@Override
boolean keepAliveOptionsSupported() {
return keepAliveOptionsSupported0();
}
boolean peerCredentialsSupported() {
return true;
}
@Override
void setTcpkeepAliveProbes(int fd, final int value) throws SocketException {
setTcpkeepAliveProbes0(fd, value);
}
@Override
void setTcpKeepAliveTime(int fd, final int value) throws SocketException {
setTcpKeepAliveTime0(fd, value);
}
@Override
void setTcpKeepAliveIntvl(int fd, final int value) throws SocketException {
setTcpKeepAliveIntvl0(fd, value);
}
@Override
int getTcpkeepAliveProbes(int fd) throws SocketException {
return getTcpkeepAliveProbes0(fd);
}
@Override
int getTcpKeepAliveTime(int fd) throws SocketException {
return getTcpKeepAliveTime0(fd);
}
@Override
int getTcpKeepAliveIntvl(int fd) throws SocketException {
return getTcpKeepAliveIntvl0(fd);
}
@Override
boolean incomingNapiIdSupported() {
return incomingNapiIdSupported0();
}
@Override
int getIncomingNapiId(int fd) throws SocketException {
return getIncomingNapiId0(fd);
}
@Override
UnixDomainPrincipal getSoPeerCred(int fd) throws SocketException {
long l = getSoPeerCred0(fd);
int uid = (int)(l >> 32);
int gid = (int)l;
UserPrincipal user = UnixUserPrincipals.fromUid(uid);
GroupPrincipal group = UnixUserPrincipals.fromGid(gid);
return new UnixDomainPrincipal(user, group);
}
private static native void setTcpkeepAliveProbes0(int fd, int value) throws SocketException;
private static native void setTcpKeepAliveTime0(int fd, int value) throws SocketException;
private static native void setTcpKeepAliveIntvl0(int fd, int value) throws SocketException;
private static native int getTcpkeepAliveProbes0(int fd) throws SocketException;
private static native int getTcpKeepAliveTime0(int fd) throws SocketException;
private static native int getTcpKeepAliveIntvl0(int fd) throws SocketException;
private static native void setQuickAck0(int fd, boolean on) throws SocketException;
private static native boolean getQuickAck0(int fd) throws SocketException;
private static native long getSoPeerCred0(int fd) throws SocketException;
private static native boolean keepAliveOptionsSupported0();
private static native boolean quickAckSupported0();
private static native boolean incomingNapiIdSupported0();
private static native int getIncomingNapiId0(int fd) throws SocketException;
static {
if (System.getSecurityManager() == null) {
System.loadLibrary("extnet");
} else {
AccessController.doPrivileged((PrivilegedAction<Void>) () -> {
System.loadLibrary("extnet");
return null;
});
}
}
}