Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 421 - 430 of 506 for Closer (0.04 seconds)

  1. cmd/metacache-server-pool.go

    		}
    	}
    	if !truncated {
    		return entries, io.EOF
    	}
    	return entries, nil
    }
    
    // listMerged will list across all sets and return a merged results stream.
    // The result channel is closed when no more results are expected.
    func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error {
    	var mu sync.Mutex
    	var wg sync.WaitGroup
    	var errs []error
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  2. docs/ko/docs/tutorial/request-files.md

    * `read(size)`: 파일의 바이트 및 글자의 `size`(`int`)를 읽습니다.
    * `seek(offset)`: 파일 내 `offset`(`int`) 위치의 바이트로 이동합니다.
        * 예) `await myfile.seek(0)` 를 사용하면 파일의 시작부분으로 이동합니다.
        * `await myfile.read()` 를 사용한 후 내용을 다시 읽을 때 유용합니다.
    * `close()`: 파일을 닫습니다.
    
    상기 모든 메소드들이 `async` 메소드이기 때문에 “await”을 사용하여야 합니다.
    
    예를들어, `async` *경로 작동 함수*의 내부에서 다음과 같은 방식으로 내용을 가져올 수 있습니다:
    
    ```Python
    contents = await myfile.read()
    ```
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Nov 18 02:25:44 GMT 2024
    - 8K bytes
    - Click Count (0)
  3. gorm.go

    		config.ClauseBuilders = map[string]clause.ClauseBuilder{}
    	}
    
    	if config.Dialector != nil {
    		err = config.Dialector.Initialize(db)
    		if err != nil {
    			if db, _ := db.DB(); db != nil {
    				_ = db.Close()
    			}
    
    			// DB is not initialized, so we skip AfterInitialize
    			skipAfterInitialize = true
    			return
    		}
    
    		if config.TranslateError {
    			if _, ok := db.Dialector.(ErrorTranslator); !ok {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Aug 26 06:24:29 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  4. src/archive/tar/format.go

    // the maximum number of bytes allowed for each string field and
    // the integer type used to store each numeric field
    // (where timestamps are stored as the number of seconds since the Unix epoch).
    //
    // The table's lower portion shows specialized features of each format,
    // such as supported string encodings, support for sub-second timestamps,
    // or support for sparse files.
    //
    // The Writer currently provides no support for sparse files.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 11.3K bytes
    - Click Count (0)
  5. cmd/config-current.go

    		if err != nil {
    			return err
    		}
    		if etcdCfg.Enabled {
    			etcdClnt, err := etcd.New(etcdCfg)
    			if err != nil {
    				return err
    			}
    			etcdClnt.Close()
    		}
    	case config.IdentityOpenIDSubSys:
    		if _, err := openid.LookupConfig(s,
    			xhttp.WithUserAgent(NewHTTPTransport(), func() string {
    				return getUserAgent(getMinioMode())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  6. cmd/prepare-storage.go

    // connect to list of endpoints and load all Erasure disk formats, validate the formats are correct
    // and are in quorum, if no formats are found attempt to initialize all of them for the first
    // time. additionally make sure to close all the disks used in this attempt.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  7. cmd/local-locker.go

    		if len(v) == 0 {
    			delete(l.lockMap, k)
    			continue
    		}
    		lockCopy[k] = append(make([]lockRequesterInfo, 0, len(v)), v...)
    	}
    	return lockCopy
    }
    
    func (l *localLocker) Close() error {
    	return nil
    }
    
    // IsOnline - local locker is always online.
    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  8. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/SinceAndIncubatingRulesKotlinTest.kt

                v1 = baseline,
                v2 = """
    
                /** @since 1.0 */
                interface Foo : AutoCloseable {
                    fun foo()
                    override fun close()
                }
    
                /** @since 1.0 */
                class Bar() {
    
                    constructor(bar: String) : this()
    
                    $publicKotlinMembers
                }
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Jun 06 17:52:09 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  9. api/go1.9.txt

    pkg crypto, const BLAKE2s_256 Hash
    pkg crypto/x509, type Certificate struct, ExcludedDNSDomains []string
    pkg database/sql, method (*Conn) BeginTx(context.Context, *TxOptions) (*Tx, error)
    pkg database/sql, method (*Conn) Close() error
    pkg database/sql, method (*Conn) ExecContext(context.Context, string, ...interface{}) (Result, error)
    pkg database/sql, method (*Conn) PingContext(context.Context) error
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Oct 04 20:20:20 GMT 2021
    - 10.7K bytes
    - Click Count (0)
  10. cmd/erasure-multipart.go

    			return pi, toObjectErr(errUploadIDNotFound, bucket, object, uploadID)
    		}
    		if errors.Is(err, errFileNotFound) {
    			// An in-quorum errFileNotFound means that client stream
    			// prematurely closed and we do not find any xl.meta or
    			// part.1's - in such a scenario we must return as if client
    			// disconnected. This means that erasure.Encode() CreateFile()
    			// did not do anything.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
Back to Top