Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 181 for readSize (0.09 sec)

  1. istioctl/pkg/waypoint/waypoint_test.go

    				t.Fatal(err)
    			}
    
    			for _, gw := range tt.gateways {
    				_, _ = client.GatewayAPI().GatewayV1().Gateways(gw.Namespace).Create(context.Background(), gw, metav1.CreateOptions{})
    			}
    			defaultFile, err := os.ReadFile(fmt.Sprintf("testdata/waypoint/%s", tt.expectedOutFile))
    			if err != nil {
    				t.Fatal(err)
    			}
    			expectedOut := string(defaultFile)
    			if len(expectedOut) == 0 {
    				t.Fatal("expected output is empty")
    			}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Apr 04 15:53:09 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbComNegotiateResponse.java

            server.sessionKey    = readInt4( buffer, bufferIndex ); bufferIndex += 4;
            server.capabilities  = readInt4( buffer, bufferIndex ); bufferIndex += 4;
            server.serverTime    = readTime( buffer, bufferIndex ); bufferIndex += 8;
            server.serverTimeZone = readInt2( buffer, bufferIndex ); bufferIndex += 2;
            server.encryptionKeyLength = buffer[bufferIndex++] & 0xFF;
    
            return bufferIndex - start;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 6.1K bytes
    - Viewed (0)
  3. cmd/xl-storage_test.go

    		}
    	}
    
    	{
    		buf := make([]byte, 5)
    		// Test for negative offset.
    		if _, err = xlStorage.ReadFile(context.Background(), volume, "myobject", -1, buf, v); err == nil {
    			t.Fatalf("expected: error, got: <nil>")
    		}
    	}
    
    	for l := 0; l < 2; l++ {
    		// Following block validates all ReadFile test cases.
    		for i, testCase := range testCases {
    			var n int64
    			// Common read buffer.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

                    new BufferedReader(new InputStreamReader(this.getClass().getClassLoader().getResourceAsStream(getSuggestAnalyzerPath())))) {
    
                String line;
                while ((line = br.readLine()) != null) {
                    sb.append(line);
                }
            }
            return sb.toString().replaceAll(Pattern.quote("${fess.dictionary.path}"), dictionaryPath);
        }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/nego/Smb2NegotiateResponse.java

            bufferIndex += 4;
            this.maxWriteSize = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
    
            this.systemTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.serverStartTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
    
            int securityBufferOffset = SMBUtil.readInt2(buffer, bufferIndex);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Mar 22 10:09:46 UTC 2020
    - 17.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/io/LineIterator.java

            assertArgumentNotNull("reader", reader);
            this.reader = reader;
        }
    
        @Override
        public boolean hasNext() {
            if (line == EMPTY) {
                line = ReaderUtil.readLine(reader);
            }
            return line != null;
        }
    
        @Override
        public String next() {
            if (!hasNext()) {
                throw new NoSuchElementException();
            }
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocScanner.java

            StringBuilder builder = new StringBuilder();
            try {
                BufferedReader reader = new BufferedReader(new StringReader(rawCommentText));
                String line;
                while ((line = reader.readLine()) != null) {
                    line = line.replaceFirst("\\s*\\* ?", "");
                    if (line.startsWith("@")) {
                        // Ignore the tag section of the comment
                        break;
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 4.3K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader_amd64_test.go

    	Fatal(args ...interface{})
    }
    
    func loadCompressed(t tester, file string) (js []byte) {
    	dec, err := zstd.NewReader(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer dec.Close()
    	js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	js, err = dec.DecodeAll(js, nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	return js
    }
    
    var testCases = []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/RobotsTxtHelper.java

                final RobotsTxt robotsTxt = new RobotsTxt();
                final List<Directive> currentDirectiveList = new ArrayList<>();
                boolean isGroupRecodeStarted = false;
                while ((line = reader.readLine()) != null) {
                    line = stripComment(line).trim();
                    if (StringUtil.isEmpty(line)) {
                        continue;
                    }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:40:57 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. cni/pkg/iptables/iptables_linux.go

    	return forEachLoopbackRoute(cfg, "remove", netlink.RouteDel)
    }
    
    const ipv6DisabledLo = "/proc/sys/net/ipv6/conf/lo/disable_ipv6"
    
    func ReadSysctl(key string) (string, error) {
    	data, err := os.ReadFile(key)
    	if err != nil {
    		return "", err
    	}
    	return strings.TrimSpace(string(data)), nil
    }
    
    func forEachLoopbackRoute(cfg *Config, operation string, f func(*netlink.Route) error) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 06 09:44:28 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top