Skip to content

Commit 4267b61

Browse files
committed
Fix: duplicate resource allocation in AcquireContainer()
1 parent 1b078ca commit 4267b61

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

internal/node/pool.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ func AcquireContainer(f *function.Function) (*container.Container, bool, error)
151151
if !AcquireResources(f.CPUDemand, f.MemoryMB, true) {
152152
return nil, false, OutOfResourcesErr
153153
}
154-
c, err = NewContainer(f, false)
154+
c, err = NewContainerWithAcquiredResources(f, false)
155155
return c, false, err
156156
}
157157

internal/scheduling/scheduler.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,7 @@ func Run(p Policy) {
5656
for {
5757
select {
5858
case r = <-requests: // receive request
59+
log.Printf("onArrival resources: %v\n", &node.Resources)
5960
go p.OnArrival(r)
6061
case c = <-completions:
6162
node.HandleCompletion(c.cont, c.fun)
@@ -68,6 +69,7 @@ func Run(p Policy) {
6869
}
6970
}
7071

72+
log.Printf("after completion resources: %v\n", &node.Resources)
7173
}
7274
}
7375

0 commit comments

Comments
 (0)