Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 1,106 for sync (0.15 sec)

  1. 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{}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  2. 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"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 21 04:25:07 UTC 2025
    - 10K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    	"encoding/json"
    	"errors"
    	"fmt"
    	"io/fs"
    	"os"
    	"sync"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio/internal/color"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/config/storageclass"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    const (
    	// Represents Erasure backend.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
  4. cmd/admin-handlers_test.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/json"
    	"fmt"
    	"io"
    	"net/http"
    	"net/http/httptest"
    	"net/url"
    	"sort"
    	"sync"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/mux"
    )
    
    // adminErasureTestBed - encapsulates subsystems that need to be setup for
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  5. misc/go_android_exec/main.go

    package main
    
    import (
    	"bytes"
    	"errors"
    	"fmt"
    	"io"
    	"log"
    	"os"
    	"os/exec"
    	"os/signal"
    	"path"
    	"path/filepath"
    	"regexp"
    	"runtime"
    	"strconv"
    	"strings"
    	"sync"
    	"syscall"
    )
    
    func adbRun(args string) (int, error) {
    	// The exit code of adb is often wrong. In theory it was fixed in 2016
    	// (https://code.google.com/p/android/issues/detail?id=3254), but it's
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Aug 21 17:46:57 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/sync/errgroup"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/minio/pkg/v3/workers"
    	"github.com/puzpuzpuz/xsync/v3"
    )
    
    type erasureServerPools struct {
    	poolMetaMutex sync.RWMutex
    	poolMeta      poolMeta
    
    	rebalMu     sync.RWMutex
    	rebalMeta   *rebalanceMeta
    	rebalCancel context.CancelFunc
    
    	deploymentID     [16]byte
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    	diskInfoCache *cachevalue.Cache[DiskInfo]
    	sync.RWMutex
    	formatData []byte
    
    	nrRequests   uint64
    	major, minor uint32
    	fsType       string
    
    	immediatePurge       chan string
    	immediatePurgeCancel context.CancelFunc
    
    	// mutex to prevent concurrent read operations overloading walks.
    	rotational bool
    	walkMu     *sync.Mutex
    	walkReadMu *sync.Mutex
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  8. cmd/grid.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 (
    	"context"
    	"crypto/tls"
    	"sync/atomic"
    
    	"github.com/minio/minio/internal/crypto"
    	"github.com/minio/minio/internal/grid"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/rest"
    )
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    package cmd
    
    import (
    	"context"
    	"encoding/base64"
    	"encoding/binary"
    	"errors"
    	"fmt"
    	"io"
    	"maps"
    	"math/rand"
    	"net/http"
    	"net/url"
    	"path"
    	"reflect"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/encrypt"
    	"github.com/minio/minio-go/v7/pkg/tags"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  10. cmd/bucket-lifecycle.go

    package cmd
    
    import (
    	"context"
    	"encoding/xml"
    	"errors"
    	"fmt"
    	"io"
    	"maps"
    	"net/http"
    	"strconv"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/tags"
    	"github.com/minio/minio/internal/amztime"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
Back to top