up

shinpei/faults/posix/1-deletefile.k

@@ -4,7 +4,6 @@
  */
 
 include "faultinjector.k";
-
 using konoha.posix.*;
 
 class DeleteFileFault extends FaultInstance {
@@ -22,4 +21,3 @@ class DeleteFileFault extends FaultInstance {
 		return false;
 	}
 }
-

shinpei/faults/posix/faultsetup.k

@@ -0,0 +1,23 @@
+/*
+ * 1. deletefile
+ * Shinpei Nakata (c) 2011
+ */
+
+class FaultSetup {
+	String filename;
+
+	FaultSetup () {
+		filename = "";
+	}
+
+	void createFile (String fname, int size) {
+		filename = fname;
+		OutputStream ous = new OutputStream(filename,"w");
+		int wrote_bytes = 0;
+		while (wrote_bytes < size) {
+			ous << "@" ;
+			wrote_bytes++;
+		}
+		ous.close();
+	}
+}

shinpei/faults/posix/sample/1-posix.k → shinpei/faults/posix/sample-posix.k

@@ -1,14 +1,16 @@
 using konoha.posix.*;
 
+
 int main (String[] args) {
 	Path fpth = null;
+	String filename = "";
 	if (|args| > 0) {
 		filename = args[0];
 		fpth = file::filename;
 	}
+	OUT <<< "filename" <<< EOL;
 	DFile f = System.fopen(fpth, "r");
 	int bufsiz = 128;
-
 	Bytes buf = new byte[bufsiz];
 	int total_readsize = 0;
 	while (total_readsize < 1024) {

shinpei/faults/posix/sc1.k

@@ -3,13 +3,31 @@
  * Shinpei Nakata (c) 2011
  */
 
+using konoha.proc.*;
 include "1-deletefile.k"
+include "faultsetup.k"
+
+boolean isFaultInject = false;
 
 int main (String[] args)
 {
-	FaultInjector fi = new FaultInjector();
-	DeleteFileFault fdFault = new DeleteFileFault("hoge");
+	FaultSetup fs = new FaultSetup();
+	String input_file = "hoge.txt";
+	fs.createFile(input_file, 1024);
+ 	FaultInjector fi = new FaultInjector();
+	DeleteFileFault fdFault = new DeleteFileFault(input_file);
 	fi.addFaultInstance(fdFault);
-	//wait timinig
-	fi.loadToLocalTarget();
+
+	if (isFaultInject) {
+		print "injecting...";
+		fi.loadToLocalTarget();
+	}
+	Proc p = new Proc(["/usr/local/bin/konoha", "-a", "sample-posix.k", input_file]);
+	ins = p.getInputStream();
+	while (p.isAlive()) {
+		while ((line = ins.readLine()) != null) {
+			OUT << line;
+		}
+	}
+	return 0;
 }