mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2026-05-14 06:50:25 +00:00
2d2029c598
When two goroutines attempt to access the content of the buffer log writer, they must be made thread safe with a write mutex. The buffer log writer is only used in testing. ## Checklist ### Tests for Go changes - I added test coverage for Go changes... - [x] in their respective `*_test.go` for unit tests. - [ ] in the `tests/integration` directory if it involves interactions with a live Forgejo server. - I ran... - [ ] `make pr-go` before pushing ### Documentation - [ ] I created a pull request [to the documentation](https://codeberg.org/forgejo/docs) to explain to Forgejo users how to use this change. - [x] I did not document these changes and I do not expect someone else to do it. ### Release notes - [ ] This change will be noticed by a Forgejo user or admin (feature, bug fix, performance, etc.). I suggest to include a release note for this change. - [x] This change is not visible to a Forgejo user or admin (refactor, dependency upgrade, etc.). I think there is no need to add a release note for this change. *The decision if the pull request will be shown in the release notes is up to the mergers / release team.* The content of the `release-notes/<pull request number>.md` file will serve as the basis for the release notes. If the file does not exist, the title of the pull request will be used instead. Reviewed-on: https://codeberg.org/forgejo/forgejo/pulls/11962 Reviewed-by: Mathieu Fenniak <mfenniak@noreply.codeberg.org> Co-authored-by: limiting-factor <limiting-factor@posteo.com> Co-committed-by: limiting-factor <limiting-factor@posteo.com>
48 lines
927 B
Go
48 lines
927 B
Go
// Copyright 2025 The Forgejo Authors.
|
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
|
|
|
package log
|
|
|
|
import (
|
|
"bytes"
|
|
"sync"
|
|
)
|
|
|
|
type EventWriterBuffer interface {
|
|
EventWriter
|
|
GetString() string
|
|
}
|
|
|
|
type eventWriterBuffer struct {
|
|
*EventWriterBaseImpl
|
|
buffer *bytes.Buffer
|
|
mu sync.RWMutex
|
|
}
|
|
|
|
var _ EventWriterBuffer = (*eventWriterBuffer)(nil)
|
|
|
|
func (*eventWriterBuffer) Close() error {
|
|
return nil
|
|
}
|
|
|
|
func (o *eventWriterBuffer) Write(p []byte) (n int, err error) {
|
|
o.mu.Lock()
|
|
defer o.mu.Unlock()
|
|
return o.buffer.Write(p)
|
|
}
|
|
|
|
func (o *eventWriterBuffer) GetString() string {
|
|
o.mu.Lock()
|
|
defer o.mu.Unlock()
|
|
b := o.buffer.Bytes()
|
|
s := make([]byte, len(b))
|
|
copy(s, b)
|
|
return string(s)
|
|
}
|
|
|
|
func NewEventWriterBuffer(name string, mode WriterMode) EventWriter {
|
|
w := &eventWriterBuffer{EventWriterBaseImpl: NewEventWriterBase(name, "buffer", mode)}
|
|
w.buffer = new(bytes.Buffer)
|
|
w.OutputWriteCloser = w
|
|
return w
|
|
}
|