Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 622 for continua (0.05 sec)

  1. cmd/erasure-server-pool-decom.go

    	var newPools []PoolStatus
    	for _, pool := range p.Pools {
    		if pool.Decommission == nil {
    			continue
    		}
    		if pool.Decommission.Complete || pool.Decommission.Canceled {
    			// Do not resume decommission upon startup for
    			// - decommission complete
    			// - decommission canceled
    			continue
    		} // In all other situations we need to resume
    		newPools = append(newPools, pool)
    	}
    	return newPools
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 42.2K bytes
    - Viewed (1)
  2. cmd/object-api-putobject_test.go

    			t.Errorf("Test %d: %s: Expected to pass, but failed with: error %s.", i, instanceType, actualErr.Error())
    			continue
    		}
    		if actualErr == nil && testCase.expectedError != nil {
    			t.Errorf("Test %d: %s: Expected to fail with error \"%s\", but passed instead.", i, instanceType, testCase.expectedError.Error())
    			continue
    		}
    		// Failed as expected, but does it fail for the expected reason.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. cmd/os-reliable.go

    	i := 0
    	for {
    		// Removes all the directories and files.
    		if err = RemoveAll(dirPath); err != nil {
    			// Retry only for the first retryable error.
    			if isSysErrNotEmpty(err) && i == 0 {
    				i++
    				continue
    			}
    		}
    		break
    	}
    	return err
    }
    
    // Wrapper functions to os.MkdirAll, which calls reliableMkdirAll
    // this is to ensure that if there is a racy parent directory
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Apr 22 17:49:30 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/suggest/index/contents/DefaultContentsParser.java

                if (textObj == null) {
                    continue;
                }
                final String text = textObj.toString();
                final String lang = document.get(langFieldName) == null ? null : document.get(langFieldName).toString();
    
                final List<AnalyzeToken> tokens = analyzeText(analyzer, field, text, lang);
                if (tokens == null) {
                    continue;
                }
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  5. internal/grid/connection.go

    				atomic.StoreInt64(&c.LastPong, time.Now().UnixNano())
    				continue
    			}
    			toSend, err = pingFrame.MarshalMsg(GetByteBuffer()[:0])
    			if err != nil {
    				gridLogIf(ctx, err) // Fake it... Though this should never fail.
    				atomic.StoreInt64(&c.LastPong, time.Now().UnixNano())
    				continue
    			}
    		case toSend = <-c.outQueue:
    			if len(toSend) == 0 {
    				continue
    			}
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  6. cmd/config.go

    			}
    			if withData {
    				data, err := readConfig(ctx, objAPI, obj.Name)
    				if err != nil {
    					// ignore history file if not readable.
    					continue
    				}
    
    				data, err = decryptData(data, obj.Name)
    				if err != nil {
    					// ignore history file that cannot be loaded.
    					continue
    				}
    
    				cfgEntry.Data = string(data)
    			}
    			configHistory = append(configHistory, cfgEntry)
    			count--
    			if count == 0 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  7. cmd/background-newdisks-heal-ops.go

    	if err != nil {
    		return err
    	}
    
    	for _, disk := range disks {
    		if disk == nil {
    			continue
    		}
    
    		t, err := loadHealingTracker(ctx, disk)
    		if err != nil {
    			if !errors.Is(err, errFileNotFound) {
    				healingLogIf(ctx, err)
    			}
    			continue
    		}
    		if t.HealID == tracker.HealID {
    			t.Finished = true
    			t.update(ctx)
    		}
    	}
    
    	return nil
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    			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 {
    					fmt.Println("Client done, sending EOF to mux", m.MuxID)
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  9. cmd/batch-expire.go

    					toDel = append(toDel, expireObjInfo{
    						ObjectInfo: result.Item,
    						ExpireAll:  true,
    					})
    					continue
    				}
    			} else if prevObj.Name == result.Item.Name {
    				if matchedFilter.Purge.RetainVersions == 0 {
    					continue // including latest version in toDel suffices, skipping other versions
    				}
    				versionsCount++
    			} else {
    				// switch the object
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
  10. cmd/erasure-healing-common_test.go

    	for i := range 16 {
    		// Have 13 good xl.meta, 12 for default parity count = 4 (EC:4) and one
    		// to be tampered with.
    		if i > 12 {
    			modTimesThreeFour[i] = fourNanoSecs
    			modTimesThreeNone[i] = timeSentinel
    			continue
    		}
    		modTimesThreeFour[i] = threeNanoSecs
    		modTimesThreeNone[i] = threeNanoSecs
    	}
    
    	testCases := []struct {
    		modTimes       []time.Time
    		expectedTime   time.Time
    		errs           []error
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
Back to top