Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 283 for Lock (0.04 sec)

  1. cmd/bucket-policy-handlers_test.go

    				if _, ok := err.(BucketExists); !ok {
    					t.Logf("unexpected error: %T: %v", err, err)
    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    	close(start)
    	wg.Wait()
    	if ok != 1 {
    		t.Fatalf("want 1 ok, got %d", ok)
    	}
    	if errs != n-1 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  2. cmd/erasure-healing_test.go

    	}
    
    	setDisks := func(newDisks ...StorageAPI) {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		copy(disks, newDisks)
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    	}
    	getDisk := func(n int) StorageAPI {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		disk := disks[n]
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    		return disk
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  3. tensorflow/c/eager/parallel_device/parallel_device_lib.cc

    // Allows a single op at a time to be launched without blocking.
    //
    // DeviceThread itself is thread-safe, in that StartExecute will block if there
    // is a pending execution. Since StartExecute is equivalent to grabbing a lock,
    // multiple DeviceThreads should always be accessed in the same order to avoid
    // deadlocks.
    class DeviceThread {
     public:
      // Starts a background thread waiting for `StartExecute`.
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  4. internal/grid/grid_test.go

    	<-reqStarted
    
    	// Block until we have exceeded the deadline several times over.
    	nowBlocking := make(chan struct{})
    	var mu sync.Mutex
    	time.AfterFunc(time.Second, func() {
    		mu.Lock()
    		cancel()
    		close(nowBlocking)
    		mu.Unlock()
    	})
    	if inCap > 0 {
    		go func() {
    			defer close(st.Requests)
    			if !blockReq {
    				<-nowBlocking
    				return
    			}
    			for {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  5. cmd/sftp-server-driver.go

    	wg     *sync.WaitGroup
    	buffer map[int64][]byte
    	err    error
    
    	nextOffset int64
    	m          sync.Mutex
    }
    
    func (w *writerAt) WriteAt(b []byte, offset int64) (n int, err error) {
    	w.m.Lock()
    	defer w.m.Unlock()
    
    	if w.nextOffset == offset {
    		n, err = w.w.Write(b)
    		w.nextOffset += int64(n)
    	} else {
    		if offset > w.nextOffset+ftpMaxWriteOffset {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. cmd/metrics-v3-types.go

    	}
    }
    
    // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns
    // a function to unlock the buckets.
    func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() {
    	mg.bucketsLock.Lock()
    	mg.buckets = buckets
    	return func() {
    		mg.bucketsLock.Unlock()
    	}
    }
    
    // MetricFQN - returns the fully qualified name for the given metric name.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 30 22:28:46 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. tensorflow/c/c_api_experimental.cc

      static std::unordered_map<std::string, void*>* loaded_libs =
          new std::unordered_map<std::string, void*>();
      tensorflow::Env* env = tensorflow::Env::Default();
      {
        tensorflow::mutex_lock lock(mu);
        auto it = loaded_libs->find(library_filename);
        if (it != loaded_libs->end()) {
          lib_handle->lib_handle = it->second;
        } else {
          status->status =
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  8. docs/ko/docs/deployment/docker.md

    2. `/tmp`를 현재의 워킹 디렉터리로 설정합니다.
    
        이 위치에 우리는 `requirements.txt` 파일을 생성할 것입니다.
    
    3. 이 도커 스테이지에서 Poetry를 설치합니다.
    
    4. 파일 `pyproject.toml`와 `poetry.lock`를 `/tmp` 디렉터리로 복사합니다.
    
        `./poetry.lock*` (`*`로 끝나는) 파일을 사용하기 때문에, 파일이 아직 사용가능하지 않더라도 고장나지 않을 것입니다.
    
    5. `requirements.txt` 파일을 생성합니다.
    
    6. 이것이 마지막 스테이지로, 여기에 위치한 모든 것이 마지막 컨테이너 이미지에 포함될 것입니다.
    
    7. 현재의 워킹 디렉터리를 `/code`로 설정합니다.
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 42.7K bytes
    - Viewed (0)
  9. cmd/utils.go

    	return p.ext
    }
    
    // Returns current profile data, returns error if there is no active
    // profiling in progress. Stops an active profile.
    func getProfileData() (map[string][]byte, error) {
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if len(globalProfiler) == 0 {
    		return nil, errors.New("profiler not enabled")
    	}
    
    	dst := make(map[string][]byte, len(globalProfiler))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  10. cmd/object-api-utils.go

    // Eliminate non-compressible objects by extensions/content-types.
    func isCompressible(header http.Header, object string) bool {
    	globalCompressConfigMu.Lock()
    	cfg := globalCompressConfig
    	globalCompressConfigMu.Unlock()
    
    	return !excludeForCompression(header, object, cfg)
    }
    
    // Eliminate the non-compressible objects.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
Back to top