Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 571 - 580 of 1,016 for pool (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/ioutil/append-file_nix.go

    package ioutil
    
    import (
    	"io"
    	"os"
    )
    
    // AppendFile - appends the file "src" to the file "dst"
    func AppendFile(dst string, src string, osync bool) error {
    	flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE
    	if osync {
    		flags |= os.O_SYNC
    	}
    	appendFile, err := os.OpenFile(dst, flags, 0o666)
    	if err != nil {
    		return err
    	}
    	defer appendFile.Close()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 1.3K bytes
    - Click Count (0)
  2. callbacks/callmethod.go

    package callbacks
    
    import (
    	"reflect"
    
    	"gorm.io/gorm"
    )
    
    func callMethod(db *gorm.DB, fc func(value interface{}, tx *gorm.DB) bool) {
    	tx := db.Session(&gorm.Session{NewDB: true})
    	if called := fc(db.Statement.ReflectValue.Interface(), tx); !called {
    		switch db.Statement.ReflectValue.Kind() {
    		case reflect.Slice, reflect.Array:
    			db.Statement.CurDestIndex = 0
    			for i := 0; i < db.Statement.ReflectValue.Len(); i++ {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Feb 18 01:20:29 GMT 2023
    - 846 bytes
    - Click Count (0)
  3. docs/fr/docs/tutorial/query-params.md

    ///
    
    ## Conversion des types des paramètres de requête { #query-parameter-type-conversion }
    
    Vous pouvez aussi déclarer des types `bool`, ils seront convertis :
    
    {* ../../docs_src/query_params/tutorial003_py310.py hl[7] *}
    
    Dans ce cas, si vous allez sur :
    
    ```
    http://127.0.0.1:8000/items/foo?short=1
    ```
    
    ou
    
    ```
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 5.3K bytes
    - Click Count (0)
  4. internal/http/transports.go

    	DialTimeout time.Duration
    
    	// TLS Settings
    	RootCAs          *x509.CertPool
    	CipherSuites     []uint16
    	CurvePreferences []tls.CurveID
    
    	// HTTP2
    	EnableHTTP2 bool
    
    	// TCP Options
    	TCPOptions TCPOptions
    }
    
    func (s ConnSettings) getDefaultTransport(maxIdleConnsPerHost int) *http.Transport {
    	if maxIdleConnsPerHost <= 0 {
    		maxIdleConnsPerHost = 1024
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 17:51:53 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  5. internal/deadlineconn/deadlineconn.go

    	writeDeadline           time.Duration // sets the write deadline on a connection.
    	writeSetAt              time.Time
    	abortReads, abortWrites atomic.Bool // A deadline was set to indicate caller wanted the conn to time out.
    	infReads, infWrites     atomic.Bool
    	mu                      sync.Mutex
    }
    
    // Unwrap will unwrap the connection and remove the deadline if applied.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/query/TermQueryCommandTest.java

                }
            });
        }
    
        @Test
        public void test_convertTermQuery() throws Exception {
            setQueryType("bool");
            assertQueryBuilder(DefaultQueryBuilder.class,
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 20.4K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/helper/SearchLogHelperTest.java

            searchLogHelper.createSearchLog(params, now, "test-query-id", "test query", 0, 10, queryResponseList, context);
    
            assertFalse(searchLogHelper.searchLogQueue.isEmpty());
            return searchLogHelper.searchLogQueue.poll();
        }
    
        @Test
        public void test_addSearchLog_accessType_json() {
            final SearchLog searchLog = callCreateSearchLogAndGetResult(Constants.SEARCH_LOG_ACCESS_TYPE_JSON);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 16.6K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/opensearch/log/cbean/cq/bs/BsFavoriteLogCQ.java

        }
    
        public void bool(BoolCall<FavoriteLogCQ> boolLambda) {
            bool(boolLambda, null);
        }
    
        public void bool(BoolCall<FavoriteLogCQ> boolLambda, ConditionOptionCall<BoolQueryBuilder> opLambda) {
            FavoriteLogCQ mustQuery = new FavoriteLogCQ();
            FavoriteLogCQ shouldQuery = new FavoriteLogCQ();
            FavoriteLogCQ mustNotQuery = new FavoriteLogCQ();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 42.7K bytes
    - Click Count (0)
  9. internal/crypto/auto-encryption.go

    	EnvKMSAutoEncryption = "MINIO_KMS_AUTO_ENCRYPTION"
    )
    
    // LookupAutoEncryption returns true if and only if
    // the MINIO_KMS_AUTO_ENCRYPTION env. variable is
    // set to "on".
    func LookupAutoEncryption() bool {
    	auto, _ := config.ParseBool(env.Get(EnvKMSAutoEncryption, config.EnableOff))
    	return auto
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 1.4K bytes
    - Click Count (0)
  10. cmd/common-main.go

    	if updateMsg == "" {
    		return
    	}
    
    	logger.Info(prepareUpdateMessage("Run `mc admin update ALIAS`", lrTime.Sub(currentReleaseTime)))
    }
    
    func newConfigDir(dir string, dirSet bool, getDefaultDir func() string) (*ConfigDir, error) {
    	if dir == "" {
    		dir = getDefaultDir()
    	}
    
    	if dir == "" {
    		if !dirSet {
    			return nil, fmt.Errorf("missing option must be provided")
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
Back to Top