diff options
author | 2022-11-05 12:10:19 +0100 | |
---|---|---|
committer | 2022-11-05 11:10:19 +0000 | |
commit | bcb80d3ff4a669d52d63950c8830427646c05884 (patch) | |
tree | 4aa95a83545b3f87a80fe4b625cb6f2ad9c4427f /vendor/codeberg.org/gruf/go-store/util | |
parent | [bugfix] Increase field size limits when registering apps (#958) (diff) | |
download | gotosocial-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.go | 82 | ||||
-rw-r--r-- | vendor/codeberg.org/gruf/go-store/util/io.go | 42 | ||||
-rw-r--r-- | vendor/codeberg.org/gruf/go-store/util/pool.go | 20 | ||||
-rw-r--r-- | vendor/codeberg.org/gruf/go-store/util/sys.go | 14 |
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 - } -} |