File tree Expand file tree Collapse file tree 2 files changed +7
-5
lines changed
modules/core/src/main/java/org/apache/ignite/internal Expand file tree Collapse file tree 2 files changed +7
-5
lines changed Original file line number Diff line number Diff line change 8383import org .apache .ignite .configuration .BinaryConfiguration ;
8484import org .apache .ignite .configuration .CacheConfiguration ;
8585import org .apache .ignite .configuration .CollectionConfiguration ;
86+ import org .apache .ignite .configuration .DataStorageConfiguration ;
8687import org .apache .ignite .configuration .IgniteConfiguration ;
8788import org .apache .ignite .configuration .MemoryConfiguration ;
8889import org .apache .ignite .configuration .NearCacheConfiguration ;
266267import static org .apache .ignite .internal .IgniteNodeAttributes .ATTR_TX_AWARE_QUERIES_ENABLED ;
267268import static org .apache .ignite .internal .IgniteNodeAttributes .ATTR_TX_SERIALIZABLE_ENABLED ;
268269import static org .apache .ignite .internal .IgniteNodeAttributes .ATTR_USER_NAME ;
270+ import static org .apache .ignite .internal .IgniteNodeAttributes .ATTR_WAL_MODE ;
269271import static org .apache .ignite .internal .IgniteVersionUtils .BUILD_TSTAMP_STR ;
270272import static org .apache .ignite .internal .IgniteVersionUtils .COPYRIGHT ;
271273import static org .apache .ignite .internal .IgniteVersionUtils .VER ;
@@ -1653,6 +1655,11 @@ private void addDataStorageConfigurationAttributes() throws IgniteCheckedExcepti
16531655
16541656 // Save data storage configuration.
16551657 add (ATTR_DATA_STORAGE_CONFIG , ctx .marshallerContext ().jdkMarshaller ().marshal (cfg .getDataStorageConfiguration ()));
1658+
1659+ DataStorageConfiguration dsCfg = cfg .getDataStorageConfiguration ();
1660+
1661+ ctx .addNodeAttribute (ATTR_WAL_MODE ,
1662+ dsCfg != null ? dsCfg .getWalMode ().ordinal () : DataStorageConfiguration .DFLT_WAL_MODE .ordinal ());
16561663 }
16571664
16581665 /**
Original file line number Diff line number Diff line change @@ -486,11 +486,6 @@ private void updateClientNodes(UUID leftNodeId) {
486486 ctx .addNodeAttribute (ATTR_OFFHEAP_SIZE , requiredOffheap ());
487487 ctx .addNodeAttribute (ATTR_DATA_REGIONS_OFFHEAP_SIZE , configuredOffheap ());
488488
489- DataStorageConfiguration dsCfg = ctx .config ().getDataStorageConfiguration ();
490-
491- if (CU .isPersistenceEnabled (dsCfg ))
492- ctx .addNodeAttribute (ATTR_WAL_MODE , dsCfg .getWalMode ().ordinal ());
493-
494489 DiscoverySpi spi = getSpi ();
495490
496491 discoOrdered = discoOrdered ();
You can’t perform that action at this time.
0 commit comments