diff options
| author |  kim <89579420+NyaaaWhatsUpDoc@users.noreply.github.com> | 2024-06-21 15:43:17 +0000 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2024-06-21 16:43:17 +0100 |
| commit | b93087ceb4f508c1d5262f363a21bdea3e502c31 (patch) | |
| tree | 71ff80a06ee447f4694fd242cb84d9010fc46ccd /vendor/codeberg.org/gruf/go-structr/queue.go | |
| parent | [feature] add worker task serialization logic (#2989) (diff) | |
| download | gotosocial-b93087ceb4f508c1d5262f363a21bdea3e502c31.tar.xz | |
[chore] update go-structr and go-mangler to no longer rely on modern-go/reflect2 (#3026)
* updates go-structr and go-mangler to no longer rely on modern-go/reflect2 (*phew* now we're go1.23 safe)
* update go-structr version
* bump go-structr to improve memory usage (v. slightly) in certain conditions
Diffstat (limited to 'vendor/codeberg.org/gruf/go-structr/queue.go')
| -rw-r--r-- | vendor/codeberg.org/gruf/go-structr/queue.go | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/vendor/codeberg.org/gruf/go-structr/queue.go b/vendor/codeberg.org/gruf/go-structr/queue.go index bdead6ea8..1c49edbb1 100644 --- a/vendor/codeberg.org/gruf/go-structr/queue.go +++ b/vendor/codeberg.org/gruf/go-structr/queue.go @@ -214,10 +214,9 @@ func (q *Queue[T]) Debug() map[string]any { m["indices"] = indices for i := range q.indices { var n uint64 - q.indices[i].data.Iter(func(_ string, l *list) (stop bool) { + for _, l := range q.indices[i].data.m { n += uint64(l.len) - return - }) + } indices[q.indices[i].name] = n } q.mutex.Unlock() @@ -331,8 +330,8 @@ func (q *Queue[T]) delete(item *indexed_item) { // Drop this index_entry. index.delete_entry(entry) - // Check compact. - index.compact() + // Check compact map. + index.data.Compact() } // Drop entry from queue list. |