Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1171 - 1180 of 1,417 for source (0.18 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. benchmarks/src/main/java/org/elasticsearch/benchmark/search/aggregations/TermsReduceBenchmark.java

                );
                shards.add(result);
            }
            SearchRequest request = new SearchRequest();
            request.source(new SearchSourceBuilder().size(0).aggregation(AggregationBuilders.terms("test")));
            request.setBatchedReduceSize(bufferSize);
            ExecutorService executor = Executors.newFixedThreadPool(1);
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Fri Aug 20 15:45:38 GMT 2021
    - 8.1K bytes
    - Click Count (0)
  2. src/archive/tar/reader_test.go

    // Copyright 2009 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package tar
    
    import (
    	"bytes"
    	"compress/bzip2"
    	"errors"
    	"fmt"
    	"hash/crc32"
    	"internal/obscuretestdata"
    	"io"
    	"maps"
    	"math"
    	"os"
    	"path"
    	"reflect"
    	"slices"
    	"strconv"
    	"strings"
    	"testing"
    	"time"
    )
    
    func TestReader(t *testing.T) {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Dec 30 15:28:53 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  3. cmd/metrics-v2.go

    		Type:      gaugeMetric,
    	}
    }
    
    func getRepReceivedBytesMD(namespace MetricNamespace) MetricDescription {
    	helpText := "Total number of bytes replicated to this bucket from another source bucket"
    	if namespace == clusterMetricNamespace {
    		helpText = "Total number of bytes replicated to this cluster from site replication peer"
    	}
    	return MetricDescription{
    		Namespace: namespace,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  4. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt

            throw IOException(
              "response size exceeds limit ($MAX_RESPONSE_SIZE bytes): ${body.contentLength()} bytes",
            )
          }
    
          val responseBytes = body.source().readByteString()
    
          return DnsRecordCodec.decodeAnswers(hostname, responseBytes)
        }
      }
    
      private fun buildRequest(
        hostname: String,
        type: Int,
      ): Request =
        Request
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat May 10 11:15:14 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  5. internal/grid/connection.go

    			c.connChange.Broadcast()
    		}
    		c.connChange.L.Unlock()
    		conn.Close()
    		c.handleMsgWg.Done()
    	}()
    
    	controlHandler := wsutil.ControlFrameHandler(conn, c.side)
    	wsReader := wsutil.Reader{
    		Source:          conn,
    		State:           c.side,
    		CheckUTF8:       true,
    		SkipHeaderCheck: false,
    		OnIntermediate:  controlHandler,
    	}
    	readDataInto := func(dst []byte, s ws.State, want ws.OpCode) ([]byte, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  6. cmd/admin-handlers.go

    }
    
    func lriToLockEntry(l lockRequesterInfo, now time.Time, resource, server string) *madmin.LockEntry {
    	t := time.Unix(0, l.Timestamp)
    	entry := &madmin.LockEntry{
    		Timestamp:  t,
    		Elapsed:    now.Sub(t),
    		Resource:   resource,
    		ServerList: []string{server},
    		Source:     l.Source,
    		Owner:      l.Owner,
    		ID:         l.UID,
    		Quorum:     l.Quorum,
    	}
    	if l.Writer {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  7. cmd/testdata/xl-meta-merge.zip

    with a *minimum* of 4 drives per MinIO server. See [MinIO Erasure Code Overview](https://min.io/docs/minio/linux/operations/concepts/erasure-coding.html#) for more complete documentation. ## Install from Source Use the following commands to compile and run a standalone MinIO server from source. Source installation is only intended for developers and advanced users. If you do not have a working Golang environment, please follow [How to install Golang](https://golang.org/doc/install). Minimum version...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 30.2K bytes
    - Click Count (0)
  8. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/DomUtilsTest.java

                    <groupId>test</groupId>
                    <artifactId>test</artifactId>
                    <version>1.0.0</version>
                    <properties>
                        <maven.compiler.source>17</maven.compiler.source>
                    </properties>
                </project>
                """;
    
            Document doc = Document.of(pomXml);
            Element root = doc.root();
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 31.3K bytes
    - Click Count (0)
  9. src/cmd/asm/internal/asm/testdata/amd64enc_extra.s

    // Copyright 2017 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // This input extends auto-generated amd64enc.s test suite
    // with manually added tests.
    
    #include "../../../../../runtime/textflag.h"
    
    TEXT asmtest(SB),DUPOK|NOSPLIT,$0
    	// AVX2GATHER: basic combinations.
    	VPGATHERDQ Y2, (BP)(X7*2), Y1           // c4e2ed904c7d00
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 20 11:20:03 GMT 2025
    - 57.7K bytes
    - Click Count (0)
  10. src/cmd/asm/internal/asm/testdata/loong64enc1.s

    // Copyright 2022 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    #include "../../../../../runtime/textflag.h"
    
    TEXT asmtest(SB),DUPOK|NOSPLIT,$0
    lable1:
    	BFPT	1(PC)				// 00050048
    	BFPT	lable1		// BFPT 2	// 1ffdff4b
    	BFPT	FCC0, lable1	// BFPT FCC0, 2	// 1ff9ff4b
    	BFPT	FCC7, lable1	// BFPT FCC7, 2	// fff5ff4b
    
    lable2:
    	BFPF	1(PC)				// 00040048
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Nov 27 00:46:52 GMT 2025
    - 44.5K bytes
    - Click Count (0)
Back to Top