- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 428 for Reset (0.02 sec)
-
src/test/java/jcifs/internal/smb1/trans/nt/SmbComNtTransactionResponseTest.java
for (int pos : positions) { when(mockConfig.getPid()).thenReturn(1234); // Mock getPid for each new instance response = new TestSmbComNtTransactionResponse(mockConfig); // Reset response // Fill buffer at position for (int i = 0; i < 37; i++) { buffer[pos + i] = 0x00; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 16.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} else { assertThat(numSuccessfulSetCalls.get()).isEqualTo(1); } } else { assertThat(numSuccessfulSetCalls.get()).isEqualTo(1); } // reset for next iteration numSuccessfulSetCalls.set(0); finalResults.clear(); } executor.shutdown(); } // setFuture and cancel() interact in more complicated ways than the other setters.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
src/main/java/jcifs/util/ServerResponseValidator.java
return new ValidationStats(totalValidations.get(), failedValidations.get(), bufferOverflowsPrevented.get(), integerOverflowsPrevented.get()); } /** * Reset statistics */ public void resetStats() { totalValidations.set(0); failedValidations.set(0); bufferOverflowsPrevented.set(0); integerOverflowsPrevented.set(0); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 16.6K bytes - Viewed (0) -
doc/godebug.md
the Go 1.23 behavior. ### Go 1.23 Go 1.23 changed the channels created by package time to be unbuffered (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop) and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier. The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change. There are no runtime metrics for this change,
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Jul 08 18:30:38 UTC 2025 - 22.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
if (getType() != TYPE_WORKGROUP) { break; } req.subCommand = (byte) SmbComTransaction.NET_SERVER_ENUM3; req.reset(0, ((NetServerEnum2Response) resp).lastName); resp.reset(); } while (more); } void doFindFirstNext(final ArrayList list, final boolean files, final String wildcard, final int searchAttributes,
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 112.2K bytes - Viewed (0) -
cmd/erasure-decode.go
p.buf[bufIdx] = make([]byte, p.shardSize) } // For the last shard, the shardsize might be less than previous shard sizes. // Hence the following statement ensures that the buffer size is reset to the right size. p.buf[bufIdx] = p.buf[bufIdx][:p.shardSize] n, err := rr.ReadAt(p.buf[bufIdx], p.offset) if err != nil { switch { case errors.Is(err, errFileNotFound):
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
cmd/metacache-walk.go
return ctx.Err() } if opts.Limit > 0 && objsReturned >= opts.Limit { return nil } // Skip forward, if requested... sb := bytebufferpool.Get() defer func() { sb.Reset() bytebufferpool.Put(sb) }() forward := "" if len(opts.ForwardTo) > 0 && strings.HasPrefix(opts.ForwardTo, current) { forward = strings.TrimPrefix(opts.ForwardTo, current)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 26 07:06:43 UTC 2025 - 12.6K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTransportImplTest.java
when(address.getHostName()).thenReturn("localhost"); // Create the transport with safe defaults (no real sockets) transport = new SmbTransportImpl(ctx, address, 445, null, 0, false); // Reset MID to a known starting point for deterministic behavior setField(transport, "mid", new AtomicLong()); } // Utility: reflectively set a private/protected field (searches up the hierarchy)
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/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
sink1.writeUtf8("abc") assertFailsWith<IOException> { sink2.writeUtf8("abc") sink2.flush() }.also { expected -> assertThat(expected.message).isEqualTo("stream was reset: REFUSED_STREAM") } sink1.writeUtf8("def") sink1.close() assertFailsWith<ConnectionShutdownException> { connection.newStream(headerEntries("c", "cola"), true) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
final String unc = "\\\\" + tconHostName + '\\' + this.share; /* * IBM iSeries doesn't like specifying a service. Always reset * the service to whatever was determined in the constructor. */ final String svc = this.service0; /*
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 30K bytes - Viewed (0)