- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for newm1 (0.47 sec)
-
src/runtime/proc.go
checkdead() unlock(&sched.lock) for { lock(&newmHandoff.lock) for newmHandoff.newm != 0 { newm := newmHandoff.newm.ptr() newmHandoff.newm = 0 unlock(&newmHandoff.lock) for newm != nil { next := newm.schedlink.ptr() newm.schedlink = 0 newm1(newm) newm = next } lock(&newmHandoff.lock) } newmHandoff.waiting = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
pkg/config/analysis/diag/messages.go
func (ms *Messages) SortedDedupedCopy() Messages { newMs := append((*ms)[:0:0], *ms...) newMs.Sort() // Take advantage of the fact that the list is already sorted to dedupe // messages (any duplicates should be adjacent). var deduped Messages for _, m := range newMs { // Two messages are duplicates if they have the same string representation.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 02:47:46 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/config/mesh/watcher_test.go
assert.Equal(t, w.Mesh(), m) doneCh := make(chan struct{}, 1) var newM *meshconfig.MeshConfig w.AddMeshHandler(func() { newM = w.Mesh() close(doneCh) }) // Change the file to trigger the update. m.IngressClass = "foo" writeMessage(t, path, m) select { case <-doneCh: assert.Equal(t, newM, m) assert.Equal(t, w.Mesh(), newM) break case <-time.After(time.Second * 5):
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 3K bytes - Viewed (0) -
pkg/test/framework/components/authz/kube.go
ist, err := istio.Get(ctx) if err != nil { return err } // Now parse the provider YAML. newMC := &meshconfig.MeshConfig{} if err := protomarshal.ApplyYAML(providerYAML, newMC); err != nil { return err } providerNames := sets.New[string]() for _, p := range newMC.GetExtensionProviders() { providerNames.Insert(p.Name) } return ist.UpdateMeshConfig(ctx,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 7K bytes - Viewed (0) -
src/runtime/sys_windows_386.s
POPL SI POPL DI // remove callback parameters before return (as per Windows spec) POPL DX ADDL CX, SP PUSHL DX CLD RET // void tstart(M *newm); TEXT tstart<>(SB),NOSPLIT,$8-4 MOVL newm+0(FP), CX // m MOVL m_g0(CX), DX // g // Layout new m scheduler stack on os stack. MOVL SP, AX MOVL AX, (g_stack+stack_hi)(DX)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 21 15:56:43 UTC 2023 - 6.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/counter/file.go
if v, _, _, _ := current.lookup(name); v != nil { return v, nop } v, newM, err := current.newCounter(name) if err != nil { debugPrintf("newCounter %s: %v\n", name, err) return nil, nop } cleanup = nop if newM != nil { f.current.Store(newM) cleanup = f.invalidateCounters } return v, cleanup } // Open associates counting with the defaultFile.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 18.2K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java
// fill in domain md with actual version data ArtifactMetadata md = v.getMd(); ArtifactMetadata newMd = new ArtifactMetadata( md.getGroupId(), md.getArtifactId(), edge.getVersion(), md.getType(),
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 11:28:54 UTC 2023 - 8.2K bytes - Viewed (0) -
pkg/config/mesh/kubemesh/watcher_test.go
stop := test.NewStop(t) w := NewConfigMapWatcher(client, namespace, name, key, false, stop) client.RunAndWait(stop) var mu sync.Mutex newM := mesh.DefaultMeshConfig() w.AddMeshHandler(func() { mu.Lock() defer mu.Unlock() newM = w.Mesh() }) steps := []struct { added *v1.ConfigMap updated *v1.ConfigMap deleted *v1.ConfigMap expect *meshconfig.MeshConfig
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.7K bytes - Viewed (0) -
src/encoding/gob/type_test.go
} } func TestMapType(t *testing.T) { var m map[string]int mapStringInt := getTypeUnlocked("map", reflect.TypeOf(m)) var newm map[string]int newMapStringInt := getTypeUnlocked("map1", reflect.TypeOf(newm)) if mapStringInt != newMapStringInt { t.Errorf("second registration of map[string]int creates new type") } var b map[string]bool
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 01 14:26:13 UTC 2023 - 6.1K bytes - Viewed (0) -
src/runtime/sys_solaris_amd64.s
MOVQ (m_mOS+mOS_perrno)(BX), AX CMPQ AX, $0 JEQ skiperrno2 MOVL 0(AX), AX MOVQ AX, libcall_err(DI) skiperrno2: RET // uint32 tstart_sysvicall(M *newm); TEXT runtime·tstart_sysvicall(SB),NOSPLIT,$0 // DI contains first arg newm MOVQ m_g0(DI), DX // g // Make TLS entries point at g and m. get_tls(BX) MOVQ DX, g(BX) MOVQ DI, g_m(DX) // Layout new m scheduler stack on os stack.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 21 19:29:00 UTC 2023 - 6.4K bytes - Viewed (0)