Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 910 for dove (0.02 sec)

  1. cmd/erasure-server-pool.go

    				defer xioutil.SafeClose(updates)
    				// Start update collector.
    				go func() {
    					defer wg.Done()
    					for info := range updates {
    						mu.Lock()
    						results[i] = info
    						mu.Unlock()
    					}
    				}()
    				// Start scanner. Blocks until done.
    				err := erObj.nsScanner(ctx, allBuckets, wantCycle, updates, healScanMode)
    				if err != nil {
    					scannerLogIf(ctx, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer_test.go

    	done := make(chan error)
    	go func() {
    		defer close(done)
    		_, err := rb.Write([]byte("hello"))
    		if err != nil {
    			t.Errorf("got error: %q; expected none", err)
    		}
    		rb.CloseWriter()
    		_, err = rb.Write([]byte("world"))
    		done <- err
    		err = rb.WriteByte(0)
    		done <- err
    		_, err = rb.TryWrite([]byte("world"))
    		done <- err
    		err = rb.TryWriteByte(0)
    		done <- err
    	}()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

          // When a listener is first added, we run a task that will wait for the delegate to finish,
          // and when it is done will run the listeners.
          if (hasListeners.compareAndSet(false, true)) {
            if (delegate.isDone()) {
              // If the delegate is already done, run the execution list immediately on the current
              // thread.
              executionList.execute();
              return;
            }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  4. docs/pt/docs/tutorial/metadata.md

    | `license_info` | `dict` | As informaรงรตes de licenรงa para a API exposta. Ela pode conter...
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 29 10:36:14 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  5. docs/bucket/replication/sio-error.sh

    	args1+=("http://localhost:$((9000 + i))/tmp/xl/1/$i ")
    	args2+=("http://localhost:$((9100 + i))/tmp/xl/2/$i ")
    done
    
    for i in $(seq 1 $NODES); do
    	./minio server --address "127.0.0.1:$((9000 + i))" ${args1[@]} & # | tee /tmp/minio/node.$i &
    	./minio server --address "127.0.0.1:$((9100 + i))" ${args2[@]} & # | tee /tmp/minio/node.$i &
    done
    
    sleep 10
    
    ./mc alias set myminio1 http://localhost:9001 minioadmin minioadmin
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 18 18:19:01 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. docs/em/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` ๐Ÿ“จ โšซ๏ธ ๐ŸŽฏ ๐ŸŽš &amp; ๐ŸŽ `user`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. cmd/background-newdisks-heal-ops.go

    	h.ItemsSkipped = h.ResumeItemsSkipped
    	h.BytesDone = h.ResumeBytesDone
    	h.BytesFailed = h.ResumeBytesFailed
    	h.BytesSkipped = h.ResumeBytesSkipped
    }
    
    // bucketDone should be called when a bucket is done healing.
    // Adds the bucket to the list of healed buckets and updates resume numbers.
    func (h *healingTracker) bucketDone(bucket string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.ResumeItemsHealed = h.ItemsHealed
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. internal/grid/grid_test.go

    				// Just wait for it to cancel.
    				for blockResp {
    					select {
    					case <-ctx.Done():
    						close(serverCanceled)
    						return NewRemoteErr(ctx.Err())
    					case resp <- []byte{1}:
    						time.Sleep(10 * time.Millisecond)
    					}
    				}
    				// Just wait for it to cancel.
    				<-ctx.Done()
    				close(serverCanceled)
    				return NewRemoteErr(ctx.Err())
    			},
    			OutCapacity: 1,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  9. docs/site-replication/run-ssec-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: Tue Sep 24 08:03:58 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. docs/site-replication/run-replication-with-checksum-header.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: Mon Jul 29 08:02:16 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top