// Message ID
        SMBUtil.writeInt8(1, buffer, bufferIndex + 24);
        // Reserved/Async ID
        SMBUtil.writeInt8(0, buffer, bufferIndex + 32);
        // Session ID
        SMBUtil.writeInt8(0, buffer, bufferIndex + 40);
        // Signature
        System.arraycopy(new byte[16], 0, buffer, bufferIndex + 48, 16);

        // Body starts at bufferIndex + 64

				stmt.AddVar(writer, v...)
				writer.WriteByte(')')
			} else {
				writer.WriteString("(NULL)")
			}
		case interface{ getInstance() *DB }:
			cv := v.getInstance()

			subdb := cv.Session(&Session{Logger: logger.Discard, DryRun: true}).getInstance()
			if cv.Statement.SQL.Len() > 0 {
				var (
					vars = subdb.Statement.Vars
					sql  = cv.Statement.SQL.String()
				)

    /** Info map key for data index size. */
    public static final String DATA_INDEX_SIZE = "DataIndexSize";

    /** Session identifier key. */
    public static final String SESSION_ID = "sessionId";

    /** Crawling information identifier key. */
    public static final String CRAWLING_INFO_ID = "crawlingInfoId";

    /** Indexing target identifier key. */

Это могло бы выглядеть так:

{* ../../docs_src/dependencies/tutorial013_an_py310.py *}

Код после `yield`, автоматическое закрытие `Session` в:

{* ../../docs_src/dependencies/tutorial013_an_py310.py ln[19:21] *}

…будет выполнен после того, как ответ закончит отправку медленных данных:

import org.apache.maven.di.impl.DIException;
import org.apache.maven.di.impl.Dependency;
import org.apache.maven.di.impl.InjectorImpl;
import org.apache.maven.execution.scope.internal.MojoExecutionScope;
import org.apache.maven.session.scope.internal.SessionScope;
import org.codehaus.plexus.PlexusContainer;
import org.codehaus.plexus.component.repository.exception.ComponentLookupException;
import org.eclipse.sisu.BeanEntry;

            throw new IOException("Connection lost and reconnection failed", e);
        }
    } else {
        throw e;  // No durable handle, propagate error
    }
}
```

### 6.3 Session Integration
```java
// In SmbSession.java
private PersistentHandleManager handleManager;

public SmbSession(CIFSContext context, SmbTransport transport) {
    // ... existing initialization ...
    

  /**
   * Returns the time that this cookie expires, in the same format as [System.currentTimeMillis].
   * This is December 31, 9999 if the cookie is not [persistent], in which case it will expire at the
   * end of the current session.
   *
   * This may return a value less than the current time, in which case the cookie is already
   * expired. Webservers may return expired cookies as a mechanism to delete previously set cookies

        // Directory leasing requires SMB 3.0 or higher
        // MS-SMB2: Level 2 leasing (which includes directory leasing) is only supported in SMB 3.0+
        // We'll validate this when we actually need to use the session

        // Request base lease
        Smb2LeaseKey leaseKey = baseLeaseManager.requestLease(directoryPath, requestedState);

        // Create directory cache entry

        byte[] readBuffer = new byte[100];
        IOException exception = assertThrows(IOException.class, () -> {
            packet.readTrailerWireFormat(bais, readBuffer, 0);
        });

        assertEquals("invalid session request wire format", exception.getMessage());
    }

    @ParameterizedTest
    @MethodSource("provideNamesForWriteTest")
    @DisplayName("writeTrailerWireFormat should handle various name combinations")

    val size: Int = formBody.size()
  }

  @Test @Disabled
  fun handshake() {
    val handshake: Handshake =
      Handshake.get((localhost().sslSocketFactory().createSocket() as SSLSocket).session)
    val tlsVersion: TlsVersion = handshake.tlsVersion()
    val cipherSuite: CipherSuite = handshake.cipherSuite()
    val peerCertificates: List<Certificate> = handshake.peerCertificates()