- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 501 for send (0.13 sec)
-
cmd/erasure-server-pool.go
recursive: true, forwardTo: opts.Marker, minDisks: listingQuorum, reportNotFound: false, agreed: send, partial: func(entries metaCacheEntries, _ []error) { entry, ok := entries.resolve(&resolver) if ok { send(*entry) } }, finished: nil, } if err := listPathRaw(ctx, lopts); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
object DisconnectDuringResponseBody : SocketPolicy /** * Process the response without even attempting to reading the request body. For HTTP/2 this will * send [http2ErrorCode] after the response body or trailers. For HTTP/1 this will close the * socket after the response body or trailers. */ class DoNotReadRequestBody( val http2ErrorCode: Int = 0, ) : SocketPolicy
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
import okio.BufferedSource import okio.ForwardingTimeout import okio.Sink import okio.Source import okio.Timeout /** * A socket connection that can be used to send HTTP/1.1 messages. This class strictly enforces the * following lifecycle: * * 1. [Send request headers][writeRequest]. * 2. Open a sink to write the request body. Either [known][newKnownLengthSink] or * [chunked][newChunkedSink].
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
manifests/charts/base/crds/crd-all.gen.yaml
type: string probes: description: Maximum number of keepalive probes to send without response before deciding the connection is dead. maximum: 4294967295 minimum: 0
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K bytes - Viewed (0) -
cmd/admin-handlers-idp-config.go
return } if err = validateConfig(ctx, cfg, subSys); err != nil { var validationErr ldap.Validation if errors.As(err, &validationErr) { // If we got an LDAP validation error, we need to send appropriate // error message back to client (likely mc). writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigLDAPValidation), validationErr.FormatError(), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
import org.codelibs.fess.timer.SystemMonitorTarget; import org.codelibs.fess.util.ComponentUtil; import org.codelibs.fess.util.SystemUtil; import org.codelibs.fess.util.ThreadDumpUtil; import org.dbflute.mail.send.hook.SMailCallbackContext; import org.kohsuke.args4j.CmdLineException; import org.kohsuke.args4j.CmdLineParser; import org.kohsuke.args4j.Option; import org.lastaflute.core.mail.Postbox;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 24.1K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* @param debugData only valid for HTTP/2; opaque debug data to send. */ fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode, debugData: ByteString, ) /** * Notifies that an additional `windowSizeIncrement` bytes can be sent on `streamId`, or the * connection if `streamId` is zero. */ fun windowUpdate(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt
.build(), ) val request = HttpRequest.newBuilder(server.url("/").toUri()) .header("Accept", "text/plain") .build() val response = httpClient.send(request, BodyHandlers.ofString()) assertThat(response.statusCode()).isEqualTo(200) assertThat(response.body()).isEqualTo("hello, Java HTTP Client") val recorded = server.takeRequest()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/cmd/istio-cni/main.go
if err := runPlugin(); err != nil { os.Exit(1) } } func runPlugin() error { if err := log.Configure(plugin.GetLoggingOptions("")); err != nil { return err } defer func() { // Log sync will send logs to install-cni container via UDS. // We don't need a timeout here because underlying the log pkg already handles it. // this may fail, but it should be safe to ignore according
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 13:56:46 GMT 2024 - 1.9K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_cluster_notification_current_send_in_progress` | `counter` | Number of concurrent async Send calls active to all targets | | | `minio_cluster_notification_events_errors_total` | `counter` | Events that were failed to be sent to the targets | |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0)