Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 833 for context_b (0.05 seconds)

  1. cmd/background-newdisks-heal-ops.go

    	// Be sure that they are included in toHealingDisk
    }
    
    // loadHealingTracker will load the healing tracker from the supplied disk.
    // The disk ID will be validated against the loaded one.
    func loadHealingTracker(ctx context.Context, disk StorageAPI) (*healingTracker, error) {
    	if disk == nil {
    		return nil, errors.New("loadHealingTracker: nil drive given")
    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  2. internal/ioutil/ioutil_test.go

    	_, err := w.Write([]byte("1"))
    	if err != context.DeadlineExceeded {
    		t.Error("DeadlineWriter shouldn't be successful - should return context.DeadlineExceeded")
    	}
    	_, err = w.Write([]byte("1"))
    	if err != context.DeadlineExceeded {
    		t.Error("DeadlineWriter shouldn't be successful - should return context.DeadlineExceeded")
    	}
    	w.Close()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  3. cmd/sftp-server-driver.go

    	}
    	ok, err := clnt.BucketExists(r.Context(), bucket)
    	if err != nil {
    		return nil, err
    	}
    	if !ok {
    		return nil, os.ErrNotExist
    	}
    
    	pr, pw := io.Pipe()
    
    	wa := &writerAt{
    		buffer: make(map[int64][]byte),
    		w:      pw,
    		r:      pr,
    		wg:     &sync.WaitGroup{},
    	}
    	wa.wg.Add(1)
    	go func() {
    		oi, err := clnt.PutObject(r.Context(), bucket, object, pr, -1, minio.PutObjectOptions{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Feb 10 16:35:49 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  4. cmd/erasure-encode_test.go

    	return nil, errFaultyDisk
    }
    
    func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error {
    	return errFaultyDisk
    }
    
    func (badDisk) Hostname() string {
    	return ""
    }
    
    const oneMiByte = 1 * humanize.MiByte
    
    var erasureEncodeTests = []struct {
    	dataBlocks                   int
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  5. cmd/admin-handlers-pools.go

    		return
    	}
    
    	status, err := pools.Status(r.Context(), idx)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	adminLogIf(r.Context(), json.NewEncoder(w).Encode(&status))
    }
    
    func (a adminAPIHandlers) ListPools(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  6. cmd/object-api-multipart_test.go

    	err = obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{})
    	if err != nil {
    		// failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	res, err := obj.NewMultipartUpload(context.Background(), bucket, "\\", opts)
    	if err != nil {
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	err = obj.AbortMultipartUpload(context.Background(), bucket, "\\", res.UploadID, opts)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
  7. internal/lsync/lrwmutex_test.go

    package lsync_test
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"sync"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	. "github.com/minio/minio/internal/lsync"
    )
    
    func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
    	ctx := t.Context()
    	lrwm := NewLRWMutex()
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  8. api/maven-api-core/src/main/java/org/apache/maven/api/services/RequestTrace.java

     * application-specific data to provide context when invoking session methods.</p>
     *
     * <p>This trace information is particularly useful for:</p>
     * <ul>
     *   <li>Debugging and troubleshooting request flows</li>
     *   <li>Audit logging of session operations</li>
     *   <li>Performance monitoring of nested operations</li>
     * </ul>
     *
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  9. cmd/veeam-sos-api.go

    		return false
    	}
    }
    
    // isVeeamClient - returns true if the request is from Veeam client.
    func isVeeamClient(ctx context.Context) bool {
    	ri := logger.GetReqInfo(ctx)
    	return ri != nil && strings.Contains(ri.UserAgent, veeamAgentSubstr)
    }
    
    func veeamSOSAPIHeadObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) {
    	gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 15 00:34:56 GMT 2024
    - 8.8K bytes
    - Click Count (0)
  10. .github/workflows/create_issue.js

      @param {!object}
        github enables querying for PR and also create issue using rest endpoint
        context has the commit message details in the payload
      @return {string} Returns the issue number and title
    */
    module.exports = async ({github, context}) => {
      const rollback_commit = context.payload.head_commit.id;
      const pr_match_groups = context.payload.head_commit.message.match(/\Rollback of PR #(\d+).*/) || [];
      if (pr_match_groups.length != 2) {
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Oct 18 23:04:59 GMT 2021
    - 2.8K bytes
    - Click Count (0)
Back to Top