AckMsg.java revision 0d397efc4b781ef5b60108708fa1131467d2c3c8
/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* You can obtain a copy of the license at
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at
* trunk/opends/resource/legal-notices/OpenDS.LICENSE. If applicable,
* add the following below this CDDL HEADER, with the fields enclosed
* by brackets "[]" replaced with your own identifying information:
* Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*
*
* Copyright 2006-2009 Sun Microsystems, Inc.
*/
/**
* AckMsg messages are used for acknowledging an update that has been sent
* requesting an ack: update sent in Assured Mode, either safe data or safe
* read sub mode.
* The change number refers to the update change number that was requested to be
* acknowledged.
* If some errors occurred during attempt to acknowledge the update in the path
* to final servers, errors are marked with the following fields:
* - hasTimeout:
* Some servers went in timeout when the matching update was sent.
* - hasWrongStatus:
* Some servers were in a status where we cannot ask for an ack when the
* matching update was sent.
* - hasReplayError:
* Some servers made an error replaying the sent matching update.
* - failedServers:
* The list of server ids that had errors for the sent matching update. Each
* /replay error)
*
* AckMsg messages are sent all along the reverse path of the path followed
* an update message.
*/
public class AckMsg extends ReplicationMsg
{
// ChangeNumber of the update that was acked.
private ChangeNumber changeNumber;
// Did some servers go in timeout when the matching update (corresponding to
// change number) was sent ?
private boolean hasTimeout = false;
// Were some servers in wrong status when the matching
// update (correspondig to change number) was sent ?
private boolean hasWrongStatus = false;
// Did some servers make an error replaying the sent matching update
// (corresponding to change number) ?
private boolean hasReplayError = false;
// The list of server ids that had errors for the sent matching update
// (corresponding to change number). Each server id of the list had one of the
/**
* Creates a new AckMsg from a ChangeNumber (no errors).
*
* @param changeNumber The ChangeNumber used to build the AckMsg.
*/
{
this.changeNumber = changeNumber;
}
/**
* Creates a new AckMsg from a ChangeNumber (with specified error info).
*
* @param changeNumber The ChangeNumber used to build the AckMsg.
* @param hasTimeout The hasTimeout info
* @param hasWrongStatus The hasWrongStatus info
* @param hasReplayError The hasReplayError info
* @param failedServers The list of failed servers
*/
{
this.changeNumber = changeNumber;
this.hasTimeout = hasTimeout;
this.hasWrongStatus = hasWrongStatus;
this.hasReplayError = hasReplayError;
this.failedServers = failedServers;
}
/**
* Sets the timeout marker for this message.
* @param hasTimeout True if some timeout occurred
*/
public void setHasTimeout(boolean hasTimeout)
{
this.hasTimeout = hasTimeout;
}
/**
* Sets the wrong status marker for this message.
* @param hasWrongStatus True if some servers were in wrong status
*/
public void setHasWrongStatus(boolean hasWrongStatus)
{
this.hasWrongStatus = hasWrongStatus;
}
/**
* Sets the replay error marker for this message.
* @param hasReplayError True if some servers had errors replaying the change
*/
public void setHasReplayError(boolean hasReplayError)
{
this.hasReplayError = hasReplayError;
}
/**
* Sets the list of failing servers for this message.
* @param idList The list of failing servers for this message.
*/
{
this.failedServers = idList;
}
/**
* Creates a new AckMsg by decoding the provided byte array.
*
* @param in The byte array containing the encoded form of the AckMsg.
* @throws DataFormatException If in does not contain a properly encoded
* AckMsg.
*/
{
try
{
/*
* The message is stored in the form:
* <operation type><change number><has timeout><has degraded><has replay
* error><failed server ids>
*/
/* First byte is the type */
{
throw new DataFormatException("byte[] is not a valid modify msg");
}
int pos = 1;
/* Read the changeNumber */
/* Read the hasTimeout flag */
{
hasTimeout = true;
} else
{
hasTimeout = false;
}
/* Read the hasWrongStatus flag */
{
hasWrongStatus = true;
} else
{
hasWrongStatus = false;
}
/* Read the hasReplayError flag */
{
hasReplayError = true;
} else
{
hasReplayError = false;
}
/* Read the list of failed server ids */
{
}
} catch (UnsupportedEncodingException e)
{
throw new DataFormatException("UTF-8 is not supported by this jvm.");
}
}
/**
* Get the ChangeNumber from the message.
*
* @return the ChangeNumber
*/
public ChangeNumber getChangeNumber()
{
return changeNumber;
}
/**
* {@inheritDoc}
*/
public byte[] getBytes()
{
try
{
/*
* The message is stored in the form:
* <operation type><change number><has timeout><has degraded><has replay
* error><failed server ids>
*/
/* Put the type of the operation */
/* Put the ChangeNumber */
/* Put the hasTimeout flag */
/* Put the hasWrongStatus flag */
/* Put the hasReplayError flag */
/* Put the list of server ids */
{
}
return oStream.toByteArray();
} catch (IOException e)
{
// never happens
return null;
}
}
/**
* Tells if the matching update had timeout.
* @return true if the matching update had timeout
*/
public boolean hasTimeout()
{
return hasTimeout;
}
/**
* Tells if the matching update had wrong status error.
* @return true if the matching update had wrong status error
*/
public boolean hasWrongStatus()
{
return hasWrongStatus;
}
/**
* Tells if the matching update had replay error.
* @return true if the matching update had replay error
*/
public boolean hasReplayError()
{
return hasReplayError;
}
/**
* Get the list of failed servers.
* @return the list of failed servers
*/
{
return failedServers;
}
/**
* Transforms the errors information of the ack into human readable string.
* @return A human readable string for errors embedded in the message.
*/
public String errorsToString()
{
{
idList = "[";
for (int i=0 ; i<size ; i++) {
if ( i != (size-1) )
idList += ", ";
}
idList += "]";
} else
{
idList="none";
}
"concerned server ids: " + idList;
return ackErrorStr;
}
}