Add rust timing

That is trailblaizin' bloody fast!

Author: H.Merijn Brand - Tux

.gitignore

@@ -23,6 +23,7 @@ lib/.precomp
 csv-c
 csv-cc
 csv-go
+rust*/target
 
 # Re-enable parts later
 sandbox/

csv-rust-csvrdr

@@ -0,0 +1 @@
+rust-csvreader/target/release/csvreader

csv-rust-libcsv

@@ -0,0 +1 @@
+rust-libcsv/target/release/csvreader

csv-rust-qckrdr

@@ -0,0 +1 @@
+rust-quick-reader/target/release/quick-reader

rust-csvreader/Cargo.lock

@@ -0,0 +1,15 @@
+[package]
+
+name = "csvreader"
+version = "0.0.1"
+authors = [ "Your name <[email protected]>" ]
+
+[[bin]]
+name = "csvreader"
+
+[dependencies]
+csv = "*"
+
+[profile.release]
+opt-level = 3
+lto = true

rust-csvreader/Cargo.toml

@@ -0,0 +1,16 @@
+extern crate csv;
+
+fn main () {
+    let fpath = ::std::env::args ().nth (1).unwrap ();
+    let mut rdr = csv::Reader::from_file (fpath).unwrap ().has_headers (false);
+    let mut sum = 0;
+    loop {
+        match rdr.next_bytes () {
+            csv::NextField::Data (_)    => sum += 1,
+            csv::NextField::EndOfRecord => {}
+            csv::NextField::EndOfCsv    => break,
+            csv::NextField::Error (err) => panic! ("{}", err),
+            }
+        }
+    println!("{}", sum);
+    }

rust-csvreader/src/csvreader.rs

@@ -0,0 +1,15 @@
+[package]
+name = "csvreader"
+version = "0.0.1"
+authors = [ "Ewan Higgs <[email protected]>" ]
+
+[[bin]]
+name = "csvreader"
+
+[dependencies]
+libc = "0.2"
+num-traits = "0.1"
+
+[profile.release]
+opt-level = 3
+lto = true

rust-libcsv/Cargo.lock

@@ -0,0 +1,93 @@
+extern crate libc;
+extern crate num_traits;
+
+use std::io::Read;
+use num_traits::NumCast;
+use std::ptr;
+use libc::{size_t, c_void};
+
+extern "C" fn field_count(_ : *mut c_void, _ : size_t, data : *mut i64) {
+    unsafe {
+        *data = *data + 1;
+    }
+}
+
+#[repr(C)]
+struct CSVParser {
+  pstate: i64,
+  quoted: i64,
+  spaces: size_t,
+  entry_buf: *mut u8,
+  entry_po: size_t,
+  entry_size: size_t,
+  status: i64,    
+  opts: u8, // was "options"
+  quote_char: u8,
+  delim_char: u8,
+  is_space: fn(u8)-> i64,
+  is_term: fn(u8) -> i64,
+  blk_size: size_t,
+  malloc_func: fn(size_t) -> *mut c_void,
+  relloc_func: fn(*mut c_void, size_t) -> *mut c_void,
+  free_func: fn(*mut c_void),
+}
+
+impl CSVParser {
+    fn new() -> CSVParser{
+        unsafe {
+            return ::std::mem::zeroed();
+        }
+    }
+}
+
+#[link(name = "csv")]
+extern {
+    fn csv_init(parser : *mut CSVParser, opt: u8) -> i64;
+    fn csv_parse(parser: *mut CSVParser, buf: *mut u8, buflen : size_t, 
+        cb: extern fn(*mut c_void, size_t, *mut i64), 
+        cb2: *const c_void, //cb2: fn(i64, *mut c_void), 
+        data: *mut i64) -> size_t;
+    fn csv_free(parser: *mut CSVParser);
+}
+
+fn main() {
+    const CSV_APPEND_NULL : u8 = 8;
+    const READ_SZ : usize = 1024 * 1024;
+
+    let args : Vec<String> = ::std::env::args().collect();
+    if args.len() < 2 {
+        println!("Usage: csvreader <csv-file>");
+        return;
+    }
+    let filename = &args[1];
+    let path = ::std::path::Path::new(filename);
+    let mut rdr = ::std::fs::File::open(&path).unwrap();
+
+    let mut parser = CSVParser::new();
+    unsafe { csv_init(&mut parser, CSV_APPEND_NULL); };
+
+    let mut buf = [0; READ_SZ];
+    let mut sum = 0;
+    loop {
+        match rdr.read(&mut buf) {
+            Ok(0) => break,
+            Ok(nread) => {
+                let pbuf = buf.as_mut_ptr();
+                unsafe {
+                    csv_parse(&mut parser, 
+                          pbuf, 
+                          NumCast::from(nread).unwrap(), 
+                          field_count, 
+                          ptr::null::<c_void>(), 
+                          &mut sum);
+                };
+            },
+            Err(e) => {
+                println!("Error reaidng file: {}", e); 
+                return;
+            }
+        }
+    }
+    unsafe { csv_free(&mut parser); };
+    println!("{}", sum);
+}

rust-libcsv/Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+
+name = "quick-reader"
+version = "0.0.1"
+authors = [ "Johann Tuffe <[email protected]>" ]
+
+[[bin]]
+name = "quick-reader"
+
+[dependencies]
+quick-csv = "0.1"
+
+[profile.release]
+opt-level = 3
+lto = true

rust-libcsv/src/main.rs

@@ -0,0 +1,10 @@
+extern crate quick_csv as csv;
+
+fn main() {
+    let fpath = ::std::env::args().nth(1).unwrap();
+    let rdr = csv::Csv::from_file(fpath).unwrap();
+    let sum = rdr.into_iter()
+                 .map(|r| r.unwrap().len())
+                 .fold(0usize, |c, n| c + n);
+    println!("{}", sum);
+}

rust-quick-reader/Cargo.lock

@@ -48,6 +48,7 @@ sub usage {
     13 => [ ".R",   "R",       "--slave -f" ],
     15 => [ "",     "C++"              ],
     16 => [ "",     "java8",   "-cp csv-pi-easy-pp.jar Main /tmp/hello.csv" ],
+    17 => [ "",     "Rust",    "/tmp/hello.csv" ],
     );
 my @test = (
     # lang irc script
@@ -80,13 +81,17 @@ sub usage {
     [ 13, 0, "csv-R"       ],
     [ 12, 0, "csv-java9"   ],
     [ 16, 0, "csv-easy-pp-pi", "Text::CSV::Easy_PP, Perlito" ],
+    [ 17, 0, "csv-rust-csvrdr" ],
+    [ 17, 0, "csv-rust-libcsv" ],
+    [ 17, 0, "csv-rust-qckrdr" ],
     );
 
 sub runfrom {
     my ($v, $script, $file) = @_;
     my ($ext, $exe, @arg) = @{$lang{$v}};
 
-    $exe eq "C" || $exe eq "C++" and $exe = "";
+    $exe eq "Rust" and $exe = $script;
+    $exe eq "C" || $exe eq "C++" || $exe eq "Rust" and $exe = "";
     my $run = join " " => $exe, @arg;
 
     $opt_v > 4 and say "$v / $ext / $exe\t/ $run";