[OpenAFS] volume_top.d
Derrick Brashear
shadow@gmail.com
Thu, 25 Oct 2012 19:10:07 -0400
What's the copyright on this? Is it something we could potentially
commit and ship (and presumably
keep updated when/if structures change, or possibly emit as part of the build?)
On Thu, Oct 25, 2012 at 6:48 PM, Robert Milkowski
<rmilkowski@task.gda.pl> wrote:
> Hi,
>
> Couple of people asked me about the dtrace scripts I referred to during my
> presentation.
> Below is one of them - it is a very quickly written script, only tested on
> our 1.4.11 based tree (with lots of patches, specifically DAFS), but there
> is a good chance it will just work on 1.4.11+ and maybe even on 1.6 (I
> haven't tried it though). It makes some very specific assumptions about how
> a given release of OpenAFS works, and it might not work correctly or at all
> for you - although it should be trivial to fix it then.
>
> Please use it at your own risk.
>
> The script requires two arguments - pid of fileserver, and how often it
> should print its output (for example 5s).
> It then clears terminal at a specified interval and prints all the volumes
> which were read or written to since the script was started, sorted by the
> number of read MBs.
>
> Example output:
>
>
> # ./volume_top.d `pgrep fileserver` 5s
> [...]
>
> Mountpoint VolID Read[MB] Wrote[MB]
>
> =============== ============ ========= =========
> /vicepa 542579958 100 10
> /vicepa 536904476 0 24
> /vicepb 536874428 0 0
> ============ ========= =========
> 100 34
>
>
> started: 2010 Nov 8 16:16:01
> current: 2010 Nov 8 16:25:46
>
>
>
>
> $ cat volume_top.d
> #!/usr/sbin/dtrace -qCs
>
> typedef unsigned int afs_uint32;
> typedef long long afs_int64;
> typedef int afs_int32;
>
> typedef afs_uint32 VolumeId;
> typedef afs_uint32 bit32; /* Unsigned, 32 bits */
> typedef bit32 Device; /* Unix device number */
>
> struct rx_queue {
> struct rx_queue *prev;
> struct rx_queue *next;
> };
>
> struct DiskPartition64 {
> struct DiskPartition64 *next;
> char *name; /* Mounted partition name */
> char *devName; /* Device mounted on */
> Device device; /* device number */
> afs_int32 index; /* partition index (0<=x<=VOLMAXPARTS) */
> int lock_fd; /* File descriptor of this partition if
> locked; otherwise -1;
> * Not used by the file server */
> afs_int64 free; /* Total number of blocks (1K)
> presumed
> * available on this partition (accounting
> * for the minfree parameter for the
> * partition). This is adjusted
> * approximately by the sizes of files
> * and directories read/written, and
> * periodically the superblock is read and
> * this is recomputed. This number can
> * be negative, if the partition starts
> * out too full */
> afs_int64 totalUsable; /* Total number of blocks available
> on this
> * partition, taking into account the
> minfree
> * parameter for the partition (see the
> * 4.2bsd command tunefs, but note that the
> * bug mentioned there--that the superblock
> * is not reread--does not apply here. The
> * superblock is re-read periodically by
> * VSetPartitionDiskUsage().) */
> afs_int64 minFree; /* Number blocks to be kept free, as last
> read
> * from the superblock */
> int flags;
> afs_int64 f_files; /* total number of files in this partition
> */
> }; /* IT IS NOT a complete structure definition */
>
>
> typedef struct Volume {
> struct rx_queue q; /* Volume hash chain pointers */
> VolumeId hashid; /* Volume number -- for hash table lookup */
> void *header; /* Cached disk data - FAKED TYPE */
> Device device; /* Unix device for the volume */
> struct DiskPartition64
> *partition; /* Information about the Unix partition */
>
> }; /* it is not the entire structure! */
>
>
> BEGIN
> {
> start_timestamp = timestamp;
> start_walltimestamp = walltimestamp;
> }
>
>
> pid$1:a.out:FetchData_RXStyle:entry
> {
> self->fetchdata = 1;
> this->volume = (struct Volume *)copyin(arg0, sizeof(struct Volume));
> this->partition = (struct DiskPartition64
> *)copyin((uintptr_t)this->volume->partition, sizeof(struct
> DiskPartition64));
> self->volumeid = this->volume->hashid;
> self->partition_name = copyinstr((uintptr_t)this->partition->name);
> }
>
> pid$1:a.out:FetchData_RXStyle:return
> / self->fetchdata /
> {
> self->fetchdata = 0;
> self->volumeid = 0;
> self->partition_name = 0;
> }
>
> syscall::readv:return
> / self->fetchdata /
> {
> @rx_fetchdata[self->partition_name, self->volumeid] = sum(arg0);
> @rx_fetchdata_total = sum(arg0);
> }
>
> pid$1:a.out:StoreData_RXStyle:entry
> {
> self->storedata = 1;
> this->volume = (struct Volume *)copyin(arg0, sizeof(struct Volume));
> this->partition = (struct DiskPartition64
> *)copyin((uintptr_t)this->volume->partition, sizeof(struct
> DiskPartition64));
> self->volumeid = this->volume->hashid;
> self->partition_name = copyinstr((uintptr_t)this->partition->name);
> }
>
> pid$1:a.out:StoreData_RXStyle:return
> / self->storedata /
> {
> self->storedata = 0;
> self->volumeid = 0;
> self->partition_name = 0;
> }
>
> syscall::writev:return
> / self->storedata /
> {
> @rx_storedata[self->partition_name, self->volumeid] = sum(arg0);
> @rx_storedata_total = sum(arg0);
> }
>
>
> tick-$2
> {
> setopt("aggsortrev", "true");
> printf("\033[H\033[J");
>
> normalize(@rx_fetchdata, 1024*1024);
> normalize(@rx_storedata, 1024*1024);
> normalize(@rx_fetchdata_total, 1024*1024);
> normalize(@rx_storedata_total, 1024*1024);
>
> printf("Mountpoint Volume ID Read[MB] Wrote[MB]\n");
> printf("=============== ============ ========= =========\n");
> printa("%-15s %12d %@9d %@9d\n", \
> @rx_fetchdata, @rx_storedata);
> printf(" ============ ========= =========\n");
> printf("%-15s %12s ", " ", " ");
> printa("%@9d %@9d\n", @rx_fetchdata_total, @rx_storedata_total);
>
> printf("\n\n");
> printf(" started: %Y\n", start_walltimestamp);
> printf(" current: %Y\n", walltimestamp);
>
> }
>
>
>
> --
> Robert Milkowski
> http://milek.blogspot.com
>
>
> _______________________________________________
> OpenAFS-info mailing list
> OpenAFS-info@openafs.org
> https://lists.openafs.org/mailman/listinfo/openafs-info
>
--
Derrick