- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 766 for slate (0.56 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertEquals(Service.State.RUNNING, service.state()); exitRun.countDown(); // the service will exit voluntarily executionThread.join(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); service.stopAsync().awaitTerminated(); // no-op assertEquals(Service.State.TERMINATED, service.state()); assertTrue(service.shutDownCalled); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
public void failed(State from, Throwable failure) { assertEquals(State.RUNNING, from); assertEquals(error, failure); latch.countDown(); } }, directExecutor()); service.startAsync(); latch.await(); assertEquals(0, service.numberOfTimesRunCalled.get()); assertEquals(Service.State.FAILED, service.state()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/AbstractIterator.java
checkState(state != State.FAILED); switch (state) { case DONE: return false; case READY: return true; default: } return tryToComputeNext(); } private boolean tryToComputeNext() { state = State.FAILED; // temporary pessimism next = computeNext(); if (state != State.DONE) { state = State.READY; return true; }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Jul 09 17:31:04 GMT 2021 - 2.5K bytes - Viewed (0) -
cmd/metacache-entries_test.go
"src/compress/bzip2/testdata/random.data.bz2", "src/compress/flate/deflate.go", "src/compress/flate/deflate_test.go", "src/compress/flate/deflatefast.go", "src/compress/flate/dict_decoder.go", "src/compress/flate/dict_decoder_test.go", "src/compress/flate/example_test.go", "src/compress/flate/flate_test.go", "src/compress/flate/huffman_bit_writer.go", "src/compress/flate/huffman_bit_writer_test.go", "src/compress/flate/huffman_code.go", "src/compress/flate/inflate.go", "src/compress/flate/inflate_test.go",...
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 31.6K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/netdfs.idl
const uint32_t DFS_STORAGE_STATE_OFFLINE = 0x0001; const uint32_t DFS_STORAGE_STATE_ONLINE = 0x0002; const uint32_t DFS_STORAGE_STATE_ACTIVE = 0x0004; typedef struct { [string] wchar_t *entry_path; } DfsInfo1; typedef struct { uint32_t count; [size_is(count)] DfsInfo1 *s; } DfsEnumArray1; typedef struct { uint32_t state; [string] wchar_t *server_name;
Others - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 1.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/netdfs.idl
const uint32_t DFS_STORAGE_STATE_OFFLINE = 0x0001; const uint32_t DFS_STORAGE_STATE_ONLINE = 0x0002; const uint32_t DFS_STORAGE_STATE_ACTIVE = 0x0004; typedef struct { [string] wchar_t *entry_path; } DfsInfo1; typedef struct { uint32_t count; [size_is(count)] DfsInfo1 *s; } DfsEnumArray1; typedef struct { uint32_t state; [string] wchar_t *server_name;
Others - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 1.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
completed.assertCompletionExpected(); assertEquals(Thread.State.TERMINATED, thread.getState()); } void joinSuccessfully(long timeoutMillis) { Uninterruptibles.joinUninterruptibly(thread, timeoutMillis, MILLISECONDS); completed.assertCompletionExpected(); assertEquals(Thread.State.TERMINATED, thread.getState()); } void joinUnsuccessfully(long timeoutMillis) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 30.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
assertThat(manager.servicesByState().keySet()).containsExactly(Service.State.FAILED); } private static void assertState( ServiceManager manager, Service.State state, Service... services) { Collection<Service> managerServices = manager.servicesByState().get(state); for (Service service : services) { assertEquals(service.toString(), state, service.state());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceTest.java
import static com.google.common.util.concurrent.Service.State.FAILED; import static com.google.common.util.concurrent.Service.State.NEW; import static com.google.common.util.concurrent.Service.State.RUNNING; import static com.google.common.util.concurrent.Service.State.STARTING; import static com.google.common.util.concurrent.Service.State.STOPPING; import static com.google.common.util.concurrent.Service.State.TERMINATED; import java.util.Locale;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 1.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcHandle.java
protected static DcerpcBinding parseBinding(String str) throws DcerpcException { int state, mark, si; char[] arr = str.toCharArray(); String proto = null, key = null; DcerpcBinding binding = null; state = mark = si = 0; do { char ch = arr[si]; switch (state) { case 0: if (ch == ':') {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 8.8K bytes - Viewed (0)