Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 551 for ensures (0.05 sec)

  1. .github/workflows/iam-integrations.yaml

    name: IAM integration
    
    on:
      pull_request:
        branches:
          - master
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      iam-matrix-test:
        name: "[Go=${{ matrix.go-version }}|ldap=${{ matrix.ldap }}|etcd=${{ matrix.etcd }}|openid=${{ matrix.openid }}]"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt

          .isEqualTo("<< 0x00000003 10000 HEADERS       PRIORITY")
        assertThat(frameLog(true, 3, 10000, TYPE_DATA, 0x20))
          .isEqualTo("<< 0x00000003 10000 DATA          COMPRESSED")
      }
    
      /**
       * Ensures that valid flag combinations appear visually correct, and invalid show in hex.  This
       * also demonstrates how sparse the lookup table is.
       */
      @Test
      fun allFormattedFlagsWithValidBits() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. internal/s3select/progress.go

    	scannedReader   *countUpReader
    	processedReader *countUpReader
    
    	closedMu sync.Mutex
    	closer   io.ReadCloser
    	closed   bool
    }
    
    func (pr *progressReader) Read(p []byte) (n int, err error) {
    	// This ensures that Close will block until Read has completed.
    	// This allows another goroutine to close the reader.
    	pr.closedMu.Lock()
    	defer pr.closedMu.Unlock()
    	if pr.closed {
    		return 0, errors.New("progressReader: read after Close")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/io/FlushablesTest.java

    import java.io.Flushable;
    import java.io.IOException;
    import junit.framework.TestCase;
    
    /**
     * Unit tests for {@link Flushables}.
     *
     * <p>Checks proper flushing behavior, and ensures that IOExceptions on Flushable.flush() are not
     * propagated out from the {@link Flushables#flush} method if {@code swallowException} is true.
     *
     * @author Michael Lancaster
     */
    public class FlushablesTest extends TestCase {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 3.3K bytes
    - Viewed (0)
  5. docs/hotfixes.md

    ```
    λ make verify-healing
    ```
    
    At this point in time the backport is ready to be submitted as a pull request to the relevant branch. A pull request is recommended to ensure [mint](http://github.com/minio/mint) tests are validated. Pull request also ensures code-reviews for the backports in case of any unforeseen regressions.
    
    ### Building a hotfix binary and container
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 14 21:36:02 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CloseablesTest.java

    import java.io.IOException;
    import java.io.InputStream;
    import java.io.Reader;
    import junit.framework.TestCase;
    
    /**
     * Unit tests for {@link Closeables}.
     *
     * <p>Checks proper closing behavior, and ensures that IOExceptions on Closeable.close() are not
     * propagated out from the {@link Closeables#close} method if {@code swallowException} is true.
     *
     * @author Michael Lancaster
     */
    public class CloseablesTest extends TestCase {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

          assertEquals(before + 1, after); // default implementation pads and calls process()
          processCalled--; // don't count the tail invocation (makes tests a bit more understandable)
        }
    
        // ensures that the number of invocations looks sane
        void assertInvariants(int expectedBytes) {
          // we should have seen as many bytes as the next multiple of chunk after expectedBytes - 1
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. internal/s3select/json/reader.go

    // reads are running.
    type syncReadCloser struct {
    	rc io.ReadCloser
    	mu sync.Mutex
    }
    
    func (pr *syncReadCloser) Read(p []byte) (n int, err error) {
    	// This ensures that Close will block until Read has completed.
    	// This allows another goroutine to close the reader.
    	pr.mu.Lock()
    	defer pr.mu.Unlock()
    	if pr.rc == nil {
    		return 0, io.EOF
    	}
    	return pr.rc.Read(p)
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. cmd/encryption-v1_test.go

    				t.Errorf("Case %d: test failed: %d %d %d %d %d", i, o, l, skip, sn, ps)
    			}
    		}
    
    		// Skip 1Mib and read 1Mib (in the decrypted object)
    		//
    		// The check below ensures the object is large enough
    		// for the read.
    		if lsum(test.decSizes) >= 2*humanize.MiByte {
    			skipLen, readLen := int64(1)*humanize.MiByte, int64(1)*humanize.MiByte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

         *
         * Our solution is for threads to CAS seenExceptions from null to a Set populated with _the
         * initial exception_, no matter which thread does the work. This ensures that seenExceptions
         * always contains not just the current thread's exception but also the initial thread's.
         */
        Set<Throwable> seenExceptionsLocal = seenExceptions;
        if (seenExceptionsLocal == null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top