fail("Expected exception for invalid Word document");
        } catch (final ExtractException e) {
            // ExtractException with improved message
            assertTrue("Error message should contain context about Word document or extraction",
                    e.getMessage().contains("Word") || e.getMessage().contains("extract"));
        } catch (final RuntimeException e) {

        this(System.getProperty("jaaslounge.sso.jaas.config"));
    }

    /**
     * Creates KerberosCredentials using the specified JAAS login context.
     *
     * @param loginContextName the name of the JAAS login context
     * @throws LoginException if authentication fails
     */
    public KerberosCredentials(String loginContextName) throws LoginException {

 *
 * @author mbechler
 */
public interface SmbNegotiationResponse extends CommonServerMessageBlock, Response {

    /**
     * Check if the negotiation response is valid
     *
     * @param cifsContext the CIFS context
     * @param request the negotiation request
     * @return whether the protocol negotiation was successful
     */
    boolean isValid(CIFSContext cifsContext, SmbNegotiationRequest request);

    /**

	if err != nil {
		target.loggerOnce(context.Background(), err, target.ID().String())
		return err
	}
	target.producer = producer

	err = target.producer.Ping()
	if err != nil {
		// To treat "connection refused" errors as errNotConnected.
		if !xnet.IsConnRefusedErr(err) && !xnet.IsConnResetErr(err) {
			target.loggerOnce(context.Background(), err, target.ID().String())
		}

            when(resource.getContext()).thenReturn(mockContext);

            // When
            CIFSContext context = resource.getContext();

            // Then
            assertNotNull(context, "Context should not be null");
            assertSame(mockContext, context, "Should return the expected context");
        }

        @Test
        @DisplayName("getName should return resource name")

   <Event>s3:ObjectRemoved:*</Event>
</QueueConfiguration>`)
	queue3 := &Queue{}
	if err := xml.Unmarshal(data, queue3); err != nil {
		panic(err)
	}

	targetList1 := NewTargetList(t.Context())

	targetList2 := NewTargetList(t.Context())
	if err := targetList2.Add(&ExampleTarget{TargetID{"1", "webhook"}, false, false}); err != nil {
		panic(err)
	}

	testCases := []struct {
		queue      *Queue
		region     string

			f.ServeHTTP(w, r)
			return
		}

		if tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt); ok {
			tc.FuncName = "s3.MaxClients"
		}

		w.Header().Set("X-RateLimit-Limit", strconv.Itoa(cap(pool)))
		w.Header().Set("X-RateLimit-Remaining", strconv.Itoa(cap(pool)-len(pool)))

		ctx := r.Context()
		select {
		case pool <- struct{}{}:
			defer func() { <-pool }()

			t.Errorf("(%d) expected to get %s, instead got %s", i, niceError(testCase.expected), niceError(code))
		}
	}
}

func TestDoesPresignedSignatureMatch(t *testing.T) {
	ctx, cancel := context.WithCancel(t.Context())
	defer cancel()

	obj, fsDir, err := prepareFS(ctx)
	if err != nil {
		t.Fatal(err)
	}
	defer os.RemoveAll(fsDir)
	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {

        assertSame(session, result);
        verify(transport).getSmbSession(eq(ctx));
    }

    // Edge inputs: null context returns null session per mock setup
    @Test
    @DisplayName("getSmbSession(ctx) with null context returns null as stubbed")
    void getSmbSession_byContext_null() {
        when(transport.getSmbSession(isNull(jcifs.CIFSContext.class))).thenReturn(null);

        @Test
        public void testConstructorWithContextAndName() throws Exception {
            // Test constructor that takes a context SmbFile and a name
            SmbFile context = new SmbFile("smb1://server/share/");
            String name = "file.txt";
            SmbFile smbFile = new SmbFile(context, name);
            assertEquals("smb1://server/share/file.txt", smbFile.getCanonicalPath());
        }

        @Test