X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.db.server%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fserver%2Fprotocol%2FAskTransactionFunction.java;h=c701bf9631eff9be44c8be5b9956f0bb39a26a68;hb=5675f72f9664c8ff275614d1ebe8a5a5d3014a98;hp=c8d20e281a35634041da690f5a1515a7d0cf4054;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AskTransactionFunction.java b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AskTransactionFunction.java index c8d20e281..c701bf963 100644 --- a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AskTransactionFunction.java +++ b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AskTransactionFunction.java @@ -1,46 +1,46 @@ -/******************************************************************************* - * 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 AskTransactionFunction extends AbstractFunction { - public int type = 0; - public long transactionId = 0; - public long headChangeSetId = 0; - public AskTransactionFunction() { - super(MessageNumber.AskTransactionRequest, MessageNumber.AskTransactionResponse); - } - public AskTransactionFunction(int type, long transactionId) { - super(MessageNumber.AskTransactionRequest, MessageNumber.AskTransactionResponse); - this.type = type; - this.transactionId = transactionId; - } - @Override - public DataBuffer serialize(ByteOrder byteOrder) { - buffer.clear(); - buffer.order(byteOrder); - buffer.put(type); - buffer.put(transactionId); - buffer.mark(); - return buffer; - } - @Override - public void deserialize(int receivedNumber_, DataBuffer dataBuffer) { - receivedNumber = receivedNumber_; - if (notRightDataForUs()) - return; - transactionId = dataBuffer.get(transactionId); - 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 AskTransactionFunction extends AbstractFunction { + public int type = 0; + public long transactionId = 0; + public long headChangeSetId = 0; + public AskTransactionFunction() { + super(MessageNumber.AskTransactionRequest, MessageNumber.AskTransactionResponse); + } + public AskTransactionFunction(int type, long transactionId) { + super(MessageNumber.AskTransactionRequest, MessageNumber.AskTransactionResponse); + this.type = type; + this.transactionId = transactionId; + } + @Override + public DataBuffer serialize(ByteOrder byteOrder) { + buffer.clear(); + buffer.order(byteOrder); + buffer.put(type); + buffer.put(transactionId); + buffer.mark(); + return buffer; + } + @Override + public void deserialize(int receivedNumber_, DataBuffer dataBuffer) { + receivedNumber = receivedNumber_; + if (notRightDataForUs()) + return; + transactionId = dataBuffer.get(transactionId); + headChangeSetId = dataBuffer.get(headChangeSetId); + gotResponse(); + } +}