From 4148e2f847e501c70a27f35c686f651b1e19fc4e Mon Sep 17 00:00:00 2001 From: lfbrehm <97600985+lfbrehm@users.noreply.github.com> Date: Wed, 22 May 2024 11:26:50 +0200 Subject: [PATCH] fix: Added handshake and skip messages for data replication --- .../api/dataproxy/services/v2/dataproxy_service.proto | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/aruna/api/dataproxy/services/v2/dataproxy_service.proto b/aruna/api/dataproxy/services/v2/dataproxy_service.proto index dfc574af..bef85168 100644 --- a/aruna/api/dataproxy/services/v2/dataproxy_service.proto +++ b/aruna/api/dataproxy/services/v2/dataproxy_service.proto @@ -180,6 +180,14 @@ message PullReplicationRequest { } // Messages (responses) from PROXY A + +message Handshake {} // Response that gets send after channel creation + +// Gets send if PROXY A has only a tmp location +message Skip { + string object_id = 1; +} + message ObjectInfo { string object_id = 1; int64 chunks = 2; // == (Compressed_size / (65536 + 28)) + 1 @@ -197,9 +205,11 @@ message Chunk { message PullReplicationResponse { oneof message { + Handshake handshake = 5; ObjectInfo object_info = 1; Chunk chunk = 2; // If no ack is received, the chunk will be resent Empty finish_message = 3; + Skip skip = 4; } }