SmbFile initialFile = new SmbFile(baseUrl + "shared/initial.txt", context);
        assertTrue(initialFile.exists(), "Initial file should exist");
        assertTrue(initialFile.isFile(), "Initial file should be a file");
        assertTrue(initialFile.canRead(), "Should be able to read initial file");

        log.info("Basic connectivity test passed - can connect, list, and read files");
    }

        IO.writer(temporaryBndFile).use { writer ->
          val bndFileVal = bndfile.asFile.getOrNull()
          if (bndFileVal != null && bndFileVal.isFile) {
            Processor(gradleProperties).let { p ->
              p.loadProperties(bndFileVal).store(writer, null)
            }
          } else {
            val bndVal = bnd.getOrElse("")

      this.shutdown = shutdown;
      start();
    }

    @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
    void shutdown() {
      shutdown.set(true);
      while (this.isAlive()) {
        Thread.yield();
      }
    }
  }

  void assertWrapsInterruptedException(RuntimeException e) {
    assertThat(e).hasMessageThat().contains("Unexpected interrupt");

            final File noImageFile = new File(outputFile.getAbsolutePath() + NOIMAGE_FILE_SUFFIX);
            final Path noImagePath = noImageFile.toPath();
            if (!noImageFile.isFile() || systemHelper.getCurrentTimeAsLong() - noImageFile.lastModified() > noImageExpired) {
                try {
                    Files.deleteIfExists(noImagePath);
                } catch (final IOException e) {

        smbTree.tree_num = 1;

        // Mock the SmbFile
        smbFile = mock(SmbFile.class);
        smbFile.tree = smbTree;
        smbFile.fid = 1;
        smbFile.tree_num = 1;

        when(smbFile.isFile()).thenReturn(true);
        when(smbFile.getUncPath()).thenReturn("\\\\server\\share\\file.txt");
        when(smbFile.isOpen()).thenReturn(true);

        // Mock the open method to do nothing

		if text == nil {
			t.Errorf("%s: instruction outside TEXT", p)
		}
		size := int64(len(text.P)) - p.Pc
		if p.Link != nil {
			size = p.Link.Pc - p.Pc
		} else if p.Isize != 0 {
			size = int64(p.Isize)
		}
		var code []byte
		if p.Pc < int64(len(text.P)) {
			code = text.P[p.Pc:]
			if size < int64(len(code)) {
				code = code[:size]
			}
		}
		codeHex := fmt.Sprintf("%x", code)

        }
    }

    private
    fun assertLeftoverFilesCleanedUpEventually(vararg leftoverFiles: String) {
        leftoverFiles.forEach {
            assertTrue(projectDir.resolve(it).walk().filter { it.isFile }.toList().isEmpty())
        }
    }

    @Test
    fun `fail build if leftover file found and test passes`() {
        val result = run(":successful-test-with-leftover:test").buildAndFail()

                    logger.debug("generator path: {}", s);
                }
                return s;
            }).allMatch(s -> {
                final boolean found = new File(s).isFile();
                if (found && logger.isDebugEnabled()) {
                    logger.debug("Generator command found: {}", s);
                }
                return found;
            });
        } else {

        // Stop the thread by sending n = -1
        synchronized (w) {
            w.write(new byte[0], -1, out);
        }

        w.join(2000);
        assertFalse(w.isAlive(), "WriterThread should stop after -1 sentinel");
    }

    @Test
    @DisplayName("WriterThread surfaces SmbException via checkException")
    void writerThread_propagates_exception() throws Exception {

            assertNotNull(jobProcess);

            // Poll for process to complete
            for (int i = 0; i < 50; i++) {
                if (!jobProcess.getProcess().isAlive()) {
                    break;
                }
                Thread.sleep(100);
            }

            // Clean up
            processHelper.destroyProcess(sessionId);