- Sort Score
- Num 10 results
- Language All
Results 611 - 620 of 901 for lose (0.08 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} if (connectResult.isSuccess) { // We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 5.8K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/SmbSessionTest.java
smbtStatic.when(() -> SmbTransport.getSmbTransport(addr, 445)).thenReturn(transport); } @AfterEach void tearDown() { if (smbtStatic != null) { smbtStatic.close(); } } @Test void transportLazyInitialisation() { SmbSession session = new SmbSession(addr, 445, inet, 0, auth); // transport should still be null until first use
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.6K bytes - Click Count (0) -
internal/disk/stat_linux.go
} return iostats, err } func readStat(fileName string) (stats []uint64, err error) { file, err := os.Open(fileName) if err != nil { return nil, err } defer file.Close() s, err := bufio.NewReader(file).ReadString('\n') if err != nil && !errors.Is(err, io.EOF) { return nil, err } statLine := strings.TrimSpace(s) for _, token := range strings.Fields(statLine) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.8K bytes - Click Count (0) -
callbacks/delete.go
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun May 25 07:40:40 GMT 2025 - 5.8K bytes - Click Count (0) -
src/test/java/jcifs/dcerpc/msrpc/samrTest.java
class SamrCloseHandleTests { @Test @DisplayName("Should construct with correct opnum") void testConstructorAndOpnum() { // When: Creating close handle message samr.SamrCloseHandle message = new samr.SamrCloseHandle(mockPolicyHandle); // Then: Should have correct opnum and handle assertEquals(0x01, message.getOpnum());Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 33.7K bytes - Click Count (0) -
cmd/peer-s3-client.go
} } } // loop through buckets and see if some with lost quorum // these could be stale buckets lying around, queue a heal // of such a bucket. This is needed here as we identify such // buckets here while listing buckets. As part of regular // globalBucketMetadataSys.Init() call would get a valid // buckets only and not the quourum lost ones like this, so // explicit call
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
CREDITS
See the License for the specific language governing permissions and limitations under the License. ================================================================ github.com/go-jose/go-jose/v4 https://github.com/go-jose/go-jose/v4 ---------------------------------------------------------------- Apache License Version 2.0, January 2004Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Mar 13 05:29:51 GMT 2025 - 1.8M bytes - Click Count (0) -
cmd/storage-rest-server.go
xioutil.SafeClose(c.done) c.done = nil } } return n, err } func (c *closeNotifier) Close() error { if c.done != nil { xioutil.SafeClose(c.done) c.done = nil } return c.rc.Close() } // keepHTTPReqResponseAlive can be used to avoid timeouts with long storage // operations, such as bitrot verification or data usage scanning. // Every 10 seconds a space character is sent.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
src/test/java/jcifs/smb1/dcerpc/msrpc/samrTest.java
class SamrCloseHandleTests { @Test @DisplayName("Should construct with correct opnum") void testConstructorAndOpnum() { // When: Creating close handle message samr.SamrCloseHandle message = new samr.SamrCloseHandle(mockPolicyHandle); // Then: Should have correct opnum and handle assertEquals(0x01, message.getOpnum());Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 33.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/com/SmbComWriteAndX.java
if (cmd == SMB_COM_READ_ANDX) { return cfg.getBatchLimit("WriteAndX.ReadAndX"); } if (cmd == SMB_COM_CLOSE) { return cfg.getBatchLimit("WriteAndX.Close"); } return 0; } @Override protected int writeParameterWordsWireFormat(final byte[] dst, int dstIndex) { final int start = dstIndex;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.1K bytes - Click Count (0)