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
[email protected]
https://lists.openafs.org/mailman/listinfo/openafs-info
