/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/pkg/sftp/ |
H A D | packet-manager.go | 47 type orderedRequest struct { struct 52 func (s *packetManager) newOrderedRequest(p requestPacket) orderedRequest { 53 return orderedRequest{requestPacket: p, orderid: s.newOrderId()} 55 func (p orderedRequest) orderId() uint32 { return p.orderid } argument 56 func (p orderedRequest) setOrderId(oid uint32) { p.orderid = oid } argument 84 func (s *packetManager) incomingPacket(pkt orderedRequest) { 105 func (s *packetManager) workerChan(runWorker func(chan orderedRequest), 106 ) chan orderedRequest { 109 rwChan := make(chan orderedRequest, SftpServerWorkerCount) 115 cmdChan := make(chan orderedRequest) [all …]
|
H A D | packet-manager_test.go | 50 in orderedRequest 97 in: orderedRequest{p.in, p.in.oid},
|
H A D | request-server.go | 94 runWorker := func(ch chan orderedRequest) { 148 ctx context.Context, pktChan chan orderedRequest,
|
H A D | server.go | 126 func (svr *Server) sftpServerWorker(pktChan chan orderedRequest) error { 155 func handlePacket(s *Server, p orderedRequest) error { argument 293 runWorker := func(ch chan orderedRequest) {
|
/dports/net/rclone/rclone-1.57.0/vendor/github.com/pkg/sftp/ |
H A D | packet-manager.go | 57 type orderedRequest struct { struct 62 func (s *packetManager) newOrderedRequest(p requestPacket) orderedRequest { 63 return orderedRequest{requestPacket: p, orderid: s.newOrderID()} 65 func (p orderedRequest) orderID() uint32 { return p.orderid } argument 66 func (p orderedRequest) setOrderID(oid uint32) { p.orderid = oid } argument 94 func (s *packetManager) incomingPacket(pkt orderedRequest) { 115 func (s *packetManager) workerChan(runWorker func(chan orderedRequest), 116 ) chan orderedRequest { 118 rwChan := make(chan orderedRequest, SftpServerWorkerCount) 124 cmdChan := make(chan orderedRequest) [all …]
|
H A D | packet-manager_test.go | 50 in orderedRequest 97 in: orderedRequest{p.in, p.in.oid},
|
H A D | request-server.go | 107 func (rs *RequestServer) serveLoop(pktChan chan<- orderedRequest) error { 148 runWorker := func(ch chan orderedRequest) { 182 ctx context.Context, pktChan chan orderedRequest,
|
H A D | server.go | 137 func (svr *Server) sftpServerWorker(pktChan chan orderedRequest) error { 166 func handlePacket(s *Server, p orderedRequest) error { argument 326 runWorker := func(ch chan orderedRequest) {
|
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/pkg/sftp/ |
H A D | packet-manager.go | 57 type orderedRequest struct { struct 62 func (s *packetManager) newOrderedRequest(p requestPacket) orderedRequest { 63 return orderedRequest{requestPacket: p, orderid: s.newOrderID()} 65 func (p orderedRequest) orderID() uint32 { return p.orderid } argument 66 func (p orderedRequest) setOrderID(oid uint32) { p.orderid = oid } argument 94 func (s *packetManager) incomingPacket(pkt orderedRequest) { 115 func (s *packetManager) workerChan(runWorker func(chan orderedRequest), 116 ) chan orderedRequest { 118 rwChan := make(chan orderedRequest, SftpServerWorkerCount) 124 cmdChan := make(chan orderedRequest) [all …]
|
H A D | packet-manager_test.go | 50 in orderedRequest 97 in: orderedRequest{p.in, p.in.oid},
|
H A D | request-server.go | 107 func (rs *RequestServer) serveLoop(pktChan chan<- orderedRequest) error { 148 runWorker := func(ch chan orderedRequest) { 182 ctx context.Context, pktChan chan orderedRequest,
|
H A D | server.go | 137 func (svr *Server) sftpServerWorker(pktChan chan orderedRequest) error { 166 func handlePacket(s *Server, p orderedRequest) error { argument 326 runWorker := func(ch chan orderedRequest) {
|
/dports/ftp/sftpgo/sftpgo-2.2.0/vendor/github.com/pkg/sftp/ |
H A D | packet-manager.go | 57 type orderedRequest struct { struct 62 func (s *packetManager) newOrderedRequest(p requestPacket) orderedRequest { 63 return orderedRequest{requestPacket: p, orderid: s.newOrderID()} 65 func (p orderedRequest) orderID() uint32 { return p.orderid } argument 66 func (p orderedRequest) setOrderID(oid uint32) { p.orderid = oid } argument 94 func (s *packetManager) incomingPacket(pkt orderedRequest) { 115 func (s *packetManager) workerChan(runWorker func(chan orderedRequest), 116 ) chan orderedRequest { 118 rwChan := make(chan orderedRequest, SftpServerWorkerCount) 124 cmdChan := make(chan orderedRequest) [all …]
|
H A D | request-server.go | 116 func (rs *RequestServer) serveLoop(pktChan chan<- orderedRequest) error { 159 runWorker := func(ch chan orderedRequest) { 192 func (rs *RequestServer) packetWorker(ctx context.Context, pktChan chan orderedRequest) error {
|
H A D | server.go | 137 func (svr *Server) sftpServerWorker(pktChan chan orderedRequest) error { 166 func handlePacket(s *Server, p orderedRequest) error { argument 326 runWorker := func(ch chan orderedRequest) {
|
/dports/databases/litestream/litestream-0.3.6/vendor/github.com/pkg/sftp/ |
H A D | packet-manager.go | 57 type orderedRequest struct { struct 62 func (s *packetManager) newOrderedRequest(p requestPacket) orderedRequest { 63 return orderedRequest{requestPacket: p, orderid: s.newOrderID()} 65 func (p orderedRequest) orderID() uint32 { return p.orderid } argument 66 func (p orderedRequest) setOrderID(oid uint32) { p.orderid = oid } argument 94 func (s *packetManager) incomingPacket(pkt orderedRequest) { 115 func (s *packetManager) workerChan(runWorker func(chan orderedRequest), 116 ) chan orderedRequest { 118 rwChan := make(chan orderedRequest, SftpServerWorkerCount) 124 cmdChan := make(chan orderedRequest) [all …]
|
H A D | packet-manager_test.go | 50 in orderedRequest 97 in: orderedRequest{p.in, p.in.oid},
|
H A D | request-server.go | 108 func (rs *RequestServer) serveLoop(pktChan chan<- orderedRequest) error { 149 runWorker := func(ch chan orderedRequest) { 183 ctx context.Context, pktChan chan orderedRequest,
|
H A D | server.go | 138 func (svr *Server) sftpServerWorker(pktChan chan orderedRequest) error { 167 func handlePacket(s *Server, p orderedRequest) error { argument 325 runWorker := func(ch chan orderedRequest) {
|