/* * Copyright (c) 2009, Oracle and/or its affiliates. All rights reserved. * 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 * published by the Free Software Foundation.  Oracle designates this * particular file as subject to the "Classpath" exception as provided * by Oracle in the LICENSE file that accompanied this code. * * 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. * * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA * or visit www.oracle.com if you need additional information or have any * questions. */package sun.nio.ch; import java.net.SocketAddress;import com.sun.nio.sctp.MessageInfo;import com.sun.nio.sctp.Association; /** * An implementation of a MessageInfo. */public class SctpMessageInfoImpl extends MessageInfo {    private final SocketAddress address;    private final int bytes;          /* 0 */     private Association association;    private int assocId;    private int streamNumber;    private boolean complete = true;    private boolean unordered;  /* false */    private long timeToLive;    /* 0L */    private int ppid;           /* 0 */     public SctpMessageInfoImpl(Association association,                               SocketAddress address,                               int streamNumber) {        this.association = association;        this.address = address;        this.streamNumber = streamNumber;        bytes = 0;    }     /* Invoked from native */    private SctpMessageInfoImpl(int assocId,                                SocketAddress address,                                int bytes,                                int streamNumber,                                boolean complete,                                boolean unordered,                                int ppid) {        this.assocId = assocId;        this.address = address;        this.bytes = bytes;        this.streamNumber = streamNumber;        this.complete = complete;        this.unordered = unordered;        this.ppid = ppid;    }     @Override    public Association association() {        return association;    }     /**     * SctpMessageInfoImpl instances created from native will need to have their     * association set from the channel.     */    void setAssociation(Association association) {        this.association = association;    }     int associationID() {        return assocId;    }     @Override    public SocketAddress address() {        return address;    }     @Override    public int bytes() {        return bytes;    }     @Override    public int streamNumber() {        return streamNumber;    }     @Override    public MessageInfo streamNumber(int streamNumber) {        if (streamNumber < 0 || streamNumber > 65536)            throw new IllegalArgumentException("Invalid stream number");         this.streamNumber = streamNumber;        return this;    }     @Override    public int payloadProtocolID() {        return ppid;    }     @Override    public MessageInfo payloadProtocolID(int ppid) {        this.ppid = ppid;        return this;    }     @Override    public boolean isComplete() {        return complete;    }     @Override    public MessageInfo complete(boolean complete) {        this.complete = complete;        return this;    }     @Override    public boolean isUnordered() {        return unordered;    }     @Override    public MessageInfo unordered(boolean unordered) {        this.unordered = unordered;        return this;    }     @Override    public long timeToLive() {        return timeToLive;    }     @Override    public MessageInfo timeToLive(long millis) {        timeToLive = millis;        return this;    }     @Override    public String toString() {        StringBuilder sb = new StringBuilder(super.toString());        sb.append( "[Address: ").append(address)          .append(", Association: ").append(association)          .append(", Assoc ID: ").append(assocId)          .append(", Bytes: ").append(bytes)          .append(", Stream Number: ").append(streamNumber)          .append(", Complete: ").append(complete)          .append(", isUnordered: ").append(unordered)          .append("]");        return sb.toString();    }}