FilesExpand file tree

master

/

getfiled.go

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

75 lines (67 loc) · 1.62 KB

master

/

getfiled.go

Copy path

Top

File metadata and controls

• Code
• Blame

75 lines (67 loc) · 1.62 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

package main

import (

"flag"

"fmt"

"log"

"os"

"os/exec"

"os/signal"

"strings"

"syscall"

)

func main() {

boot()

wait()

}

func boot() {

flag.Parse()

parts := flag.Args()

if len(parts) != 2 {

log.Fatalf("Syntax: getfiled file generator\n")

}

startGenerating(parts[0], parts[1])

}

func wait() {

sigs := make(chan os.Signal, 0)

signal.Notify(sigs, os.Interrupt, os.Kill)

sig := <-sigs

log.Println("Got signal", sig, ", quitting.")

}

func startGenerating(fname, cmdString string) {

parts := strings.Fields(cmdString)

go genFile(fname, parts)

}

func genFile(fname string, parts []string) {

num := 0

log.Printf("Creating `%s` to provide `%s`\n", parts, fname)

createFifo := func() {

fi, statErr := os.Stat(fname)

if statErr == nil && (fi.Mode()|os.ModeNamedPipe == 0) {

log.Fatalf("%s exists and is not a FIFO, quitting for safety\n", fname)

}

tmp := fmt.Sprintf("%s%d", fname, num)

num += 1

if creErr := syscall.Mknod(tmp, syscall.S_IFIFO|0666, 0); creErr != nil {

log.Fatalf("Failed to create fifo %s: %s", tmp, creErr.Error())

}

os.Rename(tmp, fname)

}

createFifo()

for {

writeFile, openErr := os.OpenFile(fname, os.O_WRONLY, os.ModeNamedPipe|os.ModePerm|os.ModeExclusive)

createFifo()

if openErr != nil {

log.Fatalf("Failed to feed %s: %s", fname, openErr.Error())

}

cmd := exec.Command(parts[0], parts[1:]...)

cmd.Stderr = os.Stderr

cmd.Stdout = writeFile

go func() {

if execErr := cmd.Run(); execErr != nil {

log.Printf("Failed to run %s because %s\n", parts, execErr.Error())

}

writeFile.Close()

log.Printf("Executed `%s` to provide `%s`", parts, fname)

}()

}

}