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/>.
27 "go.cypherpunks.ru/recfile"
28 "golang.org/x/sys/unix"
31 const LogFdPrefix = "FD:"
44 func (les LEs) Rec() string {
45 fields := make([]recfile.Field, 0, len(les)+1)
46 fields = append(fields, recfile.Field{
47 Name: "When", Value: time.Now().UTC().Format(time.RFC3339Nano),
50 for _, le := range les {
51 switch v := le.V.(type) {
52 case int, int8, uint8, int64, uint64:
53 val = fmt.Sprintf("%d", v)
55 val = fmt.Sprintf("%v", v)
57 val = fmt.Sprintf("%s", v)
59 fields = append(fields, recfile.Field{Name: le.K, Value: val})
61 b := bytes.NewBuffer(make([]byte, 0, 1<<10))
62 w := recfile.NewWriter(b)
63 _, err := w.RecordStart()
67 _, err = w.WriteFields(fields...)
74 func (ctx *Ctx) Log(rec string) {
77 LogFd.WriteString(rec)
81 fdLock, err := os.OpenFile(
83 os.O_CREATE|os.O_WRONLY,
87 fmt.Fprintln(os.Stderr, "Can not open lock for log:", err)
91 fdLockFd := int(fdLock.Fd())
92 err = unix.Flock(fdLockFd, unix.LOCK_EX)
94 fmt.Fprintln(os.Stderr, "Can not acquire lock for log:", err)
97 defer unix.Flock(fdLockFd, unix.LOCK_UN)
98 fd, err := os.OpenFile(
100 os.O_CREATE|os.O_WRONLY|os.O_APPEND,
104 fmt.Fprintln(os.Stderr, "Can not open log:", err)
111 func (ctx *Ctx) LogD(who string, les LEs, msg func(LEs) string) {
115 les = append(LEs{{"Debug", true}, {"Who", who}}, les...)
116 les = append(les, LE{"Msg", msg(les)})
117 fmt.Fprint(os.Stderr, les.Rec())
120 func (ctx *Ctx) LogI(who string, les LEs, msg func(LEs) string) {
121 les = append(LEs{{"Who", who}}, les...)
122 les = append(les, LE{"Msg", msg(les)})
125 fmt.Fprintln(os.Stderr, ctx.HumanizeRec(rec))
130 func (ctx *Ctx) LogE(who string, les LEs, err error, msg func(LEs) string) {
131 les = append(LEs{{"Err", err.Error()}, {"Who", who}}, les...)
132 les = append(les, LE{"Msg", msg(les)})
135 fmt.Fprintln(os.Stderr, ctx.HumanizeRec(rec))