Skip to content

Commit 0b44fc5

Browse files
committed
util: rename calculateChecksum => calculateAdler32Checksum
1 parent fb1ab48 commit 0b44fc5

3 files changed

Lines changed: 5 additions & 5 deletions

File tree

src/main/java/org/dcache/nearline/cta/CtaCli.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package org.dcache.nearline.cta;
22

3-
import static org.dcache.nearline.cta.Utils.calculateChecksum;
3+
import static org.dcache.nearline.cta.Utils.calculateAdler32Checksum;
44
import static org.dcache.nearline.cta.CtaNearlineStorage.CTA_ENDPOINT;
55
import static org.dcache.nearline.cta.CtaNearlineStorage.CTA_GROUP;
66
import static org.dcache.nearline.cta.CtaNearlineStorage.CTA_INSTANCE;
@@ -186,7 +186,7 @@ private FlushRequest mockedFlushRequest(String s, String storageClass) throws IO
186186
.storageClass(storageClass)
187187
.hsm("cta").creationTime(posixAttr.creationTime().toMillis())
188188
.pnfsId(InodeId.toPnfsid(id)) // just reuse
189-
.checksum(calculateChecksum(path.toFile())).build();
189+
.checksum(calculateAdler32Checksum(path.toFile())).build();
190190

191191
return new FlushRequest() {
192192
@Override

src/main/java/org/dcache/nearline/cta/Utils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ private Utils(){ /* prevent instantiation */ }
2323
* @return the ADLER32 checksum of the file
2424
* @throws IOException if an I/O error occurs
2525
*/
26-
public static Checksum calculateChecksum(File file) throws IOException {
26+
public static Checksum calculateAdler32Checksum(File file) throws IOException {
2727

2828
ByteBuffer bb = ByteBuffer.allocate(8192);
2929
var adler = new Adler32();

src/main/java/org/dcache/nearline/cta/xrootd/DataServerHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
*/
1717
package org.dcache.nearline.cta.xrootd;
1818

19-
import static org.dcache.nearline.cta.Utils.calculateChecksum;
19+
import static org.dcache.nearline.cta.Utils.calculateAdler32Checksum;
2020
import static org.dcache.xrootd.protocol.XrootdProtocol.kXR_ArgInvalid;
2121
import static org.dcache.xrootd.protocol.XrootdProtocol.kXR_FileNotOpen;
2222
import static org.dcache.xrootd.protocol.XrootdProtocol.kXR_IOError;
@@ -433,7 +433,7 @@ protected QueryResponse doOnQuery(ChannelHandlerContext ctx, QueryRequest msg)
433433
var file = getFile(r);
434434
ForkJoinPool.commonPool().execute(() -> {
435435
try {
436-
Checksum checksum = calculateChecksum(file);
436+
Checksum checksum = calculateAdler32Checksum(file);
437437
LOGGER.info("Files {} checksum after restore: {}", file, checksum);
438438
LOGGER.info("Successful restored from {} : {} : archive id: {}", new RemoteAddressHolder(ctx), requestId, archiveId);
439439
r.completed(Set.of(checksum));

0 commit comments

Comments
 (0)