Changeset 154 in code for trunk/server.go

Timestamp:

Mar 25, 2020, 10:17:46 PM (5 years ago)

Author:

delthas

Message:

Add a server-unique id to each downstream

Adding a simple uint64 id to each downstream is preparatory work
for labeled-responses tags targeting a specific downstream.

File:

• trunk/server.go (modified) (2 diffs)

trunk/server.go

@@ -101 +101 @@
 
 func (s *Server) Serve(ln net.Listener) error {
+        var nextDownstreamID uint64 = 1
         for {
                 netConn, err := ln.Accept()
@@ -109 +110 @@
                 setKeepAlive(netConn)
 
-                dc := newDownstreamConn(s, netConn)
+                dc := newDownstreamConn(s, netConn, nextDownstreamID)
+                nextDownstreamID++
                 go func() {
                         s.lock.Lock()