public class PreauthIntegrityTest {

    @Mock
    private CIFSContext context;

    @Mock
    private Configuration config;

    @Mock
    private Address address;

    @Mock
    private Smb2NegotiateResponse negotiateResponse;

    private SmbTransportImpl transport;

    @BeforeEach
    void setUp() throws Exception {
        when(context.getConfig()).thenReturn(config);

		if err != nil {
			t.Fatalf("Test %d: failed to setup Erasure environment: %v", i, err)
		}
		disks := setup.disks
		erasure, err := NewErasure(t.Context(), test.dataBlocks, test.disks-test.dataBlocks, test.blocksize)
		if err != nil {
			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
		}
		data := make([]byte, test.size)

    }

    /**
     * Initializes the context and server for this SID for deferred resolution.
     *
     * @param context the CIFS context to use
     * @param server the server name for SID resolution
     */
    public void initContext(final String server, final CIFSContext context) {
        this.origin_ctx = context;
        this.origin_server = server;
    }

            throw new IORuntimeException(e);
        }
    }

    /**
     * Reads the contents of a file into a byte array and returns it.
     *
     * @param file
     *            The file. Must not be {@literal null}.
     * @return A byte array containing the contents of the file.
     */
    public static byte[] readBytes(final File file) {
        assertArgumentNotNull("file", file);

        loc.type = this.type;
        return loc;
    }

    /**
     * @param context
     * @param name
     */
    void resolveInContext(final SmbResourceLocator context, String name) {
        final String shr = context.getShare();
        if (shr != null) {
            this.dfsReferral = context.getDfsReferral();
        }
        final int last = name.length() - 1;

Added context aware dial functions for TCP, UDP, IP and Unix networks....

name: 'Dependency Review'
on: [pull_request]

permissions:
  contents: read

jobs:
  dependency-review:
    runs-on: ubuntu-latest
    steps:
      - name: 'Checkout Repository'
        uses: actions/checkout@v4
      - name: 'Dependency Review'

package callbacks

import (
	"gorm.io/gorm"
)

func RawExec(db *gorm.DB) {
	if db.Error == nil && !db.DryRun {
		result, err := db.Statement.ConnPool.ExecContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
		if err != nil {
			db.AddError(err)
			return
		}

		db.RowsAffected, _ = result.RowsAffected()

		if db.Statement.Result != nil {
			db.Statement.Result.Result = result

on:
  pull_request_target:
    types:
      - opened
      - synchronize
      - reopened
      # For label-checker
      - labeled
      - unlabeled

jobs:
  labeler:
    permissions:
      contents: read
      pull-requests: write
    runs-on: ubuntu-latest
    steps:
    - uses: actions/labeler@v5
      if: ${{ github.event.action != 'labeled' && github.event.action != 'unlabeled' }}

	Pools     []rebalancePoolStatus `json:"pools"` // contains all pools, including inactive
	StoppedAt time.Time             `json:"stoppedAt"`
}

func rebalanceStatus(ctx context.Context, z *erasureServerPools) (r rebalanceAdminStatus, err error) {
	// Load latest rebalance status
	meta := &rebalanceMeta{}
	err = meta.load(ctx, z.serverPools[0])
	if err != nil {
		return r, err
	}