- Sort Score
- Result 10 results
- Languages All
Results 311 - 320 of 527 for channels (0.07 sec)
-
pom.xml
</goals> </execution> </executions> <configuration> <addDefaultLicenseMatchers>true</addDefaultLicenseMatchers> <excludes> <exclude>pom.xml</exclude> <exclude>breaking-changes.xml</exclude> <exclude>README.md</exclude> <exclude>build.properties</exclude> <exclude>src/test/resources/**</exclude> <exclude>**/*.idl</exclude> <exclude>**/*.css</exclude>
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu Sep 26 04:40:32 UTC 2024 - 9.3K bytes - Viewed (0) -
ci/official/utilities/setup.sh
# limitations under the License. # ============================================================================== # # Common setup for all TF scripts. # # Make as FEW changes to this file as possible. It should not contain utility # functions (except for tfrun); use dedicated scripts instead and reference them # specifically. Use your best judgment to keep the scripts in this directory
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Aug 07 23:01:25 UTC 2024 - 6K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
// re-acquire conflicting fields owned by other people. optional bool force = 2; // fieldManager is a name associated with the actor or entity // that is making these changes. The value must be less than or // 128 characters long, and only contain printable characters, // as defined by https://golang.org/pkg/unicode/#IsPrint. This // field is required. optional string fieldManager = 3;
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 53.3K bytes - Viewed (0) -
internal/event/target/postgresql.go
return store.ErrNotConnected } return err } } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.3K bytes - Viewed (0) -
src/main/java/jcifs/SidResolver.java
* to resolve SIDs using a cache and cache the results of any SIDs that * required resolving with the authority. SID cache entries are currently not * expired because under normal circumstances SID information never changes. * * @param tc * context to use * @param authorityServerName * The hostname of the server that should be queried. For maximum efficiency this should be the hostname
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/BiMap.java
*/ @Override Set<V> values(); /** * Returns the inverse view of this bimap, which maps each of this bimap's values to its * associated key. The two bimaps are backed by the same data; any changes to one will appear in * the other. * * <p><b>Note:</b>There is no guaranteed correspondence between the iteration order of a bimap and * that of its inverse. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Jun 17 14:40:53 UTC 2023 - 4.3K bytes - Viewed (0) -
cmd/handler-api.go
t.staleUploadsCleanupInterval = cfg.StaleUploadsCleanupInterval // signal that cleanup interval has changed select { case staleUploadsCleanupIntervalChangedCh <- struct{}{}: default: // in case the channel is blocked... } } } func (t *apiConfig) odirectEnabled() bool { t.mu.RLock() defer t.mu.RUnlock() return t.enableODirect } func (t *apiConfig) shouldGzipObjects() bool {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// does not exist in enough quorum nodes. func refreshLock(ctx context.Context, ds *Dsync, id, source string, quorum int) (bool, error) { restClnts, _ := ds.GetLockers() // Create buffered channel of size equal to total number of nodes. ch := make(chan refreshResult, len(restClnts)) var wg sync.WaitGroup args := LockArgs{ UID: id, } for index, c := range restClnts { wg.Add(1)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0) -
ci/official/utilities/code_check_full.bats
} @test "API compatibility test passes, ensuring no unexpected changes to the TF API" { bazel test $TFCI_BAZEL_COMMON_ARGS //tensorflow/tools/api/tests:api_compatibility_test echo "You have to re-generate the TF API goldens and have the API changes reviewed." echo "Look at the instructions for ':api_compatibility_test -- --update_goldens=True'" }
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Oct 23 18:48:35 UTC 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
Example: ` # Verify that Istio can be installed or upgraded istioctl x precheck # Check only a single namespace istioctl x precheck --namespace default # Check for behavioral changes since a specific version istioctl x precheck --from-version 1.10`, RunE: func(cmd *cobra.Command, args []string) (err error) { msgs := diag.Messages{} if !skipControlPlane { msgs, err = checkControlPlane(ctx)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 24 02:31:32 UTC 2024 - 15.3K bytes - Viewed (0)