220 lines
4.1 KiB
Go
220 lines
4.1 KiB
Go
|
package state
|
||
|
|
||
|
import (
|
||
|
"encoding/gob"
|
||
|
"errors"
|
||
|
"io/fs"
|
||
|
"os"
|
||
|
"path"
|
||
|
"strconv"
|
||
|
"sync"
|
||
|
"syscall"
|
||
|
)
|
||
|
|
||
|
// file-based locking
|
||
|
type simpleStore struct {
|
||
|
path []string
|
||
|
|
||
|
// created/opened by prepare
|
||
|
lockfile *os.File
|
||
|
// enforce prepare method
|
||
|
init sync.Once
|
||
|
// error returned by prepare
|
||
|
initErr error
|
||
|
|
||
|
lock sync.Mutex
|
||
|
}
|
||
|
|
||
|
func (s *simpleStore) Do(f func(b Backend)) (bool, error) {
|
||
|
s.init.Do(s.prepare)
|
||
|
if s.initErr != nil {
|
||
|
return false, s.initErr
|
||
|
}
|
||
|
|
||
|
s.lock.Lock()
|
||
|
defer s.lock.Unlock()
|
||
|
|
||
|
// lock store
|
||
|
if err := s.lockFile(); err != nil {
|
||
|
return false, err
|
||
|
}
|
||
|
|
||
|
// initialise new backend for caller
|
||
|
b := new(simpleBackend)
|
||
|
b.path = path.Join(s.path...)
|
||
|
f(b)
|
||
|
// disable backend
|
||
|
b.lock.Lock()
|
||
|
|
||
|
// unlock store
|
||
|
return true, s.unlockFile()
|
||
|
}
|
||
|
|
||
|
func (s *simpleStore) lockFileAct(lt int) (err error) {
|
||
|
op := "LockAct"
|
||
|
switch lt {
|
||
|
case syscall.LOCK_EX:
|
||
|
op = "Lock"
|
||
|
case syscall.LOCK_UN:
|
||
|
op = "Unlock"
|
||
|
}
|
||
|
|
||
|
for {
|
||
|
err = syscall.Flock(int(s.lockfile.Fd()), lt)
|
||
|
if !errors.Is(err, syscall.EINTR) {
|
||
|
break
|
||
|
}
|
||
|
}
|
||
|
if err != nil {
|
||
|
return &fs.PathError{
|
||
|
Op: op,
|
||
|
Path: s.lockfile.Name(),
|
||
|
Err: err,
|
||
|
}
|
||
|
}
|
||
|
return nil
|
||
|
}
|
||
|
|
||
|
func (s *simpleStore) lockFile() error {
|
||
|
return s.lockFileAct(syscall.LOCK_EX)
|
||
|
}
|
||
|
|
||
|
func (s *simpleStore) unlockFile() error {
|
||
|
return s.lockFileAct(syscall.LOCK_UN)
|
||
|
}
|
||
|
|
||
|
func (s *simpleStore) prepare() {
|
||
|
s.initErr = func() error {
|
||
|
prefix := path.Join(s.path...)
|
||
|
// ensure directory
|
||
|
if err := os.MkdirAll(prefix, 0700); err != nil && !errors.Is(err, fs.ErrExist) {
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
// open locker file
|
||
|
if f, err := os.OpenFile(prefix+".lock", os.O_RDWR|os.O_CREATE, 0600); err != nil {
|
||
|
return err
|
||
|
} else {
|
||
|
s.lockfile = f
|
||
|
}
|
||
|
|
||
|
return nil
|
||
|
}()
|
||
|
}
|
||
|
|
||
|
func (s *simpleStore) Close() error {
|
||
|
s.lock.Lock()
|
||
|
defer s.lock.Unlock()
|
||
|
|
||
|
err := s.lockfile.Close()
|
||
|
if err == nil || errors.Is(err, os.ErrInvalid) || errors.Is(err, os.ErrClosed) {
|
||
|
return nil
|
||
|
}
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
type simpleBackend struct {
|
||
|
path string
|
||
|
|
||
|
lock sync.RWMutex
|
||
|
}
|
||
|
|
||
|
func (b *simpleBackend) filename(pid int) string {
|
||
|
return path.Join(b.path, strconv.Itoa(pid))
|
||
|
}
|
||
|
|
||
|
// reads all launchers in simpleBackend
|
||
|
// file contents are ignored if decode is false
|
||
|
func (b *simpleBackend) load(decode bool) ([]*State, error) {
|
||
|
b.lock.RLock()
|
||
|
defer b.lock.RUnlock()
|
||
|
|
||
|
var (
|
||
|
r []*State
|
||
|
f *os.File
|
||
|
)
|
||
|
|
||
|
// read directory contents, should only contain files named after PIDs
|
||
|
if pl, err := os.ReadDir(b.path); err != nil {
|
||
|
return nil, err
|
||
|
} else {
|
||
|
for _, e := range pl {
|
||
|
// run in a function to better handle file closing
|
||
|
if err = func() error {
|
||
|
// open state file for reading
|
||
|
if f, err = os.Open(path.Join(b.path, e.Name())); err != nil {
|
||
|
return err
|
||
|
} else {
|
||
|
defer func() {
|
||
|
if f.Close() != nil {
|
||
|
// unreachable
|
||
|
panic("foreign state file closed prematurely")
|
||
|
}
|
||
|
}()
|
||
|
|
||
|
var s State
|
||
|
r = append(r, &s)
|
||
|
|
||
|
// append regardless, but only parse if required, used to implement Len
|
||
|
if decode {
|
||
|
return gob.NewDecoder(f).Decode(&s)
|
||
|
} else {
|
||
|
return nil
|
||
|
}
|
||
|
}
|
||
|
}(); err != nil {
|
||
|
return nil, err
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
return r, nil
|
||
|
}
|
||
|
|
||
|
// Save writes process state to filesystem
|
||
|
func (b *simpleBackend) Save(state *State) error {
|
||
|
b.lock.Lock()
|
||
|
defer b.lock.Unlock()
|
||
|
|
||
|
statePath := b.filename(state.PID)
|
||
|
|
||
|
// create and open state data file
|
||
|
if f, err := os.OpenFile(statePath, os.O_RDWR|os.O_CREATE|os.O_EXCL, 0600); err != nil {
|
||
|
return err
|
||
|
} else {
|
||
|
defer func() {
|
||
|
if f.Close() != nil {
|
||
|
// unreachable
|
||
|
panic("state file closed prematurely")
|
||
|
}
|
||
|
}()
|
||
|
// encode into state file
|
||
|
return gob.NewEncoder(f).Encode(state)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func (b *simpleBackend) Destroy(pid int) error {
|
||
|
b.lock.Lock()
|
||
|
defer b.lock.Unlock()
|
||
|
|
||
|
return os.Remove(b.filename(pid))
|
||
|
}
|
||
|
|
||
|
func (b *simpleBackend) Load() ([]*State, error) {
|
||
|
return b.load(true)
|
||
|
}
|
||
|
|
||
|
func (b *simpleBackend) Len() (int, error) {
|
||
|
// rn consists of only nil entries but has the correct length
|
||
|
rn, err := b.load(false)
|
||
|
return len(rn), err
|
||
|
}
|
||
|
|
||
|
// NewSimple returns an instance of a file-based store.
|
||
|
// Store prefix is typically (runDir, uid).
|
||
|
func NewSimple(prefix ...string) Store {
|
||
|
b := new(simpleStore)
|
||
|
b.path = prefix
|
||
|
return b
|
||
|
}
|