pserver.go 1.3 KB
Newer Older
1 2 3 4 5 6 7
package main

import (
	"net"
	"net/http"
	"net/rpc"
	"strconv"
W
wuyi05 已提交
8
	"time"
9

H
Helin Wang 已提交
10 11
	"github.com/namsral/flag"

12
	"github.com/PaddlePaddle/Paddle/go/pserver"
W
wuyi05 已提交
13
	log "github.com/sirupsen/logrus"
14 15 16
)

func main() {
H
Helin Wang 已提交
17
	port := flag.Int("port", 0, "port of the pserver")
W
wuyi05 已提交
18 19 20
	etcdEndpoint := flag.String("etcd-endpoint", "http://127.0.0.1:2379",
		"comma separated endpoint string for pserver to connect to etcd")
	etcdTimeout := flag.Int("etcd-timeout", 5, "timeout for etcd calls")
Y
yi.wu 已提交
21
	numPservers := flag.Int("num-pservers", 1, "total pserver count in a training job")
W
wuyi05 已提交
22 23
	logLevel := flag.String("log-level", "info",
		"log level, possible values: debug, info, warning, error, fatal, panic")
24 25
	flag.Parse()

W
wuyi05 已提交
26 27 28 29 30 31 32
	level, err := log.ParseLevel(*logLevel)
	if err != nil {
		panic(err)
	}
	log.SetLevel(level)

	timeout := time.Second * time.Duration((*etcdTimeout))
33 34 35 36 37 38 39
	e := pserver.NewEtcdClient(*etcdEndpoint, *numPservers, timeout)
	idx, err := e.Register()
	if err != nil {
		panic(err)
	}

	s, err := pserver.NewService(idx)
W
wuyi05 已提交
40 41 42 43
	if err != nil {
		panic(err)
	}
	err = rpc.Register(s)
44 45 46 47 48 49 50 51 52 53
	if err != nil {
		panic(err)
	}

	rpc.HandleHTTP()
	l, err := net.Listen("tcp", ":"+strconv.Itoa(*port))
	if err != nil {
		panic(err)
	}

W
wuyi05 已提交
54
	log.Infof("start pserver at port %d", *port)
55
	err = http.Serve(l, nil)
W
wuyi05 已提交
56

57 58 59 60
	if err != nil {
		panic(err)
	}
}