Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for Sendfile (0.35 sec)

  1. guava/src/com/google/common/io/ByteStreams.java

        return new byte[BUFFER_SIZE];
      }
    
      /**
       * There are three methods to implement {@link FileChannel#transferTo(long, long,
       * WritableByteChannel)}:
       *
       * <ol>
       *   <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output
       *       channel have their own file descriptors. Generally this only happens when both channels
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  2. cmd/sftp-server_test.go

    				suite.SFTPPublicKeyAuthNoPubKey(c)
    
    				suite.TearDownSuite(c)
    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) SFTPFailedPublicKeyAuthenticationInvalidKey(c *check) {
    	keyBytes, err := os.ReadFile("./testdata/invalid_test_key.pub")
    	if err != nil {
    		c.Fatalf("could not read test key file: %s", err)
    	}
    
    	testKey, _, _, _, err := ssh.ParseAuthorizedKey(keyBytes)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Feb 27 18:43:32 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  3. scripts/mkdocs_hooks.py

        material_langs_path = material_path / "templates" / "partials" / "languages"
        langs = [file.stem for file in material_langs_path.glob("*.html")]
        return langs
    
    
    class EnFile(File):
        pass
    
    
    def on_config(config: MkDocsConfig, **kwargs: Any) -> MkDocsConfig:
        available_langs = get_mkdocs_material_langs()
        dir_path = Path(config.docs_dir)
        lang = dir_path.parent.name
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 21:25:59 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  4. internal/kms/config.go

    				// if so, decrypt it using the user-provided password.
    				certBytes, err := os.ReadFile(certFile)
    				if err != nil {
    					return tls.Certificate{}, fmt.Errorf("Unable to load KES client certificate as specified by the shell environment: %v", err)
    				}
    				keyBytes, err := os.ReadFile(keyFile)
    				if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15K bytes
    - Viewed (0)
  5. cmd/naughty-disk_test.go

    	}
    	return d.disk.ListDir(ctx, origvolume, volume, dirPath, count)
    }
    
    func (d *naughtyDisk) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) {
    	if err := d.calcError(); err != nil {
    		return 0, err
    	}
    	return d.disk.ReadFile(ctx, volume, path, offset, buf, verifier)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbNamedPipe.java

     * <li><code>TransactNamedPipe</code> A message-type pipe call that
     * writes to and reads from an existing pipe descriptor in one operation.
     * <li><code>CreateFile</code>, <code>ReadFile</code>,
     * <code>WriteFile</code>, and <code>CloseFile</code> A byte-type pipe can
     * be opened, written to, read from and closed using the standard Win32
     * file operations.
     * </ul>
     *
     * <p>
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

     * <li> <code>TransactNamedPipe</code> A message-type pipe call that
     *      writes to and reads from an existing pipe descriptor in one operation.
     * <li> <code>CreateFile</code>, <code>ReadFile</code>,
     *      <code>WriteFile</code>, and <code>CloseFile</code> A byte-type pipe can
     *      be opened, written to, read from and closed using the standard Win32
     *      file operations.
     * </ul>
     *
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  8. internal/s3select/json/preader_test.go

    	}
    }
    
    func BenchmarkPReader(b *testing.B) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		b.Fatal(err)
    	}
    	for _, file := range files {
    		b.Run(file.Name(), func(b *testing.B) {
    			f, err := os.ReadFile(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				b.Fatal(err)
    			}
    			b.SetBytes(int64(len(f)))
    			b.ReportAllocs()
    			b.ResetTimer()
    			var record sql.Record
    			for b.Loop() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  9. internal/s3select/json/reader_test.go

    	}
    }
    
    func BenchmarkReader(b *testing.B) {
    	files, err := os.ReadDir("testdata")
    	if err != nil {
    		b.Fatal(err)
    	}
    	for _, file := range files {
    		b.Run(file.Name(), func(b *testing.B) {
    			f, err := os.ReadFile(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				b.Fatal(err)
    			}
    			b.SetBytes(int64(len(f)))
    			b.ReportAllocs()
    			b.ResetTimer()
    			var record sql.Record
    			for b.Loop() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  10. cmd/handler-api.go

    const (
    	cgroupV1MemLimitFile = "/sys/fs/cgroup/memory/memory.limit_in_bytes"
    	cgroupV2MemLimitFile = "/sys/fs/cgroup/memory.max"
    )
    
    func cgroupMemLimit() (limit uint64) {
    	buf, err := os.ReadFile(cgroupV2MemLimitFile)
    	if err != nil {
    		buf, err = os.ReadFile(cgroupV1MemLimitFile)
    	}
    	if err != nil {
    		return 0
    	}
    	limit, err = strconv.ParseUint(strings.TrimSpace(string(buf)), 10, 64)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top