Added logger (associated with shard) to CodecServiceConfig

Signed-off-by: Andriy Redko <[email protected]>

Author: reta

server/src/main/java/org/opensearch/index/codec/CodecServiceConfig.java

@@ -8,6 +8,7 @@
 
 package org.opensearch.index.codec;
 
+import org.apache.logging.log4j.Logger;
 import org.opensearch.common.Nullable;
 import org.opensearch.index.IndexSettings;
 import org.opensearch.index.mapper.MapperService;
@@ -20,10 +21,12 @@
 public final class CodecServiceConfig {
     private final IndexSettings indexSettings;
     private final MapperService mapperService;
+    private final Logger logger;
 
-    public CodecServiceConfig(IndexSettings indexSettings, @Nullable MapperService mapperService) {
+    public CodecServiceConfig(IndexSettings indexSettings, @Nullable MapperService mapperService, Logger logger) {
         this.indexSettings = Objects.requireNonNull(indexSettings);
         this.mapperService = mapperService;
+        this.logger = logger;
     }
 
     public IndexSettings getIndexSettings() {
@@ -34,4 +37,8 @@ public IndexSettings getIndexSettings() {
     public MapperService getMapperService() {
         return mapperService;
     }
+
+    public Logger getLogger() {
+        return logger;
+    }
 }

server/src/main/java/org/opensearch/index/engine/EngineConfigFactory.java

@@ -8,6 +8,7 @@
 
 package org.opensearch.index.engine;
 
+import org.apache.logging.log4j.Logger;
 import org.apache.lucene.analysis.Analyzer;
 import org.apache.lucene.index.MergePolicy;
 import org.apache.lucene.search.QueryCache;
@@ -169,7 +170,8 @@ public EngineConfig newEngineConfig(
             retentionLeasesSupplier,
             primaryTermSupplier,
             tombstoneDocSupplier,
-            null
+            null, /* mapperService */
+            null /* logger */
         );
     }
 
@@ -197,7 +199,8 @@ public EngineConfig newEngineConfig(
         Supplier<RetentionLeases> retentionLeasesSupplier,
         LongSupplier primaryTermSupplier,
         EngineConfig.TombstoneDocSupplier tombstoneDocSupplier,
-        MapperService mapperService
+        MapperService mapperService,
+        Logger logger
     ) {
 
         return new EngineConfig(
@@ -210,7 +213,7 @@ public EngineConfig newEngineConfig(
             analyzer,
             similarity,
             this.codecServiceFactory != null
-                ? this.codecServiceFactory.createCodecService(new CodecServiceConfig(indexSettings, mapperService))
+                ? this.codecServiceFactory.createCodecService(new CodecServiceConfig(indexSettings, mapperService, logger))
                 : codecService,
             eventListener,
             queryCache,

server/src/main/java/org/opensearch/index/shard/IndexShard.java

@@ -3178,7 +3178,8 @@ private EngineConfig newEngineConfig(LongSupplier globalCheckpointSupplier) {
             replicationTracker::getRetentionLeases,
             () -> getOperationPrimaryTerm(),
             tombstoneDocSupplier(),
-            mapperService
+            mapperService,
+            logger
         );
     }