dht_net: more consistent event logging for dhtSendMessage; measure la…

…tency
libp2p · Sep 17, 2017 · 1f9fe55 · 1f9fe55
1 parent a4ee75c
commit 1f9fe55
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/dht_net.go b/dht_net.go
@@ -175,6 +175,7 @@ func (ms *messageSender) prep() error {
 const streamReuseTries = 3
 
 func (ms *messageSender) SendMessage(ctx context.Context, pmes *pb.Message) error {
+	defer log.EventBegin(ctx, "dhtSendMessage", ms.dht.self, ms.p, pmes).Done()
 	ms.lk.Lock()
 	defer ms.lk.Unlock()
 	retry := false
@@ -201,8 +202,6 @@ func (ms *messageSender) SendMessage(ctx context.Context, pmes *pb.Message) erro
 			}
 		}
 
-		log.Event(ctx, "dhtSentMessage", ms.dht.self, ms.p, pmes)
-
 		if retry {
 			ms.singleMes++
 			if ms.singleMes > streamReuseTries {
@@ -244,8 +243,6 @@ func (ms *messageSender) SendRequest(ctx context.Context, pmes *pb.Message) (*pb
 			}
 		}
 
-		log.Event(ctx, "dhtSentMessage", ms.dht.self, ms.p, pmes)
-
 		resch := make(chan requestResult, 1)
 		select {
 		case ms.rch <- resch: