mirror of
https://github.com/facebook/sapling.git
synced 2024-10-09 08:18:15 +03:00
55 lines
2.1 KiB
Python
55 lines
2.1 KiB
Python
|
#!/usr/bin/env python3
|
||
|
|
#
|
||
|
|
# Copyright (c) 2016-present, Facebook, Inc.
|
||
|
|
# All rights reserved.
|
||
|
|
#
|
||
|
|
# This source code is licensed under the BSD-style license found in the
|
||
|
|
# LICENSE file in the root directory of this source tree. An additional grant
|
||
|
|
# of patent rights can be found in the PATENTS file in the same directory.
|
||
|
|
|
||
|
|
import eden.thrift
|
||
|
|
from typing import Iterable
|
||
|
|
|
||
|
|
'''Utilities for inspecting the state of the Eden server via Thrift.
|
||
|
|
|
||
|
|
This utility is parameterized by a specific mount point so that it need not be
|
||
|
|
specified for each instance method.
|
||
|
|
'''
|
||
|
|
|
||
|
|
|
||
|
|
class EdenServerInspector(object):
|
||
|
|
def __init__(self, mount_point: str) -> None:
|
||
|
|
self._mount_point = mount_point
|
||
|
|
|
||
|
|
def create_thrift_client(self) -> eden.thrift.EdenClient:
|
||
|
|
return eden.thrift.create_thrift_client(mounted_path=self._mount_point)
|
||
|
|
|
||
|
|
def unload_inode_for_path(self, path: str='') -> None:
|
||
|
|
'''path: relative path to a directory under the mount.'''
|
||
|
|
with self.create_thrift_client() as client:
|
||
|
|
client.unloadInodeForPath(self._mount_point, path)
|
||
|
|
|
||
|
|
def get_inode_count(self, path: str='') -> int:
|
||
|
|
'''path: relative path to a directory under the mount.
|
||
|
|
|
||
|
|
Use '' for the root. Note that this will include the inode count for
|
||
|
|
the root .hg and .eden entries.
|
||
|
|
'''
|
||
|
|
with self.create_thrift_client() as client:
|
||
|
|
debug_info = client.debugInodeStatus(self._mount_point, path)
|
||
|
|
count = 0
|
||
|
|
for tree_inode_debug_info in debug_info:
|
||
|
|
count += sum(1 for entry in tree_inode_debug_info.entries
|
||
|
|
if entry.loaded)
|
||
|
|
return count
|
||
|
|
|
||
|
|
def get_paths_for_inodes(self, path: str='') -> Iterable[str]:
|
||
|
|
'''path: relative path to a directory under the mount.'''
|
||
|
|
with self.create_thrift_client() as client:
|
||
|
|
debug_info = client.debugInodeStatus(self._mount_point, path)
|
||
|
|
for tree_inode_debug_info in debug_info:
|
||
|
|
parent_dir = tree_inode_debug_info.path.decode('utf-8')
|
||
|
|
for entry in tree_inode_debug_info.entries:
|
||
|
|
if entry.loaded:
|
||
|
|
yield f'{parent_dir}/{entry.name.decode("utf-8")}'
|