Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 437 for readLine (0.07 sec)

  1. cmd/callhome.go

    		}
    	}
    }
    
    func performCallhome(ctx context.Context) {
    	deadline := 10 * time.Second // Default deadline is 10secs for callhome
    	objectAPI := newObjectLayerFn()
    	if objectAPI == nil {
    		internalLogIf(ctx, errors.New("Callhome: object layer not ready"))
    		return
    	}
    
    	healthCtx, healthCancel := context.WithTimeout(ctx, deadline)
    	defer healthCancel()
    
    	healthInfoCh := make(chan madmin.HealthInfo)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/io/CharSourceTester.java

        } else {
          assertEquals(expectedLines.get(0), source.readFirstLine());
        }
      }
    
      public void testReadLines_toList() throws IOException {
        assertExpectedLines(source.readLines());
      }
    
      public void testIsEmpty() throws IOException {
        assertEquals(expected.isEmpty(), source.isEmpty());
      }
    
      public void testLength() throws IOException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/io/Files.java

       * @throws IOException if an I/O error occurs
       */
      public static List<String> readLines(File file, Charset charset) throws IOException {
        // don't use asCharSource(file, charset).readLines() because that returns
        // an immutable list, which would change the behavior of this method
        return asCharSource(file, charset)
            .readLines(
                new LineProcessor<List<String>>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  4. internal/deadlineconn/deadlineconn_test.go

    package deadlineconn
    
    import (
    	"bufio"
    	"io"
    	"net"
    	"sync"
    	"testing"
    	"time"
    )
    
    // Test deadlineconn handles read timeout properly by reading two messages beyond deadline.
    func TestBuffConnReadTimeout(t *testing.T) {
    	l, err := net.Listen("tcp", "localhost:0")
    	if err != nil {
    		t.Fatalf("unable to create listener. %v", err)
    	}
    	defer l.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Nov 05 18:09:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/io/Files.java

       * @throws IOException if an I/O error occurs
       */
      public static List<String> readLines(File file, Charset charset) throws IOException {
        // don't use asCharSource(file, charset).readLines() because that returns
        // an immutable list, which would change the behavior of this method
        return asCharSource(file, charset)
            .readLines(
                new LineProcessor<List<String>>() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/fscc/FileBothDirectoryInfo.java

            bufferIndex += 4;
            this.creationTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.lastAccessTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.lastWriteTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.changeTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 5.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb1/com/SmbComNTCreateAndXResponse.java

            bufferIndex += 4;
            this.creationTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.lastAccessTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.lastWriteTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.changeTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6.4K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/compare/comparator_test.go

    func TestComparatorMismatchedConfigs(t *testing.T) {
    	cfg, err := os.ReadFile("testdata/configdump.json")
    	if err != nil {
    		t.Fatalf("Failed to read test data: %v", err)
    	}
    	diffCfg, err := os.ReadFile("testdata/configdump_diff.json")
    	if err != nil {
    		t.Fatalf("Failed to read test data: %v", err)
    	}
    
    	var outputBuffer bytes.Buffer
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. internal/grid/grid.go

    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    	// Deadline for single (non-streaming) requests to complete.
    	// Used if no deadline is provided on context.
    	defaultSingleRequestTimeout = time.Minute
    )
    
    var internalByteBuffer = sync.Pool{
    	New: func() any {
    		m := make([]byte, 0, defaultBufferSize)
    		return &m
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. cni/pkg/install/kubeconfig.go

    	} else {
    		caFile := model.GetOrDefault(cfg.KubeCAFile, cfg.K8sServiceAccountPath+"/ca.crt")
    		caContents, err := os.ReadFile(caFile)
    		if err != nil {
    			return kubeconfig{}, err
    		}
    		cluster.CertificateAuthorityData = caContents
    	}
    
    	token, err := os.ReadFile(cfg.K8sServiceAccountPath + "/token")
    	if err != nil {
    		return kubeconfig{}, err
    	}
    
    	const contextName = "istio-cni-context"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top