Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 1,107 for ends (0.02 sec)

  1. internal/dsync/drwmutex.go

    			// Remotes will have canceled due to the missing refreshes anyway.
    			if time.Since(started) > dm.clnt.Timeouts.UnlockCall {
    				return
    			}
    		}
    	}()
    }
    
    // sendRelease sends a release message to a node that previously granted a lock
    func sendRelease(ctx context.Context, ds *Dsync, c NetLocker, owner string, uid string, isReadLock bool, names ...string) bool {
    	if c == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

       */
      object KeepOpen : SocketPolicy
    
      /**
       * Close the socket after the response. This is the default HTTP/1.0 behavior. For HTTP/2
       * connections, this sends a [GOAWAYframe](https://tools.ietf.org/html/rfc7540#section-6.8)
       * immediately after the response and will close the connection when the client's socket
       * is exhausted.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/metacache-marker.go

    func (o *listPathOptions) parseMarker() {
    	s := o.Marker
    	if !strings.Contains(s, "[minio_cache:"+markerTagVersion) {
    		return
    	}
    	start := strings.LastIndex(s, "[")
    	o.Marker = s[:start]
    	end := strings.LastIndex(s, "]")
    	tag := strings.Trim(s[start:end], "[]")
    	tags := strings.Split(tag, ",")
    	for _, tag := range tags {
    		kv := strings.Split(tag, ":")
    		if len(kv) < 2 {
    			continue
    		}
    		switch kv[0] {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    					return
    				}
    				goto sendResp
    			}
    		case <-pingTimer:
    			if !m.doPing(respHandler) {
    				return
    			}
    		}
    	}
    }
    
    // doPing checks last ping time and sends another ping.
    func (m *muxClient) doPing(respHandler chan<- Response) (ok bool) {
    	m.respMu.Lock()
    	if m.closed {
    		m.respMu.Unlock()
    		// Already closed. This is not an error state;
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  5. cmd/encryption-v1_test.go

    		ETag:       "",
    		ShouldFail: true, // modified ETag
    	},
    
    	// Special tests for ETags that end with a '-x'
    	{
    		ObjectKey:  [32]byte{},
    		ObjectInfo: ObjectInfo{ETag: "916516b396f0f4d4f2a0e7177557bec4-1"},
    		ETag:       "916516b396f0f4d4f2a0e7177557bec4-1",
    	},
    	{
    		ObjectKey:  [32]byte{},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  6. internal/etag/etag.go

    //	...
    //	 eN := MD5(part-N)
    //
    // Then, the ETag of the object is computed as MD5 of all individual
    // part checksums. S3 also encodes the number of parts into the ETag
    // by appending a -<number-of-parts> at the end:
    //
    //	ETag := MD5(e1 || e2 || e3 ... || eN) || -N
    //
    //	For example: ceb8853ddc5086cc4ab9e149f8f09c88-5
    //
    // However, this scheme is only used for multipart objects that are
    // not encrypted.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/PatternFilenameFilter.java

       * class to begin with but rather something returned from a static factory method whose declared
       * return type is plain FilenameFilter. If we made such a change, then the annotation we choose
       * here would have no significance to end users, who would be forced to conform to the signature
       * used in FilenameFilter.)
       */
      @Override
      public boolean accept(File dir, String fileName) {
        return pattern.matcher(fileName).matches();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/DosError.java

            "Cannot create a file when that file already exists.", "All pipe instances are busy.", "The pipe is being closed.",
            "No process is on the other end of the pipe.", "More data is available.", "This user account has expired.",
            "The user is not allowed to log on from this workstation.", "The user is not allowed to log on at this time.",
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:52:42 UTC 2020
    - 4.8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/smb1/DosError.java

            "The directory is not empty.",
            "Cannot create a file when that file already exists.",
            "All pipe instances are busy.",
            "The pipe is being closed.",
            "No process is on the other end of the pipe.",
            "More data is available.",
            "This user account has expired.",
            "The user is not allowed to log on from this workstation.",
            "The user is not allowed to log on at this time.",
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 4.5K bytes
    - Viewed (0)
  10. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerCertificatesTest.kt

          |
          """.trimMargin()
        val certificateByteString = certificateBase64.decodeBase64()!!
        val certificatePem =
          """
          |-----BEGIN CERTIFICATE-----
          |$certificateBase64
          |-----END CERTIFICATE-----
          |
          """.trimMargin()
    
        val javaCertificate = certificatePem.decodeCertificatePem()
        val okHttpCertificate =
          CertificateAdapters.certificate
            .fromDer(certificateByteString)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 43.9K bytes
    - Viewed (0)
Back to top