1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.cs.*; 25 import com.db4o.inside.slots.*; 26 27 public final class MWriteUpdate extends MsgObject { 28 29 public final boolean processAtServer(YapServerThread serverThread) { 30 int yapClassId = _payLoad.readInt(); 31 YapFile stream = (YapFile)stream(); 32 unmarshall(YapConst.INT_LENGTH); 33 synchronized(streamLock()){ 34 YapClass yc = stream.getYapClass(yapClassId); 35 _payLoad.writeEmbedded(); 36 int id = _payLoad.getID(); 37 transaction().dontDelete(id); 38 Slot oldSlot = ((YapFileTransaction)_trans).getCommittedSlotOfID(id); 39 stream.getSlotForUpdate(_payLoad); 40 yc.addFieldIndices(_payLoad, oldSlot); 41 _payLoad.writeEncrypt(); 42 } 43 return true; 44 } 45 } | Popular Tags |