Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 510 for locks (0.04 sec)

  1. buildscripts/rewrite-old-new.sh

    	if ! ps -p ${pid} 1>&2 >/dev/null; then
    		echo "server1 log:"
    		cat "${WORK_DIR}/server1.log"
    		echo "FAILED"
    		purge "$WORK_DIR"
    		exit 1
    	fi
    
    	"${WORK_DIR}/mc" mb minio/healing-rewrite-bucket --quiet --with-lock
    	"${WORK_DIR}/mc" cp \
    		buildscripts/verify-build.sh \
    		minio/healing-rewrite-bucket/ \
    		--disable-multipart --quiet
    
    	"${WORK_DIR}/mc" cp \
    		buildscripts/verify-build.sh \
    		minio/healing-rewrite-bucket/ \
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. internal/logger/audit.go

    		entry.API.HeaderBytes = headerBytes
    		entry.API.TimeToResponse = strconv.FormatInt(timeToResponse.Nanoseconds(), 10) + "ns"
    		entry.API.TimeToResponseInNS = strconv.FormatInt(timeToResponse.Nanoseconds(), 10)
    		// We hold the lock, so we cannot call reqInfo.GetTagsMap().
    		tags := make(map[string]interface{}, len(reqInfo.tags))
    		for _, t := range reqInfo.tags {
    			tags[t.Key] = t.Val
    		}
    		entry.Tags = tags
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/sftp-server-driver.go

    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/pkg/v3/mimedb"
    	"github.com/pkg/sftp"
    	"golang.org/x/crypto/ssh"
    )
    
    // Maximum write offset for incoming SFTP blocks.
    // Set to 100MiB to prevent hostile DOS attacks.
    const ftpMaxWriteOffset = 100 << 20
    
    type sftpDriver struct {
    	permissions *ssh.Permissions
    	endpoint    string
    }
    
    //msgp:ignore sftpMetrics
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. mockwebserver/README.md

    awkward-to-reproduce situations like 500 errors or slow-loading responses.
    
    
    ### Example
    
    Use MockWebServer the same way that you use mocking frameworks like
    [Mockito](https://github.com/mockito/mockito):
    
    1. Script the mocks.
    2. Run application code.
    3. Verify that the expected requests were made.
    
    Here's a complete example:
    
    ```java
    public void test() throws Exception {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 5K bytes
    - Viewed (0)
  5. internal/disk/stat_linux.go

    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    		Total: uint64(s.Frsize) * (s.Blocks - reservedBlocks),
    		Free:  uint64(s.Frsize) * s.Bavail,
    		Files: s.Files,
    		Ffree: s.Ffree,
    		//nolint:unconvert
    		FSType: getFSType(int64(s.Type)),
    	}
    
    	st := syscall.Stat_t{}
    	err = syscall.Stat(path, &st)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  6. src/main/assemblies/files/fess.in.bat

    set FESS_MIN_MEM=%FESS_HEAP_SIZE%
    set FESS_MAX_MEM=%FESS_HEAP_SIZE%
    )
    
    REM min and max heap sizes should be set to the same value to avoid
    REM stop-the-world GC pauses during resize, and so that we can lock the
    REM heap in memory on startup to prevent any of it from being swapped
    REM out.
    set FESS_JAVA_OPTS=%FESS_JAVA_OPTS% -Xms%FESS_MIN_MEM% -Xmx%FESS_MAX_MEM%
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle.go

    		return nil
    	}
    	workers := *w
    	return workers[h%uint64(len(workers))]
    }
    
    func (es *expiryState) ResizeWorkers(n int) {
    	if n == 0 {
    		n = 100
    	}
    
    	// Lock to avoid multiple resizes to happen at the same time.
    	es.mu.Lock()
    	defer es.mu.Unlock()
    	var workers []chan expiryOp
    	if v := es.workers.Load(); v != nil {
    		// Copy to new array.
    		workers = append(workers, *v...)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt

        /**
         * Decodes a multiline string that contains both a [certificate][certificatePem] and a
         * [private key][privateKeyPkcs8Pem], both [PEM-encoded][rfc_7468]. A typical input string looks
         * like this:
         *
         * ```
         * -----BEGIN CERTIFICATE-----
         * MIIBYTCCAQegAwIBAgIBKjAKBggqhkjOPQQDAjApMRQwEgYDVQQLEwtlbmdpbmVl
         * cmluZzERMA8GA1UEAxMIY2FzaC5hcHAwHhcNNzAwMTAxMDAwMDA1WhcNNzAwMTAx
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/ServerMessageBlock2Response.java

         */
        @Override
        public boolean verifySignature ( byte[] buffer, int i, int size ) {
            // observed too that signatures on error responses are sometimes wrong??
            // Looks like the failure case also is just reflecting back the signature we sent
    
            // with SMB3's negotiation validation it's no longer possible to ignore this (on the validation response)
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 09:45:59 UTC 2018
    - 7.4K bytes
    - Viewed (0)
  10. cmd/generic-handlers_test.go

    // Tests request guess function for net/rpc requests.
    func TestGuessIsRPC(t *testing.T) {
    	if guessIsRPCReq(nil) {
    		t.Fatal("Unexpected return for nil request")
    	}
    
    	u, err := url.Parse("http://localhost:9000/minio/lock")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	r := &http.Request{
    		Proto:  "HTTP/1.0",
    		Method: http.MethodPost,
    		URL:    u,
    	}
    	if !guessIsRPCReq(r) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top