Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 673 for john (0.02 seconds)

  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))
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  2. schema/constraint.go

    			names := strings.Split(chk, ",")
    			if len(names) > 1 && regEnLetterAndMidline.MatchString(names[0]) {
    				checks[names[0]] = CheckConstraint{Name: names[0], Constraint: strings.Join(names[1:], ","), Field: field}
    			} else {
    				if names[0] == "" {
    					chk = strings.Join(names[1:], ",")
    				}
    				name := schema.namer.CheckerName(schema.Table, field.DBName)
    				checks[name] = CheckConstraint{Name: name, Constraint: chk, Field: field}
    			}
    		}
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Mon Mar 18 07:33:54 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  3. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  4. 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),
    		},
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Sep 06 17:37:10 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  5. 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");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Mar 08 01:43:32 GMT 2026
    - 30.9K bytes
    - Click Count (0)
  6. 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).
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 3.2K bytes
    - Click Count (1)
  7. src/test/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImplTest.java

                }
            });
    
            // Start both threads
            threads[0].start();
            threads[1].start();
    
            // Wait for completion
            threads[0].join();
            threads[1].join();
    
            // Verify no exceptions occurred (the main goal is no ConcurrentModificationException)
            assertNull(exceptions[0], "Add thread threw exception");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 19.7K bytes
    - Click Count (0)
  8. 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))
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  9. tests/generics_test.go

    	}
    
    	// Left JOIN w/o WHERE
    	result, err = db.Joins(clause.LeftJoin.Association("Company"), nil).Where(map[string]any{"name": u.Name}).First(ctx)
    	if err != nil {
    		t.Fatalf("Joins failed: %v", err)
    	}
    	if result.Name != u.Name || result.Company.Name != u.Company.Name {
    		t.Fatalf("Joins expected %s, got %+v", u.Name, result)
    	}
    
    	// Left JOIN + Alias WHERE
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Tue Dec 30 08:11:14 GMT 2025
    - 34.9K bytes
    - Click Count (0)
  10. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/RestTestBasePlugin.java

                    runnerNonInputProperties.systemProperty(TESTS_REST_CLUSTER, () -> String.join(",", cluster.getAllHttpSocketURI()));
                    runnerNonInputProperties.systemProperty(TESTS_CLUSTER, () -> String.join(",", cluster.getAllTransportPortURI()));
                    runnerNonInputProperties.systemProperty(TESTS_CLUSTER_NAME, cluster::getName);
                } else {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Aug 05 18:56:52 GMT 2021
    - 4.4K bytes
    - Click Count (0)
Back to Top