- Sort Score
- Num 10 results
- Language All
Results 361 - 370 of 501 for objlock (0.05 seconds)
-
android/guava/src/com/google/common/io/CharStreams.java
total += read; Java8Compatibility.clear(buf); } return total; } /** * Discards {@code n} characters of data from the reader. This method will block until the full * amount has been skipped. Does not close the reader. * * @param reader the reader to read from * @param n the number of characters to skipCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 29 13:56:24 GMT 2025 - 11.9K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
final int type = this.file.getType(); int r, n; final int blockSize = type == SmbConstants.TYPE_FILESYSTEM ? this.readSizeFile : this.readSize; // Optimization: Use larger block sizes for better performance final int optimizedBlockSize = Math.min(blockSize * 2, 64 * 1024); // Cap at 64KB for memory efficiency final int effectiveBlockSize = Math.max(blockSize, optimizedBlockSize);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 15.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
/** * Aggregating mojo executions (possibly) modify all MavenProjects, including those that are currently in use * by concurrently running mojo executions. To prevent race conditions, an aggregating execution will block * all other executions until finished. * We also lock on a given project to forbid a forked lifecycle to be executed concurrently with the project.Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Jun 12 14:55:55 GMT 2025 - 21K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
final byte[] buffer = this.getContext().getBufferCache().getBuffer(); try { // synchronize around encode and write so that the ordering for SMB1 signing can be maintained synchronized (this.outLock) { final int n = smb.encode(buffer, 4); Encdec.enc_uint32be(n & 0xFFFF, buffer, 0); /* 4 byte session message header */ if (log.isTraceEnabled()) { do {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 69.8K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteStreams.java
"reached end of stream after reading " + read + " bytes; " + len + " bytes expected"); } } /** * Discards {@code n} bytes of data from the input stream. This method will block until the full * amount has been skipped. Does not close the stream. * * @param in the input stream to read from * @param n the number of bytes to skip
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 31.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/MultimapsTest.java
Multimap<K, V> multimap = synchronizedMultimap(HashMultimap.<K, V>create()); Collection<V> values = multimap.get(key); // Needn't be in synchronized block synchronized (multimap) { // Synchronizing on multimap, not values! Iterator<V> i = values.iterator(); // Must be in synchronized block while (i.hasNext()) { foo(i.next()); } } } private static void foo(Object unused) {}Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 39.2K bytes - Click Count (0) -
cmd/sftp-server.go
} cert, ok := clientKey.(*ssh.Certificate) if !ok { return errSftpPublicKeyWithoutCert } // ssh.CheckCert called by ssh.Authenticate accepts certificates // with empty principles list so we block those in here. if len(cert.ValidPrincipals) == 0 { return errSftpCertWithoutPrincipals } // Verify that certificate provided by user is issued by trusted CA,Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.5K bytes - Click Count (0) -
docs/config/README.md
``` ~ mc admin config set alias/ heal KEY:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 18.1K bytes - Click Count (1) -
android/guava/src/com/google/common/cache/CacheBuilderSpec.java
} } return spec; } /** Returns a CacheBuilderSpec that will prevent caching. */ public static CacheBuilderSpec disableCaching() { // Maximum size of zero is one way to block caching return CacheBuilderSpec.parse("maximumSize=0"); } /** Returns a CacheBuilder configured according to this instance's specification. */ CacheBuilder<Object, Object> toCacheBuilder() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 18.2K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheBuilderSpec.java
} } return spec; } /** Returns a CacheBuilderSpec that will prevent caching. */ public static CacheBuilderSpec disableCaching() { // Maximum size of zero is one way to block caching return CacheBuilderSpec.parse("maximumSize=0"); } /** Returns a CacheBuilder configured according to this instance's specification. */ CacheBuilder<Object, Object> toCacheBuilder() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 18.2K bytes - Click Count (0)