Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 123 for readAll (0.05 seconds)

  1. cmd/xl-storage_test.go

    		{
    			volume: "ab",
    			path:   "as-file",
    			err:    errVolumeNotFound,
    		},
    	}
    
    	var dataRead []byte
    	// Run through all the test cases and validate for ReadAll.
    	for i, testCase := range testCases {
    		dataRead, err = xlStorage.ReadAll(t.Context(), testCase.volume, testCase.path)
    		if err != testCase.err {
    			t.Errorf("TestXLStorage %d: Expected err \"%v\", got err \"%v\"", i+1, testCase.err, err)
    			continue
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 66K bytes
    - Click Count (0)
  2. api/go1.19.txt

    pkg go/doc, func Synopsis //deprecated #51082
    pkg go/doc, func ToHTML //deprecated #51082
    pkg go/doc, func ToText //deprecated #51082
    pkg io/ioutil, func NopCloser //deprecated #42026
    pkg io/ioutil, func ReadAll //deprecated #42026
    pkg io/ioutil, func ReadDir //deprecated #42026
    pkg io/ioutil, func ReadFile //deprecated #42026
    pkg io/ioutil, func TempDir //deprecated #42026
    pkg io/ioutil, func TempFile //deprecated #42026
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Dec 02 16:29:41 GMT 2022
    - 17.9K bytes
    - Click Count (0)
  3. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/rest/compat/RestCompatTestTransformTask.java

            for (File file : getTestFiles().getFiles()) {
                YAMLParser yamlParser = YAML_FACTORY.createParser(file);
                List<ObjectNode> tests = READER.<ObjectNode>readValues(yamlParser).readAll();
                List<ObjectNode> transformRestTests;
                if (skippedFilesWithReason.containsKey(file)) {
                    //skip all the tests in the file
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Sep 30 16:30:48 GMT 2021
    - 22.3K bytes
    - Click Count (0)
  4. cmd/xl-storage-disk-id-check.go

    		done(int64(sz), &err)
    	}()
    
    	return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result []byte, err error) {
    		return p.storage.ReadAll(ctx, volume, path)
    	})
    }
    
    func (p *xlStorageDiskIDCheck) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadXL, volume, path)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  5. cmd/storage-rest-server.go

    			if err == io.EOF {
    				return nil
    			}
    			return err
    		case 1:
    			errorText, err := io.ReadAll(respBody)
    			if err != nil {
    				return err
    			}
    			return errors.New(string(errorText))
    		case 2:
    			// Block of data
    			var tmp [4]byte
    			_, err := io.ReadFull(respBody, tmp[:])
    			if err != nil {
    				return err
    			}
    			length := binary.LittleEndian.Uint32(tmp[:])
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  6. cmd/xl-storage.go

    		buf = buf[:sz]
    	} else {
    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    	_, err = io.ReadFull(f, buf)
    
    	return buf, stat.ModTime().UTC(), osErrToFileErr(err)
    }
    
    // ReadAll is a raw call, reads content at any path and returns the buffer.
    func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  7. internal/config/crypto.go

    // ciphertext.
    func EncryptBytes(k *kms.KMS, plaintext []byte, context kms.Context) ([]byte, error) {
    	ciphertext, err := Encrypt(k, bytes.NewReader(plaintext), context)
    	if err != nil {
    		return nil, err
    	}
    	return io.ReadAll(ciphertext)
    }
    
    // DecryptBytes decrypts the ciphertext using a key managed by the KMS.
    // The same context that have been used during encryption must be
    // provided.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  8. internal/ioutil/read_file.go

    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, err
    	}
    	defer f.Close()
    	st, err := f.Stat()
    	if err != nil {
    		return io.ReadAll(f)
    	}
    	dst := make([]byte, st.Size())
    	_, err = io.ReadFull(f, dst)
    	return dst, err
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  9. src/bufio/bufio_test.go

    		})
    	}
    }
    
    func TestReaderReset(t *testing.T) {
    	checkAll := func(r *Reader, want string) {
    		t.Helper()
    		all, err := io.ReadAll(r)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if string(all) != want {
    			t.Errorf("ReadAll returned %q, want %q", all, want)
    		}
    	}
    
    	r := NewReader(strings.NewReader("foo foo"))
    	buf := make([]byte, 3)
    	r.Read(buf)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  10. internal/config/crypto_test.go

    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    		data, err := io.ReadAll(ciphertext)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encrypt stream: %v", i, err)
    		}
    
    		plaintext, err := Decrypt(KMS, bytes.NewReader(data), test.Context)
    		if err != nil {
    			t.Fatalf("Test %d: failed to decrypt stream: %v", i, err)
    		}
    		data, err = io.ReadAll(plaintext)
    		if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.2K bytes
    - Click Count (0)
Back to Top