Merge pull request apache#20 from wangtuanjie/wtj

Wtj

Author: wangtuanjie

go/src/pili.qiniu.com/api/flume.v1/client.go

@@ -70,22 +70,24 @@ type Client struct {
 var ErrNoInstance = errors.New("no instance")
 
 func (p Client) Call(xl *xlog.Logger, urlPath string, events []Event) (err error) {
+
 	if len(events) == 0 {
 		return
 	} else if len(events) > MaxBatchSize {
 		return ErrTooManyEvents
 	}
-	pr, pw := io.Pipe()
-	go func() {
-		err := json.NewEncoder(pw).Encode(events)
-		pw.CloseWithError(err)
-	}()
 
 	hidx, obj := p.hosts.Select(xl)
 	if obj == nil {
 		return ErrNoInstance
 	}
 
+	pr, pw := io.Pipe()
+	go func() {
+		err := json.NewEncoder(pw).Encode(events)
+		pw.CloseWithError(err)
+	}()
+
 	defer func() {
 		if err != nil {
 			p.hosts.OnFailure(hidx)

go/src/pili.qiniu.com/app/pili-dsync/main.go

@@ -2,14 +2,28 @@ package main
 
 import (
 	"flag"
+	"net/http"
+	_ "net/http/pprof"
 	"runtime"
 
+	"github.com/qiniu/log.v1"
 	"pili.qiniu.com/dsync.v1"
 )
 
 func main() {
 
-	runtime.GOMAXPROCS(2)
 	c := flag.String("f", "pili-dsync.conf", "<config file>")
+	pprof := flag.String("pprof", "", "<pprof addr>")
+
+	flag.Parse()
+
+	if *pprof != "" {
+		log.Info("pprof running at:", *pprof)
+		go func() {
+			log.Println(http.ListenAndServe(*pprof, nil))
+		}()
+	}
+
+	runtime.GOMAXPROCS(2)
 	dsync.Main(*c)
 }