mirror of
https://github.com/token2/snapd.git
synced 2026-03-13 11:15:47 -07:00
73 lines
2.0 KiB
Go
73 lines
2.0 KiB
Go
// -*- Mode: Go; indent-tabs-mode: t -*-
|
|
|
|
/*
|
|
* Copyright (C) 2018 Canonical Ltd
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License version 3 as
|
|
* published by the Free Software Foundation.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
package systemd
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"log/syslog"
|
|
"net"
|
|
"os"
|
|
)
|
|
|
|
var journalStdoutPath = "/run/systemd/journal/stdout"
|
|
|
|
// NewJournalStreamFile creates log stream file descriptor to the journal. The
|
|
// semantics is identical to that of sd_journal_stream_fd(3) call.
|
|
func NewJournalStreamFile(identifier string, priority syslog.Priority, levelPrefix bool) (*os.File, error) {
|
|
conn, err := net.DialUnix("unix", nil, &net.UnixAddr{Name: journalStdoutPath})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
// does not affect *os.File created through conn.File() later on
|
|
defer conn.Close()
|
|
|
|
if err := conn.CloseRead(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// header contents taken from the original systemd code:
|
|
// https://github.com/systemd/systemd/blob/97a33b126c845327a3a19d6e66f05684823868fb/src/journal/journal-send.c#L395
|
|
header := bytes.Buffer{}
|
|
header.WriteString(identifier)
|
|
header.WriteByte('\n')
|
|
header.WriteByte('\n')
|
|
header.WriteByte(byte('0') + byte(priority))
|
|
header.WriteByte('\n')
|
|
var prefix int
|
|
if levelPrefix {
|
|
prefix = 1
|
|
}
|
|
header.WriteByte(byte('0') + byte(prefix))
|
|
header.WriteByte('\n')
|
|
header.WriteByte('0')
|
|
header.WriteByte('\n')
|
|
header.WriteByte('0')
|
|
header.WriteByte('\n')
|
|
header.WriteByte('0')
|
|
header.WriteByte('\n')
|
|
|
|
if _, err := conn.Write(header.Bytes()); err != nil {
|
|
return nil, fmt.Errorf("failed to write header: %v", err)
|
|
}
|
|
|
|
return conn.File()
|
|
}
|