Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 548 for selects (0.19 sec)

  1. internal/s3select/select_benchmark_test.go

    func BenchmarkSelectAll_10M(b *testing.B) {
    	benchmarkSelectAll(b, 10*humanize.MiByte)
    }
    
    func benchmarkSingleCol(b *testing.B, count int) {
    	benchmarkSelect(b, count, "select id from S3Object")
    }
    
    // BenchmarkSingleRow_100K - benchmark SELECT column function with 100k records.
    func BenchmarkSingleCol_100K(b *testing.B) {
    	benchmarkSingleCol(b, 1e5)
    }
    
    // BenchmarkSelectAll_1M - benchmark * function with 1m records.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5K bytes
    - Viewed (0)
  2. internal/s3select/sql/parser.go

    	// Translate doubled quotes
    	*qi = QuotedIdentifier(strings.ReplaceAll(r, `""`, `"`))
    	return nil
    }
    
    // Types representing AST of SQL statement. Only SELECT is supported.
    
    // Select is the top level AST node type
    type Select struct {
    	Expression *SelectExpression `parser:"\"SELECT\" @@"`
    	From       *TableExpression  `parser:"\"FROM\" @@"`
    	Where      *Expression       `parser:"( \"WHERE\" @@ )?"`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  3. cmd/erasure.go

    		updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64())
    		t := time.NewTicker(updateTime)
    		defer t.Stop()
    		defer saverWg.Done()
    		var lastSave time.Time
    
    		for {
    			select {
    			case <-t.C:
    				if cache.Info.LastUpdate.Equal(lastSave) {
    					continue
    				}
    				scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update")
    				updates <- cache.clone()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformToAsciiTest.kt

    /** Runs the web platform ToAscii tests. */
    class WebPlatformToAsciiTest {
      @Suppress("ktlint:standard:max-line-length")
      val knownFailures =
        setOf(
          // OkHttp rejects empty labels.
          "x..xn--zca",
          "x..ß",
          // OkHttp rejects labels longer than 63 code points, the web platform tests don't.
          "x01234567890123456789012345678901234567890123456789012345678901x.xn--zca",
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. logger/slog_test.go

    	handler := slog.NewTextHandler(buf, &slog.HandlerOptions{AddSource: true})
    	logger := NewSlogLogger(slog.New(handler), Config{LogLevel: Info})
    
    	logger.Trace(context.Background(), time.Now(), func() (string, int64) {
    		return "select count(*) from users", 0
    	}, nil)
    
    	if strings.Contains(buf.String(), "gorm/logger/slog.go") {
    		t.Error("Found internal slog.go reference in caller frame. Expected only test file references.")
    	}
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Oct 30 10:56:26 UTC 2025
    - 782 bytes
    - Viewed (0)
  6. internal/grid/stream.go

    	muxID uint64
    	ctx   context.Context
    }
    
    // Send a payload to the remote server.
    func (s *Stream) Send(b []byte) error {
    	if s.Requests == nil {
    		return errors.New("stream does not accept requests")
    	}
    	select {
    	case s.Requests <- b:
    		return nil
    	case <-s.ctx.Done():
    		return context.Cause(s.ctx)
    	}
    }
    
    // Results returns the results from the remote server one by one.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  7. internal/bpool/bpool.go

    		bp.Put(buf[:bp.w])
    	}
    }
    
    // Get gets a []byte from the BytePool, or creates a new one if none are
    // available in the pool.
    func (bp *BytePoolCap) Get() (b []byte) {
    	if bp == nil {
    		return nil
    	}
    	select {
    	case b = <-bp.c:
    		// reuse existing buffer
    	default:
    		// create new aligned buffer
    		b = reedsolomon.AllocAligned(1, bp.wcap)[0][:bp.w]
    	}
    	return b
    }
    
    // Put returns the given Buffer to the BytePool.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/rdma/RdmaProviderFactory.java

    import jcifs.Configuration;
    import jcifs.internal.smb2.rdma.disni.DisniRdmaProvider;
    import jcifs.internal.smb2.rdma.tcp.TcpRdmaProvider;
    
    /**
     * Factory for creating RDMA provider instances.
     *
     * This factory attempts to select the best available RDMA provider
     * based on system capabilities and configuration preferences.
     */
    public class RdmaProviderFactory {
    
        /**
         * Private constructor to prevent instantiation
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  9. cmd/peer-rest-client.go

    	}
    	st.Results(func(b *grid.Bytes) error {
    		select {
    		case listenCh <- *b:
    		default:
    			// Do not block on slow receivers.
    			b.Recycle()
    		}
    		return nil
    	})
    }
    
    // Listen - listen on peers.
    func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	go func() {
    		for {
    			client.doListen(ctx, listenCh, v)
    			select {
    			case <-ctx.Done():
    				return
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  10. misc/ios/clangwrap.sh

    #!/bin/sh
    
    # This script configures clang to target the iOS simulator. If you'd like to
    # build for real iOS devices, change SDK to "iphoneos" and PLATFORM to "ios".
    # This uses the latest available iOS SDK, which is recommended. To select a
    # specific SDK, run 'xcodebuild -showsdks' to see the available SDKs and replace
    # iphonesimulator with one of them.
    
    SDK=iphonesimulator
    PLATFORM=ios-simulator
    
    if [ "$GOARCH" == "arm64" ]; then
    	CLANGARCH="arm64"
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Jun 18 16:32:49 UTC 2024
    - 724 bytes
    - Viewed (0)
Back to top