# Find the location of this exact file.
_current_file_location = _inspect.getfile(_inspect.currentframe())

def _running_from_pip_package():
  return any(
      _current_file_location.startswith(dir_) for dir_ in _site_packages_dirs)

if _running_from_pip_package():
  # TODO(gunan): Add sanity checks to loaded modules here.

  # Load first party dynamic kernels.

        bytesRemainingInChunk = socket.source.readHexadecimalUnsignedLong()
        val extensions = socket.source.readUtf8LineStrict().trim()
        if (bytesRemainingInChunk < 0L || extensions.isNotEmpty() && !extensions.startsWith(";")) {
          throw ProtocolException(
            "expected chunk size and optional extensions" +
              " but was \"$bytesRemainingInChunk$extensions\"",
          )
        }

    @Test
    public void testValidSmbUrl() throws Exception {
        String url = "smb://server/share/folder/file.txt";
        String normalized = validator.validateSmbUrl(url);
        assertTrue(normalized.startsWith("smb://"));
        assertTrue(normalized.contains("server"));
        assertTrue(normalized.contains("/share/folder/file.txt") || normalized.contains("\\share\\folder\\file.txt"));
    }

    @Test

            if (pair == null) {
                pair = new Pair<>(new HashMap<>(), new ArrayList<>());
                relatedContentMap.put(key, pair);
            }
            if (entity.getTerm().startsWith(regexPrefix)) {
                final String regex = entity.getTerm().substring(regexPrefix.length());
                if (StringUtil.isBlank(regex)) {

        String str = info.toString();

        // Verify string contains expected elements
        assertNotNull(str);
        assertTrue(str.startsWith("SmbQueryFileBasicInfo["));
        assertTrue(str.contains("createTime="));
        assertTrue(str.contains("lastAccessTime="));
        assertTrue(str.contains("lastWriteTime="));

                throw sae;
            } catch (final SmbException se) {
                fp = 0L;
            }
        }
        if (file instanceof SmbNamedPipe && file.unc.startsWith("\\pipe\\")) {
            file.unc = file.unc.substring(5);
            file.send(new TransWaitNamedPipe("\\pipe" + file.unc), new TransWaitNamedPipeResponse());
        }

      for (index in 0 until cachedHeaders.size) {
        val fieldName = cachedHeaders.name(index)
        val value = cachedHeaders.value(index)
        if ("Warning".equals(fieldName, ignoreCase = true) && value.startsWith("1")) {
          // Drop 100-level freshness warnings.
          continue
        }
        if (isContentSpecificHeader(fieldName) ||
          !isEndToEnd(fieldName) ||

        response = new Trans2QueryPathInformationResponse(mockConfig, FileInformation.FILE_BASIC_INFO);

        String result = response.toString();

        assertNotNull(result);
        assertTrue(result.startsWith("Trans2QueryPathInformationResponse["));
        assertTrue(result.endsWith("]"));
    }

    @Test
    @DisplayName("Test readDataWireFormat with partial buffer")

    void toString_notEstablished() throws Exception {
        when(gssContext.isEstablished()).thenReturn(false);
        String s = ctx.toString();
        assertTrue(s.startsWith("KERB5["));
        assertTrue(s.contains("src=null"));
    }

    @Test
    @DisplayName("toString shows names and mech when established")
    void toString_established_ok() throws Exception {

              out.writeByte(0x40)
              writeByteString(name)
              writeByteString(value)
              insertIntoDynamicTable(header)
            }
            name.startsWith(Header.PSEUDO_PREFIX) && TARGET_AUTHORITY != name -> {
              // Follow Chromes lead - only include the :authority pseudo header, but exclude all other