aggregate checksum experimentation

Author: ibrandes

sdk/storage/azure-storage-blob/src/main/java/com/azure/storage/blob/BlobAsyncClient.java

@@ -815,7 +815,15 @@ private Mono<Response<BlockBlobItem>> uploadInChunks(BlockBlobAsyncClient blockB
                     return responseMono;
                 })
                     // We only care about the stageBlock insofar as it was successful, but we need to collect the ids.
-                    .map(x -> blockId);
+                    .map(x -> {
+//                        String headerV = x.getHeaders().getValue("test_context_key");
+//                        if (Objects.equals(headerV, "-1")) {
+//                            System.out.println("does not have context key");
+//                        } else {
+//                            System.out.println("has context key: " + headerV);
+//                        }
+                        return blockId;
+                    });
             }, parallelTransferOptions.getMaxConcurrency(), 1)
             .collect(Collectors.toList())
             .flatMap(ids -> blockBlobAsyncClient

sdk/storage/azure-storage-common/src/main/java/com/azure/storage/common/implementation/structuredmessage/StructuredMessageEncoder.java

@@ -261,4 +261,13 @@ private void incrementCurrentSegment() {
     public String getEncodedMessageLength() {
         return String.valueOf(messageLength);
     }
+
+//    /**
+//     * Returns the CRC64 of the message
+//     *
+//     * @return The CRC64 of the message
+//     */
+//    public long getMessageCRC64() {
+//        return messageCRC64;
+//    }
 }

sdk/storage/azure-storage-common/src/main/java/com/azure/storage/common/policy/StorageContentValidationPolicy.java

@@ -61,6 +61,14 @@ public HttpResponse processSync(HttpPipelineCallContext context, HttpPipelineNex
     public Mono<HttpResponse> process(HttpPipelineCallContext context, HttpPipelineNextPolicy next) {
         applyContentValidation(context);
         return next.process();
+
+//        long messageCRC64 = applyContentValidation(context);
+//        return next.process().map(response -> {
+//            if (messageCRC64 != -1) {
+//                response.getHeaders().add("test_context_key", String.valueOf(messageCRC64));
+//            }
+//            return response;
+//        });
     }
 
     private void applyContentValidation(HttpPipelineCallContext context) {
@@ -115,6 +123,7 @@ private void applyStructuredMessage(HttpPipelineCallContext context) {
         // x-ms-structured-content-length
         context.getHttpRequest()
             .setHeader(STRUCTURED_CONTENT_LENGTH_HEADER_NAME, String.valueOf(unencodedContentLength));
+        //return structuredMessageEncoder.getMessageCRC64();
     }
 
 }