Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 462 for slop (0.03 sec)

  1. okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt

    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junit.jupiter.params.ParameterizedTest
    import org.junit.jupiter.params.provider.ValueSource
    
    @Flaky // STDOUT logging enabled for test
    @Timeout(30)
    @Tag("Slow")
    open class ConnectionListenerTest {
      @RegisterExtension
      val platform = PlatformRule()
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
      private var server: MockWebServer? = null
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  2. internal/config/scanner/help.go

    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	// Help provides help for config values
    	Help = config.HelpKVS{
    		config.HelpKV{
    			Key:         Speed,
    			Description: `customize scanner speed (default|slowest|slow|fast|fastest)` + defaultHelpPostfix(Speed),
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         ExcessVersions,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 12 07:41:53 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. cmd/metacache.go

    	// we intentionally operate on a copy of m, so we can update without locks.
    	t := time.NewTicker(metacacheMaxClientWait / 10)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Request is done, stop updating.
    			return
    		case <-t.C:
    			m.lastHandout = time.Now()
    
    			if m2, err := rpc.UpdateMetacacheListing(ctx, m); err == nil {
    				if m2.status != scanStateStarted {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/JodExtractor.java

            }
        }
    
        @PreDestroy
        public void destroy() {
            try {
                officeManager.stop();
            } catch (final OfficeException e) {
                throw new CrawlerSystemException("Failed to stop officeManager.", e);
            }
        }
    
        public void addConversionRule(final String inExt, final String outExt) {
            extensionMap.put(inExt, outExt);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. internal/event/target/nsq.go

    }
    
    // Close - closes underneath connections to NSQD server.
    func (target *NSQTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.producer != nil {
    		// this blocks until complete:
    		target.producer.Stop()
    	}
    	return nil
    }
    
    func (target *NSQTarget) init() error {
    	return target.initOnce.Do(target.initNSQ)
    }
    
    func (target *NSQTarget) initNSQ() error {
    	args := target.args
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. build-logic/buildquality/src/test/kotlin/gradlebuild/testcleanup/TestFilesCleanupServiceTest.kt

            assertEquals(1, StringUtils.countMatches(result.output, "Found non-empty test files dir"))
            assertEquals(1, StringUtils.countMatches(result.output, "Failed to stop service 'testFilesCleanupBuildService'"))
            result.output.assertContains("successful-test-with-leftover/build/tmp/teŝt files/leftover")
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Jun 14 12:35:52 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/es/config/exentity/ScheduledJob.java

                job.launchNow();
            }).orElse(() -> {
                throw new JobNotFoundException(this);
            });
        }
    
        public void stop() {
            ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).ifPresent(job -> {
                job.stopNow();
            }).orElse(() -> {
                throw new JobNotFoundException(this);
            });
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt

     */
    class JettyHttpClientTest {
      private val client = HttpClient()
    
      @BeforeEach fun setUp() {
        client.start()
      }
    
      @AfterEach fun tearDown() {
        client.stop()
      }
    
      @Test fun get(server: MockWebServer) {
        server.enqueue(MockResponse(body = "hello, Jetty HTTP Client"))
    
        val request =
          client.newRequest(server.url("/").toUri())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. docs/vi/docs/python-types.md

    //// tab | Python 3.8+
    
    * `List`
    * `Tuple`
    * `Set`
    * `Dict`
    * `Union`
    * `Optional`
    * ...và các kiểu khác.
    
    ////
    
    ### Lớp như kiểu dữ liệu
    
    Bạn cũng có thể khai báo một lớp như là kiểu dữ liệu của một biến.
    
    Hãy nói rằng bạn muốn có một lớp `Person` với một tên:
    
    ```Python hl_lines="1-3"
    {!../../docs_src/python_types/tutorial010.py!}
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  10. docs/features/connections.md

    (like HTTP/2).
    
    URLs that share the same address may also share the same underlying TCP socket connection. Sharing a connection has substantial performance benefits: lower latency, higher throughput (due to [TCP slow start](https://www.igvita.com/2011/10/20/faster-web-vs-tcp-slow-start/)) and conserved battery. OkHttp uses a [ConnectionPool](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection-pool/) that automatically reuses HTTP/1.x connections and multiplexes HTTP/2 connections....
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
Back to top