tronnet/ProxmoxAAS-Fabric
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change sync endpoints to synchronous calls

Browse Source
This commit is contained in:
Arthur Lu
2025-04-21 19:19:37 +00:00
parent 8e73db22b7
commit cd12365336
2 changed files with 40 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
app/app.go
View File

@@ -120,28 +120,28 @@ func Run() {
}) })
router.POST("/sync", func(c *gin.Context) { router.POST("/sync", func(c *gin.Context) {
go func() { //go func() {
start := time.Now() start := time.Now()
log.Printf("Starting cluster sync\n") log.Printf("Starting cluster sync\n")
cluster.Sync() cluster.Sync()
log.Printf("Synced cluster in %fs\n", time.Since(start).Seconds()) log.Printf("Synced cluster in %fs\n", time.Since(start).Seconds())
}() //}()
}) })
router.POST("/nodes/:node/sync", func(c *gin.Context) { router.POST("/nodes/:node/sync", func(c *gin.Context) {
nodeid := c.Param("node") nodeid := c.Param("node")
go func() { //go func() {
start := time.Now() start := time.Now()
log.Printf("Starting %s sync\n", nodeid) log.Printf("Starting %s sync\n", nodeid)
err := cluster.RebuildHost(nodeid) err := cluster.RebuildHost(nodeid)
if err != nil { if err != nil {
log.Printf("Failed to sync %s: %s", nodeid, err.Error()) log.Printf("Failed to sync %s: %s", nodeid, err.Error())
return return
} else { } else {
log.Printf("Synced %s in %fs\n", nodeid, time.Since(start).Seconds()) log.Printf("Synced %s in %fs\n", nodeid, time.Since(start).Seconds())
return return
} }
}() //}()
}) })
router.POST("/nodes/:node/instances/:vmid/sync", func(c *gin.Context) { router.POST("/nodes/:node/instances/:vmid/sync", func(c *gin.Context) {
@@ -152,31 +152,31 @@ func Run() {
return return
} }
go func() { //go func() {
start := time.Now() start := time.Now()
log.Printf("Starting %s.%d sync\n", nodeid, vmid) log.Printf("Starting %s.%d sync\n", nodeid, vmid)
node, err := cluster.GetNode(nodeid) node, err := cluster.GetNode(nodeid)
if err != nil { if err != nil {
log.Printf("Failed to sync %s.%d: %s", nodeid, vmid, err.Error()) log.Printf("Failed to sync %s.%d: %s", nodeid, vmid, err.Error())
return return
} }
instance, err := node.GetInstance(uint(vmid)) instance, err := node.GetInstance(uint(vmid))
if err != nil { if err != nil {
log.Printf("Failed to sync %s.%d: %s", nodeid, vmid, err.Error()) log.Printf("Failed to sync %s.%d: %s", nodeid, vmid, err.Error())
return return
} }
err = node.RebuildInstance(instance.Type, uint(vmid)) err = node.RebuildInstance(instance.Type, uint(vmid))
if err != nil { if err != nil {
log.Printf("Failed to sync %s.%d: %s", nodeid, vmid, err.Error()) log.Printf("Failed to sync %s.%d: %s", nodeid, vmid, err.Error())
return return
} else { } else {
log.Printf("Synced %s.%d in %fs\n", nodeid, vmid, time.Since(start).Seconds()) log.Printf("Synced %s.%d in %fs\n", nodeid, vmid, time.Since(start).Seconds())
return return
} }
}() //}()
}) })
router.Run("0.0.0.0:" + strconv.Itoa(config.ListenPort)) router.Run("0.0.0.0:" + strconv.Itoa(config.ListenPort))

2
app/model.go
View File

@@ -253,8 +253,6 @@ func (instance *Instance) RebuildBoot() {
eligibleBoot[string(k)] = true eligibleBoot[string(k)] = true
} }
log.Println(eligibleBoot)
x := strings.Split(instance.configBoot, "order=") // should be a;b;c;d ... x := strings.Split(instance.configBoot, "order=") // should be a;b;c;d ...
if len(x) == 2 { if len(x) == 2 {
y := strings.Split(x[1], ";") y := strings.Split(x[1], ";")