server

type MServer struct {
	Lock                *sync.Mutex
	MainInput           *packet.PacketParser
	Sender              *packet.PacketSender
	ClientMap           map[base.CommandKey]*shexec.ClientProc
	Debug               bool
	WriteErrorCh        chan bool // closed if there is a I/O write error
	WriteErrorChOnce    *sync.Once
	Done                bool
	InboundRpcHandlers  map[string]RpcHandler
	InboundRpcErrorSent map[string]time.Time // limits the amount of error messages sent back to the client
}

type ReinitRpcHandler struct {
	ReqId       string
	TimeoutTime time.Time
	StdinDataCh chan []byte
}

type RpcHandler interface {
	GetTimeoutTime() time.Time
	DispatchPacket(reqId string, pk packet.RpcFollowUpPacketType)
	UnRegisterCallback()
}

type ShellStateMap struct {
	Lock            *sync.Mutex
	StateMap        map[shellStateMapKey]*packet.ShellState // shelltype+hash -> state
	CurrentStateMap map[string]string                       // shelltype -> hash
}

type WriteFileContext struct {
	CVar       *sync.Cond
	Data       []*packet.FileDataPacketType
	LastActive time.Time
	Err        error
	Done       bool
}