statetransferinfo.java

JGRoups源码

// $Id: StateTransferInfo.java,v 1.13 2006/08/29 02:43:32 vlada Exp $

package org.jgroups.stack;


import java.io.InputStream;
import java.io.OutputStream;

import org.jgroups.Address;


/**
 * Contains parameters for state transfer. Exchanged between channel and STATE_TRANSFER
 * layer. The state is retrieved from 'target'. If target is null, then the state will be retrieved from the oldest
 * member (usually the coordinator).
 * @author Bela Ban
 * @version $Id: StateTransferInfo.java,v 1.13 2006/08/29 02:43:32 vlada Exp $
 */
public class StateTransferInfo {
    public Address      target=null;
    public long         timeout=0;
    public byte[]       state=null;
    public String       state_id=null;
    public InputStream  inputStream = null;
    public OutputStream outputStream = null;



    public StateTransferInfo() {
    }

    public StateTransferInfo(Address target) {
        this.target=target;
    }

    public StateTransferInfo(Address target, long timeout) {
        this.target=target;
        this.timeout=timeout;
    }

    public StateTransferInfo(Address target, String state_id, long timeout) {
        this.target=target;
        this.state_id=state_id;
        this.timeout=timeout;
    }

    public StateTransferInfo(Address target, String state_id, long timeout, byte[] state) {
        this.target=target;
        this.state=state;
        this.state_id=state_id;
        this.timeout=timeout;
    }

    public StateTransferInfo(Address target, InputStream is, String state_id) {
        this.target=target;
        this.state_id=state_id;
        this.inputStream=is;
    }

    public StateTransferInfo(Address target, OutputStream os, String state_id) {
        this.target=target;
        this.state_id=state_id;
        this.outputStream=os;
    }




    public StateTransferInfo copy() {
       if(inputStream!=null){
          return new StateTransferInfo(target,inputStream,state_id);
       }
       else if(outputStream!=null){
          return new StateTransferInfo(target,outputStream,state_id); 
       }
       else{
          return new StateTransferInfo(target, state_id, timeout, state);
       }
    }


    public String toString() {
        StringBuffer ret=new StringBuffer();
        ret.append("target=" + target);
        if(state != null)
            ret.append(", state=" + state.length + " bytes");
        if(state_id != null)
            ret.append(", state_id=" + state_id);
        ret.append(", timeout=" + timeout);
        return ret.toString();
    }
}