- Sort Score
- Num 10 results
- Language All
Results 391 - 400 of 1,546 for chose (0.03 seconds)
-
src/test/java/jcifs/smb1/smb1/DfsTest.java
if (logStreamMockedStatic != null) logStreamMockedStatic.close(); if (uniAddressMockedStatic != null) uniAddressMockedStatic.close(); if (smbTransportMockedStatic != null) smbTransportMockedStatic.close(); if (configMockedStatic != null) configMockedStatic.close(); } @Test void testCacheEntry() {
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.6K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/io/BaseEncodingBenchmark.java
StringWriter target = new StringWriter(2 * n); OutputStream encodingStream = encoding.encoding.encodingStream(target); encodingStream.write(encodingInputs[i & INPUTS_MASK]); encodingStream.close(); tmp += target.getBuffer().length(); } return tmp; } @Benchmark public int decodingStream(int reps) throws IOException { int tmp = 0; byte[] target = new byte[n];
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.2K bytes - Click Count (0) -
src/main/java/jcifs/context/BaseContext.java
return this.defaultCredentials; } /** * {@inheritDoc} * * @see jcifs.CIFSContext#close() */ @Override public boolean close() throws CIFSException { boolean inUse = super.close(); inUse |= this.transportPool.close(); return inUse; }Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 5.5K bytes - Click Count (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java
Socket result = createSocket(); try { result.connect(new InetSocketAddress(host, port)); } catch (IOException e) { result.close(); throw e; } return result; } @Override public Socket createSocket( String host, int port, InetAddress localHost, int localPort) throws IOException { return createSocket(host, port);
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Dec 03 21:33:52 GMT 2023 - 2.1K bytes - Click Count (0) -
internal/ioutil/wait_pipe.go
done func() } // CloseWithError close with supplied error the writer end. func (w *PipeWriter) CloseWithError(err error) error { err = w.PipeWriter.CloseWithError(err) w.once.Do(func() { w.done() }) return err } // PipeReader is similar to io.PipeReader with wait group type PipeReader struct { *io.PipeReader wait func() } // CloseWithError close with supplied error the reader end
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Click Count (0) -
internal/grid/connection.go
return } } } }() // Close all active requests. if debugReqs { fmt.Println(c.String(), "Reconnected. Clearing outgoing.") } c.outgoing.Range(func(key uint64, client *muxClient) bool { client.close() return true }) c.inStream.Range(func(key uint64, value *muxServer) bool { value.close() return true }) c.inStream.Clear() c.outgoing.Clear()Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
src/main/java/org/codelibs/core/io/TraversalUtil.java
handler.processResource(path, is); } }); } @Override public void close() { JarFileUtil.close(jarFile); } } /** * Object that handles a collection of resources represented by the vfszip protocol of JBossAS5. * * @author koichik */
Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 18.6K bytes - Click Count (0) -
internal/store/batch_test.go
Limit: limit, Store: store, CommitTimeout: 5 * time.Minute, Log: func(ctx context.Context, err error, id string, errKind ...any) { t.Log(err) }, }) defer batch.Close() for i := 0; i < int(limit); i++ { if err := batch.Add(testItem); err != nil { t.Fatalf("failed to add %v; %v", i, err) } } batchLen := batch.Len() if batchLen != int(limit) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt
server.enqueue(response) val request = newRequest("/") val c1 = getResponse(request) assertContent("ABCDE", c1, 5) val c2 = getResponse(request) assertContent("ABCDE", c2, 5) c1.close() c2.close() } @Test fun connectionsArePooled() { val response = MockResponse( body = "ABCDEFGHIJKLMNOPQR", ) server.enqueue(response)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Jun 21 20:36:35 GMT 2025 - 133.2K bytes - Click Count (0) -
LICENSES/vendor/cyphar.com/go-pathrs/LICENSE
1.12. "Secondary License" means either the GNU General Public License, Version 2.0, the GNU Lesser General Public License, Version 2.1, the GNU Affero General Public License, Version 3.0, or any later versions of those licenses. 1.13. "Source Code Form" means the form of the work preferred for making modifications. 1.14. "You" (or "Your") means an individual or a legal entity exercising rights under this
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Wed Nov 12 14:46:31 GMT 2025 - 16.5K bytes - Click Count (0)