From ff1046d5a755e661632f3c8c304c329e5f40a86d Mon Sep 17 00:00:00 2001 From: Yuji Ito Date: Fri, 1 Mar 2024 17:12:26 +0900 Subject: [PATCH] tuning spread range Signed-off-by: Yuji Ito --- node/controller/three/object.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/node/controller/three/object.go b/node/controller/three/object.go index cbe288d..c35d20f 100644 --- a/node/controller/three/object.go +++ b/node/controller/three/object.go @@ -79,7 +79,7 @@ func (impl *objectControllerImpl) Create(name string, podUUID string, spec *thre return "", fmt.Errorf("failed to create object: %w", err) } - if err := impl.messagingDriver.SpreadObject(obj.Meta.Uuid, spec.Position, 100); err != nil { + if err := impl.messagingDriver.SpreadObject(obj.Meta.Uuid, spec.Position, 1000); err != nil { log.Printf("failed to spread object: name=%s, uuid=%s: %s\n", name, obj.Meta.Uuid, err.Error()) } // colonio spread post is not send event to myself currently, so call ReceiveSpreadEvent directly. @@ -108,7 +108,7 @@ func (impl *objectControllerImpl) Update(uuid string, podUUID string, spec *thre return fmt.Errorf("failed to update object: %w", err) } - if err := impl.messagingDriver.SpreadObject(obj.Meta.Uuid, spec.Position, 100); err != nil { + if err := impl.messagingDriver.SpreadObject(obj.Meta.Uuid, spec.Position, 1000); err != nil { log.Printf("failed to spread object: name=%s, uuid=%s: %s\n", obj.Meta.Name, obj.Meta.Uuid, err.Error()) } // colonio spread post is not send event to myself currently, so call ReceiveSpreadEvent directly. @@ -154,7 +154,7 @@ func (impl *objectControllerImpl) Delete(uuid string, podUUID string) error { return fmt.Errorf("failed to delete object: %w", err) } - if err := impl.messagingDriver.SpreadObject(obj.Meta.Uuid, obj.Spec.Position, 100*2); err != nil { + if err := impl.messagingDriver.SpreadObject(obj.Meta.Uuid, obj.Spec.Position, 1000*2); err != nil { log.Printf("failed to spread object: name=%s, uuid=%s: %s\n", obj.Meta.Name, obj.Meta.Uuid, err.Error()) } // colonio spread post is not send event to myself currently, so call ReceiveSpreadEvent directly.