script to translate strace i/o data to ceph trace format

git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@1235 29311d96-e01e-0410-9327-a35deaab8ce9

diff --git a/branches/aleung/security1/ceph/trace_convert.pl b/branches/aleung/security1/ceph/trace_convert.pl
new file mode 100755 (executable)
index 0000000..2f1a9c7
--- /dev/null
+++ b/branches/aleung/security1/ceph/trace_convert.pl
@@ -0,0 +1,95 @@
+#!/usr/bin/perl -w
+
+use strict;
+use IO::Dir;
+use IO::File;
+
+my @files;
+my $file_handle;
+my @file_data;
+
+opendir(DIR, ".");
+@files = readdir(DIR);
+closedir(DIR);
+
+for $file_handle(@files) {
+    if($file_handle =~ /IOR/ and $file_handle !~ /cephtrace/) {
+       open(FILE, $file_handle) or die "cannot_open_file: $!";
+       flock(FILE, 2);
+       open(OUT, ">$file_handle.cephtrace") or die "cannot_open_file: $!";
+       flock(OUT, 2);
+       @file_data = <FILE>;
+       my $line;
+       my @args;
+       foreach $line (@file_data) {
+
+           my $timestamp;
+           my $op;
+           my $ret_val;
+           @args = split(/\s/, $line);
+
+           $timestamp = $args[0];
+           $op = $args[1];
+
+           my $path;
+           my $rest;
+           if ($op =~ /open\(/) {
+               # check success
+               my $before_eq;
+               my $after_eq;
+               my @replies;
+               ($before_eq, $after_eq) = split(/=/, $line);
+               @replies = split(/\s/, $after_eq);
+               $ret_val = $replies[1];
+               
+               if ($ret_val != -1) {
+                   ($op, $path, $rest) = split(/\"/, $op);
+                   print OUT "open\n$path\n102\n$ret_val\n";
+               }
+           }
+           elsif ($op =~ /close\(/) {
+               my $nothing;
+               my $rparen;
+               my $rest;
+               ($nothing, $rparen) = split(/\(/, $op);
+               ($ret_val, $rest) = split(/\)/, $rparen);
+               print OUT "close\n$ret_val\n";
+           }
+           elsif ($op =~ /read\(/) {
+               my $before;
+               my $after;
+               my $rest;
+               my $read_size;
+               my @replies;
+               ($before, $after) = split(/\(/, $op);
+               ($ret_val, $rest) = split(/,/, $after);
+               ($before, $after) = split(/\) *=/, $line);
+               @replies = split(/\s/, $after);
+               $read_size = $replies[1];
+               if (! $read_size) {
+                   print "$file_handle $line read_size=$read_size\n";
+               }
+               print OUT "read\n$ret_val\n$read_size\n0\n";
+           }
+           elsif ($op =~ /write/) {
+               my $before;
+               my $after;
+               my $rest;
+               my $write_size;
+               my @replies;
+               ($before, $after) = split(/\(/, $op);
+               ($ret_val, $rest) = split(/,/, $after);
+               ($before, $after) = split(/\) *=/, $line);
+               @replies = split(/\s/, $after);
+               $write_size = $replies[1];
+               if (! $write_size) {
+                   print "$file_handle $line write_size=$write_size\n";
+               }
+               print OUT "write\n$ret_val\n$write_size\n0\n";
+           }
+       }
+       close(FILE);
+       close(OUT);
+    }
+}
+