- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 558 for unread (0.07 sec)
-
internal/crypto/key.go
} copy(sealedKey.Key[:], encryptedKey.Bytes()) return sealedKey } // Unseal decrypts a sealed key using the 256 bit external key. Since the sealed key // may be cryptographically bound to the object's path the same bucket/object as during sealing // must be provided. On success the ObjectKey contains the decrypted sealed key. func (key *ObjectKey) Unseal(extKey []byte, sealedKey SealedKey, domain, bucket, object string) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 20:28:10 UTC 2024 - 6.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UncaughtExceptionHandlersTest.java
private Runtime runtimeMock; @Override protected void setUp() { runtimeMock = mock(Runtime.class); } public void testExiter() { new Exiter(runtimeMock).uncaughtException(new Thread(), new Exception()); verify(runtimeMock).exit(1); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* Futures#addCallback addCallback()}. * * <p>Memory consistency effects: Actions in a thread prior to adding a listener <a * href="https://docs.oracle.com/javase/specs/jls/se7/html/jls-17.html#jls-17.4.5"> * <i>happen-before</i></a> its execution begins, perhaps in another thread. * * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0) -
guava/src/com/google/common/cache/Cache.java
* evicted or manually invalidated. The common way to build instances is using {@link CacheBuilder}. * * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed * by multiple concurrent threads. * * @param <K> the type of the cache's keys, which are not permitted to be null
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sun Aug 07 02:38:22 UTC 2022 - 7.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} // Fill the receive buffer without holding any locks. val read = source.read(receiveBuffer, remainingByteCount) if (read == -1L) throw EOFException() remainingByteCount -= read // Move the received data to the read buffer to the reader can read it. If this source has // been closed since this read began we must discard the incoming data and tell the // connection we've done so.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
waitingThreadNames.size(), threadName); } return false; } if (logger.isInfoEnabled()) { logger.info("Cpu Load {}% is greater than {}%. {} waiting thread(s).", current, percent, waitingThreadNames.size());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Oct 17 12:10:08 UTC 2024 - 27.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/TearDownStack.java
import java.util.LinkedList; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; /** * A {@code TearDownStack} contains a stack of {@link TearDown} instances. * * <p>This class is thread-safe. * * @author Kevin Bourrillion * @since 10.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public class TearDownStack implements TearDownAccepter {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 21 10:19:29 UTC 2024 - 2.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/TearDownStack.java
import java.util.LinkedList; import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; /** * A {@code TearDownStack} contains a stack of {@link TearDown} instances. * * <p>This class is thread-safe. * * @author Kevin Bourrillion * @since 10.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public class TearDownStack implements TearDownAccepter {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 21 10:19:29 UTC 2024 - 2.5K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/AllowConcurrentEvents.java
import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus * may invoke the event subscriber simultaneously from multiple threads. * * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Apr 22 13:05:46 UTC 2021 - 1.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val source = relay.newSource() val sourceBuffer = Buffer() assertThat(source!!.read(sourceBuffer, 5)).isEqualTo(5) assertThat(sourceBuffer.readUtf8()).isEqualTo("abcde") assertThat(source.read(sourceBuffer, 1024)).isEqualTo(8) assertThat(sourceBuffer.readUtf8()).isEqualTo("fghijklm") assertThat(source.read(sourceBuffer, 1024)).isEqualTo(-1) assertThat(sourceBuffer.size).isEqualTo(0) source.close()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0)