Home
last modified time | relevance | path

Searched defs:recvBufferReader (Results 1 – 25 of 169) sorted by relevance

1234567

/dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/tsearch/
H A Ddict_ispell.c142 cptr++;
143 }
144 }
145 cptr->lexeme = NULL;
147 PG_RETURN_POINTER(res);
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/go-gcp-common/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/grpc/grpc-go-1.21.1/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/misc/perkeep/perkeep-0.11/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/net/bosh-cli/bosh-cli-5.5.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/Microsoft/hcsshim/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/sysutils/terraform-provider-vultr/terraform-provider-vultr-0.1.10/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/net/grpcox/grpcox-1.0.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go115 type recvBufferReader struct { struct
116 …am func(error) // Closes the client transport stream with the given error and nil trailer metadata.
117 ctx context.Context
118 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
119 recv *recvBuffer
120 last []byte // Stores the remaining data in the previous calls.
121 err error
127 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
145 func (r *recvBufferReader) read(p []byte) (n int, err error) {
154 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go138 type recvBufferReader struct { struct
140 ctx context.Context
141 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
142 recv *recvBuffer
143 last *bytes.Buffer // Stores the remaining data in the previous calls.
144 err error
145 freeBuffer func(*bytes.Buffer)
151 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
172 func (r *recvBufferReader) read(p []byte) (n int, err error) {
181 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go140 type recvBufferReader struct { struct
142 ctx context.Context
143 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
144 recv *recvBuffer
145 last *bytes.Buffer // Stores the remaining data in the previous calls.
146 err error
147 freeBuffer func(*bytes.Buffer)
153 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
174 func (r *recvBufferReader) read(p []byte) (n int, err error) {
183 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go139 type recvBufferReader struct { struct
141 ctx context.Context
142 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
143 recv *recvBuffer
144 last *bytes.Buffer // Stores the remaining data in the previous calls.
145 err error
146 freeBuffer func(*bytes.Buffer)
152 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
173 func (r *recvBufferReader) read(p []byte) (n int, err error) {
182 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go142 type recvBufferReader struct { struct
144 ctx context.Context
145 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
146 recv *recvBuffer
147 last *bytes.Buffer // Stores the remaining data in the previous calls.
148 err error
149 freeBuffer func(*bytes.Buffer)
155 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
176 func (r *recvBufferReader) read(p []byte) (n int, err error) {
185 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/security/vault/vault-1.8.2/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go139 type recvBufferReader struct { struct
141 ctx context.Context
142 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
143 recv *recvBuffer
144 last *bytes.Buffer // Stores the remaining data in the previous calls.
145 err error
146 freeBuffer func(*bytes.Buffer)
152 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
173 func (r *recvBufferReader) read(p []byte) (n int, err error) {
182 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go138 type recvBufferReader struct { struct
140 ctx context.Context
141 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
142 recv *recvBuffer
143 last *bytes.Buffer // Stores the remaining data in the previous calls.
144 err error
145 freeBuffer func(*bytes.Buffer)
151 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
172 func (r *recvBufferReader) read(p []byte) (n int, err error) {
181 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/net/evans/evans-0.9.1/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go142 type recvBufferReader struct { struct
144 ctx context.Context
145 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
146 recv *recvBuffer
147 last *bytes.Buffer // Stores the remaining data in the previous calls.
148 err error
149 freeBuffer func(*bytes.Buffer)
155 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
176 func (r *recvBufferReader) read(p []byte) (n int, err error) {
185 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go142 type recvBufferReader struct { struct
144 ctx context.Context
145 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
146 recv *recvBuffer
147 last *bytes.Buffer // Stores the remaining data in the previous calls.
148 err error
149 freeBuffer func(*bytes.Buffer)
155 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
176 func (r *recvBufferReader) read(p []byte) (n int, err error) {
185 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go139 type recvBufferReader struct { struct
141 ctx context.Context
142 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
143 recv *recvBuffer
144 last *bytes.Buffer // Stores the remaining data in the previous calls.
145 err error
146 freeBuffer func(*bytes.Buffer)
152 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
173 func (r *recvBufferReader) read(p []byte) (n int, err error) {
182 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go142 type recvBufferReader struct { struct
144 ctx context.Context
145 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
146 recv *recvBuffer
147 last *bytes.Buffer // Stores the remaining data in the previous calls.
148 err error
149 freeBuffer func(*bytes.Buffer)
155 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
176 func (r *recvBufferReader) read(p []byte) (n int, err error) {
185 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/cli/cli-20.10.2/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go139 type recvBufferReader struct { struct
141 ctx context.Context
142 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
143 recv *recvBuffer
144 last *bytes.Buffer // Stores the remaining data in the previous calls.
145 err error
146 freeBuffer func(*bytes.Buffer)
152 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
173 func (r *recvBufferReader) read(p []byte) (n int, err error) {
182 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go142 type recvBufferReader struct { struct
144 ctx context.Context
145 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
146 recv *recvBuffer
147 last *bytes.Buffer // Stores the remaining data in the previous calls.
148 err error
149 freeBuffer func(*bytes.Buffer)
155 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
176 func (r *recvBufferReader) read(p []byte) (n int, err error) {
185 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go138 type recvBufferReader struct { struct
140 ctx context.Context
141 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
142 recv *recvBuffer
143 last *bytes.Buffer // Stores the remaining data in the previous calls.
144 err error
145 freeBuffer func(*bytes.Buffer)
151 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
172 func (r *recvBufferReader) read(p []byte) (n int, err error) {
181 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/internal/transport/
H A Dtransport.go142 type recvBufferReader struct { struct
144 ctx context.Context
145 ctxDone <-chan struct{} // cache of ctx.Done() (for performance).
146 recv *recvBuffer
147 last *bytes.Buffer // Stores the remaining data in the previous calls.
148 err error
149 freeBuffer func(*bytes.Buffer)
155 func (r *recvBufferReader) Read(p []byte) (n int, err error) {
176 func (r *recvBufferReader) read(p []byte) (n int, err error) {
185 func (r *recvBufferReader) readClient(p []byte) (n int, err error) {
[all …]

1234567