- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 1,111 for sync (0.03 seconds)
-
tests/go.mod
github.com/microsoft/go-mssqldb v1.9.3 // indirect github.com/pmezard/go-difflib v1.0.0 // indirect github.com/tjfoc/gmsm v1.4.1 // indirect golang.org/x/crypto v0.43.0 // indirect golang.org/x/sync v0.17.0 // indirect golang.org/x/text v0.30.0 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect )
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sun Nov 02 14:09:18 GMT 2025 - 1.3K bytes - Click Count (0) -
cmd/site-replication-metrics.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" "sync" "sync/atomic" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio-go/v7" ) //go:generate msgp -file $GOFILE // RStat has replication error stats type RStat struct {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.2K bytes - Click Count (0) -
cmd/erasure-decode.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" "io" "sync" "sync/atomic" xioutil "github.com/minio/minio/internal/ioutil" ) // Reads in parallel from readers. type parallelReader struct { readers []io.ReaderAt orgReaders []io.ReaderAt dataBlocks int
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 29 01:40:52 GMT 2024 - 9.5K bytes - Click Count (0) -
cmd/lock-rest-server-common_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "os" "reflect" "sync" "testing" "github.com/minio/minio/internal/dsync" ) // Helper function to create a lock server for testing func createLockTestServer(ctx context.Context, t *testing.T) (string, *lockRESTServer, string) { obj, fsDir, err := prepareFS(ctx)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 3.2K bytes - Click Count (0) -
internal/store/batch.go
package store import ( "context" "errors" "sync" "time" ) // ErrBatchFull indicates that the batch is full var ErrBatchFull = errors.New("batch is full") const defaultCommitTimeout = 30 * time.Second // Batch represents an ordered batch type Batch[I any] struct { items []I limit uint32 store Store[I] quitCh chan struct{} sync.Mutex } // BatchConfig represents the batch config
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 2.9K bytes - Click Count (0) -
internal/dsync/drwmutex_test.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 dsync import ( "context" "fmt" "runtime" "sync/atomic" "testing" "time" ) const ( id = "1234-5678" source = "main.go" ) func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.4K bytes - Click Count (0) -
cmd/bucket-metadata-sys.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/policy" "github.com/minio/pkg/v3/sync/errgroup" "golang.org/x/sync/singleflight" ) // BucketMetadataSys captures all bucket metadata for a given cluster. type BucketMetadataSys struct { objAPI ObjectLayer sync.RWMutex initialized bool group *singleflight.Group metadataMap map[string]BucketMetadata }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.4K bytes - Click Count (0) -
internal/config/subnet/config.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package subnet import ( "net/http" "net/url" "os" "strings" "sync" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v3/env" xnet "github.com/minio/pkg/v3/net" ) const ( baseURL = "https://subnet.min.io" baseURLDev = "http://localhost:9000" )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.9K bytes - Click Count (0) -
src/buildall.bash
if [ "$GOARCH" = "arm5" ]; then export GOARCH=arm export GOARM=5 fi # Build and vet everything. # cmd/go/internal/work/exec.go enables the same vet flags during go test of std cmd # and should be kept in sync with any vet flag changes here. if ! "$GOROOT/bin/go" build std cmd || ! "$GOROOT/bin/go" vet -unsafeptr=false std cmd; then failed=true if $sete; then exit 1 fi fi done
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Tue Apr 23 17:45:23 GMT 2024 - 2.1K bytes - Click Count (0) -
.github/workflows/deploy-docs.yml
with: enable-cache: true cache-dependency-glob: | pyproject.toml uv.lock - name: Install GitHub Actions dependencies run: uv sync --locked --no-dev --group github-actions - name: Deploy Docs Status Pending run: uv run ./scripts/deploy_docs_status.py env: GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Tue Mar 03 00:12:02 GMT 2026 - 2.7K bytes - Click Count (0)