/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

 *

 * This code is free software; you can redistribute it and/or modify it

 * under the terms of the GNU General Public License version 2 only, as

 * particular file as subject to the "Classpath" exception as provided

 *

 * This code is distributed in the hope that it will be useful, but WITHOUT

 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

 * version 2 for more details (a copy is included in the LICENSE file that

 * accompanied this code).

 *

 * You should have received a copy of the GNU General Public License version

 * 2 along with this work; if not, write to the Free Software Foundation,

 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

 *

 */

package sun.nio.ch;

import java.io.FileDescriptor;

import java.io.IOException;

import java.net.*;

import java.nio.ByteBuffer;

import java.nio.channels.*;

import java.nio.channels.spi.*;

import java.util.*;

/**

 * An implementation of DatagramChannels.

 */

class DatagramChannelImpl

    extends DatagramChannel

    implements SelChImpl

{

    // Used to make native read and write calls

    private static NativeDispatcher nd = new DatagramDispatcher();

    // Our file descriptor

    private final FileDescriptor fd;

    // fd value needed for dev/poll. This value will remain valid

    // even after the value in the file descriptor object has been set to -1

    private final int fdVal;

    // The protocol family of the socket

    private final ProtocolFamily family;

    // IDs of native threads doing reads and writes, for signalling

    private volatile long readerThread = 0;

    private volatile long writerThread = 0;

    // Cached InetAddress and port for unconnected DatagramChannels

    // used by receive0

    private InetAddress cachedSenderInetAddress;

    private int cachedSenderPort;

    // Lock held by current reading or connecting thread

    private final Object readLock = new Object();

    // Lock held by current writing or connecting thread

    private final Object writeLock = new Object();

    // Lock held by any thread that modifies the state fields declared below

    // DO NOT invoke a blocking I/O operation while holding this lock!

    private final Object stateLock = new Object();

    // -- The following fields are protected by stateLock

    // State (does not necessarily increase monotonically)

    private static final int ST_UNINITIALIZED = -1;

    private static final int ST_UNCONNECTED = 0;

    private static final int ST_CONNECTED = 1;

    private static final int ST_KILLED = 2;

    private int state = ST_UNINITIALIZED;

    // Binding

    private SocketAddress localAddress;

    private SocketAddress remoteAddress;

    // Our socket adaptor, if any

    private DatagramSocket socket;

    // Multicast support

    private MembershipRegistry registry;

    // -- End of fields protected by stateLock

    public DatagramChannelImpl(SelectorProvider sp)

        throws IOException

    {

        super(sp);

        this.family = Net.isIPv6Available() ?

            StandardProtocolFamily.INET6 : StandardProtocolFamily.INET;

        this.fd = Net.socket(family, false);

        this.fdVal = IOUtil.fdVal(fd);

        this.state = ST_UNCONNECTED;

    }

    public DatagramChannelImpl(SelectorProvider sp, ProtocolFamily family) {

        super(sp);

        if ((family != StandardProtocolFamily.INET) &&

            (family != StandardProtocolFamily.INET6))

        {

            if (family == null)

                throw new NullPointerException("'family' is null");

            else

                throw new UnsupportedOperationException("Protocol family not supported");

        }

        if (family == StandardProtocolFamily.INET6) {

            if (!Net.isIPv6Available()) {

                throw new UnsupportedOperationException("IPv6 not available");

            }

        }

        this.family = family;

        this.fd = Net.socket(family, false);

        this.fdVal = IOUtil.fdVal(fd);

        this.state = ST_UNCONNECTED;

    }

    public DatagramChannelImpl(SelectorProvider sp, FileDescriptor fd)

        throws IOException

    {

        super(sp);

        this.family = Net.isIPv6Available() ?

            StandardProtocolFamily.INET6 : StandardProtocolFamily.INET;

        this.fd = fd;

        this.fdVal = IOUtil.fdVal(fd);

        this.state = ST_UNCONNECTED;

        this.localAddress = Net.localAddress(fd);

    }

    public DatagramSocket socket() {

        synchronized (stateLock) {

            if (socket == null)

                socket = DatagramSocketAdaptor.create(this);

            return socket;

        }

    }

    @Override

    public SocketAddress getLocalAddress() throws IOException {

        synchronized (stateLock) {

            if (!isOpen())

                throw new ClosedChannelException();

            return localAddress;

        }

    }

    @Override

    public SocketAddress getRemoteAddress() throws IOException {

        synchronized (stateLock) {

            if (!isOpen())

                throw new ClosedChannelException();

            return remoteAddress;

        }

    }

    @Override

    public <T> DatagramChannel setOption(SocketOption<T> name, T value)

        throws IOException

    {

        if (name == null)

            throw new NullPointerException();

        if (!supportedOptions().contains(name))

            throw new UnsupportedOperationException("'" + name + "' not supported");

        synchronized (stateLock) {

            ensureOpen();

            if (name == StandardSocketOption.IP_TOS) {

                // IPv4 only; no-op for IPv6

                if (family == StandardProtocolFamily.INET) {

                    Net.setSocketOption(fd, family, name, value);

                }

                return this;

            }

            if (name == StandardSocketOption.IP_MULTICAST_TTL ||

                name == StandardSocketOption.IP_MULTICAST_LOOP)

            {

                // options are protocol dependent

                Net.setSocketOption(fd, family, name, value);

                return this;

            }

            if (name == StandardSocketOption.IP_MULTICAST_IF) {

                if (value == null)

                    throw new IllegalArgumentException("Cannot set IP_MULTICAST_IF to 'null'");

                NetworkInterface interf = (NetworkInterface)value;

                if (family == StandardProtocolFamily.INET6) {

                    int index = interf.getIndex();

                    if (index == -1)

                        throw new IOException("Network interface cannot be identified");

                    Net.setInterface6(fd, index);

                } else {

                    // need IPv4 address to identify interface

                    Inet4Address target = Net.anyInet4Address(interf);

                    if (target == null)

                        throw new IOException("Network interface not configured for IPv4");

                    int targetAddress = Net.inet4AsInt(target);

                    Net.setInterface4(fd, targetAddress);

                }

                return this;

            }

            // remaining options don't need any special handling

            Net.setSocketOption(fd, Net.UNSPEC, name, value);

            return this;

        }

    }

    @Override

    @SuppressWarnings("unchecked")

    public <T> T getOption(SocketOption<T> name)

        throws IOException

    {

        if (name == null)

            throw new NullPointerException();

        if (!supportedOptions().contains(name))

            throw new UnsupportedOperationException("'" + name + "' not supported");

        synchronized (stateLock) {

            ensureOpen();

            if (name == StandardSocketOption.IP_TOS) {

                // IPv4 only; always return 0 on IPv6

                if (family == StandardProtocolFamily.INET) {

                    return (T) Net.getSocketOption(fd, family, name);

                } else {

                    return (T) Integer.valueOf(0);

                }

            }

            if (name == StandardSocketOption.IP_MULTICAST_TTL ||

                name == StandardSocketOption.IP_MULTICAST_LOOP)

            {

                return (T) Net.getSocketOption(fd, family, name);

            }

            if (name == StandardSocketOption.IP_MULTICAST_IF) {

                if (family == StandardProtocolFamily.INET) {

                    int address = Net.getInterface4(fd);

                    if (address == 0)

                        return null;    // default interface

                    InetAddress ia = Net.inet4FromInt(address);

                    NetworkInterface ni = NetworkInterface.getByInetAddress(ia);

                    if (ni == null)

                        throw new IOException("Unable to map address to interface");

                    return (T) ni;

                } else {

                    int index = Net.getInterface6(fd);

                    if (index == 0)

                        return null;    // default interface

                    NetworkInterface ni = NetworkInterface.getByIndex(index);

                    if (ni == null)

                        throw new IOException("Unable to map index to interface");

                    return (T) ni;

                }

            }

            // no special handling

            return (T) Net.getSocketOption(fd, Net.UNSPEC, name);

        }

    }

    private static class DefaultOptionsHolder {

        static final Set<SocketOption<?>> defaultOptions = defaultOptions();

        private static Set<SocketOption<?>> defaultOptions() {

            HashSet<SocketOption<?>> set = new HashSet<SocketOption<?>>(8);

            set.add(StandardSocketOption.SO_SNDBUF);

            set.add(StandardSocketOption.SO_RCVBUF);

            set.add(StandardSocketOption.SO_REUSEADDR);

            set.add(StandardSocketOption.SO_BROADCAST);

            set.add(StandardSocketOption.IP_TOS);

            set.add(StandardSocketOption.IP_MULTICAST_IF);

            set.add(StandardSocketOption.IP_MULTICAST_TTL);

            set.add(StandardSocketOption.IP_MULTICAST_LOOP);

            return Collections.unmodifiableSet(set);

        }

    }

    @Override

    public final Set<SocketOption<?>> supportedOptions() {

        return DefaultOptionsHolder.defaultOptions;

    }

    private void ensureOpen() throws ClosedChannelException {

        if (!isOpen())

            throw new ClosedChannelException();

    }

    private SocketAddress sender;       // Set by receive0 (## ugh)

    public SocketAddress receive(ByteBuffer dst) throws IOException {

        if (dst.isReadOnly())

            throw new IllegalArgumentException("Read-only buffer");

        if (dst == null)

            throw new NullPointerException();

        synchronized (readLock) {

            ensureOpen();

            // Socket was not bound before attempting receive

            if (localAddress() == null)

                bind(null);

            int n = 0;

            ByteBuffer bb = null;

            try {

                begin();

                if (!isOpen())

                    return null;

                SecurityManager security = System.getSecurityManager();

                readerThread = NativeThread.current();

                if (isConnected() || (security == null)) {

                    do {

                        n = receive(fd, dst);

                    } while ((n == IOStatus.INTERRUPTED) && isOpen());

                    if (n == IOStatus.UNAVAILABLE)

                        return null;

                } else {

                    bb = Util.getTemporaryDirectBuffer(dst.remaining());

                    for (;;) {

                        do {

                            n = receive(fd, bb);

                        } while ((n == IOStatus.INTERRUPTED) && isOpen());

                        if (n == IOStatus.UNAVAILABLE)

                            return null;

                        InetSocketAddress isa = (InetSocketAddress)sender;

                        try {

                            security.checkAccept(

                                isa.getAddress().getHostAddress(),

                                isa.getPort());

                        } catch (SecurityException se) {

                            // Ignore packet

                            bb.clear();

                            n = 0;

                            continue;

                        }

                        bb.flip();

                        dst.put(bb);

                        break;

                    }

                }

                return sender;

            } finally {

                if (bb != null)

                    Util.releaseTemporaryDirectBuffer(bb);

                readerThread = 0;

                end((n > 0) || (n == IOStatus.UNAVAILABLE));

                assert IOStatus.check(n);

            }

        }

    }

    private int receive(FileDescriptor fd, ByteBuffer dst)

        throws IOException

    {

        int pos = dst.position();

        int lim = dst.limit();

        assert (pos <= lim);

        int rem = (pos <= lim ? lim - pos : 0);

        if (dst instanceof DirectBuffer && rem > 0)

            return receiveIntoNativeBuffer(fd, dst, rem, pos);

        // Substitute a native buffer. If the supplied buffer is empty

        // we must instead use a nonempty buffer, otherwise the call

        // will not block waiting for a datagram on some platforms.

        int newSize = Math.max(rem, 1);

        ByteBuffer bb = null;

        try {

            bb = Util.getTemporaryDirectBuffer(newSize);

            int n = receiveIntoNativeBuffer(fd, bb, newSize, 0);

            bb.flip();

            if (n > 0 && rem > 0)

                dst.put(bb);

            return n;

        } finally {

            Util.releaseTemporaryDirectBuffer(bb);

        }

    }

    private int receiveIntoNativeBuffer(FileDescriptor fd, ByteBuffer bb,

                                        int rem, int pos)

        throws IOException

    {

        int n = receive0(fd, ((DirectBuffer)bb).address() + pos, rem,

                         isConnected());

        if (n > 0)

            bb.position(pos + n);

        return n;

    }

    public int send(ByteBuffer src, SocketAddress target)

        throws IOException

    {

        if (src == null)

            throw new NullPointerException();

        synchronized (writeLock) {

            ensureOpen();

            InetSocketAddress isa = (InetSocketAddress)target;

            InetAddress ia = isa.getAddress();

            if (ia == null)

                throw new IOException("Target address not resolved");

            synchronized (stateLock) {

                if (!isConnected()) {

                    if (target == null)

                        throw new NullPointerException();

                    SecurityManager sm = System.getSecurityManager();

                    if (sm != null) {

                        if (ia.isMulticastAddress()) {

                            sm.checkMulticast(isa.getAddress());

                        } else {

                            sm.checkConnect(isa.getAddress().getHostAddress(),

                                            isa.getPort());

                        }

                    }

                } else { // Connected case; Check address then write

                    if (!target.equals(remoteAddress)) {

                        throw new IllegalArgumentException(

                            "Connected address not equal to target address");

                    }

                    return write(src);

                }

            }

            int n = 0;

            try {

                begin();

                if (!isOpen())

                    return 0;

                writerThread = NativeThread.current();

                do {

                    n = send(fd, src, target);

                } while ((n == IOStatus.INTERRUPTED) && isOpen());

                synchronized (stateLock) {

                    if (isOpen() && (localAddress == null)) {

                        localAddress = Net.localAddress(fd);

                    }

                }

                return IOStatus.normalize(n);

            } finally {

                writerThread = 0;

                end((n > 0) || (n == IOStatus.UNAVAILABLE));

                assert IOStatus.check(n);

            }

        }

    }

    private int send(FileDescriptor fd, ByteBuffer src, SocketAddress target)

        throws IOException

    {

        if (src instanceof DirectBuffer)

            return sendFromNativeBuffer(fd, src, target);

        // Substitute a native buffer

        int pos = src.position();

        int lim = src.limit();

        assert (pos <= lim);

        int rem = (pos <= lim ? lim - pos : 0);

        ByteBuffer bb = null;

        try {

            bb = Util.getTemporaryDirectBuffer(rem);

            bb.put(src);

            bb.flip();

            // Do not update src until we see how many bytes were written

            src.position(pos);

            int n = sendFromNativeBuffer(fd, bb, target);

            if (n > 0) {

                // now update src

                src.position(pos + n);

            }

            return n;

        } finally {

            Util.releaseTemporaryDirectBuffer(bb);

        }

    }

    private int sendFromNativeBuffer(FileDescriptor fd, ByteBuffer bb,

                                            SocketAddress target)

        throws IOException

    {

        int pos = bb.position();

        int lim = bb.limit();

        assert (pos <= lim);

        int rem = (pos <= lim ? lim - pos : 0);

        boolean preferIPv6 = (family != StandardProtocolFamily.INET);

        int written = send0(preferIPv6, fd, ((DirectBuffer)bb).address() + pos,

                            rem, target);

        if (written > 0)

            bb.position(pos + written);

        return written;

    }