1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.cs.*; 25 26 public final class MReadObject extends MsgD { 27 28 public final boolean processAtServer(YapServerThread serverThread) { 29 YapWriter bytes = null; 30 31 34 synchronized (streamLock()) { 35 try { 36 bytes = stream().readWriterByID(transaction(), _payLoad.readInt()); 37 } catch (Exception e) { 38 if (Deploy.debug) { 39 System.out.println("MsD.ReadObject:: readObjectByID failed"); 40 } 41 } 42 } 43 if (bytes == null) { 44 bytes = new YapWriter(transaction(), 0, 0); 45 } 46 serverThread.write(Msg.OBJECT_TO_CLIENT.getWriter(bytes)); 47 return true; 48 } 49 } | Popular Tags |