- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 584 for sync (0.18 sec)
-
internal/grid/muxserver.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 grid import ( "context" "errors" "fmt" "sync" "sync/atomic" "time" xioutil "github.com/minio/minio/internal/ioutil" ) const lastPingThreshold = 4 * clientPingInterval type muxServer struct { ID uint64 LastPing int64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/consolelogger.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "container/ring" "context" "io" "sync" "sync/atomic" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/logger/target/console" "github.com/minio/minio/internal/logger/target/types"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
doc/go_mem.html
w() <-limit }(w) } select{} } </pre> <h3 id="locks">Locks</h3> <p> The <code>sync</code> package implements two lock data types, <code>sync.Mutex</code> and <code>sync.RWMutex</code>. </p> <p class="rule"> For any <code>sync.Mutex</code> or <code>sync.RWMutex</code> variable <code>l</code> and <i>n</i> < <i>m</i>,
HTML - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
internal/http/server.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (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?
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Mar 01 05:46:51 GMT 2024 - 17.7K bytes - Viewed (0) -
fastapi/concurrency.py
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Mon Dec 25 17:57:35 GMT 2023 - 1.4K bytes - Viewed (0) -
cmd/bucket-replication_test.go
}, } func TestReplicationResync(t *testing.T) { ctx := context.Background() for i, test := range replicationConfigTests { if sync := test.rcfg.Resync(ctx, test.info, test.dsc, test.tgtStatuses); sync.mustResync() != test.expectedSync { t.Errorf("Test%d (%s): Resync got %t , want %t", i+1, test.name, sync.mustResync(), test.expectedSync) } } } var ( start = UTCNow().AddDate(0, 0, -1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 16 09:28:06 GMT 2023 - 12.2K bytes - Viewed (0) -
internal/dsync/drwmutex.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" "errors" "math/rand" "sort" "strconv" "sync" "time" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/mcontext" "github.com/minio/pkg/v2/console" "github.com/minio/pkg/v2/env"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
internal/config/callhome/callhome.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 callhome import ( "sync" "time" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v2/env" ) // Callhome related keys const ( Enable = "enable" Frequency = "frequency" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.6K bytes - Viewed (0) -
schema/constraint_test.go
package schema_test import ( "reflect" "sync" "testing" "gorm.io/gorm/schema" "gorm.io/gorm/utils/tests" ) type UserCheck struct { Name string `gorm:"check:name_checker,name <> 'jinzhu'"` Name2 string `gorm:"check:name <> 'jinzhu'"` Name3 string `gorm:"check:,name <> 'jinzhu'"` } func TestParseCheck(t *testing.T) { user, err := schema.Parse(&UserCheck{}, &sync.Map{}, schema.NamingStrategy{}) if err != nil {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sun Feb 04 07:49:19 GMT 2024 - 2.2K bytes - Viewed (0)