diff options
| author | chrislu <chris.lu@gmail.com> | 2024-07-11 00:04:24 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-07-11 00:04:24 -0700 |
| commit | 33b11f92bca0272b6e25579a42477a8aebb16cbe (patch) | |
| tree | 6750d45be694d000fe4c4771f67db091e8aa536b /weed/util | |
| parent | 9c440d472c97d88efc92d6c5956306d418cfa3ce (diff) | |
| download | seaweedfs-33b11f92bca0272b6e25579a42477a8aebb16cbe.tar.xz seaweedfs-33b11f92bca0272b6e25579a42477a8aebb16cbe.zip | |
Squashed commit of the following:
commit 465b47b8f72668dfc12eaa72befb232513c9e1db
Merge: f39272b54 9c440d472
Author: chrislu <chris.lu@gmail.com>
Date: Wed Jul 10 23:56:51 2024 -0700
Merge branch 'master' into merged-persisted-logs
commit f39272b5416bdd4d1714ce3e99aded0fe62e7d89
Author: chrislu <chris.lu@gmail.com>
Date: Wed Jul 10 23:49:26 2024 -0700
merge meta logs from multiple files
Diffstat (limited to 'weed/util')
| -rw-r--r-- | weed/util/queue.go | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/weed/util/queue.go b/weed/util/queue.go index 1437fe8be..69efc078f 100644 --- a/weed/util/queue.go +++ b/weed/util/queue.go @@ -61,3 +61,14 @@ func (q *Queue[T]) Dequeue() (result T) { return n.data } + +func (q *Queue[T]) Peek() (result T) { + q.RLock() + defer q.RUnlock() + + if q.head == nil { + return + } + + return q.head.data +} |