Search Options

Results per page
Sort
Preferred Languages
Advance

Results 551 - 560 of 1,147 for pool (0.02 sec)

  1. schema/utils.go

    	var (
    		results       = [][]interface{}{}
    		dataResults   = map[string][]reflect.Value{}
    		loaded        = map[interface{}]bool{}
    		notZero, zero bool
    	)
    
    	if reflectValue.Kind() == reflect.Ptr ||
    		reflectValue.Kind() == reflect.Interface {
    		reflectValue = reflectValue.Elem()
    	}
    
    	switch reflectValue.Kind() {
    	case reflect.Map:
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Oct 30 11:15:36 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/crypto/CachedCipher.java

         *
         * @return an encryption cipher
         */
        protected Cipher pollEncryptoCipher() {
            Cipher cipher = encryptoQueue.poll();
            if (cipher == null) {
                try {
                    final SecretKeySpec sksSpec = new SecretKeySpec(key.getBytes(charsetName), algorithm);
                    cipher = Cipher.getInstance(algorithm);
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat Nov 22 11:21:59 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  3. docs_src/python_types/tutorial005_py39.py

    def get_items(item_a: str, item_b: int, item_c: float, item_d: bool, item_e: bytes):
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 20 06:40:21 UTC 2025
    - 135 bytes
    - Viewed (0)
  4. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerThreadTest.java

         */
        public void test_run_noUrlsInQueue() throws Exception {
            when(urlQueueService.poll(anyString())).thenReturn(null);
            crawlerContext.setStatus(CrawlerStatus.RUNNING);
            crawlerContext.maxThreadCheckCount = 1; // Will exit after 1 check
    
            crawlerThread.run();
    
            verify(urlQueueService, times(1)).poll(anyString());
        }
    
        /**
         * Test run method with crawler status DONE.
         */
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  5. cmd/erasure_test.go

    import (
    	"bytes"
    	"crypto/rand"
    	"io"
    	"testing"
    )
    
    var erasureEncodeDecodeTests = []struct {
    	dataBlocks, parityBlocks   int
    	missingData, missingParity int
    	reconstructParity          bool
    	shouldFail                 bool
    }{
    	{dataBlocks: 2, parityBlocks: 2, missingData: 0, missingParity: 0, reconstructParity: true, shouldFail: false},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  6. internal/arn/arn_test.go

    		})
    	}
    }
    
    func TestNewIAMRoleARN(t *testing.T) {
    	type args struct {
    		resourceID   string
    		serverRegion string
    	}
    	tests := []struct {
    		name    string
    		args    args
    		want    ARN
    		wantErr bool
    	}{
    		{
    			name: "valid resource ID must succeed",
    			args: args{
    				resourceID:   "my-role",
    				serverRegion: "us-east-1",
    			},
    			want: ARN{
    				Partition:    "minio",
    				Service:      "iam",
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 04 08:31:34 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/opensearch/log/cbean/cq/bs/BsUserInfoCQ.java

        }
    
        public void bool(BoolCall<UserInfoCQ> boolLambda) {
            bool(boolLambda, null);
        }
    
        public void bool(BoolCall<UserInfoCQ> boolLambda, ConditionOptionCall<BoolQueryBuilder> opLambda) {
            UserInfoCQ mustQuery = new UserInfoCQ();
            UserInfoCQ shouldQuery = new UserInfoCQ();
            UserInfoCQ mustNotQuery = new UserInfoCQ();
            UserInfoCQ filterQuery = new UserInfoCQ();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 20.1K bytes
    - Viewed (0)
  8. internal/config/lambda/event/targetlist.go

    package event
    
    import (
    	"fmt"
    	"maps"
    	"net/http"
    	"strings"
    	"sync"
    )
    
    // Target - lambda target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Send(Event) (*http.Response, error)
    	Stat() TargetStat
    	Close() error
    }
    
    // TargetStats is a collection of stats for multiple targets.
    type TargetStats struct {
    	TargetStats map[string]TargetStat
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  9. cmd/bucket-metadata-sys.go

    	"golang.org/x/sync/singleflight"
    )
    
    // BucketMetadataSys captures all bucket metadata for a given cluster.
    type BucketMetadataSys struct {
    	objAPI ObjectLayer
    
    	sync.RWMutex
    	initialized bool
    	group       *singleflight.Group
    	metadataMap map[string]BucketMetadata
    }
    
    // Count returns number of bucket metadata map entries.
    func (sys *BucketMetadataSys) Count() int {
    	sys.RLock()
    	defer sys.RUnlock()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  10. docs/pt/docs/tutorial/query-params.md

    ///
    
    ## Conversão dos tipos de parâmetros de consulta { #query-parameter-type-conversion }
    
    Você também pode declarar tipos `bool`, e eles serão convertidos:
    
    {* ../../docs_src/query_params/tutorial003_py310.py hl[7] *}
    
    Nesse caso, se você for para:
    
    ```
    http://127.0.0.1:8000/items/foo?short=1
    ```
    
    ou
    
    ```
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 5K bytes
    - Viewed (0)
Back to top