X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.server%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fserver%2Fprotocol%2FCancelCommitFunction.java;fp=bundles%2Forg.simantics.db.server%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fserver%2Fprotocol%2FCancelCommitFunction.java;h=4d3c984601fabf76d6c03c431d5710db8e31626e;hb=0ae2b770234dfc3cbb18bd38f324125cf0faca07;hp=18d4bce7d5f4fcd7563f8c9be92222522dbd729e;hpb=24e2b34260f219f0d1644ca7a138894980e25b14;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/CancelCommitFunction.java b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/CancelCommitFunction.java index 18d4bce7d..4d3c98460 100644 --- a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/CancelCommitFunction.java +++ b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/CancelCommitFunction.java @@ -1,48 +1,48 @@ -/******************************************************************************* - * Copyright (c) 2007, 2010 Association for Decentralized Information Management - * in Industry THTH ry. - * All rights reserved. This program and the accompanying materials - * are made available under the terms of the Eclipse Public License v1.0 - * which accompanies this distribution, and is available at - * http://www.eclipse.org/legal/epl-v10.html - * - * Contributors: - * VTT Technical Research Centre of Finland - initial API and implementation - *******************************************************************************/ -package org.simantics.db.server.protocol; - -import java.nio.ByteOrder; - -public class CancelCommitFunction extends AbstractFunction { - public long transactionId = 0; - public long changeSetId = 0; - public byte[] changeSetContext = null; - public long headChangeSetId = 0; - public CancelCommitFunction() { - super(MessageNumber.CancelCommitRequest, MessageNumber.CancelCommitResponse); - } - public CancelCommitFunction(long transactionId, long changeSetId, byte[] changeSetContext) { - super(MessageNumber.CancelCommitRequest, MessageNumber.CancelCommitResponse); - this.transactionId = transactionId; - this.changeSetId = changeSetId; - this.changeSetContext = changeSetContext; - } - @Override - public DataBuffer serialize(ByteOrder byteOrder) { - buffer.clear(); - buffer.order(byteOrder); - buffer.put(transactionId); - buffer.put(changeSetId); - buffer.put(changeSetContext); - buffer.mark(); - return buffer; - } - @Override - public void deserialize(int receivedNumber_, DataBuffer dataBuffer) { - receivedNumber = receivedNumber_; - if (notRightDataForUs()) - return; - headChangeSetId = dataBuffer.get(headChangeSetId); - gotResponse(); - } -} +/******************************************************************************* + * Copyright (c) 2007, 2010 Association for Decentralized Information Management + * in Industry THTH ry. + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 + * which accompanies this distribution, and is available at + * http://www.eclipse.org/legal/epl-v10.html + * + * Contributors: + * VTT Technical Research Centre of Finland - initial API and implementation + *******************************************************************************/ +package org.simantics.db.server.protocol; + +import java.nio.ByteOrder; + +public class CancelCommitFunction extends AbstractFunction { + public long transactionId = 0; + public long changeSetId = 0; + public byte[] changeSetContext = null; + public long headChangeSetId = 0; + public CancelCommitFunction() { + super(MessageNumber.CancelCommitRequest, MessageNumber.CancelCommitResponse); + } + public CancelCommitFunction(long transactionId, long changeSetId, byte[] changeSetContext) { + super(MessageNumber.CancelCommitRequest, MessageNumber.CancelCommitResponse); + this.transactionId = transactionId; + this.changeSetId = changeSetId; + this.changeSetContext = changeSetContext; + } + @Override + public DataBuffer serialize(ByteOrder byteOrder) { + buffer.clear(); + buffer.order(byteOrder); + buffer.put(transactionId); + buffer.put(changeSetId); + buffer.put(changeSetContext); + buffer.mark(); + return buffer; + } + @Override + public void deserialize(int receivedNumber_, DataBuffer dataBuffer) { + receivedNumber = receivedNumber_; + if (notRightDataForUs()) + return; + headChangeSetId = dataBuffer.get(headChangeSetId); + gotResponse(); + } +}