1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.cs.*; 25 26 public final class MDelete extends MsgD { 27 public final boolean processAtServer(YapServerThread serverThread) { 28 YapReader bytes = this.getByteLoad(); 29 YapStream stream = stream(); 30 synchronized (streamLock()) { 31 Object obj = stream.getByID1(transaction(), bytes.readInt()); 32 boolean userCall = bytes.readInt() == 1; 33 if (obj != null) { 34 try { 35 stream.delete1(transaction(), obj, userCall); 36 } catch (Exception e) { 37 if (Deploy.debug) { 38 System.out.println("MsgD.Delete failed."); 39 } 40 } 41 } 42 } 43 return true; 44 } 45 } | Popular Tags |