summaryrefslogtreecommitdiff
path: root/vendor/codeberg.org/gruf/go-store/util
diff options
context:
space:
mode:
authorLibravatar tobi <31960611+tsmethurst@users.noreply.github.com>2022-11-05 12:10:19 +0100
committerLibravatar GitHub <noreply@github.com>2022-11-05 11:10:19 +0000
commitbcb80d3ff4a669d52d63950c8830427646c05884 (patch)
tree4aa95a83545b3f87a80fe4b625cb6f2ad9c4427f /vendor/codeberg.org/gruf/go-store/util
parent[bugfix] Increase field size limits when registering apps (#958) (diff)
downloadgotosocial-bcb80d3ff4a669d52d63950c8830427646c05884.tar.xz
[chore] bump gruf/go-store to v2 (#953)
* [chore] bump gruf/go-store to v2 * no more boobs
Diffstat (limited to 'vendor/codeberg.org/gruf/go-store/util')
-rw-r--r--vendor/codeberg.org/gruf/go-store/util/fs.go82
-rw-r--r--vendor/codeberg.org/gruf/go-store/util/io.go42
-rw-r--r--vendor/codeberg.org/gruf/go-store/util/pool.go20
-rw-r--r--vendor/codeberg.org/gruf/go-store/util/sys.go14
4 files changed, 0 insertions, 158 deletions
diff --git a/vendor/codeberg.org/gruf/go-store/util/fs.go b/vendor/codeberg.org/gruf/go-store/util/fs.go
deleted file mode 100644
index 53fef7750..000000000
--- a/vendor/codeberg.org/gruf/go-store/util/fs.go
+++ /dev/null
@@ -1,82 +0,0 @@
-package util
-
-import (
- "io/fs"
- "os"
-
- "codeberg.org/gruf/go-fastpath"
-)
-
-// WalkDir traverses the dir tree of the supplied path, performing the supplied walkFn on each entry
-func WalkDir(pb *fastpath.Builder, path string, walkFn func(string, fs.DirEntry)) error {
- // Read supplied dir path
- dirEntries, err := os.ReadDir(path)
- if err != nil {
- return err
- }
-
- // Iter entries
- for _, entry := range dirEntries {
- // Pass to walk fn
- walkFn(path, entry)
-
- // Recurse dir entries
- if entry.IsDir() {
- err = WalkDir(pb, pb.Join(path, entry.Name()), walkFn)
- if err != nil {
- return err
- }
- }
- }
-
- return nil
-}
-
-// CleanDirs traverses the dir tree of the supplied path, removing any folders with zero children
-func CleanDirs(path string) error {
- // Acquire builder
- pb := GetPathBuilder()
- defer PutPathBuilder(pb)
-
- // Get dir entries
- entries, err := os.ReadDir(path)
- if err != nil {
- return err
- }
-
- // Recurse dirs
- for _, entry := range entries {
- if entry.IsDir() {
- err := cleanDirs(pb, pb.Join(path, entry.Name()))
- if err != nil {
- return err
- }
- }
- }
- return nil
-}
-
-// cleanDirs performs the actual dir cleaning logic for the exported version
-func cleanDirs(pb *fastpath.Builder, path string) error {
- // Get dir entries
- entries, err := os.ReadDir(path)
- if err != nil {
- return err
- }
-
- // If no entries, delete
- if len(entries) < 1 {
- return os.Remove(path)
- }
-
- // Recurse dirs
- for _, entry := range entries {
- if entry.IsDir() {
- err := cleanDirs(pb, pb.Join(path, entry.Name()))
- if err != nil {
- return err
- }
- }
- }
- return nil
-}
diff --git a/vendor/codeberg.org/gruf/go-store/util/io.go b/vendor/codeberg.org/gruf/go-store/util/io.go
deleted file mode 100644
index d034cf62b..000000000
--- a/vendor/codeberg.org/gruf/go-store/util/io.go
+++ /dev/null
@@ -1,42 +0,0 @@
-package util
-
-import "io"
-
-// NopReadCloser turns a supplied io.Reader into io.ReadCloser with a nop Close() implementation
-func NopReadCloser(r io.Reader) io.ReadCloser {
- return &nopReadCloser{r}
-}
-
-// NopWriteCloser turns a supplied io.Writer into io.WriteCloser with a nop Close() implementation
-func NopWriteCloser(w io.Writer) io.WriteCloser {
- return &nopWriteCloser{w}
-}
-
-// ReadCloserWithCallback adds a customizable callback to be called upon Close() of a supplied io.ReadCloser
-func ReadCloserWithCallback(rc io.ReadCloser, cb func()) io.ReadCloser {
- return &callbackReadCloser{
- ReadCloser: rc,
- callback: cb,
- }
-}
-
-// nopReadCloser turns an io.Reader -> io.ReadCloser with a nop Close()
-type nopReadCloser struct{ io.Reader }
-
-func (r *nopReadCloser) Close() error { return nil }
-
-// nopWriteCloser turns an io.Writer -> io.WriteCloser with a nop Close()
-type nopWriteCloser struct{ io.Writer }
-
-func (w nopWriteCloser) Close() error { return nil }
-
-// callbackReadCloser allows adding our own custom callback to an io.ReadCloser
-type callbackReadCloser struct {
- io.ReadCloser
- callback func()
-}
-
-func (c *callbackReadCloser) Close() error {
- defer c.callback()
- return c.ReadCloser.Close()
-}
diff --git a/vendor/codeberg.org/gruf/go-store/util/pool.go b/vendor/codeberg.org/gruf/go-store/util/pool.go
deleted file mode 100644
index 8400cb5b7..000000000
--- a/vendor/codeberg.org/gruf/go-store/util/pool.go
+++ /dev/null
@@ -1,20 +0,0 @@
-package util
-
-import (
- "codeberg.org/gruf/go-fastpath"
- "codeberg.org/gruf/go-pools"
-)
-
-// pathBuilderPool is the global fastpath.Builder pool
-var pathBuilderPool = pools.NewPathBuilderPool(512)
-
-// GetPathBuilder fetches a fastpath.Builder object from the pool
-func GetPathBuilder() *fastpath.Builder {
- return pathBuilderPool.Get()
-}
-
-// PutPathBuilder places supplied fastpath.Builder back in the pool
-func PutPathBuilder(pb *fastpath.Builder) {
- pb.Reset()
- pathBuilderPool.Put(pb)
-}
diff --git a/vendor/codeberg.org/gruf/go-store/util/sys.go b/vendor/codeberg.org/gruf/go-store/util/sys.go
deleted file mode 100644
index 6661029e5..000000000
--- a/vendor/codeberg.org/gruf/go-store/util/sys.go
+++ /dev/null
@@ -1,14 +0,0 @@
-package util
-
-import "syscall"
-
-// RetryOnEINTR is a low-level filesystem function for retrying syscalls on O_EINTR received
-func RetryOnEINTR(do func() error) error {
- for {
- err := do()
- if err == syscall.EINTR {
- continue
- }
- return err
- }
-}