Changeset 73 in code for trunk/server.go
- Timestamp:
- Mar 4, 2020, 2:44:13 PM (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/server.go
r71 r73 83 83 } 84 84 85 func (u *user) getChannel(name string ) (*upstreamChannel, error) {85 func (u *user) getChannel(name string, upstream *Upstream) (*upstreamChannel, error) { 86 86 var channel *upstreamChannel 87 87 var err error 88 88 u.forEachUpstream(func(uc *upstreamConn) { 89 89 if err != nil { 90 return 91 } 92 if upstream != nil && uc.upstream != upstream { 90 93 return 91 94 } … … 197 200 } 198 201 202 func (s *Server) getUpstream(name string) *Upstream { 203 for i, upstream := range s.Upstreams { 204 if upstream.Addr == name { 205 return &s.Upstreams[i] 206 } 207 } 208 return nil 209 } 210 199 211 func (s *Server) Serve(ln net.Listener) error { 200 212 for {
Note:
See TracChangeset
for help on using the changeset viewer.