- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 325 for Sync (0.03 seconds)
-
internal/logger/target/kafka/kafka.go
package kafka import ( "context" "crypto/tls" "crypto/x509" "encoding/json" "errors" "fmt" "log" "os" "path/filepath" "sync" "sync/atomic" "time" "github.com/IBM/sarama" saramatls "github.com/IBM/sarama/tools/tls" xioutil "github.com/minio/minio/internal/ioutil" types "github.com/minio/minio/internal/logger/target/loggertypes"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
prepare_stmt.go
package gorm import ( "context" "database/sql" "database/sql/driver" "errors" "reflect" "sync" "time" "gorm.io/gorm/internal/stmt_store" ) type PreparedStmtDB struct { Stmts stmt_store.Store Mux *sync.RWMutex ConnPool } // NewPreparedStmtDB creates and initializes a new instance of PreparedStmtDB. // // Parameters:
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Apr 25 08:22:26 GMT 2025 - 5.7K bytes - Click Count (0) -
cmd/metacache-manager.go
var localMetacacheMgr = &metacacheManager{ buckets: make(map[string]*bucketMetacache), trash: make(map[string]metacache), } type metacacheManager struct { mu sync.RWMutex init sync.Once buckets map[string]*bucketMetacache trash map[string]metacache // Recently deleted lists. } const metacacheMaxEntries = 5000 // initManager will start async saving the cache.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Click Count (0) -
internal/logger/target/http/http.go
workers atomic.Int64 maxWorkers int64 // workerStartMu sync.Mutex lastStarted time.Time wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan any logChMu sync.RWMutex // If this webhook is being re-configured we will
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0) -
cmd/post-policy-fan-out.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 ( "bytes" "context" "maps" "sync" "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/tags" "github.com/minio/minio/internal/crypto" "github.com/minio/minio/internal/hash" xhttp "github.com/minio/minio/internal/http"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.5K bytes - Click Count (0) -
cmd/bucket-replication-stats.go
Cache map[string]*BucketReplicationStats mostRecentStats BucketStatsMap registry metrics.Registry sync.RWMutex // mutex for Cache mostRecentStatsMu sync.Mutex // mutex for mostRecentStats wlock sync.RWMutex // mutex for active workers movingAvgTicker *time.Ticker // Ticker for calculating moving averages
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 13.6K bytes - Click Count (0) -
src/archive/tar/stat_unix.go
//go:build unix package tar import ( "io/fs" "os/user" "runtime" "strconv" "sync" "syscall" ) func init() { sysStat = statUnix } // userMap and groupMap caches UID and GID lookups for performance reasons. // The downside is that renaming uname or gname by the OS never takes effect. var userMap, groupMap sync.Map // map[int]string func statUnix(fi fs.FileInfo, h *Header, doNameLookups bool) error {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 3.2K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleUserManualPlugin.java
task.getDestinationDirectory().convention(layout.getBuildDirectory().dir("tmp/" + task.getName())); }); TaskProvider<Sync> userguideFlattenSources = tasks.register("stageUserguideSource", Sync.class, task -> { task.setDuplicatesStrategy(DuplicatesStrategy.FAIL); // TODO: This doesn't allow adoc files to be generated?
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Thu Dec 04 14:26:28 GMT 2025 - 19.3K bytes - Click Count (0) -
internal/dsync/dsync_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" "math/rand" "os" "sync" "testing" "time" "github.com/google/uuid" ) const ( testDrwMutexAcquireTimeout = 250 * time.Millisecond testDrwMutexRefreshCallTimeout = 250 * time.Millisecond
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.8K bytes - Click Count (0) -
internal/s3select/json/reader.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 json import ( "io" "sync" "github.com/minio/minio/internal/s3select/jstream" "github.com/minio/minio/internal/s3select/sql" ) // Limit single document size to 10MiB, 10x the AWS limit:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.2K bytes - Click Count (0)