DPL Analysis: make WritingCursor aware of how many rows were written (#3069)

ktf · web-flow · commit cbfedce80a14 · 2020-03-03T23:01:41.000+01:00
diff --git a/Framework/Core/include/Framework/AnalysisTask.h b/Framework/Core/include/Framework/AnalysisTask.h
@@ -71,12 +71,20 @@ struct WritingCursor<soa::Table<PC...>> {
   void operator()(T... args)
   {
     static_assert(sizeof...(PC) == sizeof...(T), "Argument number mismatch");
+    ++mCount;
     cursor(0, extract(args)...);
   }
 
+  /// Last index inserted in the table
+  int64_t lastIndex()
+  {
+    return mCount;
+  }
+
   bool resetCursor(TableBuilder& builder)
   {
     cursor = std::move(FFL(builder.cursor<persistent_table_t>()));
+    mCount = -1;
     return true;
   }
 
@@ -93,6 +101,8 @@ struct WritingCursor<soa::Table<PC...>> {
       return arg;
     }
   }
+
+  int64_t mCount = -1;
 };
 
 /// This helper class allow you to declare things which will be crated by a

Original file line number	Diff line number	Diff line change
`@@ -71,12 +71,20 @@ struct WritingCursor<soa::Table<PC...>> {`
`71`	`71`	`void operator()(T... args)`
`72`	`72`	`{`
`73`	`73`	`static_assert(sizeof...(PC) == sizeof...(T), "Argument number mismatch");`
	`74`	`+ ++mCount;`
`74`	`75`	`cursor(0, extract(args)...);`
`75`	`76`	`}`
`76`	`77`
	`78`	`+ /// Last index inserted in the table`
	`79`	`+ int64_t lastIndex()`
	`80`	`+ {`
	`81`	`+ return mCount;`
	`82`	`+ }`
	`83`	`+`
`77`	`84`	`bool resetCursor(TableBuilder& builder)`
`78`	`85`	`{`
`79`	`86`	`cursor = std::move(FFL(builder.cursor<persistent_table_t>()));`
	`87`	`+ mCount = -1;`
`80`	`88`	`return true;`
`81`	`89`	`}`
`82`	`90`
`@@ -93,6 +101,8 @@ struct WritingCursor<soa::Table<PC...>> {`
`93`	`101`	`return arg;`
`94`	`102`	`}`
`95`	`103`	`}`
	`104`	`+`
	`105`	`+ int64_t mCount = -1;`
`96`	`106`	`};`
`97`	`107`
`98`	`108`	`/// This helper class allow you to declare things which will be crated by a`