mirror of
https://github.com/Kong/go-pluginserver.git
synced 2025-10-15 12:42:22 +08:00
refactor(main) flag parsing and validation in init
This commit is contained in:
42
main.go
42
main.go
@@ -14,6 +14,15 @@ import (
|
|||||||
|
|
||||||
var socket = flag.String("socket", "", "Socket to listen into")
|
var socket = flag.String("socket", "", "Socket to listen into")
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
flag.Parse()
|
||||||
|
|
||||||
|
if *socket == "" {
|
||||||
|
flag.Usage()
|
||||||
|
os.Exit(2)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func runServer(listener net.Listener) {
|
func runServer(listener net.Listener) {
|
||||||
var handle codec.MsgpackHandle
|
var handle codec.MsgpackHandle
|
||||||
handle.ReaderBufferSize = 4096
|
handle.ReaderBufferSize = 4096
|
||||||
@@ -37,24 +46,19 @@ func runServer(listener net.Listener) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
flag.Parse()
|
err := os.Remove(*socket)
|
||||||
|
if err != nil && !os.IsNotExist(err) {
|
||||||
if *socket != "" {
|
log.Printf(`removing "%s": %s`, socket, err)
|
||||||
|
return
|
||||||
err := os.Remove(*socket)
|
|
||||||
if err != nil && !os.IsNotExist(err) {
|
|
||||||
log.Printf(`removing "%s": %s`, socket, err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
listener, err := net.Listen("unix", *socket)
|
|
||||||
if err != nil {
|
|
||||||
log.Printf(`listen("%s"): %s`, socket, err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
rpc.RegisterName("plugin", newServer())
|
|
||||||
|
|
||||||
runServer(listener)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
listener, err := net.Listen("unix", *socket)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf(`listen("%s"): %s`, socket, err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
rpc.RegisterName("plugin", newServer())
|
||||||
|
|
||||||
|
runServer(listener)
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user