Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 171 for readSize (0.05 sec)

  1. cmd/erasure-server-pool-rebalance_gen.go

    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "startTs":
    			z.StartTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "StartTime")
    				return
    			}
    		case "stopTs":
    			z.EndTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "EndTime")
    				return
    			}
    		case "status":
    			{
    				var zb0002 uint8
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.8K bytes
    - Viewed (0)
  2. internal/store/queuestore.go

    	defer func(store *QueueStore[I]) {
    		store.RUnlock()
    		if err != nil && !os.IsNotExist(err) {
    			// Upon error we remove the entry.
    			store.Del(key)
    		}
    	}(store)
    
    	raw, err = os.ReadFile(filepath.Join(store.directory, key.String()))
    	if err != nil {
    		return raw, err
    	}
    
    	if len(raw) == 0 {
    		return raw, os.ErrNotExist
    	}
    
    	if key.Compress {
    		raw, err = s2.Decode(nil, raw)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  3. api/maven-api-di/src/main/java/org/apache/maven/di/tool/DiIndexProcessor.java

                    String line;
                    StringBuilder contentBuilder = new StringBuilder();
                    while ((line = reader.readLine()) != null) {
                        if (!line.trim().startsWith("#")) {
                            existingClasses.add(line.trim());
                        }
                        contentBuilder.append(line).append("\n");
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Apr 03 13:33:59 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  4. internal/ioutil/ioutil_test.go

    		t.Fatal(err)
    	}
    	name2 := f.Name()
    	defer os.Remove(name2)
    	f.WriteString("bbbbbbbbbb")
    	f.Close()
    
    	if err = AppendFile(name1, name2, false); err != nil {
    		t.Error(err)
    	}
    
    	b, err := os.ReadFile(name1)
    	if err != nil {
    		t.Error(err)
    	}
    
    	expected := "aaaaaaaaaabbbbbbbbbb"
    	if string(b) != expected {
    		t.Errorf("AppendFile() failed, expected: %s, got %s", expected, string(b))
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  5. src/cmd/api/api_test.go

    			f, err := os.Create(goldenFile)
    			if err != nil {
    				t.Fatal(err)
    			}
    			for _, feat := range w.Features() {
    				fmt.Fprintf(f, "%s\n", feat)
    			}
    			f.Close()
    		}
    
    		bs, err := os.ReadFile(goldenFile)
    		if err != nil {
    			t.Fatalf("opening golden.txt for package %q: %v", fi.Name(), err)
    		}
    		wanted := strings.Split(string(bs), "\n")
    		slices.Sort(wanted)
    		for _, feature := range wanted {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri May 02 17:06:27 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  6. docs/smb3-features/05-rdma-smb-direct-design.md

        try (InputStream is = file.getInputStream()) {
            is.read(readData);
        }
        
        long readTime = System.currentTimeMillis() - start;
        
        assertArrayEquals(data, readData);
        
        // RDMA should be faster than TCP for large transfers
        log.info("RDMA Write: {}ms, Read: {}ms", writeTime, readTime);
    }
    
    @Test
    public void testRdmaFallbackToTcp() throws Exception {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/fscc/FileBasicInfoTest.java

            FileBasicInfo decoded = new FileBasicInfo();
            decoded.decode(buffer, 0, 36); // decode reads 36 bytes
    
            // Note: When encoding time 0, SMBUtil.writeTime writes 0 directly,
            // but SMBUtil.readTime interprets 0 as Jan 1, 1601 in Unix time (-11644473600000)
            // This is the expected behavior for Windows FILETIME
            long expectedTime = -11644473600000L; // Jan 1, 1601 in Unix time
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  8. cmd/mrf_gen.go

    				return
    			}
    		case "PoolIndex":
    			z.PoolIndex, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "PoolIndex")
    				return
    			}
    		case "Queued":
    			z.Queued, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "Queued")
    				return
    			}
    		case "BitrotScan":
    			z.BitrotScan, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "BitrotScan")
    				return
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  9. docs/en/docs/tutorial/body-nested-models.md

    So, in our example, we can make `tags` be specifically a "list of strings":
    
    {* ../../docs_src/body_nested_models/tutorial002_py310.py hl[12] *}
    
    ## Set types { #set-types }
    
    But then we think about it, and realize that tags shouldn't repeat, they would probably be unique strings.
    
    And Python has a special data type for sets of unique items, the `set`.
    
    Then we can declare `tags` as a set of strings:
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb1/com/SmbComNegotiateResponse.java

            bufferIndex += 4;
            this.server.scapabilities = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
            this.server.serverTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            int tzOffset = SMBUtil.readInt2(buffer, bufferIndex);
            // tzOffset is signed!
            if (tzOffset > Short.MAX_VALUE) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 15.8K bytes
    - Viewed (0)
Back to top