Search Options

Results per page
Sort
Preferred Languages
Advance

Results 891 - 900 of 1,387 for funcs (0.02 sec)

  1. cmd/shared-lock.go

    				break keepLock
    			case ld.lockContext <- lkctx:
    				// Send the lock context to anyone asking for it
    			}
    		}
    	}
    }
    
    func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) {
    	ctx, cancel := context.WithCancel(context.Background())
    	go func() {
    		select {
    		case <-ctx1.Done():
    		case <-ctx2.Done():
    		// The lock acquirer decides to cancel, exit this goroutine
    		case <-ctx.Done():
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. cmd/xl-storage_unix_test.go

    	"syscall"
    	"testing"
    )
    
    // Based on `man getumask` a vaporware GNU extension to glibc.
    // returns file mode creation mask.
    func getUmask() int {
    	mask := syscall.Umask(0)
    	syscall.Umask(mask)
    	return mask
    }
    
    // Tests if the directory and file creations happen with proper umask.
    func TestIsValidUmaskVol(t *testing.T) {
    	tmpPath := t.TempDir()
    	testCases := []struct {
    		volName       string
    		expectedUmask int
    	}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  3. istioctl/pkg/dashboard/dashboard_test.go

    		Namespace: "istio-system",
    	}))
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.Args, " ")), func(t *testing.T) {
    			testutil.VerifyOutput(t, dbCmd, c)
    			cleanupTestCase()
    		})
    	}
    }
    
    func cleanupTestCase() {
    	labelSelector = ""
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Nov 21 01:17:24 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users.go

    // ImportIAM - imports all IAM info into MinIO
    func (a adminAPIHandlers) ImportIAM(w http.ResponseWriter, r *http.Request) {
    	a.importIAM(w, r, "")
    }
    
    // ImportIAMV2 - imports all IAM info into MinIO
    func (a adminAPIHandlers) ImportIAMV2(w http.ResponseWriter, r *http.Request) {
    	a.importIAM(w, r, "v2")
    }
    
    // ImportIAM - imports all IAM info into MinIO
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  5. cmd/metrics-v3-system-drive.go

    		"Average time for write requests served on a drive",
    		allDriveLabels...)
    	drivePercUtilMD = NewGaugeMD(drivePercUtil,
    		"Percentage of time the disk was busy",
    		allDriveLabels...)
    )
    
    func getCurrentDriveIOStats() map[string]madmin.DiskIOStats {
    	var types madmin.MetricType = madmin.MetricsDisk
    	driveRealtimeMetrics := collectLocalMetrics(types, collectMetricsOpts{
    		hosts: map[string]struct{}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  6. tensorflow/c/eager/c_api_unified_experimental_test.cc

      ASSERT_EQ(h->FullType().type_id(), TFT_UNSET);
      ASSERT_EQ(unwrap(inputs[0])->FullType().type_id(), TFT_UNSET);
    
      // Clean up operation and inputs.
      TF_DeleteAbstractOp(add_op);
    
      TF_AbstractFunction* func =
          TF_FinalizeFunction(graph_ctx, add_outputs, status.get());
      ASSERT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get());
      // Note: TF_OutputList does not own the underlying AbstractTensors, those
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 39.1K bytes
    - Viewed (0)
  7. cmd/xl-storage_test.go

    	}
    
    	for _, testCase := range testCases {
    		gotErr := checkPathLength(testCase.path)
    		t.Run("", func(t *testing.T) {
    			if gotErr != testCase.expectedErr {
    				t.Errorf("Expected %s, got %s", testCase.expectedErr, gotErr)
    			}
    		})
    	}
    }
    
    // Tests validate volume name.
    func TestIsValidVolname(t *testing.T) {
    	testCases := []struct {
    		volName    string
    		shouldPass bool
    	}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  8. internal/config/help.go

    	MultipleTargets bool `json:"multipleTargets"`
    }
    
    // HelpKVS - implement order of keys help messages.
    type HelpKVS []HelpKV
    
    // Lookup - lookup a key from help kvs.
    func (hkvs HelpKVS) Lookup(key string) (HelpKV, bool) {
    	for _, hkv := range hkvs {
    		if hkv.Key == key {
    			return hkv, true
    		}
    	}
    	return HelpKV{}, false
    }
    
    // DefaultComment used across all sub-systems.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 23 14:45:27 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  9. cni/pkg/repair/repair.go

    package repair
    
    import (
    	"context"
    
    	"istio.io/istio/cni/pkg/config"
    	"istio.io/istio/cni/pkg/scopes"
    	"istio.io/istio/pkg/kube"
    )
    
    var repairLog = scopes.CNIAgent
    
    func StartRepair(ctx context.Context, cfg config.RepairConfig) {
    	if !cfg.Enabled {
    		repairLog.Info("CNI repair controller is disabled")
    		return
    	}
    	repairLog.Info("starting CNI sidecar repair controller")
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. cmd/bucket-replication-utils_gen.go

    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z MRFReplicateEntry) Msgsize() (s int) {
    	s = 1 + 2 + msgp.StringPrefixSize + len(z.Bucket) + 2 + msgp.StringPrefixSize + len(z.Object) + 3 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *ReplicateDecision) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 61.1K bytes
    - Viewed (0)
Back to top