Search Options

Results per page
Sort
Preferred Languages
Advance

Results 961 - 970 of 1,197 for current (0.05 sec)

  1. internal/s3select/sql/statement.go

    		r := int64(*v.Int)
    		if r < 0 {
    			return -1, errBadLimitSpecified
    		}
    		return r, nil
    	}
    }
    
    // EvalFrom evaluates the From clause on the input record. It only
    // applies to JSON input data format (currently).
    func (e *SelectStatement) EvalFrom(format string, input Record) ([]*Record, error) {
    	if !e.selectAST.From.HasKeypath() {
    		return []*Record{&input}, nil
    	}
    	_, rawVal := input.Raw()
    
    	if format != "json" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       * call cancel() and be unable to cancel the delegate.
       * There are a number of ways to solve this, none of which are very pretty, and it is currently
       * believed to be a purely theoretical problem (since the other actions should supply sufficient
       * write-barriers).
       */
    
      @CheckForNull @LazyInit private ListenableFuture<V> delegateRef;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. cmd/metrics-v3-handler.go

    	return fmt.Sprintf("| `%s` | `%s` | %s | %s |\n", md.Name, md.Type, md.Help, labels)
    }
    
    // listMetrics - returns a handler that lists all the metrics that could be
    // returned for the requested path.
    //
    // FIXME: It currently only lists `minio_` prefixed metrics.
    func (h *metricsV3Server) listMetrics(path string) http.Handler {
    	// First collect all matching MetricsGroup's
    	matchingMG := make(map[collectorPath]*MetricsGroup)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            Future<?> possiblyIgnoredError = executor.submit(task);
          }
          awaitUnchecked(barrier);
          assertThat(future.isDone()).isTrue();
          // inspect state and ensure it is correct!
          // asserts that all get calling threads received the same value
          Object result = Iterables.getOnlyElement(finalResults);
          if (result == CancellationException.class) {
            assertTrue(future.isCancelled());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server.go

    				logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2))
    				if len(offlineEndpoints) > 0 {
    					logger.Info(fmt.Sprintf("Following servers are currently offline or unreachable %s", offlineEndpoints))
    				}
    				if len(incorrectConfigs) > 0 {
    					logger.Info(fmt.Sprintf("Following servers have mismatching configuration %s", incorrectConfigs))
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

        if (writerTask != null) {
          taskQueue.schedule(writerTask)
        }
      }
    
      /**
       * Attempts to remove a single frame from a queue and send it. This prefers to write urgent pongs
       * before less urgent messages and close frames. For example it's possible that a caller will
       * enqueue messages followed by pongs, but this sends pongs followed by messages. Pongs are always
       * written in the order they were enqueued.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  7. docs/en/docs/how-to/custom-docs-ui-assets.md

     */
    !function(e,t){"object"==typeof exports&&"object"==typeof m
    
    ...
    ```
    
    That confirms that you are being able to serve static files from your app, and that you placed the static files for the docs in the correct place.
    
    Now we can configure the app to use those static files for the docs.
    
    ### Disable the automatic docs for static files
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:42:34 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/request-files.md

    But when the form includes files, it is encoded as `multipart/form-data`. If you use `File`, **FastAPI** will know it has to get the files from the correct part of the body.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/graph/DefaultGraphBuilder.java

                    String message = String.format(
                            "The project exclusion%s in --projects/-pl resulted in an "
                                    + "empty reactor, please correct %s.",
                            isPlural ? "s" : "", isPlural ? "them" : "it");
                    throw new MavenExecutionException(message, request.getPom());
                }
            }
    
            return result;
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  10. internal/grid/muxserver.go

    				gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last))
    				m.close()
    				return
    			}
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    		if debugPrint {
    			fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top