Merge pull request #17 from llamerada-jp/update-range

tuning spread range
llamerada-jp · Mar 1, 2024 · 0e20f3b · 0e20f3b
2 parents 6896f89 + ff1046d
commit 0e20f3b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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.