Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 146 for idempotent (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. staging/src/k8s.io/api/admissionregistration/v1/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: Wed Mar 06 00:00:21 UTC 2024
    - 48.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/admissionregistration/v1/generated.proto

      // 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.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  10. src/database/sql/sql.go

    // to finish.
    //
    // It is rare to Close a [DB], as the [DB] handle is meant to be
    // long-lived and shared between many goroutines.
    func (db *DB) Close() error {
    	db.mu.Lock()
    	if db.closed { // Make DB.Close idempotent
    		db.mu.Unlock()
    		return nil
    	}
    	if db.cleanerCh != nil {
    		close(db.cleanerCh)
    	}
    	var err error
    	fns := make([]func() error, 0, len(db.freeConn))
    	for _, dc := range db.freeConn {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:53 UTC 2024
    - 103.6K bytes
    - Viewed (0)
Back to top