runtime_primitives.go RawHistoryFolder

1package client
2
3import (
4	"crypto/rand"
5	"fmt"
6	"sync"
7
8	"github.com/bnema/vev/internal/ports"
9)
10
11// ProtocolError is a session- or protocol-level failure reported before attach.
12type ProtocolError struct {
13	Code uint16
14	Text string
15}
16
17func (e *ProtocolError) Error() string {
18	if e.Text == "" {
19		return fmt.Sprintf("vev: daemon rejected attach (code %d)", e.Code)
20	}
21	return fmt.Sprintf("vev: %s", e.Text)
22}
23
24func newClientID() [16]byte {
25	var id [16]byte
26	if _, err := rand.Read(id[:]); err != nil {
27		panic("crypto/rand failed generating client ID: " + err.Error())
28	}
29	return id
30}
31
32func requestedOutputWindow(connection ports.ClientConnection) uint8 {
33	if windowed, ok := connection.(interface{ OutputWindow() uint8 }); ok {
34		return windowed.OutputWindow()
35	}
36	return 1
37}
38
39type foregroundSendLease struct {
40	mu     sync.Mutex
41	active bool
42}
43
44func newForegroundSendLease() *foregroundSendLease { return &foregroundSendLease{active: true} }
45
46func (l *foregroundSendLease) send(send func() bool) bool {
47	l.mu.Lock()
48	defer l.mu.Unlock()
49	return l.active && send()
50}
51
52func (l *foregroundSendLease) stop() {
53	l.mu.Lock()
54	l.active = false
55	l.mu.Unlock()
56}
57
58const stdinBufSize = 4096