Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 412 for donde (0.05 sec)

  1. buildscripts/verify-healing.sh

    		test $foundFiles1 -eq $foundFiles2
    		v2=$?
    		[ $v1 == 0 -a $v2 == 0 ] && return 0
    		sleep 10
    	done
    	return 1
    }
    
    function purge() {
    	rm -rf "$1"
    }
    
    function fail() {
    	for i in $(seq 1 3); do
    		echo "server$i log:"
    		cat "${WORK_DIR}/dist-minio-server$i.log"
    	done
    	pkill -9 minio
    	echo "FAILED"
    	purge "$WORK_DIR"
    	exit 1
    }
    
    function __init__() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. internal/ioutil/wait_pipe.go

    // PipeWriter is similar to io.PipeWriter with wait group
    type PipeWriter struct {
    	*io.PipeWriter
    	once sync.Once
    	done func()
    }
    
    // CloseWithError close with supplied error the writer end.
    func (w *PipeWriter) CloseWithError(err error) error {
    	err = w.PipeWriter.CloseWithError(err)
    	w.once.Do(func() {
    		w.done()
    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 27 14:55:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

                }
            });
        }
    
        protected void printStats(final Object keyObj, final StatsObject data, final long begin, final boolean done) {
            final StringBuilder buf = createStringBuffer(keyObj, begin);
            if (done) {
                buf.append('\t').append("done:").append(getCurrentTimeMillis() - begin);
            }
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    // Caller should close the channel when done.
    // The returned function will return the results once there is enough or input is closed,
    // or the context is canceled.
    func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) {
    	resultsDone := make(chan metaCacheEntriesSorted)
    	// Copy so we can mutate
    	resCh := resultsDone
    	var done bool
    	var mu sync.Mutex
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  5. buildscripts/verify-healing-empty-erasure-set.sh

    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
    	# Wait for all drives to be healed
    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].healing | select(. != null) | select(. == true)' | wc -l) -gt 0 ]; do sleep 1; done
    
    	# Wait for Status: in MinIO output
    	while true; do
    		rv=$(check_online)
    		if [ "$rv" != "1" ]; then
    			# success
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. buildscripts/multipart-quorum-test.sh

    		aws --endpoint-url http://localhost:"$start_port" s3api upload-part \
    			--upload-id "$uploadId" --bucket bucket --key obj-1 \
    			--part-number "$i" --body ./file-5mib
    	done
    	for i in {1..6}; do
    		find ${WORK_DIR}/disk${i}/.minio.sys/multipart/ -type f -name "part.1" -delete
    	done
    	cat <<EOF >parts.json
    {
        "Parts": [
            {
                "PartNumber": 1,
                "ETag": "5f363e0e58a95f06cbe9bbc662c5dfb6"
            },
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 10:51:23 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    		hostMap = make(map[string]struct{}, len(hosts))
    		for _, k := range hosts {
    			if k != "" {
    				hostMap[k] = struct{}{}
    			}
    		}
    	}
    	dID := r.Form.Get("by-depID")
    	done := ctx.Done()
    	ticker := time.NewTicker(interval)
    	defer ticker.Stop()
    	w.Header().Set(xhttp.ContentType, string(mimeJSON))
    
    	enc := json.NewEncoder(w)
    	for n > 0 {
    		var m madmin.RealtimeMetrics
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  9. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 19 14:35:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	timer := time.NewTimer(globalAPIConfig.getDeleteCleanupInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-timer.C:
    			var wg sync.WaitGroup
    			for _, set := range s.sets {
    				wg.Add(1)
    				go func(set *erasureObjects) {
    					defer wg.Done()
    					if set == nil {
    						return
    					}
    					set.cleanupDeletedObjects(ctx)
    				}(set)
    			}
    			wg.Wait()
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
Back to top