Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 49 for xioutil (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. cmd/metacache-server-pool.go

    				funcReturnedMu.Lock()
    				returned = funcReturned
    				funcReturnedMu.Unlock()
    				outCh <- entry
    				if returned {
    					xioutil.SafeClose(outCh)
    				}
    			}
    			entry.reusable = returned
    			saveCh <- entry
    		}
    		if !returned {
    			xioutil.SafeClose(outCh)
    		}
    		xioutil.SafeClose(saveCh)
    	}()
    
    	entries, err = filteredResults()
    	if err == nil {
    		// Check if listing recorded an error.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  7. cmd/s3-zip-handlers.go

    		return
    	}
    	// s3zip does not allow ranges
    	w.Header().Del(xhttp.AcceptRanges)
    
    	setHeadGetRespHeaders(w, r.Form)
    
    	httpWriter := xioutil.WriteOnClose(w)
    
    	// Write object content to response body
    	if _, err = xioutil.Copy(httpWriter, rc); err != nil {
    		if !httpWriter.HasWritten() {
    			// write error response only if no data or headers has been written to client yet
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  8. cmd/object-api-interface.go

    	"github.com/minio/minio-go/v7/pkg/encrypt"
    	"github.com/minio/minio-go/v7/pkg/tags"
    	"github.com/minio/minio/internal/hash"
    
    	"github.com/minio/minio/internal/bucket/replication"
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    //go:generate msgp -file $GOFILE -io=false -tests=false -unexported=false
    
    //msgp:ignore ObjectOptions TransitionOptions DeleteBucketOptions
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  9. cmd/admin-handlers-site-replication.go

    	"context"
    	"encoding/gob"
    	"encoding/json"
    	"errors"
    	"io"
    	"net/http"
    	"strings"
    	"sync/atomic"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/madmin-go/v3"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    )
    
    // SiteReplicationAdd - PUT /minio/admin/v3/site-replication/add
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  10. internal/logger/target/http/http.go

    	"net/url"
    	"os"
    	"path/filepath"
    	"strconv"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	jsoniter "github.com/json-iterator/go"
    	xhttp "github.com/minio/minio/internal/http"
    	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: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
Back to Top