fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks
fs.s3a.multipart.size=512M # Size of each multipart chunk
fs.s3a.multipart.threshold=512M # Size before using multipart uploads
fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint
fs.s3a.socket.send.buffer=65536 # Write socket buffer hint
fs.s3a.threads.max=2048 # Maximum number of threads for S3A
```

            final SmbPipeInputStream in = getInput();
            out.write(buf, off, length);
            return in.read(inB);
        }
    }

    @Override
    public int recv(final byte[] buf, final int off, final int len) throws IOException {
        return getInput().readDirect(buf, off, len);

    }

    @Override

pkg go/doc/comment, type DocLink struct #51082
pkg go/doc/comment, type DocLink struct, ImportPath string #51082
pkg go/doc/comment, type DocLink struct, Name string #51082
pkg go/doc/comment, type DocLink struct, Recv string #51082
pkg go/doc/comment, type DocLink struct, Text []Text #51082
pkg go/doc/comment, type Heading struct #51082
pkg go/doc/comment, type Heading struct, Text []Text #51082
pkg go/doc/comment, type Italic string #51082

                    log.trace("Remote closed connection");
                } else if (timeout) {
                    log.debug("socket timeout in non peek state", ex);
                } else {
                    log.debug("recv failed", ex);
                }

                synchronized (this) {
                    try {
                        disconnect(!timeout, false);
                    } catch (final IOException ioe) {

	ctxt.SFTP = ctx.StringSlice("sftp")
	ctxt.Interface = ctx.String("interface")
	ctxt.UserTimeout = ctx.Duration("conn-user-timeout")
	ctxt.SendBufSize = ctx.Int("send-buf-size")
	ctxt.RecvBufSize = ctx.Int("recv-buf-size")
	ctxt.IdleTimeout = ctx.Duration("idle-timeout")
	ctxt.UserTimeout = ctx.Duration("conn-user-timeout")

	if conf := ctx.String("config"); len(conf) > 0 {
		err = mergeServerCtxtFromConfigFile(conf, ctxt)

pkg go/types, method (*Selection) Obj() Object
pkg go/types, method (*Selection) Recv() Type
pkg go/types, method (*Selection) String() string
pkg go/types, method (*Selection) Type() Type
pkg go/types, method (*Signature) Params() *Tuple
pkg go/types, method (*Signature) Recv() *Var
pkg go/types, method (*Signature) Results() *Tuple
pkg go/types, method (*Signature) String() string

		Hidden: true,
		EnvVar: "MINIO_MEMLIMIT",
	},
	cli.IntFlag{
		Name:   "send-buf-size",
		Value:  4 * humanize.MiByte,
		EnvVar: "MINIO_SEND_BUF_SIZE",
		Hidden: true,
	},
	cli.IntFlag{
		Name:   "recv-buf-size",
		Value:  4 * humanize.MiByte,
		EnvVar: "MINIO_RECV_BUF_SIZE",
		Hidden: true,
	},
	cli.StringFlag{
		Name:   "log-dir",
		Usage:  "specify the directory to save the server log",

pkg syscall (freebsd-386-cgo), type BpfProgram struct, Len uint32
pkg syscall (freebsd-386-cgo), type BpfStat struct
pkg syscall (freebsd-386-cgo), type BpfStat struct, Drop uint32
pkg syscall (freebsd-386-cgo), type BpfStat struct, Recv uint32
pkg syscall (freebsd-386-cgo), type BpfVersion struct
pkg syscall (freebsd-386-cgo), type BpfVersion struct, Major uint16
pkg syscall (freebsd-386-cgo), type BpfVersion struct, Minor uint16

pkg go/ast, const FilterImportDuplicates MergeMode
pkg go/ast, const FilterUnassociatedComments MergeMode
pkg go/ast, const Fun ObjKind
pkg go/ast, const Lbl ObjKind
pkg go/ast, const Pkg ObjKind
pkg go/ast, const RECV ChanDir
pkg go/ast, const SEND ChanDir
pkg go/ast, const Typ ObjKind
pkg go/ast, const Var ObjKind
pkg go/ast, func FileExports(*File) bool
pkg go/ast, func FilterDecl(Decl, Filter) bool

pkg syscall (freebsd-arm64), type BpfProgram struct, Pad_cgo_0 [4]uint8
pkg syscall (freebsd-arm64), type BpfStat struct
pkg syscall (freebsd-arm64), type BpfStat struct, Drop uint32
pkg syscall (freebsd-arm64), type BpfStat struct, Recv uint32
pkg syscall (freebsd-arm64), type BpfVersion struct
pkg syscall (freebsd-arm64), type BpfVersion struct, Major uint16
pkg syscall (freebsd-arm64), type BpfVersion struct, Minor uint16