| 1 21 package com.db4o.cs.messages; 22 23 import com.db4o.*; 24 import com.db4o.config.*; 25 import com.db4o.cs.*; 26 import com.db4o.inside.query.*; 27 28 public final class MGetAll extends MsgQuery { 29 30 public final boolean processAtServer(YapServerThread serverThread) { 31 QueryEvaluationMode evaluationMode = QueryEvaluationMode.fromInt(readInt()); 32 writeQueryResult(getAll(evaluationMode), serverThread, evaluationMode); 33 return true; 34 } 35 36 private AbstractQueryResult getAll(QueryEvaluationMode mode) { 37 synchronized (streamLock()) { 38 try { 39 return file().getAll(transaction(), mode); 40 } catch (Exception e) { 41 if(Debug.atHome){ 42 e.printStackTrace(); 43 } 44 } 45 return newQueryResult(mode); 46 } 47 } 48 49 } | Popular Tags |