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"
30 const LogFdPrefix = "FD:"
40 func (les LEs) Rec() string {
41 fields := make([]recfile.Field, 0, len(les)+1)
42 fields = append(fields, recfile.Field{
43 Name: "When", Value: time.Now().UTC().Format(time.RFC3339Nano),
46 for _, le := range les {
47 switch v := le.V.(type) {
48 case int, int8, uint8, int64, uint64:
49 val = fmt.Sprintf("%d", v)
51 val = fmt.Sprintf("%v", v)
53 val = fmt.Sprintf("%s", v)
55 fields = append(fields, recfile.Field{Name: le.K, Value: val})
57 b := bytes.NewBuffer(make([]byte, 0, 1<<10))
58 w := recfile.NewWriter(b)
59 _, err := w.RecordStart()
63 _, err = w.WriteFields(fields...)
70 func (ctx *Ctx) Log(rec string) {
72 LogFd.WriteString(rec)
75 fdLock, err := os.OpenFile(
77 os.O_CREATE|os.O_WRONLY,
81 fmt.Fprintln(os.Stderr, "Can not open lock for log:", err)
85 fdLockFd := int(fdLock.Fd())
86 err = unix.Flock(fdLockFd, unix.LOCK_EX)
88 fmt.Fprintln(os.Stderr, "Can not acquire lock for log:", err)
91 defer unix.Flock(fdLockFd, unix.LOCK_UN)
92 fd, err := os.OpenFile(
94 os.O_CREATE|os.O_WRONLY|os.O_APPEND,
98 fmt.Fprintln(os.Stderr, "Can not open log:", err)
105 func (ctx *Ctx) LogD(who string, les LEs, msg func(LEs) string) {
109 les = append(LEs{{"Debug", true}, {"Who", who}}, les...)
110 les = append(les, LE{"Msg", msg(les)})
111 fmt.Fprint(os.Stderr, les.Rec())
114 func (ctx *Ctx) LogI(who string, les LEs, msg func(LEs) string) {
115 les = append(LEs{{"Who", who}}, les...)
116 les = append(les, LE{"Msg", msg(les)})
119 fmt.Fprintln(os.Stderr, ctx.HumanizeRec(rec))
124 func (ctx *Ctx) LogE(who string, les LEs, err error, msg func(LEs) string) {
125 les = append(LEs{{"Err", err.Error()}, {"Who", who}}, les...)
126 les = append(les, LE{"Msg", msg(les)})
129 fmt.Fprintln(os.Stderr, ctx.HumanizeRec(rec))