func (db *PreparedStmtDB) Close() {
	db.Mux.Lock()
	defer db.Mux.Unlock()

	for _, key := range db.Stmts.Keys() {
		db.Stmts.Delete(key)
	}
}

// Reset Deprecated use Close instead
func (db *PreparedStmtDB) Reset() {
	db.Close()
}

func (db *PreparedStmtDB) prepare(ctx context.Context, conn ConnPool, isTransaction bool, query string) (_ *stmt_store.Stmt, err error) {
	db.Mux.RLock()

{* ../../docs_src/additional_status_codes/tutorial001_an_py310.py hl[4,25] *}

/// warning | Advertencia

Cuando devuelves un `Response` directamente, como en el ejemplo anterior, se devuelve directamente.

No se serializará con un modelo, etc.

Asegúrate de que tenga los datos que deseas que tenga y que los valores sean JSON válidos (si estás usando `JSONResponse`).

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodemetacache Msgsize() is inaccurate")
	}

	vn := metacache{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

func BenchmarkEncodemetacache(b *testing.B) {
	v := metacache{}
	var buf bytes.Buffer

Link with a title: [Example](https://example.com "Example site") - URL will be fixed, title preserved.

### Markdown link to static assets { #markdown-link-to-static-assets }

These are links to static assets:

* [FastAPI Logo](https://fastapi.tiangolo.com/img/fastapi-logo.png)
* [FastAPI CSS](https://fastapi.tiangolo.com/css/fastapi.css)

    @Mock
    private CommonServerMessageBlockRequest splitRequest;

    @Mock
    private CommonServerMessageBlockRequest cancelRequest;

    @BeforeEach
    void setUp() {
        // Reset mocks before each test
        reset(request, nextRequest, splitRequest, cancelRequest);
    }

    @Test
    @DisplayName("Test isResponseAsync returns true when response is async")
    void testIsResponseAsyncTrue() {
        // Given

        return state.get();
    }

    /**
     * Reset the circuit breaker
     */
    public void reset() {
        state.set(State.CLOSED);
        consecutiveFailures.set(0);
        halfOpenSuccesses.set(0);
        lastFailureTime.set(0);
        stateChangeTime.set(System.currentTimeMillis());
        log.info("Circuit breaker {} reset", name);
    }

    /**
     * Force the circuit to open

    }

    /**
     * Sets the file entry results for the response
     * @param results
     *            the results to set
     */
    protected final void setResults(final FileEntry[] results) {
        this.results = results;
    }

    @Override
    public void reset() {
        super.reset();
        this.bufDataStart = 0;
        this.isPrimary = this.hasMore = true;

    name: elastic+elasticsearch+%BRANCH%+periodic+packaging-tests
    display-name: "elastic / elasticsearch # %BRANCH% - packaging tests"
    description: "Testing of the Elasticsearch %BRANCH% branch packaging tests.\n"
    project-type: multijob
    node: master
    vault: []
    scm:
      - git:
          wipe-workspace: false
    builders:
      - multijob:
          name: Packaging tests
          projects:

---
- job:
    name: elastic+elasticsearch+%BRANCH%+periodic+release-tests
    workspace: /dev/shm/elastic+elasticsearch+%BRANCH%+periodic+release-tests
    display-name: "elastic / elasticsearch # %BRANCH% - release tests"
    description: "Release version tests for the Elasticsearch %BRANCH% branch.\n"
    node: "general-purpose && docker"
    builders:
      - inject:
          properties-file: '.ci/java-versions.properties'
          properties-content: |

        // Wait for original TTL to pass
        Thread.sleep(600);

        // Should still not be expired because we reset
        assertFalse(auth.isExpired());

        // Wait for the full TTL since reset
        Thread.sleep(500);

        // Now it should be expired
        assertTrue(auth.isExpired());
    }

    /**
     * Test password array independence after construction