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/>.
26 "go.cypherpunks.ru/recfile"
27 "golang.org/x/sys/unix"
36 func (les LEs) Rec() string {
37 fields := make([]recfile.Field, 0, len(les)+1)
38 fields = append(fields, recfile.Field{
39 Name: "When", Value: time.Now().UTC().Format(time.RFC3339Nano),
42 for _, le := range les {
43 switch v := le.V.(type) {
44 case int, int8, uint8, int64, uint64:
45 val = fmt.Sprintf("%d", v)
47 val = fmt.Sprintf("%v", v)
49 val = fmt.Sprintf("%s", v)
51 fields = append(fields, recfile.Field{Name: le.K, Value: val})
53 b := bytes.NewBuffer(make([]byte, 0, 1<<10))
54 w := recfile.NewWriter(b)
55 _, err := w.RecordStart()
59 _, err = w.WriteFields(fields...)
66 func (ctx *Ctx) Log(rec string) {
67 fdLock, err := os.OpenFile(
69 os.O_CREATE|os.O_WRONLY,
73 fmt.Fprintln(os.Stderr, "Can not open lock for log:", err)
77 fdLockFd := int(fdLock.Fd())
78 err = unix.Flock(fdLockFd, unix.LOCK_EX)
80 fmt.Fprintln(os.Stderr, "Can not acquire lock for log:", err)
83 defer unix.Flock(fdLockFd, unix.LOCK_UN)
84 fd, err := os.OpenFile(
86 os.O_CREATE|os.O_WRONLY|os.O_APPEND,
90 fmt.Fprintln(os.Stderr, "Can not open log:", err)
93 fd.WriteString(rec) // #nosec G104
94 fd.Close() // #nosec G104
97 func (ctx *Ctx) LogD(who string, les LEs, msg func(LEs) string) {
101 les = append(LEs{{"Debug", true}, {"Who", who}}, les...)
102 les = append(les, LE{"Msg", msg(les)})
103 fmt.Fprint(os.Stderr, les.Rec())
106 func (ctx *Ctx) LogI(who string, les LEs, msg func(LEs) string) {
107 les = append(LEs{{"Who", who}}, les...)
108 les = append(les, LE{"Msg", msg(les)})
111 fmt.Fprintln(os.Stderr, ctx.HumanizeRec(rec))
116 func (ctx *Ctx) LogE(who string, les LEs, err error, msg func(LEs) string) {
117 les = append(LEs{{"Err", err.Error()}, {"Who", who}}, les...)
118 les = append(les, LE{"Msg", msg(les)})
121 fmt.Fprintln(os.Stderr, ctx.HumanizeRec(rec))