Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 365 for timeouts (0.12 sec)

  1. guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java

        } catch (ExecutionException e) {
          rethrow(e);
        }
        throw new AssertionError("Unreachable");
      }
    
      @Override
      public V get(long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        try {
          super.get(timeout, unit);
        } catch (ExecutionException e) {
          rethrow(e);
        }
        throw new AssertionError("Unreachable");
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 12 20:02:10 UTC 2018
    - 3.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/timer/TimeoutTask.java

        private final boolean permanent;
    
        private long startTime;
    
        private int status = ACTIVE;
    
        TimeoutTask(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
            this.timeoutTarget = timeoutTarget;
            this.timeoutMillis = timeout * 1000L;
            this.permanent = permanent;
            this.startTime = System.currentTimeMillis();
        }
    
        /**
         * 期限切れかどうかを返します。
         *
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java

                        esClient.admin().cluster().prepareNodesHotThreads().setIgnoreIdleThreads(ignoreIdleThreads).setInterval(interval)
                                .setThreads(threads).setTimeout(timeout).setType(type).execute().actionGet(timeout);
                append(buf, "cluster_name", () -> response.getClusterName().value()).append(',');
                final String hotThreads = response.getNodesMap().entrySet().stream().map(e -> {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    	defer func() {
    		if err != nil {
    			if xnet.IsNetworkOrHostDown(err, false) {
    				h.status.Store(statusOffline)
    			}
    			h.failedMessages.Add(int64(payloadCount))
    		} else {
    			h.status.Store(statusOnline)
    		}
    	}()
    
    	ctx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/timer/TimeoutManager.java

         *
         * @param timeoutTarget target
         * @param timeout timeout
         * @param permanent permanent
         * @return {@link TimeoutTask}
         */
        public synchronized TimeoutTask addTimeoutTarget(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
            final TimeoutTask task = new TimeoutTask(timeoutTarget, timeout, permanent);
            timeoutTaskList.addLast(task);
            start();
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  6. src/test/java/jcifs/tests/WatchTest.java

                    cr.createNewFile();
                    assertNotified(w, FileNotifyInformation.FILE_ACTION_ADDED, "created", null);
                }
            }
            catch ( TimeoutException e ) {
                log.info("Timeout waiting", e);
                fail("Did not recieve notification");
            }
        }
    
    
        @Test
        public void testWatchModified () throws InterruptedException, ExecutionException, IOException {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 8.4K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt

          | * EventSourceListener
          | * WebSocketListener
          |(It is safe to call contentType() and contentLength() on these response bodies.)
          """.trimMargin(),
        )
      }
    
      override fun timeout() = Timeout.NONE
    
      override fun close() {
      }
    }
    
    fun Response.stripBody(): Response {
      return newBuilder()
        .body(UnreadableResponseBody(body.contentType(), body.contentLength()))
        .build()
    }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                nextNameTrnId = 1;
            }
            return nextNameTrnId;
        }
        void ensureOpen( int timeout ) throws IOException {
            closeTimeout = 0;
            if( SO_TIMEOUT != 0 ) {
                closeTimeout = Math.max( SO_TIMEOUT, timeout );
            }
            // If socket is still good, the new closeTimeout will
            // be ignored; see tryClose comment.
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 17.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Service.java

      void awaitRunning();
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
       * than the given time.
       *
       * @param timeout the maximum time to wait
       * @param unit the time unit of the timeout argument
       * @throws TimeoutException if the service has not reached the given state within the deadline
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  10. internal/logger/target/kafka/kafka.go

    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    	sconfig.Producer.Return.Successes = true
    	sconfig.Producer.Return.Errors = true
    	sconfig.Producer.RequiredAcks = 1
    	sconfig.Producer.Timeout = (10 * time.Second)
    	sconfig.Net.ReadTimeout = (10 * time.Second)
    	sconfig.Net.DialTimeout = (10 * time.Second)
    	sconfig.Net.WriteTimeout = (10 * time.Second)
    	sconfig.Metadata.Retry.Max = 1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top