Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 510 for locks (0.05 sec)

  1. internal/logger/logger.go

    	}
    	req.RLock()
    	defer req.RUnlock()
    
    	API := "SYSTEM"
    	switch {
    	case req.API != "":
    		API = req.API
    	case subsystem != "":
    		API += "." + subsystem
    	}
    
    	// Copy tags. We hold read lock already.
    	tags := make(map[string]interface{}, len(req.tags))
    	for _, entry := range req.tags {
    		tags[entry.Key] = entry.Val
    	}
    
    	// Get the cause for the Error
    	deploymentID := req.DeploymentID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. docs/bucket/versioning/README.md

        }
      }
    }
    ```
    
    ## Explore Further
    
    - [Use `minio-java` SDK with MinIO Server](https://min.io/docs/minio/linux/developers/java/minio-java.html)
    - [Object Lock and Immutablity Guide](https://min.io/docs/minio/linux/administration/object-management/object-retention.html)
    - [MinIO Admin Complete Guide](https://min.io/docs/minio/linux/reference/minio-mc-admin.html)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 04 21:43:52 UTC 2023
    - 11.9K bytes
    - Viewed (0)
  3. docs/de/docs/deployment/docker.md

        Hier werden wir die Datei `requirements.txt` generieren.
    
    3. Installiere Poetry in dieser Docker-Phase.
    
    4. Kopiere die Dateien `pyproject.toml` und `poetry.lock` in das Verzeichnis `/tmp`.
    
        Da es `./poetry.lock*` verwendet (endet mit einem `*`), stürzt es nicht ab, wenn diese Datei noch nicht verfügbar ist.
    
    5. Generiere die Datei `requirements.txt`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 39K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    			userDefined[minIOErasureUpgraded] = strconv.Itoa(parityOrig) + "->" + strconv.Itoa(parityDrives)
    		}
    	}
    
    	dataDrives := len(onlineDisks) - parityDrives
    
    	// we now know the number of blocks this object needs for data and parity.
    	// establish the writeQuorum using this data
    	writeQuorum := dataDrives
    	if dataDrives == parityDrives {
    		writeQuorum++
    	}
    
    	// Initialize parts metadata
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    // Note that upstream errors are currently not forwarded, but may be in the future.
    func (h *httpStreamResponse) Write(b []byte) (int, error) {
    	if len(b) == 0 || h.err != nil {
    		// Ignore 0 length blocks
    		return 0, h.err
    	}
    	tmp := make([]byte, len(b))
    	copy(tmp, b)
    	h.block <- tmp
    	return len(b), h.err
    }
    
    // CloseWithError will close the stream and return the specified error.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ArrayTable.java

      /**
       * Returns a two-dimensional array with the table contents. The row and column indices correspond
       * to the positions of the row and column in the iterables provided during table construction. If
       * the table lacks a mapping for a given row and column, the corresponding array element is null.
       *
       * <p>Subsequent table changes will not modify the array, and vice versa.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  9. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    **FastAPI** uses them internally to achieve this.
    
    ///
    
    ## Dependencies with `yield` and `HTTPException`
    
    You saw that you can use dependencies with `yield` and have `try` blocks that catch exceptions.
    
    The same way, you could raise an `HTTPException` or similar in the exit code, after the `yield`.
    
    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 14K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt

          private val useCompression: Boolean = true,
          private val out: Buffer,
        ) {
          /**
           * In the scenario where the dynamic table size changes multiple times between transmission of
           * header blocks, we need to keep track of the smallest value in that interval.
           */
          private var smallestHeaderTableSizeSetting = Integer.MAX_VALUE
          private var emitDynamicTableSizeUpdate: Boolean = false
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 22.5K bytes
    - Viewed (0)
Back to top