Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 910 for dove (0.02 sec)

  1. cmd/os_other.go

    		maxEntries = opts.count
    	}
    
    	done := false
    	remaining := opts.count
    
    	for !done {
    		// Read up to max number of entries.
    		fis, err := d.Readdir(maxEntries)
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return nil, osErrToFileErr(err)
    		}
    		if opts.count > -1 {
    			if remaining <= len(fis) {
    				fis = fis[:remaining]
    				done = true
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 13 15:14:36 UTC 2023
    - 4K bytes
    - Viewed (0)
  2. internal/dsync/dsync_test.go

    		// fmt.Println("Unlocking dm1")
    
    		dm1st.Unlock(context.Background())
    	}()
    	expect += 2 * testDrwMutexAcquireTimeout
    
    	var wg sync.WaitGroup
    	wg.Add(2)
    
    	go func() {
    		defer wg.Done()
    
    		dm2nd.Lock(id, source)
    
    		// Release lock after 10 seconds
    		go func() {
    			time.Sleep(2 * testDrwMutexAcquireTimeout)
    			// fmt.Println("Unlocking dm2")
    
    			dm2nd.Unlock(context.Background())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/main/java/org/fusesource/jansi/Ansi.java

         *
         * @param x the index (1-based) of the column to move to
         * @return this Ansi instance
         */
        public Ansi cursorToColumn(final int x) {
            return appendEscapeSequence('G', Math.max(1, x));
        }
    
        /**
         * Moves the cursor up. If the parameter y is negative it moves the cursor down.
         *
         * @param y the number of lines to move up
         * @return this Ansi instance
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  4. docs/site-replication/run-sse-kms-object-replication.sh

    echo "done"
    
    if [ ! -f ./mc ]; then
    	echo -n "Downloading MinIO client ..."
    	wget -O mc https://dl.min.io/client/mc/release/linux-amd64/mc &&
    		chmod +x mc
    	echo "done"
    fi
    
    export MC_HOST_minio1=https://minio:minio123@localhost:9001
    export MC_HOST_minio2=https://minio:minio123@localhost:9002
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. internal/grid/muxclient.go

    	for !errState {
    		select {
    		case <-m.ctx.Done():
    			if debugPrint {
    				fmt.Println("Client sending disconnect to mux", m.MuxID)
    			}
    			m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx))
    			errState = true
    			continue
    		case <-pingTimer:
    			if !m.doPing(errResp) {
    				errState = true
    				continue
    			}
    		case req, ok := <-requests:
    			if !ok {
    				// Done send EOF
    				if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  6. docs/ko/docs/tutorial/body-multiple-params.md

    ```JSON
    {
        "item": {
            "name": "Foo",
            "description": "The pretender",
            "price": 42.0,
            "tax": 3.2
        },
        "user": {
            "username": "dave",
            "full_name": "Dave Grohl"
        }
    }
    ```
    
    /// note | "참고"
    
    이전과 같이 `item`이 선언 되었더라도, 본문 내의 `item` 키가 있을 것이라고 예측합니다.
    
    ///
    
    FastAPI는 요청을 자동으로 변환해, 매개변수의 `item`과 `user`를 특별한 내용으로 받도록 할 것입니다.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. tests/prepared_stmt_test.go

    	wg := sync.WaitGroup{}
    	for i := 0; i < 100; i++ {
    		wg.Add(1)
    		go func() {
    			user := User{Name: "jinzhu"}
    			tx.Create(&user)
    
    			var result User
    			tx.First(&result)
    			wg.Done()
    		}()
    	}
    	wg.Wait()
    
    	conn, ok := tx.ConnPool.(*gorm.PreparedStmtDB)
    	AssertEqual(t, ok, true)
    	AssertEqual(t, len(conn.Stmts), 2)
    	for _, stmt := range conn.Stmts {
    		if stmt == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  8. buildscripts/heal-inconsistent-versions.sh

    		"${PWD}/mc" cp /etc/hosts minio/bucket/testobj
    
    		sudo chown -R ${USER}. "${WORK_DIR}/disk${i}"
    	done
    
    	for vid in $("${PWD}/mc" ls --json --versions minio/bucket/testobj | jq -r .versionId); do
    		"${PWD}/mc" cat --vid "${vid}" minio/bucket/testobj | md5sum
    	done
    
    	pkill minio
    	sleep 3
    }
    
    function main() {
    	start_port=$(shuf -i 10000-65000 -n 1)
    
    	start_minio_4drive ${start_port}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 26 05:07:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  9. docs/pt/docs/advanced/additional-responses.md

    Essas respostas adicionais serão incluídas no esquema do OpenAPI, e também aparecerão na documentação da API.
    
    Porém para as respostas adicionais, você deve garantir que está retornando um `Response` como por exemplo o `JSONResponse` diretamente, junto com o código de status e o conteúdo.
    
    ## Retorno Adicional com `model`
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  10. internal/http/listener.go

    	send := func(result acceptResult) bool {
    		select {
    		case listener.acceptCh <- result:
    			// Successfully written to acceptCh
    			return true
    		case <-listener.ctx.Done():
    			return false
    		}
    	}
    
    	// Closure to handle TCPListener until done channel is closed.
    	handleListener := func(idx int, listener net.Listener) {
    		for {
    			conn, err := listener.Accept()
    			send(acceptResult{conn, err, idx})
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top