Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 2681 - 2690 of 3,176 for Then (0.09 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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); // ReadChannelInfoLength
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top