X-Git-Url: https://gerrit.simantics.org/r/gitweb?p=simantics%2Fplatform.git;a=blobdiff_plain;f=bundles%2Forg.simantics.db.server%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fserver%2Fprotocol%2FGetClusterChangesFunction.java;fp=bundles%2Forg.simantics.db.server%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fserver%2Fprotocol%2FGetClusterChangesFunction.java;h=ef140ac9cec5e7be851b5c3d37426bd47979c49d;hp=1603787eea3318b3621c0bd361ffc473f5e3d879;hb=0ae2b770234dfc3cbb18bd38f324125cf0faca07;hpb=24e2b34260f219f0d1644ca7a138894980e25b14 diff --git a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/GetClusterChangesFunction.java b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/GetClusterChangesFunction.java index 1603787ee..ef140ac9c 100644 --- a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/GetClusterChangesFunction.java +++ b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/GetClusterChangesFunction.java @@ -1,55 +1,55 @@ -/******************************************************************************* - * 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 GetClusterChangesFunction extends AbstractFunction { - public long changeSetId = 0; - public byte[] clusterUID = null; - public long headChangeSetId = 0; - public int[] resourceIndex = null; - public int[] predicateIndex = null; - public long[] predicateFirst = null; - public long[] predicateSecond = null; - public int[] valueIndex = null; - public GetClusterChangesFunction() { - super(MessageNumber.GetClusterChangesRequest, MessageNumber.GetClusterChangesResponse); - } - public GetClusterChangesFunction(long changeSetId, byte[] clusterUID) { - super(MessageNumber.GetClusterChangesRequest, MessageNumber.GetClusterChangesResponse); - this.changeSetId = changeSetId; - this.clusterUID = clusterUID; - } - @Override - public DataBuffer serialize(ByteOrder byteOrder) { - buffer.clear(); - buffer.order(byteOrder); - buffer.put(changeSetId); - buffer.put(clusterUID); - buffer.mark(); - return buffer; - } - @Override - public void deserialize(int receivedNumber_, DataBuffer dataBuffer) { - receivedNumber = receivedNumber_; - if (notRightDataForUs()) - return; - headChangeSetId = dataBuffer.get(headChangeSetId); - resourceIndex = dataBuffer.get(resourceIndex); - predicateIndex = dataBuffer.get(predicateIndex); - predicateFirst = dataBuffer.get(predicateFirst); - predicateSecond = dataBuffer.get(predicateSecond); - valueIndex = dataBuffer.get(valueIndex); - 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 GetClusterChangesFunction extends AbstractFunction { + public long changeSetId = 0; + public byte[] clusterUID = null; + public long headChangeSetId = 0; + public int[] resourceIndex = null; + public int[] predicateIndex = null; + public long[] predicateFirst = null; + public long[] predicateSecond = null; + public int[] valueIndex = null; + public GetClusterChangesFunction() { + super(MessageNumber.GetClusterChangesRequest, MessageNumber.GetClusterChangesResponse); + } + public GetClusterChangesFunction(long changeSetId, byte[] clusterUID) { + super(MessageNumber.GetClusterChangesRequest, MessageNumber.GetClusterChangesResponse); + this.changeSetId = changeSetId; + this.clusterUID = clusterUID; + } + @Override + public DataBuffer serialize(ByteOrder byteOrder) { + buffer.clear(); + buffer.order(byteOrder); + buffer.put(changeSetId); + buffer.put(clusterUID); + buffer.mark(); + return buffer; + } + @Override + public void deserialize(int receivedNumber_, DataBuffer dataBuffer) { + receivedNumber = receivedNumber_; + if (notRightDataForUs()) + return; + headChangeSetId = dataBuffer.get(headChangeSetId); + resourceIndex = dataBuffer.get(resourceIndex); + predicateIndex = dataBuffer.get(predicateIndex); + predicateFirst = dataBuffer.get(predicateFirst); + predicateSecond = dataBuffer.get(predicateSecond); + valueIndex = dataBuffer.get(valueIndex); + gotResponse(); + } +}