Atlas › Test

TestChannelSize_New

Exact test identity: go.temporal.io/server/common/locks/TestConditionVariableSuite/TestChannelSize_New

Package: go.temporal.io/server/common/locks
Suite / test hierarchy: TestConditionVariableSuite/TestChannelSize_New
Test: TestChannelSize_New
Introduced at: condition_variable_impl.go ×2 Frontier kind: Joint frontier
Covered ranges: 2
Covered lines: 11
Covered files: 1

Covered source

Expand a file to inspect source; the > gutter marks covered lines.

go.temporal.io/server/common/locks/condition_variable_impl.go 11 covered LOC · 2 ranges

  18
  
  func NewConditionVariable(
  
  19
  
  	lock Locker,
  
  20
  >
  ) *ConditionVariableImpl {
  
condition_variable_impl.go

  21
  >
  	return &ConditionVariableImpl{
  
  22
  >
  		lock: lock,
  
  23
  >
  
  24
  >
  		chanLock: sync.Mutex{},
  
  25
  >
  		channel:  newCVChannel(),
  
  26
  >
  	}
  
  27
  >
  }
  
  28
  
  29
  
  // Signal wakes one goroutine waiting on this condition variable, if there is any.

  82
  
  }
  
  83
  
  84
  >
  func newCVChannel() chan struct{} {
  
condition_variable_impl.go

  85
  >
  	return make(chan struct{}, 1)
  
  86
  >
  }