Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 339 for Sync (0.02 sec)

  1. cmd/erasure-multipart.go

    	var wg sync.WaitGroup
    	for _, disk := range er.getLocalDisks() {
    		if disk != nil {
    			wg.Add(1)
    			go func(disk StorageAPI) {
    				defer wg.Done()
    				er.cleanupStaleUploadsOnDisk(ctx, disk)
    			}(disk)
    		}
    	}
    	wg.Wait()
    }
    
    func (er erasureObjects) deleteAll(ctx context.Context, bucket, prefix string) {
    	var wg sync.WaitGroup
    	for _, disk := range er.getDisks() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    	infos, err := globalSiteReplicationSys.GetClusterInfo(ctx)
    	if err != nil {
    		return results, err
    	}
    	var wg sync.WaitGroup
    	var resultsMu sync.RWMutex
    	for _, info := range infos.Sites {
    		// will call siteNetperf, means call others's adminAPISiteReplicationDevNull
    		if globalDeploymentID() == info.DeploymentID {
    			wg.Add(1)
    			go func() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 184.8K bytes
    - Viewed (1)
  3. docs/en/docs/advanced/generate-clients.md

    This makes it easy to generate up-to-date **documentation**, client libraries (<abbr title="Software Development Kits">**SDKs**</abbr>) in multiple languages, and **testing** or **automation workflows** that stay in sync with your code.
    
    In this guide, you'll learn how to generate a **TypeScript SDK** for your FastAPI backend.
    
    ## Open Source SDK Generators { #open-source-sdk-generators }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 10.1K bytes
    - Viewed (1)
  4. cmd/bucket-stats.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"maps"
    	"math"
    	"sync/atomic"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    //go:generate msgp -file $GOFILE
    
    // ReplicationLatency holds information of bucket operations latency, such us uploads
    type ReplicationLatency struct {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  5. internal/kms/secret-key.go

    package kms
    
    import (
    	"context"
    	"crypto/aes"
    	"crypto/cipher"
    	"crypto/hmac"
    	"encoding/base64"
    	"encoding/json"
    	"errors"
    	"strconv"
    	"strings"
    	"sync/atomic"
    
    	"github.com/secure-io/sio-go/sioutil"
    	"golang.org/x/crypto/chacha20"
    	"golang.org/x/crypto/chacha20poly1305"
    
    	"github.com/minio/kms-go/kms"
    	"github.com/minio/madmin-go/v3"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Apr 21 16:23:51 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  6. cmd/os_unix.go

    			nameStr = string(tmp)
    		}
    
    		count--
    		entries = append(entries, nameStr)
    	}
    
    	return entries, err
    }
    
    func globalSync() {
    	defer globalOSMetrics.time(osMetricSync)()
    	syscall.Sync()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  7. internal/http/listener_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"crypto/tls"
    	"net"
    	"runtime"
    	"strconv"
    	"strings"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	"github.com/minio/minio-go/v7/pkg/set"
    )
    
    var serverPort uint32 = 60000
    
    var getCert = func(*tls.ClientHelloInfo) (*tls.Certificate, error) {
    	certificate, err := getTLSCert()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    			}
    			if !disk.IsOnline() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  9. scripts/translate.py

            $ mkdir awesome-project
            // Gehe in dieses Projektverzeichnis
            $ cd awesome-project
            ```
            »»»
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 19:05:53 UTC 2025
    - 34.1K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/testdata/mips64.s

    //	}
    	ADDD	F1, F2, F3
    
    //	LFCMP freg ',' freg
    //	{
    //		outcode(int($1), &$2, 0, &$4);
    //	}
    	CMPEQD	F1, F2
    
    
    //
    // WORD
    //
    	WORD	$1	// 00000001
    	NOOP		// 00000000
    	SYNC		// 0000000f
    
    //
    // NOP
    //
    //	LNOP comma // asm doesn't support the trailing comma.
    //	{
    //		outcode(int($1), &nullgen, 0, &nullgen);
    //	}
    	NOP
    
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Aug 08 12:17:12 UTC 2023
    - 12.4K bytes
    - Viewed (0)
Back to top