1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.cs.*; 25 26 public final class MWriteNew extends MsgObject { 27 28 public final boolean processAtServer(YapServerThread serverThread) { 29 int yapClassId = _payLoad.readInt(); 30 YapFile stream = (YapFile)stream(); 31 unmarshall(YapConst.INT_LENGTH); 32 synchronized (streamLock()) { 33 YapClass yc = yapClassId == 0 ? null : stream.getYapClass(yapClassId); 34 _payLoad.writeEmbedded(); 35 stream.prefetchedIDConsumed(_payLoad.getID()); 36 _payLoad.address(stream.getSlot(_payLoad.getLength())); 37 if(yc != null){ 38 yc.addFieldIndices(_payLoad,null); 39 } 40 stream.writeNew(yc, _payLoad); 41 transaction().writePointer( 42 _payLoad.getID(), 43 _payLoad.getAddress(), 44 _payLoad.getLength()); 45 } 46 return true; 47 } 48 } | Popular Tags |