worker: add logging

SiaFoundation · Feb 26, 2024 · 22026fe · 22026fe
1 parent fe828e2
commit 22026fe
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/worker/memory.go b/worker/memory.go
@@ -95,6 +95,7 @@ func (mm *memoryManager) AcquireMemory(ctx context.Context, amt uint64) Memory {
 	mm.sigNewMem.Signal() // wake next goroutine
 	mm.sigNewMem.L.Unlock()
 
+	fmt.Println("DEBUG PJ: acquired memory", amt)
 	return &acquiredMemory{
 		mm:        mm,
 		remaining: amt,
@@ -152,6 +153,7 @@ func (lmm *limitMemoryManager) AcquireMemory(ctx context.Context, amt uint64) Me
 		return nil
 	}
 
+	fmt.Println("DEBUG PJ: acquired limit memory", amt)
 	return &limitAcquiredMemory{
 		child:  childMem,
 		parent: parentMem,

diff --git a/worker/mocks_test.go b/worker/mocks_test.go
@@ -338,7 +338,9 @@ func (mm *memoryManagerMock) Limit(amt uint64) (MemoryManager, error) {
 func (mm *memoryManagerMock) Status() api.MemoryStatus { return api.MemoryStatus{} }
 
 func (mm *memoryManagerMock) AcquireMemory(ctx context.Context, amt uint64) Memory {
+	start := time.Now()
 	<-mm.memBlockChan
+	fmt.Println("DEBUG PJ: acquired mock memory", amt, time.Since(start))
 	return &memoryMock{}
 }