Merge pull request #588 from tamird/perf-less

transport: performance improvements
grpc · Mar 29, 2016 · 877b524 · 877b524
2 parents 3c688e3 + 54ac757
commit 877b524
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/transport/transport.go b/transport/transport.go
@@ -89,12 +89,14 @@ func newRecvBuffer() *recvBuffer {
 func (b *recvBuffer) put(r item) {
 	b.mu.Lock()
 	defer b.mu.Unlock()
-	b.backlog = append(b.backlog, r)
-	select {
-	case b.c <- b.backlog[0]:
-		b.backlog = b.backlog[1:]
-	default:
+	if len(b.backlog) == 0 {
+		select {
+		case b.c <- r:
+			return
+		default:
+		}
 	}
+	b.backlog = append(b.backlog, r)
 }
 
 func (b *recvBuffer) load() {