Changeset 154 in code


Ignore:
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.

Location:
trunk
Files:
2 edited

Legend:

Unmodified
Added
Removed

  • trunk/downstream.go

    r146 r154  
    5858
    5959type downstreamConn struct {
     60        id           uint64
    6061        net          net.Conn
    6162        irc          *irc.Conn
    … …  
    8687}
    8788
    88 func newDownstreamConn(srv *Server, netConn net.Conn) *downstreamConn {
     89func newDownstreamConn(srv *Server, netConn net.Conn, id uint64) *downstreamConn {
    8990        dc := &downstreamConn{
     91                id:           id,
    9092                net:          netConn,
    9193                irc:          irc.NewConn(netConn),

  • trunk/server.go

    r103 r154  
    101101
    102102func (s *Server) Serve(ln net.Listener) error {
     103        var nextDownstreamID uint64 = 1
    103104        for {
    104105                netConn, err := ln.Accept()
    … …  
    109110                setKeepAlive(netConn)
    110111
    111                 dc := newDownstreamConn(s, netConn)
     112                dc := newDownstreamConn(s, netConn, nextDownstreamID)
     113                nextDownstreamID++
    112114                go func() {
    113115                        s.lock.Lock()
Note: See TracChangeset for help on using the changeset viewer.