Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 551 for ensures (0.09 sec)

  1. src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java

            if( len <= 0 ) {
                return 0;
            }
            long start = fp;
    
            if( tmp == null ) {
                throw new IOException( "Bad file descriptor" );
            }
            // ensure file is open
            file.open( openFlags, access, SmbFile.ATTR_NORMAL, 0 );
    
            /*
             * Read AndX Request / Response
             */
    
            if( file.log.level >= 4 )
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/graph/AbstractNetworkTest.java

        // The choice of the size() method to call here is arbitrary.  We assume that if any of the Set
        // methods executes the validation check, they all will, and thus we only need to test one of
        // them to ensure that the validation check happens and has the expected behavior.
        assertNodeRemovedFromGraphErrorMessage(
            assertThrows(IllegalStateException.class, n1AdjacentNodes::size));
        assertNodeRemovedFromGraphErrorMessage(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  3. internal/grid/README.md

    The client does not wait for the remote handler to finish before returning.
    Returning any error will also cancel the stream remotely.
    
    CAREFUL: When utilizing two-way communication, it is important to ensure that the remote handler is not blocked on a send.
    If the remote handler is blocked on a send, and the client is trying to send without the remote receiving, 
    the operation would become deadlocked if the channels are full.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. api/maven-api-core/src/main/java/org/apache/maven/api/package-info.java

     * multi-level dependency graph to a simpler list where only the most relevant version of each artifact
     * (based on groupId and artifactId) is retained, resolving conflicts and eliminating duplicates to ensure
     * that each dependency is included only once in the final build.</p>
     *
     * <p><dfn>Dependency resolution</dfn> is the process of collecting dependencies, flattening the result graph,
     * and then resolving the artifacts.</p>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Aug 27 21:13:34 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java

                                    childKey = child.getKey();
    
                                    if (managedVersions.containsKey(childKey)) {
                                        // If this child node is a managed dependency, ensure
                                        // we are using the dependency management version
                                        // of this child if applicable b/c we want to use the
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  6. internal/logger/target/kafka/kafka.go

    	sconfig.Net.TLS.Config.InsecureSkipVerify = h.kconfig.TLS.SkipVerify
    	sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth
    	sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

       * garbage-collected, even if there are no more instances of FinalizableReferenceQueue itself.
       * The code in FinalizableReferenceQueue goes to considerable trouble to ensure that there are
       * no such references and the tests here check that that trouble has not been in vain.
       *
       * When we reference FinalizableReferenceQueue in this test, we are referencing a class that is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. internal/event/target/kafka.go

    	config.Net.TLS.Config.InsecureSkipVerify = args.TLS.SkipVerify
    	config.Net.TLS.Config.ClientAuth = args.TLS.ClientAuth
    	config.Net.TLS.Config.RootCAs = args.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	config.Producer.Retry.Max = 2
    	config.Producer.Retry.Backoff = (1 * time.Second)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. internal/dsync/dsync_test.go

    	if !dm.GetLock(context.Background(), nil, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Add delay to lock server responses to ensure that lock does not timeout
    	for i := range lockServers {
    		lockServers[i].setResponseDelay(5 * testDrwMutexUnlockCallTimeout)
    		defer lockServers[i].setResponseDelay(0)
    	}
    
    	unlockReturned := make(chan struct{}, 1)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  10. CONTRIBUTING.md

    Guidelines for any code contributions:
    
      1. Any significant changes should be accompanied by tests. The project already
         has good test coverage, so look at some existing tests if you're unsure
         how to go about it.
      2. All contributions must be licensed Apache 2.0 and all files must have a
         copy of the boilerplate license comment (can be copied from an existing
         file).
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Nov 17 18:47:47 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top