Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 377 for acquired (0.25 sec)

  1. pkg/scheduler/internal/queue/scheduling_queue.go

    		p.movePodsToActiveOrBackoffQueue(logger, p.getUnschedulablePodsWithMatchingAffinityTerm(logger, newPod), AssignedPodUpdate, oldPod, newPod)
    	}
    	p.lock.Unlock()
    }
    
    // NOTE: this function assumes a lock has been acquired in the caller.
    // moveAllToActiveOrBackoffQueue moves all pods from unschedulablePods to activeQ or backoffQ.
    // This function adds all pods and then signals the condition variable to ensure that
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  2. src/runtime/malloc.go

    //
    // This function is idempotent.
    //
    // The heap lock must not be held over this operation, since it will briefly acquire
    // the heap lock.
    //
    // Must be called on the system stack because it acquires the heap lock.
    //
    //go:systemstack
    func (h *mheap) enableMetadataHugePages() {
    	// Enable huge pages for page structure.
    	h.pages.enableChunkHugePages()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  3. src/runtime/mheap.go

    	s.state.set(mSpanDead)
    	h.freeMSpanLocked(s)
    }
    
    // scavengeAll acquires the heap lock (blocking any additional
    // manipulation of the page allocator) and iterates over the whole
    // heap, scavenging every free page available.
    //
    // Must run on the system stack because it acquires the heap lock.
    //
    //go:systemstack
    func (h *mheap) scavengeAll() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
  4. tests/test_generate_unique_id_function.py

                                        "$ref": "#/components/schemas/Body_foo_post_root"
                                    }
                                }
                            },
                            "required": True,
                        },
                        "responses": {
                            "200": {
                                "description": "Successful Response",
                                "content": {
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Jan 13 15:10:26 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  5. src/runtime/mgc.go

    	// allocations.
    	//
    	// TODO(prattmic): cleanup gcStart to use a more explicit "in gcStart"
    	// check for bailing.
    	mp := acquirem()
    	ready := make(chan struct{}, 1)
    	releasem(mp)
    
    	for gcBgMarkWorkerCount < gomaxprocs {
    		mp := acquirem() // See above, we allocate a closure here.
    		go gcBgMarkWorker(ready)
    		releasem(mp)
    
    		// N.B. we intentionally wait on each goroutine individually
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  6. tests/test_application.py

                            {
                                "required": False,
                                "schema": {"title": "Query"},
                                "name": "query",
                                "in": "query",
                            }
                        ],
                    }
                },
                "/query/param-required": {
                    "get": {
                        "responses": {
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 21:56:59 UTC 2024
    - 52.2K bytes
    - Viewed (0)
  7. pkg/apis/admissionregistration/validation/validation.go

    	var allErrors field.ErrorList
    	if len(resources) == 0 {
    		allErrors = append(allErrors, field.Required(fldPath, ""))
    	}
    	for i, resource := range resources {
    		if resource == "" {
    			allErrors = append(allErrors, field.Required(fldPath.Index(i), ""))
    		}
    		if strings.Contains(resource, "/") {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 56.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/validation/validation.go

    	}
    
    	switch *schema.XListType {
    	case "map":
    		// ensure all map keys are required or have a default
    		isRequired := make(map[string]bool, len(schema.Items.Schema.Required))
    		for _, required := range schema.Items.Schema.Required {
    			isRequired[required] = true
    		}
    
    		for _, k := range schema.XListMapKeys {
    			obj, ok := schema.Items.Schema.Properties[k]
    			if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 82.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/apis/apiserver/validation/validation_test.go

    		want        string
    	}{
    		{
    			name: "audiences is empty",
    			in:   []string{},
    			want: "issuer.audiences: Required value: at least one issuer.audiences is required",
    		},
    		{
    			name: "audience is empty",
    			in:   []string{""},
    			want: "issuer.audiences[0]: Required value: audience can't be empty",
    		},
    		{
    			name:        "invalid match policy with single audience",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 87.2K bytes
    - Viewed (0)
  10. pkg/apis/flowcontrol/validation/validation_test.go

    						NonResourceURLs: []string{"*"},
    					}},
    				}},
    			},
    		},
    		expectedErrors: field.ErrorList{
    			field.Required(field.NewPath("spec").Child("rules").Index(0).Child("subjects").Index(0).Child("serviceAccount"), "serviceAccount is required when subject kind is 'ServiceAccount'"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 54.7K bytes
    - Viewed (0)
Back to top