fixes #181 req could make use of Message.Clone()

We've also added an inproc_reqlat mode to perf for testing this
change to measure the impact.

perf/main.go

@@ -21,7 +21,6 @@ import (
 	"fmt"
 	"log"
 	"os"
-	"path"
 	"strconv"
 	"time"
 )
@@ -152,6 +151,25 @@ func doInprocLat(args []string) {
 	os.Exit(0)
 }
 
+func doInprocReqRepLatency(args []string) {
+	if len(args) < 2 {
+		log.Fatalf("Usage: inproc_lat <msg-size> <roundtrip-count>")
+	}
+
+	size, err := strconv.Atoi(args[0])
+	if err != nil {
+		log.Fatalf("Bad msg-size: %v", err)
+	}
+	count, err := strconv.Atoi(args[1])
+	if err != nil {
+		log.Fatalf("Bad roundtrip-count: %v", err)
+	}
+	go ReqRepLatencyServer("inproc://inproc_lat", size, count)
+	time.Sleep(10 * time.Millisecond)
+	ReqRepLatencyClient("inproc://inproc_lat", size, count)
+	os.Exit(0)
+}
+
 func doInprocThr(args []string) {
 	if len(args) < 2 {
 		log.Fatalf("Usage: inproc_thr <msg-size> <msg-count>")
@@ -175,7 +193,7 @@ func main() {
 
 	tries := 0
 	for tries = 0; tries < 2; tries++ {
-		switch path.Base(args[0]) {
+		switch args[0] {
 		case "remote_reqlat":
 			doRemoteReqRepLatency(args[1:])
 
@@ -208,6 +226,9 @@ func main() {
 		case "inproc_lat":
 			doInprocLat(args[1:])
 
+		case "inproc_reqlat":
+			doInprocReqRepLatency(args[1:])
+
 		default:
 			args = args[1:]
 		}

protocol/req/req.go

@@ -86,7 +86,8 @@ func (s *socket) send() {
 			c.sendID = 0
 			c.cond.Broadcast()
 		}
-		m := c.reqMsg.Dup()
+		m := c.reqMsg
+		m.Clone()
 		p := s.readyq[0]
 		s.readyq = s.readyq[1:]