2 NNCP -- Node to Node copy, utilities for store-and-forward data exchange
3 Copyright (C) 2016-2021 Sergey Matveev <stargrave@stargrave.org>
5 This program is free software: you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation, version 3 of the License.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
14 You should have received a copy of the GNU General Public License
15 along with this program. If not, see <http://www.gnu.org/licenses/>.
24 "github.com/gorhill/cronexpr"
28 Cron *cronexpr.Expression
34 OnlineDeadline time.Duration
35 MaxOnlineTime time.Duration
47 func (ctx *Ctx) CallNode(
53 onlineDeadline, maxOnlineTime time.Duration,
56 onlyPkts map[[32]byte]bool,
58 for _, addr := range addrs {
59 les := LEs{{"Node", node.Id}, {"Addr", addr}}
60 ctx.LogD("call", les, "dialing")
61 var conn ConnDeadlined
64 conn, err = NewPipeConn(addr[1:])
66 conn, err = net.Dial("tcp", addr)
69 ctx.LogD("call", append(les, LE{"Err", err}), "dialing")
72 ctx.LogD("call", les, "connected")
77 onlineDeadline: onlineDeadline,
78 maxOnlineTime: maxOnlineTime,
86 if err = state.StartI(conn); err == nil {
87 ctx.LogI("call-start", les, "connected")
89 ctx.LogI("call-finish", LEs{
90 {"Node", state.Node.Id},
91 {"Duration", int64(state.Duration.Seconds())},
92 {"RxBytes", state.RxBytes},
93 {"TxBytes", state.TxBytes},
94 {"RxSpeed", state.RxSpeed},
95 {"TxSpeed", state.TxSpeed},
98 conn.Close() // #nosec G104
101 ctx.LogE("call-start", les, err, "")
102 conn.Close() // #nosec G104