Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 60 for qsubs (0.04 sec)

  1. src/cmd/internal/obj/arm64/anames.go

    	"FRINTMS",
    	"FRINTND",
    	"FRINTNS",
    	"FRINTPD",
    	"FRINTPS",
    	"FRINTXD",
    	"FRINTXS",
    	"FRINTZD",
    	"FRINTZS",
    	"FSQRTD",
    	"FSQRTS",
    	"FSTPD",
    	"FSTPQ",
    	"FSTPS",
    	"FSUBD",
    	"FSUBS",
    	"HINT",
    	"HLT",
    	"HVC",
    	"IC",
    	"ISB",
    	"LDADDAB",
    	"LDADDAD",
    	"LDADDAH",
    	"LDADDALB",
    	"LDADDALD",
    	"LDADDALH",
    	"LDADDALW",
    	"LDADDAW",
    	"LDADDB",
    	"LDADDD",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 18 01:40:37 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub.go

    			if wg != nil {
    				wg.Done()
    			}
    			// Clean up and de-register the subscriber
    			ps.Lock()
    			defer ps.Unlock()
    			var remainTypes Mask
    			for i, s := range ps.subs {
    				if s == sub {
    					ps.subs = append(ps.subs[:i], ps.subs[i+1:]...)
    				} else {
    					remainTypes.Merge(s.types)
    				}
    			}
    			atomic.StoreUint64(&ps.types, uint64(remainTypes))
    			atomic.AddInt32(&ps.numSubscribers, -1)
    		}()
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. src/runtime/netpoll_wasip1.go

    	eventtype := s.u.eventtype()
    	switch mode {
    	case 'r':
    		*eventtype = eventtypeFdRead
    		ridx = len(subs)
    	case 'w':
    		*eventtype = eventtypeFdWrite
    		widx = len(subs)
    	}
    
    	if len(subs) == disarmed {
    		throw("overflow")
    	}
    
    	pd.user = uint32(ridx)<<16 | uint32(widx)
    
    	subs = append(subs, s)
    	evts = append(evts, event{})
    
    	unlock(&mtx)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 18:23:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/util/version.go

    	var bucketURL, urlSuffix string
    	subs := kubeBucketPrefixes.FindAllStringSubmatch(version, 1)
    	if len(subs) != 1 || len(subs[0]) != 4 {
    		return "", "", errors.Errorf("invalid version %q", version)
    	}
    
    	switch {
    	case strings.HasPrefix(subs[0][2], "ci"):
    		// Just use whichever the user specified
    		urlSuffix = subs[0][2]
    		bucketURL = kubeCIBucketURL
    	default:
    		urlSuffix = "release"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 10:50:19 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/preflight/utils.go

    	}
    
    	cleanOutput := strings.TrimSpace(string(out))
    	subs := kubeletVersionRegex.FindAllStringSubmatch(cleanOutput, -1)
    	if len(subs) != 1 || len(subs[0]) < 2 {
    		return nil, errors.Errorf("Unable to parse output from Kubelet: %q", cleanOutput)
    	}
    	return version.ParseSemantic(subs[0][1])
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 07 07:51:36 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  6. pilot/pkg/xds/workload.go

    			addresses = updatedAddresses.IntersectInPlace(subs)
    		}
    	}
    
    	if !w.Wildcard {
    		// We only need this for on-demand. This allows us to subscribe the client to resources they
    		// didn't explicitly request.
    		// For wildcard, they subscribe to everything already.
    		additional := e.Server.Env.ServiceDiscovery.AdditionalPodSubscriptions(proxy, addresses, subs)
    		if addresses == nil {
    			addresses = sets.New[string]()
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 14:14:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  7. src/regexp/all_test.go

    	b.StartTimer()
    	b.ReportAllocs()
    	for i := 0; i < b.N; i++ {
    		subs := re.FindSubmatch(s)
    		if string(subs[0]) != wantSubs {
    			b.Fatalf("FindSubmatch(%q)[0] = %q; want %q", s, subs[0], wantSubs)
    		}
    		if string(subs[1]) != "aab" {
    			b.Fatalf("FindSubmatch(%q)[1] = %q; want %q", s, subs[1], "aab")
    		}
    	}
    }
    
    func BenchmarkFindStringSubmatch(b *testing.B) {
    	b.StopTimer()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:36:03 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  8. platforms/documentation/docs/src/docs/userguide/releases/installation.adoc

    This is identifiable by the presence of the `gradlew` or `gradlew.bat` files in the root of the project:
    
    [listing,subs=+macros]
    ----
    .   // <1>
    ├── gradle
    │   └── wrapper // <2>
    ├── gradlew         // <3>
    ├── gradlew.bat     // <3>
    └── ⋮
    ----
    <1> Project root directory.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Feb 05 18:33:11 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. platforms/documentation/docs/src/docs/userguide/reference/gradle_wrapper.adoc

    [listing,subs=+attributes]
    ----
    $ gradle wrapper --gradle-version {gradleVersion} --distribution-type all
    include::{snippetsPath}/wrapper/simple/tests/wrapperCommandLine.out[]
    ----
    
    As a result, you can find the desired information (the generated distribution URL) in the Wrapper properties file:
    
    [source,properties,subs=+attributes]
    ----
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Mar 04 16:15:50 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  10. src/cmd/vendor/github.com/ianlancetaylor/demangle/demangle.go

    		} else {
    			// Merge adjacent qualifiers.  This case
    			// happens with multi-dimensional array types.
    			if qsub, ok := ret.(*TypeWithQualifiers); ok {
    				q = mergeQualifiers(q, qsub.Qualifiers)
    				ret = qsub.Base
    			}
    			ret = &TypeWithQualifiers{Base: ret, Qualifiers: q}
    		}
    		st.subs.add(ret)
    	}
    
    	return ret
    }
    
    // demangleCastTemplateArgs is for a rather hideous parse.  When we
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 94.1K bytes
    - Viewed (0)
Back to top