- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 916 for _clone (0.06 sec)
-
src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java
} this.closed = true; } finally { this.signingLock.unlock(); } } /** * Close the signing digest and securely wipe keys */ @Override public void close() { secureWipeKey(); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 9.9K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTransportImplTest.java
when(creds.clone()).thenReturn(creds); assertEquals(0, transport.getNumSessions()); // Act: create new session (happy path) SmbSessionImpl s1 = transport.getSmbSession(ctx); assertNotNull(s1); assertEquals(1, transport.getNumSessions()); s1.close(); // Act: request again with same context -> reuse existing
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt
sourcePos += bytesRead // Append the upstream bytes to the file. fileOperator!!.write( FILE_HEADER_SIZE + upstreamPos, upstreamBuffer.clone(), upstreamBytesRead, ) synchronized(this@Relay) { // Append new upstream bytes into the buffer. Trim it to its max size. buffer.write(upstreamBuffer, upstreamBytesRead)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 17:15:47 UTC 2025 - 11.8K bytes - Viewed (0) -
docs/fr/README.md
- [Forum](https://github.com/nocode2k/fess-kr-forum) ## Informations de Développement ### Récupérer le Code Source 1. Clonez le dépôt Fess : ``` $ cd ~/workspace $ git clone https://github.com/codelibs/fess.git ``` 2. Importez le dépôt cloné en tant que projet [Maven](https://maven.apache.org/) sur [Eclipse](https://www.eclipse.org/eclipseide/) ou un autre IDE.
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Oct 12 07:19:47 UTC 2024 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/compression/DefaultCompressionService.java
return true; } } return false; } @Override public int[] getSupportedAlgorithms() { return SUPPORTED_ALGORITHMS.clone(); } @Override public double estimateCompressionRatio(byte[] data, int algorithm) { if (data == null || data.length == 0) { return 1.0; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 11.2K bytes - Viewed (0) -
cmd/postpolicyform_test.go
{ name: "happy path no errors", fv: defaultFormVals.Clone(), wantErr: "", }, { name: "expired policy document", fv: defaultFormVals.Clone(), expired: true, wantErr: "Invalid according to Policy: Policy expired", }, { name: "different AMZ date", fv: defaultFormVals.Clone().Set(xhttp.AmzDate, "2017T000000Z"), wantErr: policyCondFailedErr, },
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
when { this.isNullOrEmpty() -> emptyList() this.size == 1 -> Collections.singletonList(this[0]) else -> this.clone().asList().unmodifiable() } /** Closes this, ignoring any checked exceptions. */ internal fun Socket.closeQuietly() { try { close() } catch (e: AssertionError) { throw e } catch (rethrown: RuntimeException) { if (rethrown.message == "bio == null") {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 10.2K bytes - Viewed (0) -
cmd/erasure.go
updates <- cache.clone() lastSave = cache.Info.LastUpdate case v, ok := <-bucketResults: if !ok { // Save final state... cache.Info.NextCycle = wantCycle cache.Info.LastUpdate = time.Now() scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-channel-closed") updates <- cache.clone() return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
override fun clone(): Call = RealCall(client, originalRequest, forWebSocket) override fun request(): Request = originalRequest /** * Immediately closes the socket connection if it's currently held. Use this to interrupt an * in-flight request from any thread. It's the caller's responsibility to close the request body
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 17.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
server.enqueue(MockResponse(body = "def")) val request = Request(server.url("/")) val call = client.newCall(request) val response1 = call.execute() val cloned = call.clone() val response2 = cloned.execute() assertThat("abc").isEqualTo(response1.body.string()) assertThat("def").isEqualTo(response2.body.string()) } @Test fun legalToExecuteTwiceCloning_Async() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 146.6K bytes - Viewed (0)