(id proto.NodeID, isAnonymous bool)
| 120 | } |
| 121 | |
| 122 | func newSession(id proto.NodeID, isAnonymous bool) (sess *mux.Session, err error) { |
| 123 | var conn net.Conn |
| 124 | if conn, err = rpc.DialEx(id, isAnonymous); err != nil { |
| 125 | err = errors.Wrap(err, "dialing new session connection failed") |
| 126 | return |
| 127 | } |
| 128 | return mux.Client(conn, mux.DefaultConfig()) |
| 129 | } |
| 130 | |
| 131 | func (s *Session) newSession() (sess *mux.Session, err error) { |
| 132 | return newSession(s.target, false) |
no outgoing calls