123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103 |
- //go:build darwin
- package libbox
- import (
- "context"
- "encoding/binary"
- "io"
- "net"
- )
- func (s *CommandServer) WriteMessage(message string) {
- s.subscriber.Emit(message)
- s.access.Lock()
- s.savedLines.PushBack(message)
- if s.savedLines.Len() > 100 {
- s.savedLines.Remove(s.savedLines.Front())
- }
- s.access.Unlock()
- }
- func readLog(reader io.Reader) ([]byte, error) {
- var messageLength uint16
- err := binary.Read(reader, binary.BigEndian, &messageLength)
- if err != nil {
- return nil, err
- }
- data := make([]byte, messageLength)
- _, err = io.ReadFull(reader, data)
- if err != nil {
- return nil, err
- }
- return data, nil
- }
- func writeLog(writer io.Writer, message []byte) error {
- err := binary.Write(writer, binary.BigEndian, uint16(len(message)))
- if err != nil {
- return err
- }
- _, err = writer.Write(message)
- return err
- }
- func (s *CommandServer) handleLogConn(conn net.Conn) error {
- var savedLines []string
- s.access.Lock()
- savedLines = make([]string, 0, s.savedLines.Len())
- for element := s.savedLines.Front(); element != nil; element = element.Next() {
- savedLines = append(savedLines, element.Value)
- }
- s.access.Unlock()
- subscription, done, err := s.observer.Subscribe()
- if err != nil {
- return err
- }
- defer s.observer.UnSubscribe(subscription)
- for _, line := range savedLines {
- err = writeLog(conn, []byte(line))
- if err != nil {
- return err
- }
- }
- ctx := connKeepAlive(conn)
- for {
- select {
- case <-ctx.Done():
- return ctx.Err()
- case message := <-subscription:
- err = writeLog(conn, []byte(message))
- if err != nil {
- return err
- }
- case <-done:
- return nil
- }
- }
- }
- func (c *CommandClient) handleLogConn(conn net.Conn) {
- for {
- message, err := readLog(conn)
- if err != nil {
- c.handler.Disconnected(err.Error())
- return
- }
- c.handler.WriteLog(string(message))
- }
- }
- func connKeepAlive(reader io.Reader) context.Context {
- ctx, cancel := context.WithCancelCause(context.Background())
- go func() {
- for {
- _, err := readLog(reader)
- if err != nil {
- cancel(err)
- return
- }
- }
- }()
- return ctx
- }
|