- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for lris (0.02 sec)
-
cmd/local-locker.go
defer l.getMutex()() var readers, writers int32 for k, lris := range l.lockMap { modified := false for i := 0; i < len(lris); { lri := &lris[i] if time.Since(time.Unix(0, lri.TimeLastRefresh)) > interval { delete(l.lockUID, formatUUID(lri.UID, lri.idx)) if len(lris) == 1 { // Remove the write lock. delete(l.lockMap, lri.Name) modified = false break }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
cmd/admin-handlers_test.go
resource := fmt.Sprintf("bucket/get-object-%d", i) lri := lockRequesterInfo{ Name: resource, UID: mustGetUUID(), Owner: owners[i%len(owners)], Quorum: 2, } lris = append(lris, lri) locksHeld[resource] = append(locksHeld[resource], lri) // concurrent read lock, same resource different uid lri.UID = mustGetUUID() lris = append(lris, lri) locksHeld[resource] = append(locksHeld[resource], lri)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (1) -
cmd/lock-rest-server-common_test.go
lockRequesterInfo1, lockRequesterInfo2, } lri := locker.ll.lockMap["name"] // test unknown uid if locker.ll.removeEntry("name", dsync.LockArgs{ Owner: "owner", UID: "unknown-uid", }, &lri) { t.Errorf("Expected %#v, got %#v", false, true) } if !locker.ll.removeEntry("name", dsync.LockArgs{ Owner: "owner", UID: "0123-4567", }, &lri) { t.Errorf("Expected %#v, got %#v", true, false)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 3.2K bytes - Viewed (0) -
src/main/resources/fess_message_fr.properties
errors.invalid_query_sort_value = Le tri spécifié {0} n'est pas valide. errors.invalid_query_unsupported_sort_field = Le tri spécifié {0} n'est pas pris en charge. errors.invalid_query_unsupported_sort_order = L'ordre de tri spécifié {0} n'est pas pris en charge. errors.invalid_query_cannot_process=Impossible de traiter la requête spécifiée. errors.crud_invalid_mode = Le mode est incorrect. (pas {0}, mais {1})Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 05 02:36:47 UTC 2025 - 13.1K bytes - Viewed (0) -
ci/official/envs/versions_upload
# ============================================================================== # Release jobs are very basic. They don't use any caching or RBE, # but they do upload logs to resultstore. # IMPORTANT: trailing slash is required on GCS URIs, as it tells gcloud to # pretend the path is a directory. TFCI_ARTIFACT_FINAL_GCS_ENABLE=1 TFCI_ARTIFACT_FINAL_GCS_SA_PATH="${KOKORO_KEYSTORE_DIR}/73361_tensorflow_release_binary_uploader_service_account"
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Tue Jul 29 02:07:51 UTC 2025 - 1.6K bytes - Viewed (0) -
cmd/fmt-gen.go
filesystem separated by space. You may also use a '...' convention to abbreviate the directory arguments. Remote directories in a distributed setup are encoded as HTTP(s) URIs. {{if .VisibleFlags}} FLAGS: {{range .VisibleFlags}}{{.}} {{end}}{{end}} EXAMPLES:
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/fileconfig/CreateForm.java
public String name; /** The description of the file configuration (maximum 1000 characters). */ @Size(max = 1000) public String description; /** The file paths to crawl (required, must be valid file URIs). */ @Required @UriType(protocolType = ProtocolType.FILE) @CustomSize(maxKey = "form.admin.max.input.size") public String paths; /** The paths to include during crawling (pattern-based). */Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 5.6K bytes - Viewed (0) -
ci/official/envs/nightly_upload
# See the License for the specific language governing permissions and # limitations under the License. # ============================================================================== # IMPORTANT: trailing slash is required on GCS URIs, as it tells gcloud to # pretend the path is a directory. # 1. Upload nightlies TFCI_ARTIFACT_FINAL_GCS_ENABLE=1 TFCI_ARTIFACT_FINAL_GCS_SA_PATH="${KOKORO_KEYSTORE_DIR}/73361_tensorflow_release_binary_uploader_service_account"Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Mon Jun 17 20:45:36 UTC 2024 - 1.7K bytes - Viewed (0) -
cmd/site-replication.go
if err != nil { return err } sris[depIdx[globalDeploymentID()]] = srInfo return nil }, func(deploymentID string, p madmin.PeerInfo) error { admClient, err := c.getAdminClient(ctx, deploymentID) if err != nil { switch err.(type) { case RemoteTargetConnectionErr: sris[depIdx[deploymentID]] = madmin.SRInfo{} return nil default:Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 184.7K bytes - Viewed (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheStrategy.kt
// As recommended by the HTTP RFC and implemented in Firefox, the max age of a document // should be defaulted to 10% of the document's age at the time it was served. Default // expiration dates aren't used for URIs containing a query. val servedMillis = servedDate?.time ?: sentRequestMillis val delta = servedMillis - lastModified!!.time return if (delta > 0L) delta / 10 else 0L } return 0LRegistered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 12K bytes - Viewed (0)