fix(glance): image stream worker count (#21536)

yunionio · Nov 7, 2024 · b3c9c85 · b3c9c85
1 parent 0b50b21
commit b3c9c85
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 1 deletion.
diff --git a/pkg/image/models/images.go b/pkg/image/models/images.go
@@ -92,7 +92,10 @@ func init() {
 	}
 	ImageManager.SetVirtualObject(ImageManager)
 
-	imgStreamingWorkerMan = appsrv.NewWorkerManager("image_streaming_worker", 10, 1024, true)
+}
+
+func InitImageStreamWorkers() {
+	imgStreamingWorkerMan = appsrv.NewWorkerManager("image_streaming_worker", options.Options.ImageStreamWorkerCount, 1024, true)
 }
 
 /*

diff --git a/pkg/image/options/options.go b/pkg/image/options/options.go
@@ -51,6 +51,8 @@ type SImageOptions struct {
 	S3BucketName       string `help:"s3 bucket name" default:"onecloud-images"`
 	S3MountPoint       string `help:"s3fs mount point" default:"/opt/cloud/workspace/data/glance/s3images"`
 	S3CheckImageStatus bool   `help:"Enable s3 check image status"`
+
+	ImageStreamWorkerCount int `help:"Image stream worker count" default:"10"`
 }
 
 var (

diff --git a/pkg/image/service/service.go b/pkg/image/service/service.go
@@ -68,6 +68,8 @@ func StartService() {
 
 	common_options.StartOptionManager(opts, opts.ConfigSyncPeriodSeconds, api.SERVICE_TYPE, api.SERVICE_VERSION, options.OnOptionsChange)
 
+	models.InitImageStreamWorkers()
+
 	if opts.PortV2 > 0 {
 		log.Infof("Port V2 %d is specified, use v2 port", opts.PortV2)
 		opts.Port = opts.PortV2