Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 681 for Continue (0.06 sec)

  1. cmd/leak-detect_test.go

    		sl := strings.SplitN(g, "\n", 2)
    		if len(sl) != 2 {
    			continue
    		}
    		stack := strings.TrimSpace(sl[1])
    		// ignore the testing go routine.
    		// since the tests will be invoking the leaktest it would contain the test go routine.
    		if strings.HasPrefix(stack, "testing.RunTests") {
    			continue
    		}
    		// Ignore the following go routines.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. cmd/metacache-walk.go

    				// Do not retain the file, since it doesn't
    				// match the prefix.
    				entries[i] = ""
    				continue
    			}
    			if len(forward) > 0 && entry < forward {
    				// Do not retain the file, since its
    				// lexially smaller than 'forward'
    				entries[i] = ""
    				continue
    			}
    			if hasSuffixByte(entry, SlashSeparatorChar) {
    				if strings.HasSuffix(entry, globalDirSuffixWithSlash) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. internal/config/notify/parse.go

    				continue
    			}
    			t, err := target.NewNSQTarget(id, args, logOnceIf)
    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    		}
    	case config.NotifyPostgresSubSys:
    		postgresTargets, err := GetNotifyPostgres(cfg[config.NotifyPostgresSubSys])
    		if err != nil {
    			return nil, err
    		}
    		for id, args := range postgresTargets {
    			if !args.Enable {
    				continue
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    		if ps.Info.Status != rebalStarted {
    			continue
    		}
    
    		participants[i] = ps.Participating
    	}
    	z.rebalMu.RUnlock()
    
    	for poolIdx, doRebalance := range participants {
    		if !doRebalance {
    			continue
    		}
    		// nothing to do if this node is not pool's first node (i.e pool's rebalance 'leader').
    		if !globalEndpoints[poolIdx].Endpoints[0].IsLocal {
    			continue
    		}
    
    		go func(idx int) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/WebPlatformUrlTestData.kt

          val list = mutableListOf<WebPlatformUrlTestData>()
          while (true) {
            val line = source.readUtf8Line() ?: break
            if (line.isEmpty() || line.startsWith("#")) continue
    
            var i = 0
            val parts = line.split(Regex(" ")).toTypedArray()
    
            val element = WebPlatformUrlTestData()
            element.input = unescape(parts[i++])
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/FileEntryAdapterIterator.java

                        continue;
                    }
                }
    
                try ( SmbResource r = adapt(fe) ) {
                    if ( this.filter.accept(r) ) {
                        return r;
                    }
                }
                catch ( MalformedURLException e ) {
                    log.error("Failed to create child URL", e);
                    continue;
                }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

                    skipComment();
                    continue;
                }
                if (scanner.lookingAt(HTML_ELEMENT)) {
                    parseStartElement(visitor);
                    continue;
                }
                if (scanner.lookingAt(TAG)) {
                    parseJavadocTag(visitor);
                    continue;
                }
    
                StringBuilder text = new StringBuilder();
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    				if disk == OfflineDisk {
    					continue
    				}
    				stats, err := disk.StatInfoFile(ctx, volume, file, true)
    				if err != nil {
    					continue
    				}
    				for _, si := range stats {
    					found++
    					var r io.ReadCloser
    					if !si.Dir {
    						r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size)
    						if err != nil {
    							continue
    						}
    					} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  9. cmd/metacache-stream.go

    		defer w.streamWg.Done()
    		for o := range objs {
    			if len(o.name) == 0 || w.streamErr != nil {
    				continue
    			}
    			// Indicate EOS
    			err := w.mw.WriteBool(true)
    			if err != nil {
    				w.streamErr = err
    				continue
    			}
    			err = w.mw.WriteString(o.name)
    			if err != nil {
    				w.streamErr = err
    				continue
    			}
    			err = w.mw.WriteBytes(o.metadata)
    			if w.reuseBlocks || o.reusable {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  10. internal/config/config.go

    		if len(kv) == 0 {
    			continue
    		}
    		if len(kv) == 1 && prevK != "" {
    			value := strings.Join([]string{
    				kvs.Get(prevK),
    				madmin.SanitizeValue(kv[0]),
    			}, KvSpaceSeparator)
    			kvs.Set(prevK, value)
    			continue
    		}
    		if len(kv) == 2 {
    			prevK = kv[0]
    			kvs.Set(prevK, madmin.SanitizeValue(kv[1]))
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
Back to top