parameter -s to specify the dictionary size

Author: georges-hatem

entries/ghatem-fpc/src/OneBRCproj.lpr

@@ -18,6 +18,7 @@   TOneBRCApp = class(TCustomApplication)
   private
     FFileName: string;
     FThreadCount: Integer;
+    FDictSize: Integer;
     procedure RunOneBRC;
   protected
     procedure DoRun; override;
@@ -33,7 +34,7 @@ procedure TOneBRCApp.RunOneBRC;
 var
   vOneBRC: TOneBRC;
 begin
-  vOneBRC := TOneBRC.Create (FThreadCount);
+  vOneBRC := TOneBRC.Create (FThreadCount, FDictSize);
   try
     try
       vOneBRC.mORMotMMF(FFileName);
@@ -88,15 +89,17 @@ procedure TOneBRCApp.DoRun;
   ErrorMsg: String;
 begin
   // quick check parameters
-  ErrorMsg:= CheckOptions(Format('%s%s%s%s:',[
+  ErrorMsg:= CheckOptions(Format('%s%s%s%s%s:',[
       cShortOptHelp,
       cShortOptThread,
+      cShortOptDictSize,
       cShortOptVersion,
       cShortOptInput
     ]),
     [
       cLongOptHelp,
       cLongOptThread+':',
+      cLongOptDictSize+':',
       cLongOptVersion,
       cLongOptInput+':'
     ]
@@ -126,6 +129,11 @@ procedure TOneBRCApp.DoRun;
     FThreadCount := StrToInt (GetOptionValue(cShortOptThread, cLongOptThread));
   end;
 
+  FDictSize := 45003;
+  if HasOption(cShortOptDictSize, cLongOptDictSize) then begin
+    FDictSize := StrToInt (GetOptionValue(cShortOptDictSize, cLongOptDictSize));
+  end;
+
   if HasOption(cShortOptInput, cLongOptInput) then begin
     FFileName := GetOptionValue(
       cShortOptInput,

entries/ghatem-fpc/src/baseline.console.pas

@@ -21,6 +21,8 @@ interface
   cLongOptInput          = 'input-file';
   cShortOptThread: Char  = 't';
   cLongOptThread         = 'threads';
+  cShortOptDictSize: Char = 's';
+  cLongOptDictSize        = 'size';
   {$ELSE}
   cOptionHelp:    array of string = ['-h', '--help'];
   cOptionVersion: array of string = ['-v', '--version'];

entries/ghatem-fpc/src/onebrc.pas

@@ -10,8 +10,10 @@ interface
 
 function RoundExDouble(const ATemp: Double): Double; inline;
 
+{$WRITEABLECONST ON}
 const
   cDictSize: Integer = 45003;
+{$WRITEABLECONST OFF}
 
 type
 
@@ -63,7 +65,7 @@   TOneBRC = class
     procedure ExtractLineData(const aStart: Int64; const aEnd: Int64; out aLength: ShortInt; out aTemp: SmallInt); inline;
 
   public
-    constructor Create (const aThreadCount: UInt16);
+    constructor Create (const aThreadCount: UInt16; const aDictSize: Integer);
     destructor Destroy; override;
     function mORMotMMF (const afilename: string): Boolean;
     procedure DispatchThreads;
@@ -249,9 +251,11 @@ procedure TOneBRC.ExtractLineData(const aStart: Int64; const aEnd: Int64; out aL
 
 //---------------------------------------------------
 
-constructor TOneBRC.Create (const aThreadCount: UInt16);
+constructor TOneBRC.Create (const aThreadCount: UInt16; const aDictSize: Integer);
 var I: UInt16;
 begin
+  cDictSize := aDictSize;
+
   FThreadCount := aThreadCount;
   SetLength (FStationsDicts, aThreadCount);
   SetLength (FThreads, aThreadCount);