- Sort Score
- Num 10 results
- Language All
Results 111 - 120 of 325 for Sync (0.02 seconds)
-
cmd/dynamic-timeouts_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 cmd import ( "math/rand" "runtime" "sync" "testing" "time" ) func TestDynamicTimeoutSingleIncrease(t *testing.T) { timeout := newDynamicTimeout(time.Minute, time.Second) initial := timeout.Timeout() for range dynamicTimeoutLogSize {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.2K bytes - Click Count (0) -
internal/config/browser/browser.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 browser import ( "fmt" "strconv" "sync" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v3/env" ) // Browser sub-system constants const ( // browserCSPPolicy setting name for Content-Security-Policy response header value
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jun 21 00:58:58 GMT 2024 - 5.9K bytes - Click Count (0) -
internal/config/identity/openid/provider/keycloak.go
"errors" "fmt" "net/http" "net/url" "path" "strings" "sync" ) // Token - parses the output from IDP id_token. type Token struct { AccessToken string `json:"access_token"` Expiry int `json:"expires_in"` } // KeycloakProvider implements Provider interface for KeyCloak Identity Provider. type KeycloakProvider struct { sync.Mutex oeConfig DiscoveryDoc client http.Client adminURL string
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jul 14 18:12:07 GMT 2024 - 4.6K bytes - Click Count (0) -
internal/dsync/drwmutex.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package dsync import ( "context" "errors" "math/rand" "slices" "sort" "strconv" "sync" "time" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/mcontext" "github.com/minio/pkg/v3/console" "github.com/minio/pkg/v3/env" ) // Indicator if logging is enabled.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.3K bytes - Click Count (0) -
internal/grid/debug.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package grid import ( "context" "fmt" "net" "net/http" "net/http/httptest" "sync" "time" "github.com/minio/mux" ) //go:generate stringer -type=debugMsg $GOFILE // debugMsg is a debug message for testing purposes. // may only be used for tests. type debugMsg int const (
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
tests/prepared_stmt_test.go
package tests_test import ( "context" "errors" "sync" "testing" "time" "gorm.io/gorm" . "gorm.io/gorm/utils/tests" ) func TestPreparedStmt(t *testing.T) { tx := DB.Session(&gorm.Session{PrepareStmt: true}) if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok { t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode") }
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Apr 25 08:22:26 GMT 2025 - 8K bytes - Click Count (0) -
cmd/data-scanner_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "encoding/xml" "fmt" "slices" "strings" "sync" "testing" "time" "github.com/google/uuid" "github.com/minio/minio/internal/amztime" "github.com/minio/minio/internal/bucket/lifecycle" objectlock "github.com/minio/minio/internal/bucket/object/lock"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12K bytes - Click Count (0) -
src/bytes/reader_test.go
// Copyright 2012 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package bytes_test import ( . "bytes" "fmt" "io" "sync" "testing" ) func TestReader(t *testing.T) { r := NewReader([]byte("0123456789")) tests := []struct { off int64 seek int n int want string wantpos int64 readerr error
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 13 18:45:54 GMT 2021 - 8K bytes - Click Count (0) -
api/go1.18.txt
pkg strings, func Clone(string) string pkg strings, func Cut(string, string) (string, string, bool) pkg strings, func Title //deprecated pkg sync, method (*Mutex) TryLock() bool pkg sync, method (*RWMutex) TryLock() bool pkg sync, method (*RWMutex) TryRLock() bool pkg syscall (freebsd-386), type SysProcAttr struct, Pdeathsig Signal pkg syscall (freebsd-386-cgo), type SysProcAttr struct, Pdeathsig Signal
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Feb 17 20:31:46 GMT 2023 - 13K bytes - Click Count (0) -
internal/store/queuestore.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package store import ( "bytes" "encoding/json" "errors" "os" "path/filepath" "sort" "sync" "time" "github.com/google/uuid" jsoniter "github.com/json-iterator/go" "github.com/klauspost/compress/s2" "github.com/valyala/bytebufferpool" ) const ( defaultLimit = 100000 // Default store limit.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (0)