Search Options

Results per page
Sort
Preferred Languages
Advance

Results 461 - 470 of 1,048 for smart (0.03 sec)

  1. src/main/java/jcifs/netbios/Name.java

                    c++;
                }
            }
            while ( i-- > e );
            return this.scope.length() + 2;
        }
    
    
        int readScopeWireFormat ( byte[] src, int srcIndex ) {
            int start = srcIndex;
            int n;
            StringBuffer sb;
    
            if ( ( n = src[ srcIndex++ ] & 0xFF ) == 0 ) {
                this.scope = null;
                return 1;
            }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 7.7K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_remote_test_util.cc

                      .ok());
      ASSERT_TRUE(worker_server1->Start().ok());
    
      server_def.set_task_index(2);
      std::unique_ptr<tensorflow::GrpcServer> worker_server2;
      ASSERT_TRUE(tensorflow::GrpcServer::Create(
                      server_def, tensorflow::Env::Default(), &worker_server2)
                      .ok());
      ASSERT_TRUE(worker_server2->Start().ok());
    
      TF_Status* status = TF_NewStatus();
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 9.1K bytes
    - Viewed (0)
  3. cmd/admin-handlers-pools.go

    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.RebalanceAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    	// NB rebalance-start admin API is always coordinated from first pool's
    	// first node. The following is required to serialize (the effects of)
    	// concurrent rebalance-start commands.
    	if ep := globalEndpoints[0].Endpoints[0]; !ep.IsLocal {
    		for nodeIdx, proxyEp := range globalProxyEndpoints {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/test/kotlin/okhttp3/OkHttpClientTestRuleTest.kt

        testRule.beforeEach(extensionContext)
    
        val thread =
          object : Thread() {
            override fun run() {
              throw RuntimeException("boom!")
            }
          }
        thread.start()
        thread.join()
    
        assertFailsWith<AssertionError> {
          testRule.afterEach(extensionContext)
        }.also { expected ->
          assertThat(expected).hasMessage("uncaught exception thrown during test")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  5. cmd/bucket-replication_test.go

    			t.Errorf("Test%d (%s): Resync  got %t , want %t", i+1, test.name, sync.mustResync(), test.expectedSync)
    		}
    	}
    }
    
    var (
    	start                   = UTCNow().AddDate(0, 0, -1)
    	replicationConfigTests2 = []struct {
    		info         ObjectInfo
    		name         string
    		rcfg         replicationConfig
    		dsc          ReplicateDecision
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 16 09:28:06 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

            a.append(csq);
            return this;
          }
    
          @Override
          public Appendable append(CharSequence csq, int start, int end) throws IOException {
            a.append(csq, start, end);
            return this;
          }
    
          @Override
          public Appendable append(char c) throws IOException {
            a.append(c);
            return this;
          }
        };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/CharStreamsTest.java

            a.append(csq);
            return this;
          }
    
          @Override
          public Appendable append(CharSequence csq, int start, int end) throws IOException {
            a.append(csq, start, end);
            return this;
          }
    
          @Override
          public Appendable append(char c) throws IOException {
            a.append(c);
            return this;
          }
        };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/base/CommonMatcher.java

      public abstract boolean find();
    
      public abstract boolean find(int index);
    
      public abstract String replaceAll(String replacement);
    
      public abstract int end();
    
      public abstract int start();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Apr 09 00:52:54 UTC 2021
    - 1.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication-metrics.go

    	bytesSinceLastWindow uint64    // Total bytes since last window was processed
    	startTime            time.Time // Start time for window
    	expMovingAvg         float64   // Previously calculated exponential moving average
    }
    
    // newRateMeasurement creates a new instance of the measurement with the initial start time.
    func newRateMeasurement(initTime time.Time) *rateMeasurement {
    	return &rateMeasurement{
    		startTime: initTime,
    	}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  10. tensorflow/c/eager/c_api_remote_test_util.h

    // If heavy_load_on_streaming_rpc is true, send some rpc requests before the one
    // which creates a remote input, to simulate a scenario that the remote input
    // is not ready when we start running an op or a function.
    void TestRemoteExecuteSilentCopies(bool async, bool remote, bool func,
                                       bool heavy_load_on_streaming_rpc,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 1.4K bytes
    - Viewed (0)
Back to top