- Sort Score
- Num 10 results
- Language All
Results 2681 - 2690 of 3,176 for Then (0.09 seconds)
-
internal/grid/debug.go
Hosts []string cleanupOnce sync.Once cancel context.CancelFunc } // SetupTestGrid creates a new grid for testing purposes. // Select the number of hosts to create. // Call (TestGrid).Cleanup() when done. func SetupTestGrid(n int) (*TestGrid, error) { hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{ Timeout: 5 * time.Second, } var res TestGrid
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
internal/grid/trace.go
"net/http" "strings" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/pubsub" ) // TraceParamsKey allows to pass trace parameters to the request via context. // This is only needed when un-typed requests are used. // MSS, map[string]string types are preferred, but any struct with exported fields will work. type TraceParamsKey struct{} // traceRequests adds request tracing to the connection.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sat Jun 01 05:17:37 GMT 2024 - 4.1K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/CheckstylePrecommitPlugin.java
// Always copy the checkstyle configuration files to 'buildDir/checkstyle' since the resources could be located in a jar // file. If the resources are located in a jar, Gradle will fail when it tries to turn the URL into a file URL checkstyleConfUrl = CheckstylePrecommitPlugin.class.getResource("/checkstyle.xml");
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Thu Jun 17 08:59:22 GMT 2021 - 5.5K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableRangeSet.java
* called. */ @CanIgnoreReturnValue public Builder<C> addAll(RangeSet<C> ranges) { return addAll(ranges.asRanges()); } /** * Add all of the specified ranges to this builder. Adjacent ranges are permitted and will be * merged, but overlapping ranges will cause an exception when {@link #build()} is called. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 16:45:58 GMT 2026 - 27.5K bytes - Click Count (0) -
android/guava/src/com/google/common/primitives/UnsignedLongs.java
* number. * * <p>Users of these utilities must be <i>extremely careful</i> not to mix up signed and unsigned * {@code long} values. When possible, it is recommended that the {@link UnsignedLong} wrapper class * be used, at a small efficiency penalty, to enforce the distinction in the type system. * * <p>See the Guava User Guide article on <a
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jan 05 22:13:21 GMT 2026 - 17.8K bytes - Click Count (0) -
cmd/encryption-v1_test.go
} if err == nil { if etag != test.ETag { t.Fatalf("Test %d: ETag mismatch: got %s - want %s", i, etag, test.ETag) } } } } // Tests for issue reproduced when getting the right encrypted // offset of the object. func TestGetDecryptedRange_Issue50(t *testing.T) { rs, err := parseRequestRangeSpec("bytes=594870256-594870263") if err != nil { t.Fatal(err) }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/pager/ReqHeaderPager.java
*/ public String webConfigId; /** * The user who created this request header. */ public String createdBy; /** * The timestamp when this request header was created. */ public String createdTime; /** * The version number for optimistic locking. */ public String versionNo; /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 7.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/io/Smb2ReadRequest.java
dstIndex += 4; // ReadChannelInfo (Offset/Length for SMB2_RDMA_TRANSFORM) if (rdmaChannelInfo != null && channel == Smb2Constants.SMB2_CHANNEL_RDMA_V1) { // When using RDMA channel, this points to SMB2_RDMA_TRANSFORM in Buffer SMBUtil.writeInt2(80, dst, dstIndex); // ReadChannelInfoOffset (after header) SMBUtil.writeInt2(16, dst, dstIndex + 2); // ReadChannelInfoLengthCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 7.8K bytes - Click Count (0) -
internal/handlers/forwarder.go
} // TODO: only supports HTTP 1.1 for now. outReq.Proto = "HTTP/1.1" outReq.ProtoMajor = 1 outReq.ProtoMinor = 1 f.rewriter.Rewrite(outReq) // Disable closeNotify when method GET for http pipelining if outReq.Method == http.MethodGet { quietReq := outReq.WithContext(context.Background()) *outReq = *quietReq } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 5.7K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/ValidateJsonNoKeywordsTask.java
} try { try (PrintWriter pw = new PrintWriter(getReport())) { pw.println("---------- Validation Report -----------"); pw.println("Some API names were found that, when client code is generated for these APIS,"); pw.println("could conflict with the reserved words in some programming languages. It may");Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 7.6K bytes - Click Count (0)