uaAppend - Code Search

cmd/admin-handlers.go

		hostErrs = append(hostErrs, globalNotificationSys.StartProfiling(ctx, profiler)...)

		// Start profiling locally as well.
		prof, err := startProfiler(profiler)
		if err != nil {
			hostErrs = append(hostErrs, NotificationPeerErr{
				Host: *thisAddr,
				Err:  err,
			})
		} else {
			globalProfiler[profiler] = prof
			hostErrs = append(hostErrs, NotificationPeerErr{

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Oct 04 11:32:32 UTC 2024

- 99.7K bytes

- Viewed (0)

github.com/square/okhttp

samples/static-server/src/main/java/okhttp3/sample/SampleServer.java

    StringBuilder response = new StringBuilder();
    response.append(String.format("<html><head><title>%s</title></head><body>", basePath));
    response.append(String.format("<h1>%s</h1>", basePath));
    for (String file : directory.list()) {
      response.append(String.format("<div class='file'><a href='%s'>%s</a></div>",
          basePath + file, file));
    }
    response.append("</body></html>");

    return new MockResponse()

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Wed Jan 02 02:50:44 UTC 2019

- 4.7K bytes

- Viewed (0)

github.com/minio/minio

internal/logger/reqinfo.go

			updated = true
			break
		}
	}
	if !updated {
		// Append to the end of tags list
		r.tags = append(r.tags, KeyVal{key, val})
	}
	return r
}

// GetTags - returns the user defined tags
func (r *ReqInfo) GetTags() []KeyVal {
	if r == nil {
		return nil
	}
	r.RLock()
	defer r.RUnlock()
	return append(make([]KeyVal, 0, len(r.tags)), r.tags...)
}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Tue Aug 13 22:22:04 UTC 2024

- 4.4K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/model/TypeMetaData.java

        visitSignature(new SignatureVisitor() {
            @Override
            public void visitText(String text) {
                builder.append(text);
            }

            @Override
            public void visitType(String name) {
                builder.append(name);
            }
        });
        return builder.toString();
    }

    public String getArraySuffix() {

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 6.1K bytes

- Viewed (0)

github.com/minio/minio

internal/grid/debug.go

			return nil, err
		}
		m := mux.NewRouter()
		m.Handle(RoutePath, manager.Handler(dummyRequestValidate))
		res.Managers = append(res.Managers, manager)
		res.Servers = append(res.Servers, startHTTPServer(listeners[i], m))
		res.Listeners = append(res.Listeners, listeners[i])
		res.Mux = append(res.Mux, m)
	}
	close(ready)
	for _, m := range res.Managers {
		for _, remote := range m.Targets() {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Jul 29 18:10:04 UTC 2024

- 4.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-common.go

				//   unformatted or simply not accessible for some reason.
				//
				// - Do not consume disks which are being healed
				//
				// - Future: skip busy disks
				return
			}

			mu.Lock()
			newDisks = append(newDisks, disks[i])
			mu.Unlock()
		}()
	}
	wg.Wait()
	return newDisks
}

func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) {
	disks := er.getOnlineDisks()

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Aug 12 08:38:15 UTC 2024

- 2.3K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-model-builder/src/main/java/org/apache/maven/model/interpolation/reflection/ClassMap.java

                } else if (parameterType.equals(Float.TYPE)) {
                    methodKey.append("java.lang.Float");
                } else if (parameterType.equals(Integer.TYPE)) {
                    methodKey.append("java.lang.Integer");
                } else if (parameterType.equals(Long.TYPE)) {
                    methodKey.append("java.lang.Long");

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 13.5K bytes

- Viewed (0)

github.com/minio/minio

internal/pubsub/pubsub.go

		return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers)
	}
	ps.Lock()
	defer ps.Unlock()

	sub := &Sub[T]{ch: subCh, types: Mask(mask.Mask()), filter: filter}
	ps.subs = append(ps.subs, sub)

	// We hold a lock, so we are safe to update
	combined := Mask(atomic.LoadUint64(&ps.types))
	combined.Merge(Mask(mask.Mask()))
	atomic.StoreUint64(&ps.types, uint64(combined))

	go func() {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Tue Feb 06 16:57:30 UTC 2024

- 5.2K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/HtmlToXmlJavadocLexerTest.groovy

                result.append("<$name")
            }

            @Override
            void onHtmlElementAttribute(String name, String value) {
                result.append(" $name='$value'")
            }

            @Override
            void onStartHtmlElementComplete(String name) {
                result.append(">")
            }

            @Override

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Wed Dec 09 08:14:05 UTC 2020

- 6.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

            buf.append("Processing ");
            if (totalHits > 0) {
                buf.append(arList.size()).append('/').append(totalHits).append(" docs (Doc:{access ");
            } else {
                buf.append("no docs in indexing queue (Doc:{access ");
            }
            buf.append(systemHelper.getCurrentTimeAsLong() - execTime).append("ms");
            if (cleanupTime >= 0) {

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Fri Oct 11 21:20:39 UTC 2024

- 24.2K bytes

- Viewed (0)

Search Options