Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 344 for lock2 (0.07 sec)

  1. cmd/object-handlers.go

    		return
    	}
    
    	// Take read lock on object, here so subsequent lower-level
    	// calls do not need to.
    	lock := objectAPI.NewNSLock(bucket, object)
    	lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer lock.RUnlock(lkctx)
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  2. cmd/api-headers.go

    				w.Header()[xhttp.AmzObjectTagging] = []string{objInfo.UserTags}
    			}
    		}
    	}
    
    	// Set all other user defined metadata.
    	for k, v := range objInfo.UserDefined {
    		// Empty values for object lock and retention can be skipped.
    		if v == "" && equals(k, xhttp.AmzObjectLockMode, xhttp.AmzObjectLockRetainUntilDate) {
    			continue
    		}
    
    		if stringsHasPrefixFold(k, ReservedMetadataPrefixLower) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  3. docs/em/docs/deployment/docker.md

    1ī¸âƒŖ. 👉 đŸĨ‡ â–ļī¸, âšĢī¸ 🌟 `requirements-stage`.
    
    2ī¸âƒŖ. ⚒ `/tmp` ⏎ī¸ 👷 📁.
    
        đŸ“Ĩ 🌐❔ đŸ‘Ĩ 🔜 🏗 📁 `requirements.txt`
    
    3ī¸âƒŖ. ❎ đŸŽļ 👉 ☁ â–ļī¸.
    
    4ī¸âƒŖ. 📁 `pyproject.toml` & `poetry.lock` 📁 `/tmp` 📁.
    
        ↩ī¸ âšĢī¸ ⚙ī¸ `./poetry.lock*` (â–ļī¸ ⏎ī¸ `*`), âšĢī¸ 🏆 đŸšĢ đŸ’Ĩ đŸšĨ 👈 📁 đŸšĢ đŸ’Ē.
    
    5ī¸âƒŖ. 🏗 `requirements.txt` 📁.
    
    6ī¸âƒŖ. 👉 🏁 â–ļī¸, đŸ•ŗ đŸ“Ĩ 🔜 🛡 🏁 đŸ“Ļ đŸ–ŧ.
    
    7ī¸âƒŖ. ⚒ ⏎ī¸ 👷 📁 `/code`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  4. cmd/object_api_suite_test.go

    	globalCompressConfigMu.Lock()
    	globalCompressConfig.Enabled = false
    	globalCompressConfigMu.Unlock()
    
    	globalAutoEncryption = true
    	KMS, err := kms.ParseSecretKey("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=")
    	if err != nil {
    		t.Fatal(err)
    	}
    	GlobalKMS = KMS
    }
    
    func resetCompressEncryption() {
    	// Reset...
    	globalCompressConfigMu.Lock()
    	globalCompressConfig.Enabled = false
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  5. doc/go_mem.html

    func main() {
    	for _, w := range work {
    		go func(w func()) {
    			limit <- 1
    			w()
    			<-limit
    		}(w)
    	}
    	select{}
    }
    </pre>
    
    <h3 id="locks">Locks</h3>
    
    <p>
    The <code>sync</code> package implements two lock data types,
    <code>sync.Mutex</code> and <code>sync.RWMutex</code>.
    </p>
    
    <p class="rule">
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. docs/bucket/replication/README.md

    - Multi destination replication
    
    ## How to use?
    
    Ensure that versioning is enabled on the source and target buckets with `mc version` command. If object locking is required, the buckets should have been created with `mc mb --with-lock`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 24 23:46:33 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  7. cmd/data-scanner.go

    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/object/lock"
    	objectlock "github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/minio/minio/internal/bucket/versioning"
    	"github.com/minio/minio/internal/color"
    	"github.com/minio/minio/internal/config/heal"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

                "missing event subscriber for an annotated method. Is " + listener + " registered?");
          }
    
          // don't try to remove the set if it's empty; that can't be done safely without a lock
          // anyway, if the set is empty it'll just be wrapping an array of length 0
        }
      }
    
      @VisibleForTesting
      Set<Subscriber> getSubscribersForTesting(Class<?> eventType) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 15:16:45 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  9. cmd/erasure-healing.go

    				// StorageAPI can send volume names which are
    				// incompatible with buckets - these are
    				// skipped, like the meta-bucket.
    				if isReservedOrInvalidBucket(volInfo.Name, false) {
    					continue
    				}
    				mu.Lock()
    				if _, ok := healBuckets[volInfo.Name]; !ok {
    					healBuckets[volInfo.Name] = volInfo
    				}
    				mu.Unlock()
    			}
    			return nil
    		}, index)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  10. cmd/server-main.go

    		logger.FatalIf(initGlobalGrid(GlobalContext, globalEndpoints), "Unable to configure server grid RPC services")
    	})
    
    	// Initialize lock grid
    	bootstrapTrace("initLockGrid", func() {
    		logger.FatalIf(initGlobalLockGrid(GlobalContext, globalEndpoints), "Unable to configure server lock grid RPC services")
    	})
    
    	// Configure server.
    	bootstrapTrace("configureServer", func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
Back to top