Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 1,111 for sync (0.02 seconds)

  1. tests/test_router_events.py

    
    def test_merged_mixed_state_lifespans() -> None:
        @asynccontextmanager
        async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
            yield
    
        @asynccontextmanager
        async def router_lifespan(app: FastAPI) -> AsyncGenerator[dict[str, bool], None]:
            yield {"router": True}
    
        @asynccontextmanager
        async def sub_router_lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
            yield
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 09:59:14 GMT 2026
    - 11.7K bytes
    - Click Count (0)
  2. cmd/prepare-storage.go

    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"net/http"
    	"net/url"
    	"path/filepath"
    	"sync"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    var printEndpointError = func() func(Endpoint, error, bool) {
    	var mutex sync.Mutex
    	printOnce := make(map[Endpoint]map[string]int)
    
    	return func(endpoint Endpoint, err error, once bool) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  3. cmd/notification.go

    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"math/rand"
    	"net/http"
    	"net/url"
    	"runtime"
    	"sync"
    	"time"
    
    	"github.com/cespare/xxhash/v2"
    	"github.com/klauspost/compress/zip"
    	"github.com/minio/madmin-go/v3"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	xnet "github.com/minio/pkg/v3/net"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"github.com/minio/pkg/v3/workers"
    
    	"github.com/minio/minio/internal/bucket/bandwidth"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  4. internal/event/target/amqp.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package target
    
    import (
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"net"
    	"net/url"
    	"os"
    	"path/filepath"
    	"sync"
    
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v3/net"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (0)
  5. api/go1.21.txt

    pkg slices, func SortStableFunc[$0 interface{ ~[]$1 }, $1 interface{}]($0, func($1, $1) int) #60091
    pkg strings, func ContainsFunc(string, func(int32) bool) bool #54386
    pkg sync, func OnceFunc(func()) func() #56102
    pkg sync, func OnceValue[$0 interface{}](func() $0) func() $0 #56102
    pkg sync, func OnceValues[$0 interface{}, $1 interface{}](func() ($0, $1)) func() ($0, $1) #56102
    pkg syscall (freebsd-386-cgo), type SysProcAttr struct, Jail int #46259
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Aug 07 09:39:17 GMT 2023
    - 25.6K bytes
    - Click Count (0)
  6. cmd/erasure-sets.go

    	"net/http"
    	"reflect"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/dchest/siphash"
    	"github.com/google/uuid"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio-go/v7/pkg/tags"
    	"github.com/minio/minio/internal/dsync"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"github.com/puzpuzpuz/xsync/v3"
    )
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  7. cmd/handler-api.go

    	"os"
    	"runtime"
    	"slices"
    	"strconv"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/shirou/gopsutil/v3/mem"
    
    	"github.com/minio/minio/internal/config/api"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/mcontext"
    )
    
    type apiConfig struct {
    	mu sync.RWMutex
    
    	requestsPool           chan struct{}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  8. cmd/tier.go

    // TierConfigMgr holds the collection of remote tiers configured in this deployment.
    type TierConfigMgr struct {
    	sync.RWMutex `msg:"-"`
    	drivercache  map[string]WarmBackend `msg:"-"`
    
    	Tiers           map[string]madmin.TierConfig `json:"tiers"`
    	lastRefreshedAt time.Time                    `msg:"-"`
    }
    
    type tierMetrics struct {
    	sync.RWMutex  // protects requestsCount only
    	requestsCount map[string]struct {
    		success int64
    		failure int64
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  9. cmd/background-newdisks-heal-ops.go

    	}
    	h.disk = disk
    	h.ID = diskID
    	h.mu = &sync.RWMutex{}
    	return &h, nil
    }
    
    // newHealingTracker will create a new healing tracker for the disk.
    func newHealingTracker() *healingTracker {
    	return &healingTracker{
    		mu: &sync.RWMutex{},
    	}
    }
    
    func initHealingTracker(disk StorageAPI, healID string) *healingTracker {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  10. api/go1.25.txt

    pkg runtime/trace, type FlightRecorderConfig struct #63185
    pkg runtime/trace, type FlightRecorderConfig struct, MaxBytes uint64 #63185
    pkg runtime/trace, type FlightRecorderConfig struct, MinAge time.Duration #63185
    pkg sync, method (*WaitGroup) Go(func()) #63796
    pkg testing, method (*B) Attr(string, string) #43936
    pkg testing, method (*B) Output() io.Writer #59928
    pkg testing, method (*F) Attr(string, string) #43936
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 02 16:09:57 GMT 2025
    - 6.8K bytes
    - Click Count (0)
Back to Top