X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;ds=inline;f=bundles%2Forg.simantics.db.server%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fserver%2Fprotocol%2FAbstractMessage.java;fp=bundles%2Forg.simantics.db.server%2Fsrc%2Forg%2Fsimantics%2Fdb%2Fserver%2Fprotocol%2FAbstractMessage.java;h=1f5ce1e02676350a1a7f4cfbac8ae9e285ec7ff4;hb=0ae2b770234dfc3cbb18bd38f324125cf0faca07;hp=d5f75ec2a0f7389a86cd932561525af188b7a1d1;hpb=24e2b34260f219f0d1644ca7a138894980e25b14;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AbstractMessage.java b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AbstractMessage.java index d5f75ec2a..1f5ce1e02 100644 --- a/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AbstractMessage.java +++ b/bundles/org.simantics.db.server/src/org/simantics/db/server/protocol/AbstractMessage.java @@ -1,52 +1,52 @@ -/******************************************************************************* - * 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; - -public abstract class AbstractMessage extends Message { - protected final int requestNumber; - protected final int responseNumber; - protected int receivedNumber = 0; - protected boolean responsePending = false; - protected DataBuffer buffer; - private String exceptionText = null; - AbstractMessage(int requestNumber, int responseNumber) { - this.requestNumber = requestNumber; - this.responseNumber = responseNumber; - this.buffer = new DataBuffer(DataBuffer.Allocation.DirectAllocation); //ByteBuffer.allocate(0); - } - AbstractMessage(int requestNumber, int responseNumber, DataBuffer buffer) { - this.requestNumber = requestNumber; - this.responseNumber = responseNumber; - this.buffer = buffer; - } - public int getRequestNumber() { - return requestNumber; - } - public int getResponseNumber() { - return responseNumber; - } - @Override - boolean hasResponse() { - return responseNumber != 0; - } - @Override - String getExceptionText() { - return this.exceptionText; - } - @Override - void setExceptionText(String text) { - this.exceptionText = text; - } - void gotResponse() { - responsePending = false; - } -} +/******************************************************************************* + * 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; + +public abstract class AbstractMessage extends Message { + protected final int requestNumber; + protected final int responseNumber; + protected int receivedNumber = 0; + protected boolean responsePending = false; + protected DataBuffer buffer; + private String exceptionText = null; + AbstractMessage(int requestNumber, int responseNumber) { + this.requestNumber = requestNumber; + this.responseNumber = responseNumber; + this.buffer = new DataBuffer(DataBuffer.Allocation.DirectAllocation); //ByteBuffer.allocate(0); + } + AbstractMessage(int requestNumber, int responseNumber, DataBuffer buffer) { + this.requestNumber = requestNumber; + this.responseNumber = responseNumber; + this.buffer = buffer; + } + public int getRequestNumber() { + return requestNumber; + } + public int getResponseNumber() { + return responseNumber; + } + @Override + boolean hasResponse() { + return responseNumber != 0; + } + @Override + String getExceptionText() { + return this.exceptionText; + } + @Override + void setExceptionText(String text) { + this.exceptionText = text; + } + void gotResponse() { + responsePending = false; + } +}