Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 468 for joins (0.01 sec)

  1. internal/store/queuestore.go

    	enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf)
    
    	for i := range items {
    		if err = enc.Encode(items[i]); err != nil {
    			return err
    		}
    	}
    
    	path := filepath.Join(store.directory, key.String())
    	if key.Compress {
    		err = os.WriteFile(path, s2.Encode(nil, buf.Bytes()), os.FileMode(0o770))
    	} else {
    		err = os.WriteFile(path, buf.Bytes(), os.FileMode(0o770))
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  2. internal/logger/logger.go

    		trimStrings = append(trimStrings, filepath.Join(goRootString, "src")+string(filepath.Separator))
    	}
    
    	for _, defaultgoPathString := range defaultgoPathList {
    		trimStrings = append(trimStrings, filepath.Join(defaultgoPathString, "src")+string(filepath.Separator))
    	}
    
    	for _, defaultgoRootString := range defaultgoRootList {
    		trimStrings = append(trimStrings, filepath.Join(defaultgoRootString, "src")+string(filepath.Separator))
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  3. mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt

        val endsFirst = buildRequestThread(secondRequest, secondResponseCode)
        endsFirst.start()
        endsFirst.join()
        // First response is still waiting.
        assertThat(firstResponseCode.get()).isEqualTo(0)
        // Second response is done.
        assertThat(secondResponseCode.get()).isEqualTo(200)
        latch.countDown()
        startsFirst.join()
        // And now it's done!
        assertThat(firstResponseCode.get()).isEqualTo(200)
        // (Still done).
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 3.2K bytes
    - Viewed (1)
  4. android/guava-tests/test/com/google/common/primitives/DoublesTest.java

        assertThat(Doubles.join(",", EMPTY)).isEmpty();
        assertThat(Doubles.join(",", ARRAY1)).isEqualTo("1.0");
        assertThat(Doubles.join(",", 1.0, 2.0)).isEqualTo("1.0,2.0");
        assertThat(Doubles.join("", 1.0, 2.0, 3.0)).isEqualTo("1.02.03.0");
      }
    
      public void testJoinNonTrivialDoubles() {
        assertThat(Doubles.join(",", EMPTY)).isEmpty();
        assertThat(Doubles.join(",", 1.2)).isEqualTo("1.2");
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 30.9K bytes
    - Viewed (0)
  5. internal/config/compress/legacy.go

    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOn,
    		},
    		config.KV{
    			Key:   Extensions,
    			Value: strings.Join(cfg.Extensions, config.ValueSeparator),
    		},
    		config.KV{
    			Key:   MimeTypes,
    			Value: strings.Join(cfg.MimeTypes, config.ValueSeparator),
    		},
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sat Sep 06 17:37:10 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  6. internal/crypto/key.go

    		sealingKey   [32]byte
    		encryptedKey bytes.Buffer
    	)
    	mac := hmac.New(sha256.New, extKey)
    	mac.Write(iv[:])
    	mac.Write([]byte(domain))
    	mac.Write([]byte(SealAlgorithm))
    	mac.Write([]byte(path.Join(bucket, object))) // use path.Join for canonical 'bucket/object'
    	mac.Sum(sealingKey[:0])
    	if n, err := sio.Encrypt(&encryptedKey, bytes.NewReader(key[:]), sio.Config{Key: sealingKey[:]}); n != 64 || err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. schema/index.go

    			k := strings.TrimSpace(strings.ToUpper(v[0]))
    			if k == "INDEX" || k == "UNIQUEINDEX" {
    				var (
    					name       string
    					tag        = strings.Join(v[1:], ":")
    					idx        = strings.IndexByte(tag, ',')
    					tagSetting = strings.Join(strings.Split(tag, ",")[1:], ",")
    					settings   = ParseTagSetting(tagSetting, ",")
    					length, _  = strconv.Atoi(settings["LENGTH"])
    				)
    
    				if idx == -1 {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Wed May 21 02:35:56 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  8. internal/mountinfo/mountinfo_linux_test.go

    		/dev/1    /path/to/1   type1	flags 1 1
    		/dev/2 /path/to/1/2 type2 flags,1,2=3 2 2
                    /dev/3 /path/to/1.1 type3 flags,1,2=3 3 3
    		`
    	var err error
    	dir := t.TempDir()
    	mountsPath := filepath.Join(dir, "mounts")
    	if err = os.WriteFile(mountsPath, []byte(successCase), 0o666); err != nil {
    		t.Fatal(err)
    	}
    	// Failure case where we detected successfully cross device mounts.
    	{
    		absPaths := []string{"/path/to/1"}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/dict/stopwords/StopwordsItem.java

         *
         * @return The stopword as a string.
         */
        public String toLineString() {
            if (isUpdated()) {
                return StringUtils.join(newInput);
            }
            return StringUtils.join(input);
        }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 07:09:00 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/dict/mapping/CharMappingItem.java

         *
         * @return compact string representation of the mapping rule
         */
        public String toLineString() {
            if (isUpdated()) {
                return StringUtils.join(newInputs, ",") + "=>" + newOutput;
            }
            return StringUtils.join(inputs, ",") + "=>" + output;
        }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 07:09:00 UTC 2025
    - 7.9K bytes
    - Viewed (0)
Back to top