- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 189 for Corkery (0.17 sec)
-
internal/config/errors.go
"Invalid value for replication workers", "", "MINIO_API_REPLICATION_WORKERS: should be > 0", ) ErrInvalidTransitionWorkersValue = newErrFn( "Invalid value for transition workers", "", "MINIO_API_TRANSITION_WORKERS: should be >= GOMAXPROCS/2", ) ErrInvalidBatchKeyRotationWorkersWait = newErrFn( "Invalid value for batch key rotation workers wait", "Please input a non-negative duration",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 22:25:32 GMT 2024 - 9.1K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc
BasicTestsForTwoDevices(context.get(), "/job:worker/replica:0/task:1/device:CPU:0", "/job:worker/replica:0/task:2/device:CPU:0"); worker_server1.release(); worker_server2.release(); } TEST(PARALLEL_DEVICE, TestAsyncCopyOff) { std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts(
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 22:09:57 GMT 2023 - 6.7K bytes - Viewed (0) -
cmd/data-scanner_test.go
es := newExpiryState(context.Background(), objAPI, 0) workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) globalExpiryState = es var wg sync.WaitGroup wg.Add(1) expired := make([]ObjectToDelete, 0, 5) go func() { defer wg.Done() workers := globalExpiryState.workers.Load() for t := range (*workers)[0] { if t, ok := t.(newerNoncurrentTask); ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
tensorflow/c/eager/c_api_cluster_test.cc
server_def.set_task_index(1); std::unique_ptr<tensorflow::GrpcServer> worker_server; ASSERT_TRUE(tensorflow::GrpcServer::Create( server_def, tensorflow::Env::Default(), &worker_server) .ok()); ASSERT_TRUE(worker_server->Start().ok()); TF_Status* status = TF_NewStatus(); TFE_ContextOptions* opts = TFE_NewContextOptions();
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Apr 14 10:03:59 GMT 2023 - 19.3K bytes - Viewed (0) -
internal/event/targetlist.go
return } } }() } wk.Wait() } var startOnce sync.Once // Init initialize target send workers. func (list *TargetList) Init(workers int) *TargetList { startOnce.Do(func() { go list.startSendWorkers(workers) }) return list } // NewTargetList - creates TargetList. func NewTargetList(ctx context.Context) *TargetList { list := &TargetList{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/config/api/api.go
apiRemoteTransportDeadline = "remote_transport_deadline" apiListQuorum = "list_quorum" apiReplicationPriority = "replication_priority" apiReplicationMaxWorkers = "replication_max_workers" apiTransitionWorkers = "transition_workers" apiStaleUploadsCleanupInterval = "stale_uploads_cleanup_interval" apiStaleUploadsExpiry = "stale_uploads_expiry" apiDeleteCleanupInterval = "delete_cleanup_interval"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
internal/config/heal/heal.go
const ( Bitrot = "bitrotscan" Sleep = "max_sleep" IOCount = "max_io" DriveWorkers = "drive_workers" EnvBitrot = "MINIO_HEAL_BITROTSCAN" EnvSleep = "MINIO_HEAL_MAX_SLEEP" EnvIOCount = "MINIO_HEAL_MAX_IO" EnvDriveWorkers = "MINIO_HEAL_DRIVE_WORKERS" ) var configMutex sync.RWMutex // Config represents the heal settings. type Config struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
build-logic/cleanup/src/test/groovy/gradlebuild/cleanup/services/LeakingProcessKillPatternTest.groovy
def projectDir = 'C:\\some\\agent\\workspace' expect:
Groovy - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Sep 28 07:00:39 GMT 2023 - 14.4K bytes - Viewed (0) -
android/guava/src/com/google/common/net/HttpHeaders.java
public static final String UNSAFE_URL = "unsafe-url"; } /** * The HTTP <a href="https://www.w3.org/TR/service-workers/#update-algorithm">{@code * Service-Worker}</a> header field name. * * @since 20.0 */ public static final String SERVICE_WORKER = "Service-Worker"; /** The HTTP {@code TE} header field name. */ public static final String TE = "TE";
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:08:08 GMT 2024 - 34.3K bytes - Viewed (0) -
docs/config/README.md
Each node is responsible of healing its local drives; Each drive will have multiple heal workers which is the quarter of the number of CPU cores of the node or the quarter of the configured nr_requests of the drive (https://www.kernel.org/doc/Documentation/block/queue-sysfs.txt). It is also possible to provide a custom number of workers by using this command: `mc admin config set alias/ heal drive_workers=100` . ``` ~ mc admin config set alias/ heal KEY:
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 11 21:48:54 GMT 2023 - 17.7K bytes - Viewed (0)