- Sort Score
- Result 10 results
- Languages All
Results 531 - 540 of 4,311 for chat (0.12 sec)
-
cmd/listen-notification-handlers.go
// Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (0) -
internal/event/target/kafka.go
// it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. //
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
android/guava/src/com/google/common/reflect/TypeResolver.java
* TypeVariable must have a different declaration or name. The only TypeVariable that our * new TypeVariable _will_ be equal to is an equivalent TypeVariable that was also created * by us. And that equality is guaranteed to hold because it doesn't involve the JDK * TypeVariable implementation at all. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 22:30:05 UTC 2025 - 25.3K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/PathScope.java
import org.apache.maven.api.annotations.Nonnull; import static org.apache.maven.api.ExtensibleEnums.pathScope; /** * Path scope. * A path scope is used to determine the kind of build or class path that will be built when resolving * dependencies using the {@link org.apache.maven.api.services.DependencyResolver} service. * <p> * This extensible enum has four defined values, {@link #MAIN_COMPILE}, {@link #MAIN_RUNTIME},Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jul 10 20:52:34 UTC 2024 - 2.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java
HashCode unused = sink.hash(); sink.assertInvariants(8); sink.assertBytes(new byte[] {1, 2, 3, 4, 5, 6, 7, 8}); } public void testChar() { Sink sink = new Sink(4); sink.putChar((char) 0x0201); HashCode unused = sink.hash(); sink.assertInvariants(2); sink.assertBytes(new byte[] {1, 2, 0, 0}); // padded with zeros } public void testString() { Random random = new Random();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 18:19:59 UTC 2025 - 8.6K bytes - Viewed (0) -
docs/kms/IAM.md
- Reduced server startup time. For IAM encryption with the root credentials, MinIO had to use a memory-hard function (Argon2) that (on purpose) consumes a lot of memory and CPU. The new KMS-based approach can use a key derivation function that is orders of magnitudes cheaper w.r.t. memory and CPU. - Root credentials can now be changed easily. Before, a two-step process was required to
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.3K bytes - Viewed (0) -
src/main/java/jcifs/netbios/UniAddress.java
* License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. *
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 8.3K bytes - Viewed (0) -
cmd/mrf.go
} // mrfState sncapsulates all the information // related to the global background MRF. type mrfState struct { opCh chan PartialOperation closed int32 closing int32 wg sync.WaitGroup } func newMRFState() mrfState { return mrfState{ opCh: make(chan PartialOperation, mrfOpsQueueSize), } } // Add a partial S3 operation (put/delete) when one or more disks are offline.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 6.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/NtlmUtil.java
} /** * Generates the NT password hash for the given password. * This version accepts char[] for better security. * * @param password the password to hash as char array * @return nt password hash */ public static byte[] getNTHash(final char[] password) { if (password == null) { throw new NullPointerException("Password parameter is required");Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/CacheControl.kt
} companion object { /** * Cache control request directives that require network validation of responses. Note that such * requests may be assisted by the cache via conditional GET requests. */ @JvmField val FORCE_NETWORK = commonForceNetwork() /** * Cache control request directives that uses the cache only, even if the cached response isRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 10K bytes - Viewed (0)