Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 219 for processed (0.07 sec)

  1. internal/s3select/sql/statement.go

    func (e *SelectStatement) IsAggregated() bool {
    	return e.selectQProp.isAggregation
    }
    
    // AggregateResult - returns the aggregated result after all input
    // records have been processed. Applies only to aggregation queries.
    func (e *SelectStatement) AggregateResult(output Record) error {
    	for i, expr := range e.selectAST.Expression.Expressions {
    		v, err := expr.evalNode(nil, e.tableAlias)
    		if err != nil {
    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. src/cmd/asm/internal/lex/lex_test.go

    		}
    	}
    }
    
    // lines joins the arguments together as complete lines.
    func lines(a ...string) string {
    	return strings.Join(a, "\n") + "\n"
    }
    
    // drain returns a single string representing the processed input tokens.
    func drain(input *Input) string {
    	var buf strings.Builder
    	for {
    		tok := input.Next()
    		if tok == scanner.EOF {
    			return buf.String()
    		}
    		if tok == '#' {
    			continue
    		}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/util/MD4.java

         */
        private static final int BLOCK_LENGTH = 64;       //    = 512 / 8;
    
        /**
         * 4 32-bit words (interim result)
         */
        private int[] context = new int[4];
    
        /**
         * Number of bytes processed so far mod. 2 power of 64.
         */
        private long count;
    
        /**
         * 512 bits input buffer = 16 x 32-bit words holds until reaches 512 bits.
         */
        private byte[] buffer = new byte[BLOCK_LENGTH];
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9.3K bytes
    - Viewed (0)
  4. misc/cgo/gmp/gmp.go

    multiprecision library gmp's integer type mpz_t wrapped to look like
    the Go package big's integer type Int.
    
    This is a syntactically valid Go program—it can be parsed with the Go
    parser and processed by godoc—but it is not compiled directly by gc.
    Instead, a separate tool, cgo, processes it to produce three output
    files.  The first two, 6g.go and 6c.c, are a Go source file for 6g and
    a C source file for 6c; both compile as part of the named package
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Apr 11 16:34:30 UTC 2022
    - 9.5K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AggregateFutureState.java

        extends AbstractFuture.TrustedFuture<OutputT> {
      // Lazily initialized the first time we see an exception; not released until all the input futures
      // have completed and we have processed them all.
      @CheckForNull private volatile Set<Throwable> seenExceptions = null;
    
      private volatile int remaining;
    
      private static final AtomicHelper ATOMIC_HELPER;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

            CHILD_URL, //
            CHILD_URLS, //
            EVALUATED, //
            EXCEPTION, //
            FINISHED, //
            PARSED, //
            PREPARED, //
            REDIRECTED, //
            PROCESSED,//
        }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  7. cmd/data-scanner-metric.go

    	return func(path string) {
    			atomic.StorePointer(tracker.name, unsafe.Pointer(&path))
    		}, func() {
    			p.currentPaths.Delete(disk)
    		}
    }
    
    // getCurrentPaths returns the paths currently being processed.
    func (p *scannerMetrics) getCurrentPaths() []string {
    	var res []string
    	prefix := globalLocalNodeName + "/"
    	p.currentPaths.Range(func(key, value interface{}) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 05:15:31 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

       * method returns.
       *
       * <p>This method does not create any memory pressure as would be required to cause soft
       * references to be processed.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       * @since 12.0
       */
      @SuppressWarnings({"removal", "Finalize"}) // b/260137033
      public static void awaitFullGc() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/podcgroupns.go

    	return r < '0' || r > '9'
    }
    
    func (p *PodNetnsProcFinder) FindNetnsForPods(pods map[types.UID]*corev1.Pod) (PodToNetns, error) {
    	/*
    		for each process, find its netns inode,
    		if we already seen the inode, skip it
    		if we haven't seen the inode, check the process cgroup and see if we
    		can extract a pod uid from it.
    		if we can, open the netns, and save a map of uid->netns-fd
    	*/
    
    	podUIDNetns := make(PodToNetns)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  10. src/main/resources/fess_message_ru.properties

    errors.login_error=Username or Password is not correct.
    errors.sso_login_error=Failed to process SSO login.
    errors.could_not_find_log_file=Could not find {0}.
    errors.failed_to_start_crawl_process=Failed to start a crawl process.
    errors.invalid_design_jsp_file_name=Invalid JSP file.
    errors.design_jsp_file_does_not_exist=JSP file does not exist.
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri May 20 12:12:28 UTC 2022
    - 10.2K bytes
    - Viewed (0)
Back to top