Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 599 for Refer (0.53 seconds)

  1. internal/jwt/parser.go

    		// keyFunc was not provided, return error.
    		return jwtgo.NewValidationError("no key was provided.", jwtgo.ValidationErrorUnverifiable)
    	}
    
    	bufp := base64BufPool.Get()
    	defer base64BufPool.Put(bufp)
    
    	tokenBuf := base64BufPool.Get()
    	defer base64BufPool.Put(tokenBuf)
    
    	token := *tokenBuf
    	// Copy token to buffer, truncate to length.
    	token = token[:copy(token[:base64BufferSize], tokenStr)]
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.1K bytes
    - Click Count (0)
  2. src/bytes/reader_test.go

    	// See golang.org/issue/7856
    	r := NewReader([]byte{})
    	var wg sync.WaitGroup
    	for i := 0; i < 5; i++ {
    		wg.Add(2)
    		go func() {
    			defer wg.Done()
    			var buf [1]byte
    			r.Read(buf[:])
    		}()
    		go func() {
    			defer wg.Done()
    			r.Read(nil)
    		}()
    	}
    	wg.Wait()
    }
    
    func TestReaderWriteTo(t *testing.T) {
    	for i := 0; i < 30; i += 3 {
    		var l int
    		if i > 0 {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Click Count (0)
  3. cmd/site-replication-metrics.go

    	Endpoint string `json:"-"`
    	// Secure is true if the replication target endpoint is secure
    	Secure bool `json:"-"`
    }
    
    func (sr *SRStats) update(st replStat, dID string) {
    	sr.lock.Lock()
    	defer sr.lock.Unlock()
    	srs, ok := sr.M[dID]
    	if !ok {
    		srs = &SRStatus{
    			XferRateLrg: newXferStats(),
    			XferRateSml: newXferStats(),
    		}
    	}
    	srs.Endpoint = st.Endpoint
    	srs.Secure = st.Secure
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  4. internal/cachevalue/cache_test.go

    package cachevalue
    
    import (
    	"context"
    	"errors"
    	"testing"
    	"time"
    )
    
    func slowCaller(ctx context.Context) error {
    	sl := time.NewTimer(time.Second)
    	defer sl.Stop()
    
    	select {
    	case <-sl.C:
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    
    	return nil
    }
    
    func TestCacheCtx(t *testing.T) {
    	cache := New[time.Time]()
    	t.Parallel()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  5. cmd/bucket-lifecycle-handlers.go

    // https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lifecycle-mgmt.html
    func (api objectAPIHandlers) PutBucketLifecycleHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketLifecycle")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 7K bytes
    - Click Count (0)
  6. internal/config/lambda/target/webhook.go

    // Send - sends an event to the webhook.
    func (target *WebhookTarget) Send(eventData event.Event) (resp *http.Response, err error) {
    	atomic.AddInt64(&target.activeRequests, 1)
    	defer atomic.AddInt64(&target.activeRequests, -1)
    
    	atomic.AddInt64(&target.totalRequests, 1)
    	defer func() {
    		if err != nil {
    			atomic.AddInt64(&target.failedRequests, 1)
    		}
    	}()
    
    	if err = target.init(); err != nil {
    		return nil, err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 08 21:39:49 GMT 2024
    - 6.7K bytes
    - Click Count (0)
  7. cmd/erasure-decode.go

    	if p.offset+p.shardSize > p.shardFileSize {
    		p.shardSize = p.shardFileSize - p.offset
    	}
    	if p.shardSize == 0 {
    		return newBuf, nil
    	}
    
    	readTriggerCh := make(chan bool, len(p.readers))
    	defer xioutil.SafeClose(readTriggerCh) // close the channel upon return
    
    	for i := 0; i < p.dataBlocks; i++ {
    		// Setup read triggers for p.dataBlocks number of reads so that it reads in parallel.
    		readTriggerCh <- true
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 29 01:40:52 GMT 2024
    - 9.5K bytes
    - Click Count (0)
  8. cmd/update_test.go

    	httpServer1 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))
    	defer httpServer1.Close()
    	httpServer2 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		fmt.Fprintln(w, "fbe246edbd382902db9a4035df7dce8cb441357d minio.RELEASE.2016-10-07T01-16-39Z")
    	}))
    	defer httpServer2.Close()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  9. cmd/erasure-object-conditional_test.go

    func TestPutObjectConditionalWithReadQuorumFailure(t *testing.T) {
    	ctx := context.Background()
    
    	obj, fsDirs, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer obj.Shutdown(context.Background())
    	defer removeRoots(fsDirs)
    
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    
    	bucket := "test-bucket"
    	object := "test-object"
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  10. cmd/object-multipart-handlers.go

    //   - X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key
    func (api objectAPIHandlers) NewMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "NewMultipartUpload")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 07 16:13:09 GMT 2025
    - 39.5K bytes
    - Click Count (1)
Back to Top