Home
last modified time | relevance | path

Searched refs:orderedRequest (Results 1 – 19 of 19) sorted by relevance

/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/pkg/sftp/
H A Dpacket-manager.go47 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 Dpacket-manager_test.go50 in orderedRequest
97 in: orderedRequest{p.in, p.in.oid},
H A Drequest-server.go94 runWorker := func(ch chan orderedRequest) {
148 ctx context.Context, pktChan chan orderedRequest,
H A Dserver.go126 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 Dpacket-manager.go57 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 Dpacket-manager_test.go50 in orderedRequest
97 in: orderedRequest{p.in, p.in.oid},
H A Drequest-server.go107 func (rs *RequestServer) serveLoop(pktChan chan<- orderedRequest) error {
148 runWorker := func(ch chan orderedRequest) {
182 ctx context.Context, pktChan chan orderedRequest,
H A Dserver.go137 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 Dpacket-manager.go57 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 Dpacket-manager_test.go50 in orderedRequest
97 in: orderedRequest{p.in, p.in.oid},
H A Drequest-server.go107 func (rs *RequestServer) serveLoop(pktChan chan<- orderedRequest) error {
148 runWorker := func(ch chan orderedRequest) {
182 ctx context.Context, pktChan chan orderedRequest,
H A Dserver.go137 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 Dpacket-manager.go57 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 Drequest-server.go116 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 Dserver.go137 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 Dpacket-manager.go57 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 Dpacket-manager_test.go50 in orderedRequest
97 in: orderedRequest{p.in, p.in.oid},
H A Drequest-server.go108 func (rs *RequestServer) serveLoop(pktChan chan<- orderedRequest) error {
149 runWorker := func(ch chan orderedRequest) {
183 ctx context.Context, pktChan chan orderedRequest,
H A Dserver.go138 func (svr *Server) sftpServerWorker(pktChan chan orderedRequest) error {
167 func handlePacket(s *Server, p orderedRequest) error { argument
325 runWorker := func(ch chan orderedRequest) {