Vihren Atlas

Atlas › Test

TestMap_PopAll

go.temporal.io/server/common/collection/TestMap_PopAll

Package
go.temporal.io/server/common/collection
Suite / test hierarchy
TestMap_PopAll
Test
TestMap_PopAll
Introduced at
sync_map.go ×1 Joint frontier
Covered ranges
7
Covered lines
32
Covered files
1

Covered source

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

go.temporal.io/server/common/collection/sync_map.go 32 covered LOC · 7 ranges

Open complete file

15 }
16
17 > func NewSyncMap[K comparable, V any]() SyncMap[K, V] { sync_map.go
18 > return SyncMap[K, V]{
19 > RWMutex: &sync.RWMutex{},
20 > contents: make(map[K]V),
21 > }
22 > }
23
24 > func (m *SyncMap[K, V]) Get(key K) (value V, ok bool) { sync_map.go
25 > m.RLock()
26 > defer m.RUnlock()
27 > value, ok = m.contents[key]
28 > return
29 > }
30
31 func (m *SyncMap[K, V]) GetOrSet(key K, value V) (v V, exist bool) {
47 }
48
49 > func (m *SyncMap[K, V]) Set(key K, value V) { sync_map.go
50 > m.Lock()
51 > defer m.Unlock()
52 > m.contents[key] = value
53 > }
54
55 func (m *SyncMap[K, V]) Delete(key K) {
59 }
60
61 > func (m *SyncMap[K, V]) Pop(key K) (value V, ok bool) { sync_map.go
62 > m.Lock()
63 > defer m.Unlock()
64 > value, ok = m.contents[key]
65 > if ok {
66 > delete(m.contents, key) sync_map.go
67 > }
68 > return value, ok sync_map.go
69 }
70
71 > func (m *SyncMap[K, V]) PopAll() map[K]V { sync_map.go
72 > m.Lock()
73 > defer m.Unlock()
74 > contents := maps.Clone(m.contents)
75 > clear(m.contents)
76 > return contents
77 > }