Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 299 for cluster (0.08 sec)

  1. tests/non_std_test.go

    	DB.First(&animal, animal.Counter)
    	if animal.Name != "galeone" {
    		t.Errorf("Name fields shouldn't be changed if untouched, but got %v", animal.Name)
    	}
    
    	// When changing a field with a default value, the change must occur
    	animal.Name = "amazing horse"
    	DB.Save(&animal)
    	DB.First(&animal, animal.Counter)
    	if animal.Name != "amazing horse" {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. src/cmd/addr2line/main.go

    	os.Exit(2)
    }
    
    func main() {
    	log.SetFlags(0)
    	log.SetPrefix("addr2line: ")
    	counter.Open()
    
    	// pprof expects this behavior when checking for addr2line
    	if len(os.Args) > 1 && os.Args[1] == "--help" {
    		printUsage(os.Stdout)
    		os.Exit(0)
    	}
    
    	flag.Usage = usage
    	flag.Parse()
    	counter.Inc("addr2line/invocations")
    	counter.CountFlags("addr2line/flag:", *flag.CommandLine)
    	if flag.NArg() != 1 {
    		usage()
    	}
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  3. cmd/metacache-stream.go

    				continue
    			}
    		}
    	}()
    
    	return objs, nil
    }
    
    // Close and release resources.
    func (w *metacacheWriter) Close() error {
    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  4. src/cmd/asm/main.go

    	"cmd/internal/bio"
    	"cmd/internal/obj"
    	"cmd/internal/objabi"
    	"cmd/internal/telemetry/counter"
    )
    
    func main() {
    	log.SetFlags(0)
    	log.SetPrefix("asm: ")
    	counter.Open()
    
    	buildcfg.Check()
    	GOARCH := buildcfg.GOARCH
    
    	flags.Parse()
    	counter.Inc("asm/invocations")
    	counter.CountFlags("asm/flag:", *flag.CommandLine)
    
    	architecture := arch.Set(GOARCH, *flags.Shared || *flags.Dynlink)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Sun Apr 13 15:09:12 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/TempFileCreator.java

          @SuppressWarnings("GoodTime") // reading system time without TimeSource
          String baseName = System.currentTimeMillis() + "-";
    
          for (int counter = 0; counter < TEMP_DIR_ATTEMPTS; counter++) {
            File tempDir = new File(baseDir, baseName + counter);
            if (tempDir.mkdir()) {
              return tempDir;
            }
          }
          throw new IllegalStateException(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/MultiReaderTest.java

        String testString = "abcdefgh";
        CharSource source = newCharSource(testString);
        int[] counter = new int[1];
        CharSource reader =
            new CharSource() {
              @Override
              public Reader openStream() throws IOException {
                if (counter[0]++ != 0) {
                  throw new IllegalStateException("More than one source open");
                }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java

        }
    
        /**
         * Increment requests sent counter
         */
        public void incrementRequestsSent() {
            requestsSent.incrementAndGet();
        }
    
        /**
         * Increment requests received counter
         */
        public void incrementRequestsReceived() {
            requestsReceived.incrementAndGet();
        }
    
        /**
         * Increment error counter
         */
        public void incrementErrors() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  8. compat/maven-artifact/src/main/java/org/apache/maven/artifact/resolver/MultipleArtifactsNotFoundException.java

            StringBuilder buffer = new StringBuilder(256);
    
            buffer.append("Missing:").append(LS);
            buffer.append("----------").append(LS);
    
            int counter = 0;
    
            for (Artifact artifact : artifacts) {
                String message = (++counter) + ") " + artifact.getId();
    
                buffer.append(constructMissingArtifactMessage(
                        message,
                        "  ",
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/base/SuppliersTest.java

        Supplier<Integer> nonThreadSafe =
            new Supplier<Integer>() {
              int counter = 0;
    
              @Override
              public Integer get() {
                int nextValue = counter + 1;
                Thread.yield();
                counter = nextValue;
                return counter;
              }
            };
    
        int numThreads = 10;
        int iterations = 1000;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/io/MultiInputStreamTest.java

      }
    
      public void testOnlyOneOpen() throws Exception {
        ByteSource source = newByteSource(0, 50);
        int[] counter = new int[1];
        ByteSource checker =
            new ByteSource() {
              @Override
              public InputStream openStream() throws IOException {
                if (counter[0]++ != 0) {
                  throw new IllegalStateException("More than one source open");
                }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.6K bytes
    - Viewed (0)
Back to top