Searched refs:requestSender (Results 1 – 9 of 9) sorted by relevance
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/collector/exporter/exporterhelper/ |
| H A D | common.go | 60 type requestSender interface { interface
170 sender requestSender
191 func (be *baseExporter) wrapConsumerSender(f func(consumer requestSender) requestSender) {
|
| H A D | logs.go | 85 be.wrapConsumerSender(func(nextSender requestSender) requestSender {
109 nextSender requestSender
|
| H A D | traces.go | 86 be.wrapConsumerSender(func(nextSender requestSender) requestSender {
110 nextSender requestSender
|
| H A D | metrics.go | 85 be.wrapConsumerSender(func(nextSender requestSender) requestSender {
112 nextSender requestSender
|
| H A D | queued_retry.go | 104 consumerSender requestSender
130 …r(fullName string, qCfg QueueSettings, rCfg RetrySettings, nextSender requestSender, logger *zap.L… argument
244 nextSender requestSender
|
| H A D | queued_retry_test.go | 438 nextSender requestSender
441 func newObservabilityConsumerSender(nextSender requestSender) *observabilityConsumerSender { argument
|
| /dports/www/squid/squid-4.15/src/clients/ |
| H A D | Client.cc | 44 requestSender(NULL), in Client()
314 if (!requestSender) in handleMoreRequestBodyAvailable()
325 if (!requestSender) in handleRequestBodyProductionEnded()
346 if (requestSender != NULL) in handleRequestBodyProducerAborted()
362 requestSender = NULL; in sentRequestBody()
408 assert(!requestSender); in sendMoreRequestBody()
421 requestSender = JobCallback(93,3, Dialer, this, Client::sentRequestBody); in sendMoreRequestBody()
422 Comm::Write(conn, &buf, requestSender); in sendMoreRequestBody()
425 requestSender = NULL; in sendMoreRequestBody()
|
| H A D | Client.h | 172 … AsyncCall::Pointer requestSender; /**< set if we are expecting Comm::Write to call us back */ variable
|
| /dports/www/squid/squid-4.15/src/ |
| H A D | http.cc | 2205 requestSender = JobCallback(11,5, in sendRequest()
2215 requestSender = JobCallback(11,5, in sendRequest()
2264 Comm::Write(serverConnection, &mb, requestSender); in sendRequest()
2354 requestSender = JobCallback(11,5, in finishingBrokenPost()
2356 Comm::Write(serverConnection, "\r\n", 2, requestSender, NULL); in finishingBrokenPost()
2376 requestSender = JobCallback(11,5, Dialer, this, HttpStateData::wroteLast); in finishingChunkedRequest()
2377 Comm::Write(serverConnection, "0\r\n\r\n", 5, requestSender, NULL); in finishingChunkedRequest()
|