- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 611 for channels (0.04 sec)
-
cmd/grid.go
// globalLockGrid is the global lock grid manager. var globalLockGrid atomic.Pointer[grid.Manager] // globalGridStart is a channel that will block startup of grid connections until closed. var globalGridStart = make(chan struct{}) // globalLockGridStart is a channel that will block startup of lock grid connections until closed. var globalLockGridStart = make(chan struct{})
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 16 14:27:42 UTC 2025 - 3.7K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild.binary-compatibility.gradle
} } } } // We support multiple accepted public api changes JSON files, but "accepted-public-api-changes.json" // is the "main" one that is also shown in HTML report def apiChangesJsonDirectory = layout.projectDirectory.dir("src/changes/accepted-changes") def compatibilityBaselineVersion = gradleModule.identity.releasedVersions.get().mostRecentRelease.versionRegistered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Tue Dec 30 10:14:25 UTC 2025 - 8.9K bytes - Viewed (0) -
internal/bpool/bpool_test.go
} bp.Put(b) // Check the size of the pool. if uint64(len(bp.c)) != size { t.Fatalf("bytepool size invalid: got %v want %v", len(bp.c), size) } // lets drain the buf channel first before we validate invalid buffers. for range size { bp.Get() // discard } // Try putting some invalid buffers into pool bp.Put(make([]byte, bp.w, bp.wcap-1)) // wrong capacity is rejected (less)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 2.7K bytes - Viewed (0) -
docs/en/docs/management-tasks.md
So, having a nice PR title will not only look nice in GitHub, but also in the release notes. 📝 ## Add Labels to PRs
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 14.2K bytes - Viewed (0) -
build-logic/binary-compatibility/src/test/groovy/gradlebuild/binarycompatibility/AcceptedApiChangesJsonFileManagerTest.groovy
} def "can clean existing API changes"() { given: jsonFile << existingAcceptedApiChanges() when: jsonFileManager.emptyAcceptedApiChanges(jsonFile) then: jsonFile.text == nonExistentAcceptedApiChanges() } def "can clean non-existing API changes"() { given: jsonFile << nonExistentAcceptedApiChanges()Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Tue Aug 17 08:32:56 UTC 2021 - 2.5K bytes - Viewed (0) -
src/main/java/jcifs/SmbWatchHandle.java
* implementations. * * Changes in between these calls (as long as the file is open) are buffered by the server, so iteratively calling * this method should provide all changes (size of that buffer can be adjusted through * {@link jcifs.Configuration#getNotifyBufferSize()}). * If the server cannot fulfill the request because the changes did not fit the buffer * it will return an empty list of changes.Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.3K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/AlphabeticalAcceptedApiChangesTask.kt
val messages = formattedMismatches.map { "API changes in file '${it.key.name}' should be in alphabetical order (by type and member), yet these changes were not:\n" + "$formattedMismatches\n" }.joinToString(separator = "\n") return "$messages\nTo automatically alphabetize these changes run: './gradlew :architecture-test:sortAcceptedApiChanges'" }Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Fri Nov 29 14:03:44 UTC 2024 - 2.5K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/EnrichedReportRenderer.groovy
* to quickly open the changes file. By then we can also regex that path out of the description * in order to create a changes {@link File} for further use in this class. * * @param data the report data containing a description to parse * @return accepted api changes reported upon, as a file */Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Tue Feb 07 20:38:43 UTC 2023 - 7.2K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.3.md
- [Other notable changes](#other-notable-changes-14) - [v1.3.0-alpha.3](#v130-alpha3) - [Downloads](#downloads-15) - [Changes since v1.3.0-alpha.2](#changes-since-v130-alpha2) - [Action Required](#action-required-4) - [Other notable changes](#other-notable-changes-15) - [v1.3.0-alpha.2](#v130-alpha2) - [Downloads](#downloads-16) - [Changes since v1.3.0-alpha.1](#changes-since-v130-alpha1)Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 84K bytes - Viewed (0) -
cmd/iam-etcd-store.go
if !ok { time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } if err := watchResp.Err(); err != nil { iamLogIf(ctx, err) // log and retry. time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } for _, event := range watchResp.Events {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0)