Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 329 for recorded (0.12 sec)

  1. docs/LICENSE

      b. To the extent possible, if any provision of this Public License is
         deemed unenforceable, it shall be automatically reformed to the
         minimum extent necessary to make it enforceable. If the provision
         cannot be reformed, it shall be severed from this Public License
         without affecting the enforceability of the remaining terms and
         conditions.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 10 16:50:06 UTC 2021
    - 18.2K bytes
    - Viewed (0)
  2. cmd/metacache.go

    )
    
    type scanStatus uint8
    
    const (
    	scanStateNone scanStatus = iota
    	scanStateStarted
    	scanStateSuccess
    	scanStateError
    
    	// Time in which the initiator of a scan must have reported back.
    	metacacheMaxRunningAge = time.Minute
    
    	// Max time between client calls before dropping an async cache listing.
    	metacacheMaxClientWait = 3 * time.Minute
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. internal/grid/manager.go

    type ManagerOptions struct {
    	Local        string        // Local host name.
    	Hosts        []string      // All hosts, including local in the grid.
    	Incoming     func(n int64) // Record incoming bytes.
    	Outgoing     func(n int64) // Record outgoing bytes.
    	BlockConnect chan struct{} // If set, incoming and outgoing connections will be blocked until closed.
    	RoutePath    string
    	TraceTo      *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/VersionTest.java

         *
         * Generates random UUID string based versions and tries to sort them. While this test is not as reliable
         * as {@link #testCompareUuidVersionStringStream()}, it covers broader range and in case it fails it records
         * the failed array, so we can investigate more.
         */
        @Test
        void testCompareUuidRandom() {
            for (int j = 0; j < 32; j++) {
                ArrayList<Version> versions = new ArrayList<>();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  5. src/archive/tar/reader_test.go

    	}, {
    		// BSD tar v3.1.2 and GNU tar v1.27.1 both rejects PAX records
    		// with NULs in the key.
    		file: "testdata/pax-nul-xattrs.tar",
    		err:  ErrHeader,
    	}, {
    		// BSD tar v3.1.2 rejects a PAX path with NUL in the value, while
    		// GNU tar v1.27.1 simply truncates at first NUL.
    		// We emulate the behavior of BSD since it is strange doing NUL
    		// truncations since PAX records are length-prefix strings instead
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  6. internal/event/target/mqtt.go

    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	token := target.client.Publish(target.args.Topic, target.args.QoS, false, string(data))
    	if !token.WaitTimeout(reconnectInterval) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/idn/Punycode.kt

          }
        }
    
        return result.readUtf8()
      }
    
      /**
       * Converts a single label from Punycode to Unicode.
       *
       * @return true if the range of [string] from [pos] to [limit] was valid and decoded successfully.
       *     Otherwise, the decode failed.
       */
      private fun decodeLabel(
        string: String,
        pos: Int,
        limit: Int,
        result: Buffer,
      ): Boolean {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 03 03:04:50 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt

    import okio.ByteString
    
    /**
     * ASN.1 adapters adapted from the specifications in [RFC 5280][rfc_5280].
     *
     * [rfc_5280]: https://tools.ietf.org/html/rfc5280
     */
    @Suppress("UNCHECKED_CAST") // This needs to cast decoded collections.
    internal object CertificateAdapters {
      /**
       * ```
       * Time ::= CHOICE {
       *   utcTime        UTCTime,
       *   generalTime    GeneralizedTime
       * }
       * ```
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

      val oldName = currentThread.name
      currentThread.name = name
      try {
        block()
      } finally {
        currentThread.name = oldName
      }
    }
    
    /** Returns the Content-Length as reported by the response headers. */
    internal fun Response.headersContentLength(): Long {
      return headers["Content-Length"]?.toLongOrDefault(-1L) ?: -1L
    }
    
    /** Returns an immutable copy of this. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/Handshake.kt

    import java.security.cert.X509Certificate
    import javax.net.ssl.SSLPeerUnverifiedException
    import javax.net.ssl.SSLSession
    import okhttp3.internal.immutableListOf
    import okhttp3.internal.toImmutableList
    
    /**
     * A record of a TLS handshake. For HTTPS clients, the client is *local* and the remote server is
     * its *peer*.
     *
     * This value object describes a completed handshake. Use [ConnectionSpec] to set policy for new
     * handshakes.
     */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.8K bytes
    - Viewed (0)
Back to top