Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 191 for idempotent (0.44 sec)

  1. src/runtime/os_linux.go

    	// thread B and did not need to execute the syscall, but did anyway
    	// because doAllThreadsSyscall could not be sure whether it was
    	// required.
    	//
    	// Some system calls may not be idempotent, so we ensure each thread
    	// executes the system call exactly once.
    	for mp := allm; mp != nil; mp = mp.alllink {
    		for atomic.Load64(&mp.procid) == 0 {
    			// Thread is starting.
    			osyield()
    		}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/interface.go

    	// Unreserve is called by the scheduling framework when a reserved pod was
    	// rejected, an error occurred during reservation of subsequent plugins, or
    	// in a later phase. The Unreserve method implementation must be idempotent
    	// and may be called by the scheduler even if the corresponding Reserve
    	// method for the same plugin was not called.
    	Unreserve(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	return s.muxAndDiscoveryCompleteSignals
    }
    
    // RegisterDestroyFunc registers a function that will be called during Destroy().
    // The function have to be idempotent and prepared to be called more than once.
    func (s *GenericAPIServer) RegisterDestroyFunc(destroyFn func()) {
    	s.destroyFns = append(s.destroyFns, destroyFn)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_executor.go

    // mounting, or unmounting a volume that are executed with a NewNestedPendingOperations which
    // prevents more than one operation from being triggered on the same volume.
    //
    // These operations should be idempotent (for example, AttachVolume should
    // still succeed if the volume is already attached to the node, etc.). However,
    // they depend on the volume plugins to implement this behavior.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  5. cmd/object-api-utils.go

    }
    
    // Close - calls the cleanup actions in reverse order
    func (g *GetObjectReader) Close() error {
    	if g == nil {
    		return nil
    	}
    	// sync.Once is used here to ensure that Close() is
    	// idempotent.
    	g.once.Do(func() {
    		for i := len(g.cleanUpFns) - 1; i >= 0; i-- {
    			g.cleanUpFns[i]()
    		}
    	})
    	return nil
    }
    
    // compressionIndexEncrypter returns a function that will read data from input,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 36.3K bytes
    - Viewed (0)
  6. src/go/printer/printer.go

    	// write function take care of the proper indentation
    	lines := strings.Split(text, "\n")
    
    	// The comment started in the first column but is going
    	// to be indented. For an idempotent result, add indentation
    	// to all lines such that they look like they were indented
    	// before - this will make sure the common prefix computation
    	// is the same independent of how many times formatting is
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 12:02:03 UTC 2023
    - 41.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    	defer r.customStorageLock.Unlock()
    
    	storageMap := r.customStorage.Load().(crdStorageMap)
    	for _, crdInfo := range storageMap {
    		for _, storage := range crdInfo.storages {
    			// DestroyFunc have to be implemented in idempotent way,
    			// so the potential race with r.tearDown() (being called
    			// from a goroutine) is safe.
    			storage.CustomResource.DestroyFunc()
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  8. src/runtime/mpagealloc.go

    	// summaries.
    	p.update(base, size/pageSize, true, false)
    }
    
    // enableChunkHugePages enables huge pages for the chunk bitmap mappings (disabled by default).
    //
    // This function is idempotent.
    //
    // A note on latency: for sufficiently small heaps (<10s of GiB) this function will take constant
    // time, but may take time proportional to the size of the mapped heap beyond that.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/admissionregistration/v1beta1/types_swagger_doc_generated.go

    evaluation.\n\nIfNeeded: the webhook will be called at least one additional time as part of the admission evaluation if the object being admitted is modified by other admission plugins after the initial webhook call. Webhooks that specify this option *must* be idempotent, able to process objects they previously admitted. Note: * the number of additional invocations is not guaranteed to be exactly one. * if additional invocations result in further modifications to the object, webhooks are not guaranteed to be invoked...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 20:14:19 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  10. pkg/apis/admissionregistration/types.go

    	// if the object being admitted is modified by other admission plugins after the initial webhook call.
    	// Webhooks that specify this option *must* be idempotent, and hence able to process objects they previously admitted.
    	// Note:
    	// * the number of additional invocations is not guaranteed to be exactly one.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 20:14:19 UTC 2024
    - 52.6K bytes
    - Viewed (0)
Back to top