Search Options

Results per page
Sort
Preferred Languages
Advance

Results 481 - 490 of 1,184 for varr (0.06 sec)

  1. cmd/erasure-common.go

    package cmd
    
    import (
    	"context"
    	"math/rand"
    	"sync"
    	"time"
    )
    
    func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	for _, i := range r.Perm(len(disks)) {
    		i := i
    		wg.Add(1)
    		go func() {
    			defer wg.Done()
    			if disks[i] == nil {
    				return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. internal/rest/rpc-stats.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package rest
    
    import (
    	"net/http"
    	"net/http/httptrace"
    	"sync/atomic"
    	"time"
    )
    
    var globalStats = struct {
    	errs uint64
    
    	tcpDialErrs                 uint64
    	tcpDialCount                uint64
    	tcpDialTotalDur             uint64
    	tcpTimeForFirstByteTotalDur uint64
    }{}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. internal/jwt/parser_test.go

    	"fmt"
    	"testing"
    	"time"
    
    	"github.com/golang-jwt/jwt/v4"
    )
    
    var (
    	defaultKeyFunc = func(claim *MapClaims) ([]byte, error) { return []byte("HelloSecret"), nil }
    	emptyKeyFunc   = func(claim *MapClaims) ([]byte, error) { return nil, nil }
    	errorKeyFunc   = func(claim *MapClaims) ([]byte, error) { return nil, fmt.Errorf("error loading key") }
    )
    
    var jwtTestData = []struct {
    	name        string
    	tokenString string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Nov 05 19:20:08 UTC 2021
    - 6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

      private val sink: BufferedSink,
      private val client: Boolean,
    ) : Closeable {
      internal val lock: ReentrantLock = ReentrantLock()
    
      private val hpackBuffer: Buffer = Buffer()
      private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE
      private var closed: Boolean = false
      val hpackWriter: Hpack.Writer = Hpack.Writer(out = hpackBuffer)
    
      @Throws(IOException::class)
      fun connectionPreface() {
        this.withLock {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    // of MinIO server.
    func isValidLocation(location string) bool {
    	region := globalSite.Region()
    	return region == "" || region == location
    }
    
    // Supported headers that needs to be extracted.
    var supportedHeaders = []string{
    	"content-type",
    	"cache-control",
    	"content-language",
    	"content-encoding",
    	"content-disposition",
    	"x-amz-storage-class",
    	xhttp.AmzStorageClass,
    	xhttp.AmzObjectTagging,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  6. docs/debugging/s3-verify/main.go

    	tobj, _, _, err := core.GetObject(context.Background(), targetBucket, tgtCtnt.Key, opts)
    	if err != nil {
    		fmt.Printf("unreadable on target: %s (%s)\n", tgtCtnt.Key, err)
    		return false
    	}
    
    	var sourceFailed, targetFailed bool
    	var wg sync.WaitGroup
    
    	wg.Add(2)
    	go func() {
    		defer wg.Done()
    		srcSize, err := io.Copy(srcSha256, sobj)
    		if err != nil {
    			fmt.Printf("unreadable on source: %s (%s)\n", srcCtnt.Key, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  7. internal/dsync/dsync-server_test.go

    package dsync
    
    import (
    	"fmt"
    	"io"
    	"net/http"
    	"net/http/httptest"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/minio/mux"
    )
    
    const numberOfNodes = 5
    
    var (
    	ds          *Dsync
    	nodes       = make([]*httptest.Server, numberOfNodes) // list of node IP addrs or hostname with ports.
    	lockServers = make([]*lockServer, numberOfNodes)
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  8. cmd/grid.go

    	"github.com/minio/minio/internal/rest"
    )
    
    // globalGrid is the global grid manager.
    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalLockGrid is the global lock grid manager.
    var globalLockGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. docs/auditlog/auditlog-echo.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package main
    
    import (
    	"bytes"
    	"encoding/json"
    	"flag"
    	"fmt"
    	"io"
    	"log"
    	"net/http"
    )
    
    var port int
    
    func init() {
    	flag.IntVar(&port, "port", 8080, "Port to listen on")
    }
    
    func mainHandler(w http.ResponseWriter, r *http.Request) {
    	body, err := io.ReadAll(r.Body)
    	defer r.Body.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. src/archive/zip/writer.go

    		var mbuf [9]byte // 2*SizeOf(uint16) + SizeOf(uint8) + SizeOf(uint32)
    		mt := uint32(fh.Modified.Unix())
    		eb := writeBuf(mbuf[:])
    		eb.uint16(extTimeExtraID)
    		eb.uint16(5)  // Size: SizeOf(uint8) + SizeOf(uint32)
    		eb.uint8(1)   // Flags: ModTime
    		eb.uint32(mt) // ModTime
    		fh.Extra = append(fh.Extra, mbuf[:]...)
    	}
    
    	var (
    		ow io.Writer
    		fw *fileWriter
    	)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top