example.go

package main

import (
	"log"
	"time"

	"github.com/poolpOrg/ipcmsg"
	"github.com/poolpOrg/privsep"
)

func parent_main() {
	log.Println("parent process started")
	sleep_forever := make(chan bool)
	<-sleep_forever
}

func foobar_main() {
	log.Println("foobar process started")

	barbaz := privsep.GetPeer("barbaz")
	for {
		barbaz.Write(ipcmsg.Message(0, []byte("abcdef")))
		time.Sleep(1 * time.Second)
	}
}

func barbaz_main() {
	log.Println("barbaz process started")

	foobar := privsep.GetPeer("foobar")
	for {
		foobar.Write(ipcmsg.Message(0, []byte("ghijkl")))
		time.Sleep(1 * time.Second)
	}
}

func foobar_dispatcher(r chan ipcmsg.IPCMessage, w chan ipcmsg.IPCMessage) {
	log.Println("foobar dispatcher started")
	for msg := range r {
		log.Printf("[foobar] data: %s\n", string(msg.Data))
	}
}

func barbaz_dispatcher(r chan ipcmsg.IPCMessage, w chan ipcmsg.IPCMessage) {
	log.Println("barbaz dispatcher started")
	for msg := range r {
		log.Printf("[barbaz] data: %s\n", string(msg.Data))
	}
}

func main() {
	privsep.Init()

	privsep.Parent(parent_main)

	foobar := privsep.Child("foobar", foobar_main)
	barbaz := privsep.Child("barbaz", barbaz_main)

	foobar.Channel(barbaz, foobar_dispatcher)
	barbaz.Channel(foobar, barbaz_dispatcher)

	privsep.Start()
}