if (log2 < Double.MAX_EXPONENT) {
      sqrt0 = sqrtApproxWithDoubles(x);
    } else {
      int shift = (log2 - DoubleUtils.SIGNIFICAND_BITS) & ~1; // even!
      /*
       * We have that x / 2^shift < 2^54. Our initial approximation to sqrtFloor(x) will be
       * 2^(shift/2) * sqrtApproxWithDoubles(x / 2^shift).
       */
      sqrt0 = sqrtApproxWithDoubles(x.shiftRight(shift)).shiftLeft(shift >> 1);
    }

            assertEquals(24 + (24 * 4), bytesWritten);
        }

        @Test
        @DisplayName("Should handle file ID updates")
        void testFileIdUpdates() {
            // Initial file ID
            byte[] initialFileId = new byte[16];
            Arrays.fill(initialFileId, (byte) 0x11);
            request.setFileId(initialFileId);

            byte[] buffer1 = new byte[256];

      connection.flush()
      cancelStreamIfNecessary()
    }
  }

  companion object {
    internal const val EMIT_BUFFER_SIZE = 16384L
  }

  /** [delta] will be negative if a settings frame initial window is smaller than the last. */
  fun addBytesToWriteWindow(delta: Long) {
    writeBytesMaximum += delta
    if (delta > 0L) {
      notifyAll()
    }
  }

  @Throws(IOException::class)

    @DisplayName("Path Consumed Tests")
    class PathConsumedTests {

        @Test
        @DisplayName("Should strip path consumed correctly")
        void testStripPathConsumed() {
            // Set initial pathConsumed using fromReferral
            setupReferralDataWithPathConsumed(10);

            referralData.stripPathConsumed(5);
            assertEquals(5, referralData.getPathConsumed());
        }

     * but an implemantation that encorporates the transport header(for
     * efficiency) might use a different initial bufferIndex. For example,
     * to eliminate copying data when writing NbtSession data one might
     * manage that 4 byte header specifically and therefore the initial
     * bufferIndex, and thus headerStart, would be 4).(NOTE: If one where

    
    SmbFile dir = new SmbFile("smb://server/share/testdir/", context);
    SmbFile testFile = new SmbFile("smb://server/share/testdir/newfile.txt", context);
    
    // Get initial listing (establishes cache)
    SmbFile[] initialFiles = dir.listFiles();
    
    // Create new file
    testFile.createNewFile();
    
    // Wait for change notification
    Thread.sleep(2000);
    

                    msg = msg + " query=" + query;
                    throw new IllegalStateException(msg);
                }
                sb.insert(0, CQ_PROPERTY + Srl.initCap(foreignPropertyName) + ".");
            }
            query = query.xgetReferrerQuery();
        }
        return sb.toString();
    }

    @Override

                    msg = msg + " query=" + query;
                    throw new IllegalStateException(msg);
                }
                sb.insert(0, CQ_PROPERTY + Srl.initCap(foreignPropertyName) + ".");
            }
            query = query.xgetReferrerQuery();
        }
        return sb.toString();
    }

    @Override

            assertEquals(2000L * 16 * 1024, fileFsFullSizeInfo.getCapacity());
            assertEquals(1500L * 16 * 1024, fileFsFullSizeInfo.getFree());
        }

        @Test
        @DisplayName("Should have initial zero state")
        void shouldHaveInitialZeroState() {
            // Given - newly created instance
            FileFsFullSizeInformation freshInfo = new FileFsFullSizeInformation();

            // Then

    assertSame(NULL_TICKER, map.ticker);

    assertEquals(4, map.concurrencyLevel);

    // concurrency level
    assertThat(map.segments).hasLength(4);
    // initial capacity / concurrency level
    assertEquals(16 / map.segments.length, map.segments[0].table.length());

    assertFalse(map.evictsBySize());
    assertFalse(map.expires());
    assertFalse(map.expiresAfterWrite());