jdk/src/java.base/unix/classes/java/net/PlainDatagramSocketImpl.java
author chegar
Wed, 27 Apr 2016 20:36:02 +0100
changeset 37676 24ef455da1b0
parent 36115 0676e37a0b9c
permissions -rw-r--r--
8044773: Refactor jdk.net API so that it can be moved out of the base module Reviewed-by: alanb, erikj, mchung
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
     1
/*
36115
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
     2
 * Copyright (c) 2007, 2016, Oracle and/or its affiliates. All rights reserved.
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
90ce3da70b43 Initial load
duke
parents:
diff changeset
     4
 *
90ce3da70b43 Initial load
duke
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
90ce3da70b43 Initial load
duke
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
5506
202f599c92aa 6943119: Rebrand source copyright notices
ohair
parents: 2
diff changeset
     7
 * published by the Free Software Foundation.  Oracle designates this
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
     8
 * particular file as subject to the "Classpath" exception as provided
5506
202f599c92aa 6943119: Rebrand source copyright notices
ohair
parents: 2
diff changeset
     9
 * by Oracle in the LICENSE file that accompanied this code.
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
    10
 *
90ce3da70b43 Initial load
duke
parents:
diff changeset
    11
 * This code is distributed in the hope that it will be useful, but WITHOUT
90ce3da70b43 Initial load
duke
parents:
diff changeset
    12
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
90ce3da70b43 Initial load
duke
parents:
diff changeset
    13
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
90ce3da70b43 Initial load
duke
parents:
diff changeset
    14
 * version 2 for more details (a copy is included in the LICENSE file that
90ce3da70b43 Initial load
duke
parents:
diff changeset
    15
 * accompanied this code).
90ce3da70b43 Initial load
duke
parents:
diff changeset
    16
 *
90ce3da70b43 Initial load
duke
parents:
diff changeset
    17
 * You should have received a copy of the GNU General Public License version
90ce3da70b43 Initial load
duke
parents:
diff changeset
    18
 * 2 along with this work; if not, write to the Free Software Foundation,
90ce3da70b43 Initial load
duke
parents:
diff changeset
    19
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
90ce3da70b43 Initial load
duke
parents:
diff changeset
    20
 *
5506
202f599c92aa 6943119: Rebrand source copyright notices
ohair
parents: 2
diff changeset
    21
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
202f599c92aa 6943119: Rebrand source copyright notices
ohair
parents: 2
diff changeset
    22
 * or visit www.oracle.com if you need additional information or have any
202f599c92aa 6943119: Rebrand source copyright notices
ohair
parents: 2
diff changeset
    23
 * questions.
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
    24
 */
90ce3da70b43 Initial load
duke
parents:
diff changeset
    25
package java.net;
90ce3da70b43 Initial load
duke
parents:
diff changeset
    26
90ce3da70b43 Initial load
duke
parents:
diff changeset
    27
import java.io.IOException;
23879
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    28
import java.util.Set;
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    29
import java.util.HashSet;
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    30
import sun.net.ext.ExtendedSocketOptions;
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
    31
90ce3da70b43 Initial load
duke
parents:
diff changeset
    32
/*
90ce3da70b43 Initial load
duke
parents:
diff changeset
    33
 * On Unix systems we simply delegate to native methods.
90ce3da70b43 Initial load
duke
parents:
diff changeset
    34
 *
90ce3da70b43 Initial load
duke
parents:
diff changeset
    35
 * @author Chris Hegarty
90ce3da70b43 Initial load
duke
parents:
diff changeset
    36
 */
90ce3da70b43 Initial load
duke
parents:
diff changeset
    37
90ce3da70b43 Initial load
duke
parents:
diff changeset
    38
class PlainDatagramSocketImpl extends AbstractPlainDatagramSocketImpl
90ce3da70b43 Initial load
duke
parents:
diff changeset
    39
{
90ce3da70b43 Initial load
duke
parents:
diff changeset
    40
    static {
90ce3da70b43 Initial load
duke
parents:
diff changeset
    41
        init();
90ce3da70b43 Initial load
duke
parents:
diff changeset
    42
    }
90ce3da70b43 Initial load
duke
parents:
diff changeset
    43
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    44
    static final ExtendedSocketOptions extendedOptions =
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    45
            ExtendedSocketOptions.getInstance();
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    46
23879
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    47
    protected <T> void setOption(SocketOption<T> name, T value) throws IOException {
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    48
        if (!extendedOptions.isOptionSupported(name)) {
36115
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    49
            if (!name.equals(StandardSocketOptions.SO_REUSEPORT)) {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    50
                super.setOption(name, value);
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    51
            } else {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    52
               if (supportedOptions().contains(name)) {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    53
                   super.setOption(name, value);
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    54
               } else {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    55
                   throw new UnsupportedOperationException("unsupported option");
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    56
               }
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    57
            }
23879
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    58
        } else {
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    59
            if (isClosed()) {
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    60
                throw new SocketException("Socket closed");
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    61
            }
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    62
            extendedOptions.setOption(fd, name, value);
23879
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    63
        }
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    64
    }
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    65
24046
d1f6da65881a 8041397: Lint regression in java.net.SocketOption
michaelm
parents: 23879
diff changeset
    66
    @SuppressWarnings("unchecked")
23879
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    67
    protected <T> T getOption(SocketOption<T> name) throws IOException {
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    68
        if (!extendedOptions.isOptionSupported(name)) {
36115
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    69
            if (!name.equals(StandardSocketOptions.SO_REUSEPORT)) {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    70
                return super.getOption(name);
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    71
            } else {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    72
                if (supportedOptions().contains(name)) {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    73
                    return super.getOption(name);
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    74
                } else {
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    75
                    throw new UnsupportedOperationException("unsupported option");
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    76
                }
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    77
            }
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    78
        } else {
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    79
            if (isClosed()) {
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    80
                throw new SocketException("Socket closed");
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    81
            }
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    82
            return (T) extendedOptions.getOption(fd, name);
34968
93b315c61ca3 8143554: UnsupportedOperationException is not thrown for unsupported options
kshefov
parents: 32649
diff changeset
    83
        }
23879
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    84
    }
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    85
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    86
    protected Set<SocketOption<?>> supportedOptions() {
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    87
        HashSet<SocketOption<?>> options = new HashSet<>(super.supportedOptions());
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    88
        options.addAll(extendedOptions.options());
23879
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    89
        return options;
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    90
    }
284802a2d355 8036979: Support java.net.SocketOption<> in java.net socket types
michaelm
parents: 10596
diff changeset
    91
30963
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
    92
    protected void socketSetOption(int opt, Object val) throws SocketException {
37676
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    93
        if (opt == SocketOptions.SO_REUSEPORT &&
24ef455da1b0 8044773: Refactor jdk.net API so that it can be moved out of the base module
chegar
parents: 36115
diff changeset
    94
            !supportedOptions().contains(StandardSocketOptions.SO_REUSEPORT)) {
36115
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    95
            throw new UnsupportedOperationException("unsupported option");
0676e37a0b9c 6432031: Add support for SO_REUSEPORT
alanb
parents: 34968
diff changeset
    96
        }
30963
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
    97
        try {
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
    98
            socketSetOption0(opt, val);
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
    99
        } catch (SocketException se) {
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
   100
            if (!connected)
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
   101
                throw se;
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
   102
        }
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
   103
    }
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
   104
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
   105
    protected synchronized native void bind0(int lport, InetAddress laddr)
90ce3da70b43 Initial load
duke
parents:
diff changeset
   106
        throws SocketException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   107
90ce3da70b43 Initial load
duke
parents:
diff changeset
   108
    protected native void send(DatagramPacket p) throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   109
90ce3da70b43 Initial load
duke
parents:
diff changeset
   110
    protected synchronized native int peek(InetAddress i) throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   111
90ce3da70b43 Initial load
duke
parents:
diff changeset
   112
    protected synchronized native int peekData(DatagramPacket p) throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   113
90ce3da70b43 Initial load
duke
parents:
diff changeset
   114
    protected synchronized native void receive0(DatagramPacket p)
90ce3da70b43 Initial load
duke
parents:
diff changeset
   115
        throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   116
90ce3da70b43 Initial load
duke
parents:
diff changeset
   117
    protected native void setTimeToLive(int ttl) throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   118
90ce3da70b43 Initial load
duke
parents:
diff changeset
   119
    protected native int getTimeToLive() throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   120
10596
39b3a979e600 7090158: Networking Libraries don't build with javac -Werror
chegar
parents: 5506
diff changeset
   121
    @Deprecated
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
   122
    protected native void setTTL(byte ttl) throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   123
10596
39b3a979e600 7090158: Networking Libraries don't build with javac -Werror
chegar
parents: 5506
diff changeset
   124
    @Deprecated
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
   125
    protected native byte getTTL() throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   126
90ce3da70b43 Initial load
duke
parents:
diff changeset
   127
    protected native void join(InetAddress inetaddr, NetworkInterface netIf)
90ce3da70b43 Initial load
duke
parents:
diff changeset
   128
        throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   129
90ce3da70b43 Initial load
duke
parents:
diff changeset
   130
    protected native void leave(InetAddress inetaddr, NetworkInterface netIf)
90ce3da70b43 Initial load
duke
parents:
diff changeset
   131
        throws IOException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   132
90ce3da70b43 Initial load
duke
parents:
diff changeset
   133
    protected native void datagramSocketCreate() throws SocketException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   134
90ce3da70b43 Initial load
duke
parents:
diff changeset
   135
    protected native void datagramSocketClose();
90ce3da70b43 Initial load
duke
parents:
diff changeset
   136
30963
88469d06e03f 8072384: Setting IP_TOS on java.net sockets not working on unix
coffeys
parents: 25859
diff changeset
   137
    protected native void socketSetOption0(int opt, Object val)
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
   138
        throws SocketException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   139
90ce3da70b43 Initial load
duke
parents:
diff changeset
   140
    protected native Object socketGetOption(int opt) throws SocketException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   141
90ce3da70b43 Initial load
duke
parents:
diff changeset
   142
    protected native void connect0(InetAddress address, int port) throws SocketException;
90ce3da70b43 Initial load
duke
parents:
diff changeset
   143
90ce3da70b43 Initial load
duke
parents:
diff changeset
   144
    protected native void disconnect0(int family);
90ce3da70b43 Initial load
duke
parents:
diff changeset
   145
32503
1478c9130534 8072466: Deadlock when initializing MulticastSocket and DatagramSocket
igerasim
parents: 30963
diff changeset
   146
    native int dataAvailable();
1478c9130534 8072466: Deadlock when initializing MulticastSocket and DatagramSocket
igerasim
parents: 30963
diff changeset
   147
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
   148
    /**
90ce3da70b43 Initial load
duke
parents:
diff changeset
   149
     * Perform class load-time initializations.
90ce3da70b43 Initial load
duke
parents:
diff changeset
   150
     */
32649
2ee9017c7597 8136583: Core libraries should use blessed modifier order
martin
parents: 32503
diff changeset
   151
    private static native void init();
2
90ce3da70b43 Initial load
duke
parents:
diff changeset
   152
}