1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.cs.*; 25 import com.db4o.foundation.*; 26 27 28 31 public class MObjectSetFetch extends MObjectSet { 32 33 public boolean processAtServer(YapServerThread serverThread) { 34 int queryResultID = readInt(); 35 int fetchSize = readInt(); 36 IntIterator4 idIterator = stub(serverThread, queryResultID).idIterator(); 37 MsgD message = ID_LIST.getWriterForLength(transaction(), bufferLength(fetchSize)); 38 YapWriter writer = message.payLoad(); 39 writer.writeIDs(idIterator, fetchSize); 40 serverThread.write(message); 41 return true; 42 } 43 44 private int bufferLength(int fetchSize) { 45 return YapConst.INT_LENGTH * (fetchSize + 1); 46 } 47 48 } 49 | Popular Tags |