This pushes down the null guards so that we can track down the source of
nulls.
Change-Id: Id94db7ba1810b2331f625f335ee610b3a22b3c44
Signed-off-by: Robert Varga <rovarga@cisco.com>
super("shard-tx"); //actor name override used for metering. This does not change the "real" actor name
this.shardActor = shardActor;
this.shardStats = shardStats;
super("shard-tx"); //actor name override used for metering. This does not change the "real" actor name
this.shardActor = shardActor;
this.shardStats = shardStats;
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.clientTxVersion = clientTxVersion;
}
this.clientTxVersion = clientTxVersion;
}
this.shardActor = shardActor;
this.shardStats = shardStats;
this.datastoreContext = datastoreContext;
this.shardActor = shardActor;
this.shardStats = shardStats;
this.datastoreContext = datastoreContext;
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.txnClientVersion = txnClientVersion;
this.type = type;
}
this.txnClientVersion = txnClientVersion;
this.type = type;
}
package org.opendaylight.controller.cluster.datastore.messages;
package org.opendaylight.controller.cluster.datastore.messages;
+import com.google.common.base.Preconditions;
import org.opendaylight.controller.cluster.datastore.DataStoreVersions;
import org.opendaylight.controller.protobuff.messages.transaction.ShardTransactionMessages;
import org.opendaylight.controller.cluster.datastore.DataStoreVersions;
import org.opendaylight.controller.protobuff.messages.transaction.ShardTransactionMessages;
private CreateTransaction(String transactionId, int transactionType, String transactionChainId,
short version) {
private CreateTransaction(String transactionId, int transactionType, String transactionChainId,
short version) {
- this.transactionId = transactionId;
+ this.transactionId = Preconditions.checkNotNull(transactionId);
this.transactionType = transactionType;
this.transactionChainId = transactionChainId;
this.version = version;
this.transactionType = transactionType;
this.transactionChainId = transactionChainId;
this.version = version;
public ForwardedReadyTransaction(String transactionID, short txnClientVersion,
ReadWriteShardDataTreeTransaction transaction, boolean returnSerialized,
boolean doImmediateCommit) {
public ForwardedReadyTransaction(String transactionID, short txnClientVersion,
ReadWriteShardDataTreeTransaction transaction, boolean returnSerialized,
boolean doImmediateCommit) {
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.transaction = Preconditions.checkNotNull(transaction);
this.returnSerialized = returnSerialized;
this.txnClientVersion = txnClientVersion;
this.transaction = Preconditions.checkNotNull(transaction);
this.returnSerialized = returnSerialized;
this.txnClientVersion = txnClientVersion;