- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 495 for sunt (0.02 seconds)
-
internal/event/target/nsq.go
if err != nil { return err } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { return err }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
guava/src/com/google/common/base/Throwables.java
/** * Returns the JavaLangAccess class that is present in all Sun JDKs. It is not allowed in * AppEngine, and not present in non-Sun JDKs. */ @SuppressWarnings("removal") // b/318391980 @J2ktIncompatible @GwtIncompatible // java.lang.reflect private static @Nullable Object getJla() { try { /* * We load sun.misc.* classes using reflection since Android doesn't support these classes andCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 20.6K bytes - Click Count (0) -
cmd/metrics-v3-system-network.go
internodeDialAvgTimeNanosMD = NewGaugeMD(internodeDialAvgTimeNanos, "Average dial time of internode TCP calls in nanoseconds") internodeSentBytesTotalMD = NewCounterMD(internodeSentBytesTotal, "Total number of bytes sent to other peer nodes") internodeRecvBytesTotalMD = NewCounterMD(internodeRecvBytesTotal, "Total number of bytes received from other peer nodes") ) // loadNetworkInternodeMetrics - reads internode network metrics. //
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 2.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* * <p>Since the last element of the array is actually in the middle of the sorted structure, a * childless aunt node could be smaller, which would corrupt the invariant if this element * becomes the new parent of the aunt node. In that case, we first switch the last element with * its aunt node, before returning. */ int swapWithConceptuallyLastElement(E actualLastElement) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
docs/fr/docs/advanced/security/index.md
Il existe des fonctionnalités supplémentaires pour gérer la sécurité en plus de celles couvertes dans le [Tutoriel - Guide utilisateur : Sécurité](../../tutorial/security/index.md). /// tip | Astuce Les sections suivantes **ne sont pas nécessairement « advanced »**. Et il est possible que, pour votre cas d’utilisation, la solution se trouve dans l’une d’entre elles. /// ## Lire d’abord le tutoriel { #read-the-tutorial-first }
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:37:13 GMT 2026 - 829 bytes - Click Count (0) -
docs/extensions/fan-out/README.md
method of facilitating time-shifted playback of television signaling, and media content. MinIO implements an S3 extension to the [PostUpload](https://docs.aws.amazon.com/AmazonS3/latest/API/RESTObjectPOST.html) where in a special fan-out list is sent along with the TSB's for MinIO make multiple uploads from a single source stream. Optionally supports custom metadata, tags and other retention settings. All objects are also readable independently once upload is completed via the regular S3 [GetO...
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu May 25 05:51:07 GMT 2023 - 1.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* * <p>Since the last element of the array is actually in the middle of the sorted structure, a * childless aunt node could be smaller, which would corrupt the invariant if this element * becomes the new parent of the aunt node. In that case, we first switch the last element with * its aunt node, before returning. */ int swapWithConceptuallyLastElement(E actualLastElement) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
// Masked payloads must be read on the server. Unmasked payloads must be read on the client. throw ProtocolException( if (isClient) { "Server-sent frames must not be masked." } else { "Client-sent frames must be masked." }, ) } // Get frame length, optionally reading from follow-up bytes if indicated by special values.Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10K bytes - Click Count (0) -
internal/event/target/mqtt.go
if err != nil { return err } eventData, err := target.store.Get(key) if err != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil } return err } if err = target.send(eventData); err != nil { return err }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/trans/SmbComTransaction.java
/** Number of parameter bytes being sent in this request */ protected int parameterCount; /** Offset from the start of the SMB header to the parameter bytes */ protected int parameterOffset; /** Displacement of these parameter bytes from the start of the total parameter block */ protected int parameterDisplacement; /** Number of data bytes being sent in this request */ protected int dataCount;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 17.3K bytes - Click Count (0)