Changeset 6154 for SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/search/Result.java

Timestamp:

04/22/15 08:25:01 (9 years ago)

Author:

emanuel.dima@uni-tuebingen.de

Message:

22. beta-40: fixed bug in build script; improved 'more results' behavior

File:

• SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/search/Result.java (modified) (4 diffs)

SRUAggregator/trunk/src/main/java/eu/clarin/sru/fcs/aggregator/search/Result.java

@@ -3 +3 @@
 import eu.clarin.sru.client.SRUDiagnostic;
 import eu.clarin.sru.client.SRURecord;
-import eu.clarin.sru.client.SRUSearchRetrieveRequest;
 import eu.clarin.sru.fcs.aggregator.scan.Corpus;
 import eu.clarin.sru.client.SRUSearchRetrieveResponse;
@@ -37 +36 @@
         private final Corpus corpus;
         private AtomicBoolean inProgress = new AtomicBoolean(true);
-        private AtomicInteger endpointReturnedRecords = new AtomicInteger();
+        private AtomicInteger nextRecordPosition = new AtomicInteger(1);
         private AtomicReference<JsonException> exception = new AtomicReference<JsonException>();
         private List<Diagnostic> diagnostics = Collections.synchronizedList(new ArrayList<Diagnostic>());
@@ -69 +68 @@
                         }
                 }
+                if (response.getNextRecordPosition() > 0) {
+                        nextRecordPosition.set(response.getNextRecordPosition());
+                }
         }
 
         void addRecord(SRURecord record) {
-//              TODO(edima): use response.getNextRecordPosition()
-                endpointReturnedRecords.getAndIncrement();
+                nextRecordPosition.incrementAndGet();
                 if (record.isRecordSchema(ClarinFCSRecordData.RECORD_SCHEMA)) {
                         ClarinFCSRecordData rd = (ClarinFCSRecordData) record.getRecordData();
@@ -144 +145 @@
         }
 
-        public int getEndpointReturnedRecords() {
-                return endpointReturnedRecords.get();
+        public int getNextRecordPosition() {
+                return nextRecordPosition.get();
         }