From 9e4e8c1df24e7efd4c0b5e6ea5b280477adacabb Mon Sep 17 00:00:00 2001 From: "m.malygina" Date: Wed, 19 Jun 2024 10:31:39 +0300 Subject: [PATCH] print selectionSize Signed-off-by: m.malygina --- internal/registry/obj_selector.go | 1 + scenarios/s3.js | 5 +++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/internal/registry/obj_selector.go b/internal/registry/obj_selector.go index ef9e0d9..b468d18 100644 --- a/internal/registry/obj_selector.go +++ b/internal/registry/obj_selector.go @@ -32,6 +32,7 @@ func NewObjSelector(registry *ObjRegistry, selectionSize int, kind SelectorKind, if selectionSize <= 0 { selectionSize = objectSelectCache } + println("selectionSize", selectionSize) if filter == nil || filter.Status == "" { panic("filtering without status is not supported") } diff --git a/scenarios/s3.js b/scenarios/s3.js index 22b031a..1b6b92c 100644 --- a/scenarios/s3.js +++ b/scenarios/s3.js @@ -164,7 +164,7 @@ export function obj_write() { log.withFields({bucket : bucket, key : key}).error(resp.error); return; } - + log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'WRITE'}).info("INFO"); if (obj_registry) { obj_registry.addObject('', '', bucket, key, payload.hash()); } @@ -182,7 +182,7 @@ export function obj_read() { } const resp = s3_client.get(obj.s3_bucket, obj.s3_key) if (!resp.success) { - log.withFields({bucket : obj.s3_bucket, key : obj.s3_key}) + log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'READ'}) .error(resp.error); } return @@ -210,6 +210,7 @@ export function obj_delete() { } const resp = s3_client.delete(obj.s3_bucket, obj.s3_key); + log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'DELETE'}).info("INFO"); if (!resp.success) { log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'DELETE'}) .error(resp.error);