Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 651 - 660 of 1,052 for UP (0.01 seconds)

  1. cmd/streaming-signature-v4.go

    	if err != nil {
    		return err
    	}
    	if buf[0] != '\r' || buf[1] != '\n' {
    		return errMalformedEncoding
    	}
    	return nil
    }
    
    // Read a line of bytes (up to \n) from b.
    // Give up if the line exceeds maxLineLength.
    // The returned bytes are owned by the bufio.Reader
    // so they are only valid until the next bufio read.
    func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  2. cmd/erasure-healing.go

    				cannotHeal = true
    				break
    			}
    		}
    	}
    
    	if cannotHeal {
    		// Allow for dangling deletes, on versions that have DataDir missing etc.
    		// this would end up restoring the correct readable versions.
    		m, err := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, dataErrsByPart, ObjectOptions{
    			VersionID: versionID,
    		})
    		errs = make([]error, len(errs))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  3. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/AbstractMojo.java

        @Deprecated
        @Override
        public void setLog(Log log) {
            this.log = log;
        }
    
        /**
         * <p>
         * Returns the logger that has been injected into this mojo. If no logger has been set up yet, a
         * <code>SystemStreamLog</code> logger will be created and returned.
         * </p>
         * <strong>Note:</strong>
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

           */
          /*
           * A CopyOnWriteArraySet<WeakReference> is faster than a newSetFromMap of a MapMaker map with
           * weakKeys() and concurrencyLevel(1), even up to at least 12 cached exception types.
           */
          private static final Set<WeakReference<Class<? extends Exception>>> validClasses =
              new CopyOnWriteArraySet<>();
    
          @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  5. scripts/people.py

        updated = update_content(content_path=people_path, new_content=people)
    
        if not updated:
            logging.info("The data hasn't changed, finishing.")
            return
    
        logging.info("Setting up GitHub Actions git user")
        subprocess.run(["git", "config", "user.name", "github-actions[bot]"], check=True)
        subprocess.run(
            ["git", "config", "user.email", "github-actions[bot]@users.noreply.github.com"],
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  6. cmd/os-readdir_test.go

    		if expected[i] != got[i] {
    			return false
    		}
    	}
    
    	// expected and got have same entries.
    	return true
    }
    
    // teardown - cleans up test directories.
    func teardown(testResults []result) {
    	for _, r := range testResults {
    		os.RemoveAll(r.dir)
    	}
    }
    
    // TestReadDir - test function to run various readDir() tests.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  7. cmd/bootstrap-peer-server.go

    				mu.Unlock()
    			}(clnt)
    		}
    		wg.Wait()
    
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    			retries++
    			// after 20 retries start logging that servers are not reachable yet
    			if retries >= 20 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Oct 01 22:13:18 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        /**
         * Executes the thumbnail generator process.
         * Sets up the classpath, JVM options, and command line arguments
         * to launch the ThumbnailGenerator in a separate process.
         *
         * @throws JobProcessingException if the thumbnail generation process fails
         */
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb/PreauthIntegrityService.java

         */
        public void cleanup() {
            for (PreauthIntegrityContext context : sessionContexts.values()) {
                context.invalidate();
            }
            sessionContexts.clear();
            log.debug("Cleaned up all preauth integrity contexts");
        }
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        assertEquals(0, numCalls.get());
        reject.set(false);
        executor.execute(task);
        assertEquals(1, numCalls.get());
      }
    
      /*
       * Under Android, MyError propagates up and fails the test?
       *
       * TODO(b/218700094): Does this matter to prod users, or is it just a feature of our testing
       * environment? If the latter, maybe write a custom Executor that avoids failing the test when it
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 11.4K bytes
    - Click Count (0)
Back to Top