Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 76 for Stat (0.28 sec)

  1. internal/kms/single-key.go

    const ( // algorithms used to derive and encrypt DEKs
    	algorithmAESGCM           = "AES-256-GCM-HMAC-SHA-256"
    	algorithmChaCha20Poly1305 = "ChaCha20Poly1305"
    )
    
    func (kms secretKey) Stat(context.Context) (Status, error) {
    	return Status{
    		Name:       "SecretKey",
    		DefaultKey: kms.keyID,
    	}, nil
    }
    
    // IsLocal returns true if the KMS is a local implementation
    func (kms secretKey) IsLocal() bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    	currentSendCalls int64
    	// The number of total events per target
    	totalEvents int64
    	// The number of failed events per target
    	failedEvents int64
    }
    
    func (list *TargetList) getStatsByTargetID(id TargetID) (stat targetStat) {
    	list.statLock.RLock()
    	defer list.statLock.RUnlock()
    
    	return list.targetStats[id]
    }
    
    func (list *TargetList) incCurrentSendCalls(id TargetID) {
    	list.statLock.Lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  3. internal/lock/lock_windows.go

    	f, err := Open(path, flag, perm)
    	if err != nil {
    		return nil, err
    	}
    
    	if err = lockFile(syscall.Handle(f.Fd()), lockType); err != nil {
    		f.Close()
    		return nil, err
    	}
    
    	st, err := os.Stat(path)
    	if err != nil {
    		f.Close()
    		return nil, err
    	}
    
    	if st.IsDir() {
    		f.Close()
    		return nil, &os.PathError{
    			Op:   "open",
    			Path: path,
    			Err:  syscall.EISDIR,
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    func (api objectAPIHandlers) SelectObjectContentHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "SelectObject")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	// Fetch object stat info.
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	}
    	volumes := strings.Split(r.Form.Get(storageRESTVolumes), ",")
    	err := s.getStorage().MakeVolBulk(r.Context(), volumes...)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    	}
    }
    
    // StatVolHandler - stat a volume.
    func (s *storageRESTServer) StatVolHandler(params *grid.MSS) (*VolInfo, *grid.RemoteErr) {
    	if !s.checkID(params.Get(storageRESTDiskID)) {
    		return nil, grid.NewRemoteErr(errDiskNotFound)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    	// If the connection is lost, state will switch to StateConnecting.
    	StateConnected
    
    	// StateConnectionError is the state once a connection attempt has been made, and it failed.
    	// The connection will remain in this stat until the connection has been successfully re-established.
    	StateConnectionError
    
    	// StateShutdown is the state when the server has been shut down.
    	// This will not be used under normal operation.
    	StateShutdown
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  7. cmd/common-main.go

    		if file.Mode().IsRegular() || file.Name() == "CAs" || strings.HasPrefix(file.Name(), "..") {
    			continue
    		}
    		if file.Mode()&os.ModeSymlink == os.ModeSymlink {
    			file, err = Stat(filepath.Join(root.Name(), file.Name()))
    			if err != nil {
    				// not accessible ignore
    				continue
    			}
    			if !file.IsDir() {
    				continue
    			}
    		}
    
    		var (
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  8. cmd/bucket-replication.go

    	startTime := time.Now()
    	bucket := ri.Bucket
    	object := ri.Name
    
    	// set defaults for replication action based on operation being performed - actual
    	// replication action can only be determined after stat on remote. This default is
    	// needed for updating replication metrics correctly when target is offline.
    	rAction := replicateMetadata
    
    	rinfo = replicatedTargetInfo{
    		Size:                  ri.ActualSize,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  9. cmd/metrics-v3-system-process.go

    )
    
    func loadProcStatMetrics(ctx context.Context, stat procfs.ProcStat, m MetricValues) {
    	if stat.CPUTime() > 0 {
    		m.Set(processCPUTotalSeconds, float64(stat.CPUTime()))
    	}
    
    	if stat.ResidentMemory() > 0 {
    		m.Set(processResidentMemoryBytes, float64(stat.ResidentMemory()))
    	}
    
    	if stat.VirtualMemory() > 0 {
    		m.Set(processVirtualMemoryBytes, float64(stat.VirtualMemory()))
    	}
    
    	startTime, err := stat.StartTime()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 16:07:23 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  10. cmd/xl-storage_unix_test.go

    	if err = disk.MakeVol(context.Background(), testCase.volName); err != nil {
    		t.Fatalf("Creating a volume failed with %s expected to pass.", err)
    	}
    
    	// Stat to get permissions bits.
    	st, err := os.Stat(path.Join(tmpPath, testCase.volName))
    	if err != nil {
    		t.Fatalf("Stat failed with %s expected to pass.", err)
    	}
    
    	// Get umask of the bits stored.
    	currentUmask := 0o777 - uint32(st.Mode().Perm())
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 25 19:37:26 GMT 2022
    - 3.4K bytes
    - Viewed (0)
Back to top