*/
package jcifs.internal.util;

import jcifs.SmbConstants;

/**
 * SMB protocol utility class providing low-level data encoding and decoding operations.
 * Contains methods for reading and writing various data types (integers, strings, timestamps)
 * in SMB protocol format, handling endianness and data type conversions.
 *
 * @author mbechler
 */
public class SMBUtil {

    /**

	if algo != HighwayHash256S {
		h := algo.New()
		if n, err := io.Copy(h, r); err != nil || n != wantSize {
			// Premature failure in reading the object, file is corrupt.
			return errFileCorrupt
		}
		if !bytes.Equal(h.Sum(nil), want) {
			return errFileCorrupt
		}
		return nil
	}

	h := algo.New()
	hashBuf := make([]byte, h.Size())

   */
  fun isExecuted(): Boolean

  fun isCanceled(): Boolean

  /**
   * Returns a timeout that spans the entire call: resolving DNS, connecting, writing the request
   * body, server processing, and reading the response body. If the call requires redirects or
   * retries all must complete within one timeout period.
   *
   * Configure the client's default timeout with [OkHttpClient.Builder.callTimeout].
   */

        }

        @Test
        @DisplayName("Test read string with odd Unicode alignment")
        void testReadStringUnicodeAlignment() {
            testBlock.setUseUnicode(true);
            // Test reading Unicode string with alignment

            byte[] buffer = new byte[100];
            // Write "Test" in UTF-16LE directly at position 2 (even offset)

				if err != nil {
					err = msgp.WrapError(err, "Purge")
					return
				}
				switch msgp.UnsafeString(field) {
				case "RetainVersions":
					z.Purge.RetainVersions, err = dc.ReadInt()
					if err != nil {
						err = msgp.WrapError(err, "Purge", "RetainVersions")
						return
					}
				default:
					err = dc.Skip()
					if err != nil {
						err = msgp.WrapError(err, "Purge")

		resetBuildClauses = true
	}

	if optimizer, ok := stmt.Dest.(StatementModifier); ok {
		optimizer.ModifyStatement(stmt)
	}

	if db.DefaultContextTimeout > 0 {
		if _, ok := stmt.Context.Deadline(); !ok {
			stmt.Context, _ = context.WithTimeout(stmt.Context, db.DefaultContextTimeout)
		}
	}

	// assign model values
	if stmt.Model == nil {
		stmt.Model = stmt.Dest
	} else if stmt.Dest == nil {

    stream.defaultWriteObject();
    stream.writeObject(keyTypeOrObjectUnderJ2cl);
    Serialization.writeMap(this, stream);
  }

  @SuppressWarnings("unchecked") // reading field populated by writeObject
  @GwtIncompatible // java.io.ObjectInputStream
  private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    stream.defaultReadObject();

     */
    int TYPE_COMM = 0x40;

    /* open flags */

    /**
     * Open for reading only.
     */
    int O_RDONLY = 0x01;
    /**
     * Open for writing only.
     */
    int O_WRONLY = 0x02;
    /**
     * Open for reading and writing.
     */
    int O_RDWR = 0x03;
    /**
     * Open in append mode.
     */
    int O_APPEND = 0x04;

        verify(locator, never()).locateExistingPom(any(Path.class));
    }

    @Test
    void testStreamReading() throws IOException {
        // Test stream reading functionality
        Path testFile = tempDir.resolve("test.txt");
        String content = "test content";
        Files.writeString(testFile, content);

        Source source = Sources.fromPath(testFile);

      LockFreeBitArray dataArray = new LockFreeBitArray(Math.multiplyExact(dataLength, 64L));
      for (int i = 0; i < dataLength; i++) {
        dataArray.putData(i, din.readLong());
      }

      return new BloomFilter<>(dataArray, numHashFunctions, funnel, strategy);
    } catch (IOException e) {
      throw e;
    } catch (Exception e) { // sneaky checked exception