1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.cs.*; 25 26 public final class MGetClasses extends MsgD { 27 public final boolean processAtServer(YapServerThread serverThread) { 28 YapStream stream = stream(); 29 synchronized (streamLock()) { 30 try { 31 32 stream.classCollection().write(transaction()); 36 37 } catch (Exception e) { 38 if (Deploy.debug) { 39 System.out.println("Msg.GetConfig failed."); 40 } 41 } 42 } 43 MsgD message = Msg.GET_CLASSES.getWriterForLength(transaction(), YapConst.INT_LENGTH + 1); 44 YapReader writer = message.payLoad(); 45 writer.writeInt(stream.classCollection().getID()); 46 writer.append(stream.stringIO().encodingByte()); 47 serverThread.write(message); 48 return true; 49 } 50 } | Popular Tags |