Synchronize the CSV row writing

christianrowlands · Nov 7, 2023 · 0a1bceb · 0a1bceb
1 parent f59f2aa
commit 0a1bceb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/networksurvey/src/main/java/com/craxiom/networksurvey/logging/BluetoothCsvLogger.java b/networksurvey/src/main/java/com/craxiom/networksurvey/logging/BluetoothCsvLogger.java
@@ -59,7 +59,7 @@ String[] getHeaderComments()
     }
 
     @Override
-    public void onBluetoothSurveyRecord(BluetoothRecord bluetoothRecord)
+    public synchronized void onBluetoothSurveyRecord(BluetoothRecord bluetoothRecord)
     {
         try
         {
@@ -71,7 +71,7 @@ public void onBluetoothSurveyRecord(BluetoothRecord bluetoothRecord)
     }
 
     @Override
-    public void onBluetoothSurveyRecords(List<BluetoothRecord> bluetoothRecords)
+    public synchronized void onBluetoothSurveyRecords(List<BluetoothRecord> bluetoothRecords)
     {
         bluetoothRecords.forEach(record -> {
             try

diff --git a/networksurvey/src/main/java/com/craxiom/networksurvey/logging/CsvRecordLogger.java b/networksurvey/src/main/java/com/craxiom/networksurvey/logging/CsvRecordLogger.java
@@ -38,7 +38,7 @@ public abstract class CsvRecordLogger
     private static final int RECORD_COUNT_INTERVAL = 5000;
 
     /**
-     * A lock to synchronize the writing of single records and the creation of a new GeoPackage file
+     * A lock to synchronize the writing of single records and the creation of a new CSV file
      * during rollover.
      */
     protected final Object csvFileLock = new Object();
@@ -144,7 +144,7 @@ public boolean enableLogging(boolean enable)
         }
     }
 
-    void writeCsvRecord(Object[] row, boolean flush) throws IOException
+    synchronized void writeCsvRecord(Object[] row, boolean flush) throws IOException
     {
         if (lazyFileCreation) lazyCreateFileIfNecessary();
         printer.printRecord(row);