diff options
author | Bjørn Christian Seime <bjorncs@yahooinc.com> | 2023-02-09 17:11:18 +0100 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@yahooinc.com> | 2023-02-09 17:11:18 +0100 |
commit | 3014e3e42ce93ec638eda67d0fd0c40f68431707 (patch) | |
tree | cbc4b587293c97e8d88dcc6bdf3bc0407693404b /filedistribution | |
parent | cf2673c4494f233c086dc54d747a377474801fb9 (diff) |
Define required capabilities for existing JRT RPC methods
Diffstat (limited to 'filedistribution')
-rw-r--r-- | filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java index a285fbaafe2..e5aa47fe5c9 100644 --- a/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java +++ b/filedistribution/src/main/java/com/yahoo/vespa/filedistribution/FileReceiver.java @@ -7,6 +7,7 @@ import com.yahoo.jrt.Int32Value; import com.yahoo.jrt.Method; import com.yahoo.jrt.Request; import com.yahoo.jrt.Supervisor; +import com.yahoo.security.tls.Capability; import net.jpountz.xxhash.StreamingXXHash64; import net.jpountz.xxhash.XXHashFactory; import java.io.File; @@ -170,6 +171,7 @@ public class FileReceiver { private List<Method> receiveFileMethod() { List<Method> methods = new ArrayList<>(); methods.add(new Method(RECEIVE_META_METHOD, "sssl*", "ii", this::receiveFileMeta) + .requireCapabilities(Capability.CLIENT__FILERECEIVER_API) .paramDesc(0, "filereference", "file reference to download") .paramDesc(1, "filename", "filename") .paramDesc(2, "type", "'file' or 'compressed'") @@ -178,12 +180,14 @@ public class FileReceiver { .returnDesc(0, "ret", "0 if success, 1 otherwise") .returnDesc(1, "session-id", "Session id to be used for this transfer")); methods.add(new Method(RECEIVE_PART_METHOD, "siix", "i", this::receiveFilePart) + .requireCapabilities(Capability.CLIENT__FILERECEIVER_API) .paramDesc(0, "filereference", "file reference to download") .paramDesc(1, "session-id", "Session id to be used for this transfer") .paramDesc(2, "partid", "relative part number starting at zero") .paramDesc(3, "data", "bytes in this part") .returnDesc(0, "ret", "0 if success, 1 otherwise")); methods.add(new Method(RECEIVE_EOF_METHOD, "silis", "i", this::receiveFileEof) + .requireCapabilities(Capability.CLIENT__FILERECEIVER_API) .paramDesc(0, "filereference", "file reference to download") .paramDesc(1, "session-id", "Session id to be used for this transfer") .paramDesc(2, "crc-code", "crc code (xxhash64)") |