- Sort Score
- Result 10 results
- Languages All
Results 461 - 470 of 887 for closure (0.06 sec)
-
guava-testlib/src/com/google/common/testing/TestLogHandler.java
synchronized (lock) { if (record != null) { list.add(record); } } } @Override public void flush() {} @Override public void close() {} public void clear() { synchronized (lock) { list.clear(); } } /** Returns a snapshot of the logged records. */ /*
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 21 20:53:25 UTC 2024 - 2.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComReadAndX.java
*/ package jcifs.smb1.smb1; import jcifs.smb1.Config; class SmbComReadAndX extends AndXServerMessageBlock { private static final int BATCH_LIMIT = Config.getInt( "jcifs.smb1.smb.client.ReadAndX.Close", 1 ); private long offset; private int fid, openTimeout; int maxCount, minCount, remaining; SmbComReadAndX() { super( null ); command = SMB_COM_READ_ANDX;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 3.1K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/ClingSupport.java
System.err.println(e.getMessage()); return 1; } catch (InvokerException e) { return 1; } finally { if (classWorldManaged) { classWorld.close(); } } } protected abstract Invoker<R> createInvoker(); protected abstract R parseArguments(String[] args) throws ParserException, IOException;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.7K bytes - Viewed (0) -
lib/time/mkzip.go
if err != nil { log.Fatal(err) } if _, err := w.Write(data); err != nil { log.Fatal(err) } seen[name] = true return nil }) if err != nil { log.Fatal(err) } if err := zw.Close(); err != nil { log.Fatal(err) } if len(seen) == 0 { log.Fatalf("did not find any files to add") } if !seen["US/Eastern"] { log.Fatalf("did not find US/Eastern to add") }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Mar 04 17:32:07 UTC 2024 - 2.1K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/SamrDomainHandle.java
handle.sendrecv(rpc); if ( rpc.retval != 0 ) { throw new SmbException(rpc.retval, false); } this.opened = true; } @Override public synchronized void close () throws IOException { if ( this.opened ) { this.opened = false; MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this); this.handle.sendrecv(rpc);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
assertFailsWith<IOException> { while (responseBody.read(buffer) != -1) { } }.also { expected -> assertEquals(cancelMode == INTERRUPT, Thread.interrupted()) } responseBody.close() assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount()) } @ParameterizedTest @ArgumentsSource(CancelModelParamProvider::class)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/ContainerCapsule.java
* The {@link Lookup} service backed by container in this capsule. */ @Nonnull Lookup getLookup(); /** * Performs a clean shutdown of backing container. */ @Override void close() throws InvokerException;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.3K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 12.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/UtilTest.kt
val socket = Socket() socket.connect(serverSocket.localSocketAddress) val socketSource = socket.source().buffer() assertThat(socket.isHealthy(socketSource)).isTrue() serverSocket.close() assertThat(socket.isHealthy(socketSource)).isFalse() } @Test fun testDurationTimeUnit() { assertThat(checkDuration("timeout", 0, TimeUnit.MILLISECONDS)).isEqualTo(0)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/authenticator/JavaNetAuthenticatorTest.kt
dns = fakeDns } @BeforeEach fun setup() { Authenticator.setDefault(recordingAuthenticator) } @AfterEach fun tearDown() { Authenticator.setDefault(null) factory.close() } @Test fun testBasicAuth() { fakeDns["server"] = listOf(InetAddress.getLocalHost()) val route = factory.newRoute() val request = Request.Builder()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.7K bytes - Viewed (0)