- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 561 for sesd (0.03 sec)
-
internal/event/targetlist.go
CurrentSendCalls int64 // CurrentSendCalls is the number of concurrent async Send calls to all targets CurrentQueue int // Populated if target has a store. TotalEvents int64 FailedEvents int64 // Number of failed events per target } // TargetList - holds list of targets indexed by target ID. type TargetList struct { // The number of concurrent async Send calls to all targets currentSendCalls atomic.Int64
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnection.java
<T extends CommonServerMessageBlockResponse> T send ( SmbResourceLocatorImpl loc, CommonServerMessageBlockRequest request, T response, RequestParam... params ) throws CIFSException { return send(loc, request, response, params.length == 0 ? EnumSet.noneOf(RequestParam.class) : EnumSet.copyOf(Arrays.asList(params))); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Tue Jul 07 10:50:16 UTC 2020 - 31K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
/** * Apply inbound settings and send an acknowledgement to the peer that provided them. * * We need to apply the settings and ack them atomically. This is because some HTTP/2 * implementations (nghttp2) forbid peers from taking advantage of settings before they have * acknowledged! In particular, we shouldn't send frames that assume a new `initialWindowSize` * until we send the frame that acknowledges this new size.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
docs/en/docs/tutorial/header-param-models.md
/// ```Python hl_lines="10" {!> ../../docs_src/header_param_models/tutorial002.py!} ``` //// If a client tries to send some **extra headers**, they will receive an **error** response. For example, if the client tries to send a `tool` header with a value of `plumbus`, they will receive an **error** response telling them that the header parameter `tool` is not allowed: ```json {
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 3.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/Murmur3Hash32Test.java
} public void testParanoidHashBytes() { HashFn hf = new HashFn() { @Override public byte[] hash(byte[] input, int seed) { return murmur3_32(seed).hashBytes(input).asBytes(); } }; // Murmur3A, MurmurHash3 for x86, 32-bit (MurmurHash3_x86_32) // https://github.com/aappleby/smhasher/blob/master/src/main.cpp
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:29:46 UTC 2024 - 8.3K bytes - Viewed (0) -
cmd/global-heal.go
bucket, version.Name, err)) } } if !send(result) { return } } // All versions resulted in 'ObjectNotFound/VersionNotFound' if versionNotFound == len(fivs.Versions) { return } send(healEntryDone(entry.name)) // Wait and proceed if there are active requests waitForLowHTTPReq() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/metacache-walk.go
} if err := send(meta); err != nil { return err } case osIsNotExist(err), isSysErrIsDir(err): if legacy { meta.metadata, err = xioutil.ReadFile(pathJoinBuf(sb, volumeDir, meta.name, xlStorageFormatFileV1)) diskHealthCheckOK(ctx, err) if err == nil { // It was an object if err := send(meta); err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
src/main/resources/fess_env.properties
# ---------------------------------------------------------- # Mail # ------ # Does it send mock mail? (true: no send actually, logging only) mail.send.mock = true # SMTP server settings for main: host:port mail.smtp.server.main.host.and.port = localhost:25 # The prefix of subject to show test environment or not
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Aug 07 04:53:24 UTC 2021 - 2.2K bytes - Viewed (0) -
docs/en/docs/reference/websockets.md
# WebSockets When defining WebSockets, you normally declare a parameter of type `WebSocket` and with it you can read data from the client and send data to it. It is provided directly by Starlette, but you can import it from `fastapi`: ```python from fastapi import WebSocket ``` /// tip
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/store/store.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0)