Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 1,106 for sync (0.14 sec)

  1. src/cmd/api/main_test.go

    	"go/ast"
    	"go/build"
    	"go/parser"
    	"go/token"
    	"go/types"
    	"internal/testenv"
    	"io"
    	"log"
    	"os"
    	"os/exec"
    	"path/filepath"
    	"regexp"
    	"runtime"
    	"slices"
    	"strconv"
    	"strings"
    	"sync"
    	"testing"
    )
    
    const verbose = false
    
    func goCmd() string {
    	var exeSuffix string
    	if runtime.GOOS == "windows" {
    		exeSuffix = ".exe"
    	}
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Feb 20 03:25:33 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer_test.go

    package ringbuffer
    
    import (
    	"bytes"
    	"errors"
    	"fmt"
    	"hash/crc32"
    	"io"
    	"math/rand"
    	"os"
    	"runtime"
    	"strings"
    	"sync"
    	"testing"
    	"time"
    )
    
    func TestRingBuffer_interface(t *testing.T) {
    	rb := New(1)
    	var _ io.Writer = rb
    	var _ io.Reader = rb
    	// var _ io.StringWriter = rb
    	var _ io.ByteReader = rb
    	var _ io.ByteWriter = rb
    }
    
    func TestRingBuffer_Write(t *testing.T) {
    	rb := New(64)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top