Statfs - Code Search

docs_src/websockets/tutorial002_py39.py

from typing import Union

from fastapi import (
    Cookie,
    Depends,
    FastAPI,
    Query,
    WebSocket,
    WebSocketException,
    status,
)
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 20:41:43 GMT 2025

- 2.8K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/SimpleCircuitBreakerTest.java

        assertEquals(SimpleCircuitBreaker.State.CLOSED, circuitBreaker.getState());

        SimpleCircuitBreaker.Statistics stats = circuitBreaker.getStatistics();
        assertEquals(1, stats.totalCalls);
        assertEquals(1, stats.totalSuccesses);
        assertEquals(0, stats.totalFailures);
        assertEquals(1.0, stats.successRate);
    }

    @Test
    @DisplayName("Test circuit opens after failure threshold")

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 30 05:58:03 GMT 2025

- 10.6K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/smb1/SmbAuthExceptionTest.java

class SmbAuthExceptionTest {

    /**
     * Provides a set of error codes covering normal, edge and unknown cases.
     */
    static Stream<Arguments> errorCodes() {
        return Stream.of(
                // Known NT status code - NT_STATUS_UNSUCCESSFUL
                Arguments.of(0xC0000001, "A device attached to the system is not functioning."),
                Arguments.of(0x00000000, "NT_STATUS_SUCCESS"),

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 2.2K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/math/PairedStats.java

        "Expected PairedStats.BYTES = %s, got %s",
        BYTES,
        byteArray.length);
    ByteBuffer buffer = ByteBuffer.wrap(byteArray).order(ByteOrder.LITTLE_ENDIAN);
    Stats xStats = Stats.readFrom(buffer);
    Stats yStats = Stats.readFrom(buffer);
    double sumOfProductsOfDeltas = buffer.getDouble();
    return new PairedStats(xStats, yStats, sumOfProductsOfDeltas);
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Jul 08 18:32:10 GMT 2025

- 12.6K bytes

- Click Count (0)

github.com/minio/minio

internal/event/targetlist.go

	stats.currentSendCalls--
	list.targetStats[id] = stats
}

func (list *TargetList) incFailedEvents(id TargetID) {
	list.statLock.Lock()
	defer list.statLock.Unlock()

	stats, ok := list.targetStats[id]
	if !ok {
		stats = targetStat{}
	}

	stats.failedEvents++
	list.targetStats[id] = stats
}

func (list *TargetList) incTotalEvents(id TargetID) {
	list.statLock.Lock()

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 9.2K bytes

- Click Count (0)

github.com/minio/minio

cmd/bucket-object-lock.go

func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
	if objInfo.DeleteMarker {
		return false
	}

	lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined)
	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
		return true
	}

	ret := objectlock.GetObjectRetentionMeta(objInfo.UserDefined)
	if ret.Mode.Valid() && (ret.Mode == objectlock.RetCompliance || ret.Mode == objectlock.RetGovernance) {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 08 02:38:25 GMT 2025

- 13.3K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildStep.java

        this.project = Objects.requireNonNull(project, "project cannot be null");
        this.phase = phase;
    }

    public boolean isCreated() {
        return status.get() == CREATED;
    }

    public boolean isDone() {
        int state = status.get();
        return state == EXECUTED || state == FAILED || state == SKIPPED;
    }

    public Stream<BuildStep> allPredecessors() {

Created: Sun Dec 28 03:35:09 GMT 2025

- Last Modified: Wed Apr 30 16:21:08 GMT 2025

- 4.9K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-core/src/main/java/org/apache/maven/logging/LoggingExecutionListener.java

        boolean halted;
        // The ReactorBuildStatus is only available if the SmartBuilder is used
        ReactorBuildStatus status =
                (ReactorBuildStatus) session.getRepositorySession().getData().get(ReactorBuildStatus.class);
        if (status != null) {
            halted = status.isHalted();
        } else {
            // assume sensible default
            Throwable t = projectExecutionEvent.getCause();

Created: Sun Dec 28 03:35:09 GMT 2025

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

- 6.5K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

   * process with an exit status of 1, indicating abnormal termination.
   */
  public static UncaughtExceptionHandler systemExit() {
    return new Exiter(Runtime.getRuntime()::exit);
  }

  @VisibleForTesting
  interface RuntimeWrapper {
    void exit(int status);
  }

  @VisibleForTesting
  static final class Exiter implements UncaughtExceptionHandler {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Mon Feb 10 21:03:40 GMT 2025

- 2.8K bytes

- Click Count (0)

github.com/minio/minio

cmd/metacache-manager.go

	o.Create = false
	c, err := rpc.GetMetacacheListing(ctx, o)
	if err != nil {
		return err
	}
	cache := *c

	if cache.status == scanStateNone || cache.fileNotFound {
		return errFileNotFound
	}
	if cache.status == scanStateSuccess || cache.status == scanStateStarted {
		if time.Since(cache.lastUpdate) > metacacheMaxRunningAge {
			// We got a stale entry, mark error on handling server.

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Oct 25 00:44:15 GMT 2022

- 5.2K bytes

- Click Count (0)

Search Options