diff options
author | 2021-09-11 20:12:47 +0100 | |
---|---|---|
committer | 2021-09-11 20:12:47 +0100 | |
commit | e43a46e9822a05dd0345a7676e03285ddf83205e (patch) | |
tree | 72db13159e47d7815d001285fadb8225b1f7a571 /vendor/git.iim.gay/grufwub/go-errors/once.go | |
parent | documentation updates (#211) (diff) | |
download | gotosocial-e43a46e9822a05dd0345a7676e03285ddf83205e.tar.xz |
add git.iim.gay/grufwub/go-store for storage backend, replacing blob.Storage
Signed-off-by: kim (grufwub) <grufwub@gmail.com>
Diffstat (limited to 'vendor/git.iim.gay/grufwub/go-errors/once.go')
-rw-r--r-- | vendor/git.iim.gay/grufwub/go-errors/once.go | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/vendor/git.iim.gay/grufwub/go-errors/once.go b/vendor/git.iim.gay/grufwub/go-errors/once.go new file mode 100644 index 000000000..ba21ed695 --- /dev/null +++ b/vendor/git.iim.gay/grufwub/go-errors/once.go @@ -0,0 +1,45 @@ +package errors + +import ( + "sync/atomic" + "unsafe" +) + +// OnceError is an error structure that supports safe multi-threaded +// usage and setting only once (until reset) +type OnceError struct { + err unsafe.Pointer +} + +// NewOnce returns a new OnceError instance +func NewOnce() OnceError { + return OnceError{ + err: nil, + } +} + +func (e *OnceError) Store(err error) { + // Nothing to do + if err == nil { + return + } + + // Only set if not already + atomic.CompareAndSwapPointer( + &e.err, + nil, + unsafe.Pointer(&err), + ) +} + +func (e *OnceError) Load() error { + return *(*error)(atomic.LoadPointer(&e.err)) +} + +func (e *OnceError) IsSet() bool { + return (atomic.LoadPointer(&e.err) != nil) +} + +func (e *OnceError) Reset() { + atomic.StorePointer(&e.err, nil) +} |