1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.cs.*; 25 26 public final class MGetInternalIDs extends MsgD { 27 public final boolean processAtServer(YapServerThread serverThread) { 28 YapReader bytes = this.getByteLoad(); 29 long[] ids; 30 synchronized (streamLock()) { 31 try { 32 ids = stream().getYapClass(bytes.readInt()).getIDs(transaction()); 33 } catch (Exception e) { 34 ids = new long[0]; 35 } 36 } 37 int size = ids.length; 38 MsgD message = Msg.ID_LIST.getWriterForLength(transaction(), YapConst.ID_LENGTH * (size + 1)); 39 YapReader writer = message.payLoad(); 40 writer.writeInt(size); 41 for (int i = 0; i < size; i++) { 42 writer.writeInt((int) ids[i]); 43 } 44 serverThread.write(message); 45 return true; 46 } 47 } | Popular Tags |