Skip to content

Commit

Permalink
renaming
Browse files Browse the repository at this point in the history
  • Loading branch information
NSAmelchev committed Jan 25, 2023
1 parent d5a2b0c commit 8971705
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -250,7 +250,7 @@ public class DataStorageConfiguration implements Serializable {

/** Change Data Capture directory size limit. */
@IgniteExperimental
private long cdcWalDirectoryMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE;
private long cdcWalDirMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE;

/**
* Metrics enabled flag.
Expand Down Expand Up @@ -815,7 +815,7 @@ public DataStorageConfiguration setCdcWalPath(String cdcWalPath) {
*/
@IgniteExperimental
public long getCdcWalDirectoryMaxSize() {
return cdcWalDirectoryMaxSize;
return cdcWalDirMaxSize;
}

/**
Expand All @@ -824,12 +824,12 @@ public long getCdcWalDirectoryMaxSize() {
* The CDC application will log an error due to a gap in wal files sequence. Note that cache changes will be lost.
* Default is no limit.
*
* @param cdcWalDirectoryMaxSize CDC directory maximum size in bytes.
* @param cdcWalDirMaxSize CDC directory maximum size in bytes.
* @return {@code this} for chaining.
*/
@IgniteExperimental
public DataStorageConfiguration setCdcWalDirectoryMaxSize(long cdcWalDirectoryMaxSize) {
this.cdcWalDirectoryMaxSize = cdcWalDirectoryMaxSize;
public DataStorageConfiguration setCdcWalDirectoryMaxSize(long cdcWalDirMaxSize) {
this.cdcWalDirMaxSize = cdcWalDirMaxSize;

return this;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ public class CdcSelfTest extends AbstractCdcTest {
public boolean persistenceEnabled;

/** */
private long cdcWalDirectoryMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE;
private long cdcWalDirMaxSize = DFLT_CDC_WAL_DIRECTORY_MAX_SIZE;

/** */
@Parameterized.Parameters(name = "consistentId={0}, wal={1}, persistence={2}")
Expand Down Expand Up @@ -134,7 +134,7 @@ public static Collection<?> parameters() {
.setPersistenceEnabled(persistenceEnabled)
.setCdcEnabled(true))
.setWalArchivePath(DFLT_WAL_ARCHIVE_PATH + "/" + U.maskForFileName(igniteInstanceName))
.setCdcWalDirectoryMaxSize(cdcWalDirectoryMaxSize));
.setCdcWalDirectoryMaxSize(cdcWalDirMaxSize));

cfg.setCacheConfiguration(
new CacheConfiguration<>(TX_CACHE_NAME)
Expand Down Expand Up @@ -742,8 +742,8 @@ public void testDisable() throws Exception {
/** */
@Test
public void testCdcDirectoryMaxSize() throws Exception {
cdcWalDirectoryMaxSize = 10 * U.MB;
int segmentSize = (int)(cdcWalDirectoryMaxSize / 2);
cdcWalDirMaxSize = 10 * U.MB;
int segmentSize = (int)(cdcWalDirMaxSize / 2);

IgniteEx ign = startGrid(0);

Expand Down Expand Up @@ -772,7 +772,7 @@ public void testCdcDirectoryMaxSize() throws Exception {
// The segment link creation should be skipped.
writeSgmnt.run();

assertTrue(cdcWalDirectoryMaxSize >= Arrays.stream(walCdcDir.listFiles()).mapToLong(File::length).sum());
assertTrue(cdcWalDirMaxSize >= Arrays.stream(walCdcDir.listFiles()).mapToLong(File::length).sum());

ListeningTestLogger lsnLog = new ListeningTestLogger(log);

Expand Down

0 comments on commit 8971705

Please sign in to comment.