From f26092cccd968129dfd9da2fa8d3e6c2aafe4064 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 | 8 +++++--- 2 files changed, 6 insertions(+), 3 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..73a2d4d 100644 --- a/scenarios/s3.js +++ b/scenarios/s3.js @@ -160,11 +160,11 @@ export function obj_write() { const payload = generator.genPayload(); const resp = s3_client.put(bucket, key, payload); + log.withFields({bucket : bucket, key : key, op : 'WRITE'}).info("INFO"); if (!resp.success) { log.withFields({bucket : bucket, key : key}).error(resp.error); return; } - if (obj_registry) { obj_registry.addObject('', '', bucket, key, payload.hash()); } @@ -181,8 +181,9 @@ export function obj_read() { return; } const resp = s3_client.get(obj.s3_bucket, obj.s3_key) + log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'READ'}).info("INFO") 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 @@ -208,7 +209,8 @@ export function obj_delete() { } return; } - + obj_registry.setObjectStatus(obj.id, obj.status, 'delete'); + log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'DELETE'}).info("INFO"); const resp = s3_client.delete(obj.s3_bucket, obj.s3_key); if (!resp.success) { log.withFields({bucket : obj.s3_bucket, key : obj.s3_key, op : 'DELETE'})