Search Options

Results per page
Sort
Preferred Languages
Advance

Results 751 - 760 of 1,131 for currentIO (0.05 sec)

  1. cmd/erasure-decode_test.go

    		if n != test.data {
    			t.Fatalf("Test %d: failed to create erasure test file", i)
    		}
    		for i, w := range writers {
    			if w == nil {
    				disks[i] = nil
    			}
    		}
    
    		// Get the checksums of the current part.
    		bitrotReaders := make([]io.ReaderAt, len(disks))
    		for index, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			tillOffset := erasure.ShardFileOffset(test.offset, test.length, test.data)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/CertificatePinner.kt

     * certificate authorities. It also prevents connections through man-in-the-middle certificate
     * authorities either known or unknown to the application's user.
     * This class currently pins a certificate's Subject Public Key Info as described on
     * [Adam Langley's Weblog][langley]. Pins are either base64 SHA-256 hashes as in
     * [HTTP Public Key Pinning (HPKP)][rfc_7469] or SHA-1 base64 hashes as in Chromium's
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 14.1K bytes
    - Viewed (1)
  3. src/main/java/jcifs/smb/SmbFileOutputStream.java

         */
    
        @Override
        public void write(final byte[] b) throws IOException {
            write(b, 0, b.length);
        }
    
        /**
         * Tests whether the output stream is currently open.
         *
         * @return whether the stream is open
         */
        public boolean isOpen() {
            return this.handle != null && this.handle.isValid();
        }
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

      private val perMessageDeflate: Boolean,
      private val noContextTakeover: Boolean,
    ) : Closeable {
      private var closed = false
      private var receivedCloseFrame = false
    
      // Stateful data about the current frame.
      private var opcode = 0
      private var frameLength = 0L
      private var isFinalFrame = false
      private var isControlFrame = false
      private var readingCompressedMessage = false
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 16:11:23 UTC 2025
    - 10K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/cache/Cache.java

      /** Discards all entries in the cache. */
      void invalidateAll();
    
      /** Returns the approximate number of entries in this cache. */
      long size();
    
      /**
       * Returns a current snapshot of this cache's cumulative statistics, or a set of default values if
       * the cache is not recording statistics. All statistics begin at zero and never decrease over the
       * lifetime of the cache.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  6. src/archive/tar/format.go

    //
    // The table's lower portion shows specialized features of each format,
    // such as supported string encodings, support for sub-second timestamps,
    // or support for sparse files.
    //
    // The Writer currently provides no support for sparse files.
    type Format int
    
    // Constants to identify various tar formats.
    const (
    	// Deliberately hide the meaning of constants from public API.
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  7. tests/test_tutorial/test_security/test_tutorial005.py

                            "flows": {
                                "password": {
                                    "scopes": {
                                        "me": "Read information about the current user.",
                                        "items": "Read items.",
                                    },
                                    "tokenUrl": "token",
                                }
                            },
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 18:19:10 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  8. internal/kms/kes.go

    			Method:  api.Method,
    			Path:    api.Path,
    			MaxBody: api.MaxBody,
    			Timeout: int64(api.Timeout.Truncate(time.Second).Seconds()),
    		})
    	}
    	return list, nil
    }
    
    // Stat returns the current KES status containing a
    // list of KES endpoints and the default key ID.
    func (c *kesConn) Status(ctx context.Context) (map[string]madmin.ItemState, error) {
    	if len(c.client.Endpoints) == 1 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java

                    .map(token -> ADMIN_SERVER + token)
                    .orElseThrow(() -> new FessSystemException("Cannot create an access token."));
        }
    
        /**
         * Generates and saves a new access token for the current session.
         * The token is used to authenticate API requests.
         */
        public void saveToken() {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheStrategy.kt

            val delta = servedMillis - lastModified!!.time
            return if (delta > 0L) delta / 10 else 0L
          }
    
          return 0L
        }
    
        /**
         * Returns the current age of the response, in milliseconds. The calculation is specified by RFC
         * 7234, 4.2.3 Calculating Age.
         */
        private fun cacheResponseAge(): Long {
          val servedDate = this.servedDate
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 12K bytes
    - Viewed (0)
Back to top