bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/UpdateClusterFunction.java

   1 /*******************************************************************************
   2  * Copyright (c) 2007, 2010 Association for Decentralized Information Management
   3  * in Industry THTH ry.
   4  * All rights reserved. This program and the accompanying materials
   5  * are made available under the terms of the Eclipse Public License v1.0
   6  * which accompanies this distribution, and is available at
   7  * http://www.eclipse.org/legal/epl-v10.html
   8  *
   9  * Contributors:
  10  *     VTT Technical Research Centre of Finland - initial API and implementation
  11  *******************************************************************************/
  12 package org.simantics.db.server.protocol;
  13
  14 import java.nio.ByteBuffer;
  15 import java.nio.ByteOrder;
  16
  17 public class UpdateClusterFunction extends AbstractFunction {
  18     public byte[] operation = null;
  19     public UpdateClusterFunction() {
  20         super(MessageNumber.UpdateClusterRequest, MessageNumber.UpdateClusterResponse);
  21     }
  22     public UpdateClusterFunction(byte[] operation) {
  23         super(MessageNumber.UpdateClusterRequest, MessageNumber.UpdateClusterResponse);
  24         this.operation = operation;
  25     }
  26     @Override
  27     public DataBuffer serialize(ByteOrder byteOrder) {
  28         buffer = new DataBuffer(ByteBuffer.wrap(operation));
  29         buffer.position(operation.length);
  30         buffer.mark();
  31         return buffer;
  32     }
  33     @Override
  34     public void deserialize(int receivedNumber_, DataBuffer dataBuffer) {
  35         receivedNumber = receivedNumber_;
  36         if (notRightDataForUs())
  37             return;
  38         gotResponse();
  39     }
  40 }