public static final class RequestCorrelator.Header extends Header implements Streamable
Modifier and Type | Field and Description |
---|---|
java.util.Stack<Address> |
callStack
Stack<Address>.
|
java.lang.String |
corrName
The unique name of the associated RequestCorrelator
|
java.util.List<Address> |
dest_mbrs
Contains a list of members who should receive the request (others will drop).
|
long |
id
The id of this request to distinguish among other requests from
the same RequestCorrelator
|
static byte |
REQ |
static byte |
RSP |
boolean |
rsp_expected
msg is synchronous if true
|
byte |
type
Type of header: request or reply
|
HDR_OVERHEAD
Constructor and Description |
---|
RequestCorrelator.Header()
Used for externalization
|
RequestCorrelator.Header(byte type,
long id,
boolean rsp_expected,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
void |
readExternal(java.io.ObjectInput in) |
void |
readFrom(java.io.DataInputStream in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
int |
size()
To be implemented by subclasses.
|
java.lang.String |
toString() |
void |
writeExternal(java.io.ObjectOutput out) |
void |
writeTo(java.io.DataOutputStream out)
Write the entire state of the current object (including superclasses) to outstream.
|
public static final byte REQ
public static final byte RSP
public byte type
public long id
public boolean rsp_expected
public java.lang.String corrName
public java.util.Stack<Address> callStack
public java.util.List<Address> dest_mbrs
public RequestCorrelator.Header()
public RequestCorrelator.Header(byte type, long id, boolean rsp_expected, java.lang.String name)
type
- type of header (REQ/RSP)id
- id of this header relative to ids of other requests
originating from the same correlatorrsp_expected
- whether it's a sync or async requestname
- the name of the RequestCorrelator from whichpublic void writeExternal(java.io.ObjectOutput out) throws java.io.IOException
writeExternal
in interface java.io.Externalizable
java.io.IOException
public void readExternal(java.io.ObjectInput in) throws java.io.IOException, java.lang.ClassNotFoundException
readExternal
in interface java.io.Externalizable
java.io.IOException
java.lang.ClassNotFoundException
public void writeTo(java.io.DataOutputStream out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
java.io.IOException
public void readFrom(java.io.DataInputStream in) throws java.io.IOException, java.lang.IllegalAccessException, java.lang.InstantiationException
Streamable
readFrom
in interface Streamable
java.io.IOException
java.lang.IllegalAccessException
java.lang.InstantiationException
public int size()
Header
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.