Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for rlock (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/bucket-replication.go

    	}
    
    	// Compare only necessary headers
    	compareKeys := []string{
    		"Expires",
    		"Cache-Control",
    		"Content-Language",
    		"Content-Disposition",
    		"X-Amz-Object-Lock-Mode",
    		"X-Amz-Object-Lock-Retain-Until-Date",
    		"X-Amz-Object-Lock-Legal-Hold",
    		"X-Amz-Website-Redirect-Location",
    		"X-Amz-Meta-",
    	}
    
    	// compare metadata on both maps to see if meta is identical
    	compareMeta1 := make(map[string]string)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  2. cmd/admin-handlers.go

    		if err != nil {
    			bugLogIf(ctx, err)
    			return nil
    		}
    		return out
    	}
    }
    
    func bytesToPublicKey(pub []byte) (*rsa.PublicKey, error) {
    	block, _ := pem.Decode(pub)
    	if block != nil {
    		pub = block.Bytes
    	}
    	key, err := x509.ParsePKCS1PublicKey(pub)
    	if err != nil {
    		return nil, err
    	}
    	return key, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  3. 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
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  4. tensorflow/c/c_api.cc

    // call Session::Extend().
    bool ExtendSessionGraphHelper(TF_Session* session, TF_Status* status) {
      if (session->graph != nullptr) {
        // Take the graph lock before the session lock to avoid deadlock. This is
        // safe since session->graph does not change.
        session->graph->mu.lock();
        mutex_lock session_lock(session->mu);
        const Graph& graph = session->graph->graph;
    
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Sat Oct 04 05:55:32 GMT 2025
    - 102.4K bytes
    - Click Count (0)
  5. cmd/server_test.go

    }
    
    func (s *TestSuiteCommon) TestPutBucket(c *check) {
    	// generate a random bucket name.
    	bucketName := getRandomBucketName()
    	// Block 1: Testing for racy access
    	// The assertion is removed from this block since the purpose of this block is to find races
    	// The purpose this block is not to check for correctness of functionality
    	// Run the test with -race flag to utilize this
    	var wg sync.WaitGroup
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
  6. api/go1.3.txt

    pkg sync, method (*Pool) Put(interface{})
    pkg sync, type Pool struct
    pkg sync, type Pool struct, New func() interface{}
    pkg syscall (darwin-386), func FcntlFlock(uintptr, int, *Flock_t) error
    pkg syscall (darwin-386), func Mlock([]uint8) error
    pkg syscall (darwin-386), func Mlockall(int) error
    pkg syscall (darwin-386), func Mprotect([]uint8, int) error
    pkg syscall (darwin-386), func Munlock([]uint8) error
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Jun 02 02:45:00 GMT 2014
    - 117K bytes
    - Click Count (0)
  7. cmd/object-handlers_test.go

    		{"enc-mp-2", []int64{5487701, 5487799, 3}, mapCopy(metaWithSSEC)},
    		{"enc-mp-3", []int64{10499807, 10499963, 7}, mapCopy(metaWithSSEC)},
    	}
    
    	// SSEC can't be used with compression
    	globalCompressConfigMu.Lock()
    	compressEnabled := globalCompressConfig.Enabled
    	globalCompressConfigMu.Unlock()
    	if compressEnabled {
    		objectInputs = objectInputs[0:9]
    	}
    
    	// iterate through the above set of inputs and upload the object.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  8. fastapi/routing.py

                        "Response not awaited. There's a high chance that the "
                        "application code is raising an exception and a dependency with yield "
                        "has a block with a bare except, or a block with except Exception, "
                        "and is not raising the exception again. Read more about it in the "
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 174.6K bytes
    - Click Count (0)
Back to Top