Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 706 for break (0.04 sec)

  1. cmd/bucket-metadata-sys.go

    			}
    			// find a single expiry rule set the flag
    			for _, rl := range lcCfg.Rules {
    				if !rl.Expiration.IsNull() || !rl.NoncurrentVersionExpiration.IsNull() {
    					expiryRuleRemoved = true
    					break
    				}
    			}
    		}
    
    		// Form empty ILM details with `ExpiryUpdatedAt` field and save
    		var cfgData []byte
    		if expiryRuleRemoved {
    			var lcCfg lifecycle.Lifecycle
    			currtime := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer_test.go

    			readBytes += n
    			read.Write(buf[:n])
    			debugln("READ 1\t", n, readBytes)
    			if err != nil {
    				readErr = err
    				break
    			}
    
    			// ReadByte
    			b, err := rb.ReadByte()
    			if err != nil {
    				readErr = err
    				break
    			}
    			readBytes++
    			read.Write([]byte{b})
    			debugln("READ 2\t", 1, readBytes)
    
    			// TryRead
    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. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

          while (true) {
            try {
              Thread.sleep(everyMillis);
            } catch (InterruptedException e) {
              // ok. just stop sleeping.
            }
            if (shouldStop) {
              break;
            }
            interruptee.interrupt();
          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.4K bytes
    - Viewed (0)
  4. schema/index.go

    	for _, field := range schema.Fields {
    		if field.TagSettings["INDEX"] != "" || field.TagSettings["UNIQUEINDEX"] != "" {
    			fieldIndexes, err := parseFieldIndexes(field)
    			if err != nil {
    				schema.err = err
    				break
    			}
    			for _, index := range fieldIndexes {
    				idx := indexes[index.Name]
    				idx.Name = index.Name
    				if idx.Class == "" {
    					idx.Class = index.Class
    				}
    				if idx.Type == "" {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. internal/s3select/message.go

    			// Flush collected records before sending error message
    			if !writer.flushRecords() {
    				break
    			}
    			writer.write(data)
    
    		case payload, ok := <-writer.payloadCh:
    			if !ok {
    				// payloadCh is closed by caller to
    				// indicate finish with success
    				quitFlag = true
    
    				if !writer.flushRecords() {
    					break
    				}
    				// Write Stats message, then End message
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cache.go

    		m := collectLocalMetrics(types, collectMetricsOpts{
    			hosts: map[string]struct{}{
    				globalLocalNodeName: {},
    			},
    		})
    
    		for _, hm := range m.ByHost {
    			if hm.CPU != nil {
    				v = *hm.CPU
    				break
    			}
    		}
    
    		return
    	}
    
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadCPUMetrics)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. src/archive/tar/example_test.go

    		}
    	}
    	if err := tw.Close(); err != nil {
    		log.Fatal(err)
    	}
    
    	// Open and iterate through the files in the archive.
    	tr := tar.NewReader(&buf)
    	for {
    		hdr, err := tr.Next()
    		if err == io.EOF {
    			break // End of archive
    		}
    		if err != nil {
    			log.Fatal(err)
    		}
    		fmt.Printf("Contents of %s:\n", hdr.Name)
    		if _, err := io.Copy(os.Stdout, tr); err != nil {
    			log.Fatal(err)
    		}
    		fmt.Println()
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 16 16:54:08 UTC 2017
    - 1.4K bytes
    - Viewed (0)
  8. cmd/admin-handlers-idp-config.go

    			}
    
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    
    		hasEnv := false
    		for _, ci := range cfgInfos {
    			if ci.IsCfg && ci.IsEnv {
    				hasEnv = true
    				break
    			}
    		}
    
    		if hasEnv {
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigEnvOverridden), r.URL)
    			return
    		}
    	case madmin.LDAPIDPCfg:
    		subSys = config.IdentityLDAPSubSys
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. src/main/java/jcifs/http/NetworkExplorer.java

                        if ( compareNames(dirents[ i ], name, iter.next()) < 0 ) {
                            break;
                        }
                    }
                    else if ( sort == 1 ) {
                        if ( compareSizes(dirents[ i ], name, iter.next()) < 0 ) {
                            break;
                        }
                    }
                    else if ( sort == 2 ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 21.3K bytes
    - Viewed (0)
  10. lib/wasm/wasm_exec.js

    				switch (typeof v) {
    					case "object":
    						if (v !== null) {
    							typeFlag = 1;
    						}
    						break;
    					case "string":
    						typeFlag = 2;
    						break;
    					case "symbol":
    						typeFlag = 3;
    						break;
    					case "function":
    						typeFlag = 4;
    						break;
    				}
    				this.mem.setUint32(addr + 4, nanHead | typeFlag, true);
    				this.mem.setUint32(addr, id, true);
    			}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Aug 30 19:15:21 UTC 2024
    - 16.5K bytes
    - Viewed (0)
Back to top