crypto/ssh/channel.go

150 type channel struct {  struct
152 	chanType          string
153 	extraData         []byte
154 	localId, remoteId uint32
160 	maxIncomingPayload uint32
161 	maxRemotePayload   uint32
163 	mux *mux
167 	decided bool
171 	direction channelDirection
174 	msg chan interface{}
179 	sentRequestMu sync.Mutex
181 	incomingRequests chan *Request
183 	sentEOF bool
186 	remoteWin  window
187 	pending    *buffer
188 	extPending *buffer
191 	windowMu sync.Mutex
192 	myWindow uint32
198 	writeMu   sync.Mutex
199 	sentClose bool
203 	packetPool map[uint32][]byte
208 func (ch *channel) writePacket(packet []byte) error {
220 func (ch *channel) sendMessage(msg interface{}) error {
232 func (ch *channel) WriteExtended(data []byte, extendedCode uint32) (n int, err error) {
286 func (ch *channel) handleData(packet []byte) error {
335 func (c *channel) adjustWindow(n uint32) error {
346 func (c *channel) ReadExtended(data []byte, extended uint32) (n int, err error) {
370 func (c *channel) close() {
387 func (ch *channel) responseMessageReceived() error {
398 func (ch *channel) handlePacket(packet []byte) error {
491 func (ch *channel) Accept() (Channel, <-chan *Request, error) {
510 func (ch *channel) Reject(reason RejectionReason, message string) error {
524 func (ch *channel) Read(data []byte) (int, error) {
531 func (ch *channel) Write(data []byte) (int, error) {
538 func (ch *channel) CloseWrite() error {
547 func (ch *channel) Close() error {
558 func (ch *channel) Extended(code uint32) io.ReadWriter {
565 func (ch *channel) Stderr() io.ReadWriter {
569 func (ch *channel) SendRequest(name string, wantReply bool, payload []byte) (bool, error) {
609 func (ch *channel) ackRequest(ok bool) error {
627 func (ch *channel) ChannelType() string {
631 func (ch *channel) ExtraData() []byte {