jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(backend-sink): check if dir exists

Browse source
This commit is contained in:
ShiKhu 2021-12-14 21:07:04 +01:00
parent d206d96b8a
commit 44ad157960
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
backend/services/sink/main.go
View file

@ -20,8 +20,13 @@ import (
func main() {
log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
writer := NewWriter(env.Uint16("FS_ULIMIT"), env.String("FS_DIR"))
FS_DIR := env.String("FS_DIR");
if _, err := os.Stat(FS_DIR); os.IsNotExist(err) {
log.Fatalf("%v doesn't exist. %v", FS_DIR, err)
}
writer := NewWriter(env.Uint16("FS_ULIMIT"), FS_DIR)
count := 0
consumer := queue.NewMessageConsumer(