- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 918 for syncs (0.04 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go
t.Parallel() var ( service Service err error data = []byte("test data") kubeAPIServerWG sync.WaitGroup kmsPluginWG sync.WaitGroup testCompletedWG sync.WaitGroup socketName = newEndpoint() ) testCompletedWG.Add(1) defer testCompletedWG.Done() ctx := testContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
See the License for the specific language governing permissions and limitations under the License. */ package generic import ( "context" goerrors "errors" "fmt" "sync" "sync/atomic" "time" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package nettest import ( "bytes" "encoding/binary" "io" "math/rand" "net" "runtime" "sync" "testing" "time" ) // MakePipe creates a connection between two endpoints and returns the pair // as c1 and c2, such that anything written to c1 is read by c2 and vice-versa.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K 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>,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
limitations under the License. */ package peerproxy import ( "context" "errors" "fmt" "math/rand" "net" "net/http" "net/url" "strconv" "strings" "sync" "sync/atomic" "k8s.io/api/apiserverinternal/v1alpha1" apierrors "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/runtime" schema "k8s.io/apimachinery/pkg/runtime/schema"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
src/cmd/trace/gen.go
// to trace.ResourceNone (the global scope). type globalRangeGenerator struct { ranges map[string]activeRange seenSync bool } // Sync notifies the generator of an EventSync event. func (g *globalRangeGenerator) Sync() { g.seenSync = true } // GlobalRange implements a handler for EventRange* events whose Scope.Kind is ResourceNone. // It expects ev to be one such event.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/kubelet/config/config.go
func (c *PodConfig) Updates() <-chan kubetypes.PodUpdate { return c.updates } // Sync requests the full configuration be delivered to the update channel. func (c *PodConfig) Sync() { c.pods.sync() } // podStorage manages the current pod state at any point in time and ensures updates
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
schema/relationship_test.go
package schema_test import ( "sync" "testing" "gorm.io/gorm" "gorm.io/gorm/schema" ) func checkStructRelation(t *testing.T, data interface{}, relations ...Relation) { if s, err := schema.Parse(data, &sync.Map{}, schema.NamingStrategy{}); err != nil { t.Errorf("Failed to parse schema, got error %v", err) } else { for _, rel := range relations { checkSchemaRelation(t, s, rel) } } }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Apr 15 03:20:20 UTC 2024 - 25.5K bytes - Viewed (0) -
src/go/internal/gcimporter/ureader.go
for i, n := 0, r.Len(); i < n; i++ { // As if r.obj(), but avoiding the Scope.Lookup call, // to avoid eager loading of imports. r.Sync(pkgbits.SyncObject) assert(!r.Bool()) r.p.objIdx(r.Reloc(pkgbits.RelocObj)) assert(r.Len() == 0) } r.Sync(pkgbits.SyncEOF) for _, fn := range pr.laterFns { fn() } for _, iface := range pr.ifaces { iface.Complete() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.6K 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)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Sep 16 09:28:06 UTC 2023 - 12.2K bytes - Viewed (0)