Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 65 for xioutil (0.04 seconds)

  1. internal/store/store.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"strconv"
    	"strings"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    const (
    	retryInterval = 3 * time.Second
    )
    
    type logger = func(ctx context.Context, err error, id string, errKind ...any)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  2. internal/grid/muxserver.go

    }
    
    func (m *muxServer) close() {
    	m.cancel()
    	m.recvMu.Lock()
    	defer m.recvMu.Unlock()
    
    	if m.inbound != nil {
    		xioutil.SafeClose(m.inbound)
    		m.inbound = nil
    	}
    
    	if m.outBlock != nil {
    		xioutil.SafeClose(m.outBlock)
    		m.outBlock = nil
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  3. cmd/bitrot.go

    	// Calculate the size of the bitrot file and compare
    	// it with the actual file size.
    	if left != bitrotShardFileSize(partSize, shardSize, algo) {
    		return errFileCorrupt
    	}
    
    	bufp := xioutil.ODirectPoolSmall.Get()
    	defer xioutil.ODirectPoolSmall.Put(bufp)
    
    	for left > 0 {
    		// Read expected hash...
    		h.Reset()
    		n, err := io.ReadFull(r, hashBuf)
    		if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  4. cmd/perf-tests.go

    						errOnce.Do(func() {
    							retError = err.Error()
    						})
    					}
    					downloadsCancel()
    					return
    				}
    				fbr := firstByteRecorder{
    					r: r,
    				}
    				n, err := xioutil.Copy(xioutil.Discard, &fbr)
    				r.Close()
    				if err == nil {
    					response := time.Since(t)
    					ttfb := time.Since(*fbr.t)
    					// Only capture success criteria - do not
    					// have to capture failed reads, truncated
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  5. cmd/speedtest.go

    import (
    	"context"
    	"fmt"
    	"net/url"
    	"runtime"
    	"sort"
    	"time"
    
    	"github.com/minio/dperf/pkg/dperf"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    const speedTest = "speedtest"
    
    type speedTestOpts struct {
    	objectSize       int
    	concurrencyStart int
    	concurrency      int
    	duration         time.Duration
    	autotune         bool
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  6. cmd/handler-api.go

    		// Returns 75% of max memory allowed
    		maxMem := globalServerCtxt.MemLimit
    
    		// max requests per node is calculated as
    		// total_ram / ram_per_request
    		blockSize := xioutil.LargeBlock + xioutil.SmallBlock
    		if legacy {
    			// ram_per_request is (1MiB+32KiB) * driveCount \
    			//    + 2 * 10MiB (default erasure block size v1) + 2 * 1MiB (default erasure block size v2)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  7. cmd/erasure.go

    import (
    	"context"
    	"errors"
    	"fmt"
    	"maps"
    	"math/rand"
    	"os"
    	"runtime"
    	"sort"
    	"sync"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/dsync"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    // list all errors that can be ignore in a bucket operation.
    var bucketOpIgnoredErrs = append(baseIgnoredErrs, errDiskAccessDenied, errUnformattedDisk)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  8. cmd/metacache-walk.go

    package cmd
    
    import (
    	"context"
    	"errors"
    	"io"
    	"sort"
    	"strings"
    
    	"github.com/minio/minio/internal/grid"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/valyala/bytebufferpool"
    )
    
    //go:generate msgp -file $GOFILE
    
    // WalkDirOptions provides options for WalkDir operations.
    type WalkDirOptions struct {
    	// Bucket to scanner
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon May 26 07:06:43 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  9. internal/logger/target/kafka/kafka.go

    	"encoding/json"
    	"errors"
    	"fmt"
    	"log"
    	"os"
    	"path/filepath"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/IBM/sarama"
    	saramatls "github.com/IBM/sarama/tools/tls"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    	types "github.com/minio/minio/internal/logger/target/loggertypes"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  10. internal/grid/muxclient.go

    	defer m.respMu.Unlock()
    	if !m.closed {
    		m.respErr.Store(&err)
    		// Do not block.
    		select {
    		case respHandler <- Response{Err: err}:
    			xioutil.SafeClose(respHandler)
    		default:
    			go func() {
    				respHandler <- Response{Err: err}
    				xioutil.SafeClose(respHandler)
    			}()
    		}
    		gridLogIf(m.ctx, m.sendLocked(message{Op: OpDisconnectServerMux, MuxID: m.MuxID}))
    		m.closed = true
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
Back to Top