Commit 4fade3e9 authored by Marc Vef's avatar Marc Vef
Browse files

ifs_test: flexibility changes

parent dcf7eee8

.gitignore

+2 −0
Original line number Diff line number Diff line
@@ -81,3 +81,5 @@ playground 
.fuse_hidden*



ifs/\.hidden_playground/



ifs_test/build/

ifs_test/main.cpp

+3 −6
Original line number Diff line number Diff line 
#include <iostream>

#include <unistd.h>

#include <fstream>

#include <fcntl.h>

#include <sys/stat.h>

#include <chrono>

using namespace std;
@@ -11,7 +8,7 @@ using get_time = chrono::steady_clock; 


int main(int argc, char* argv[]) {



    auto filen = strtol(argv[1], NULL, 20);

    auto filen = atoi(argv[1]);



//    cout << mkdir("/tmp/mountdir/bla", 0775) << endl;

//    auto buf = "BUFFERINO2";
@@ -42,10 +39,10 @@ int main(int argc, char* argv[]) { 
    auto start_t = get_time::now();



    for (int i = 0; i < filen; ++i) {

        string p = "/tmp/mountdir/file2" + to_string(i);

        string p = "/tmp/mountdir/file" + to_string(i);

        creat(p.c_str(), 0666);

        if (i % 25000 == 0)

            cout << i << " files processed.2" << endl;

            cout << i << " files processed." << endl;

//        cout << p << endl;

    }

ifs_test/main_MPI.cpp

+8 −8
Original line number Diff line number Diff line 
#include <iostream>

#include <unistd.h>

#include <fstream>

#include <fcntl.h>

#include <sys/stat.h>

#include <chrono>

#include <mpi.h>

using namespace std;
@@ -12,7 +10,7 @@ using get_time = chrono::steady_clock; 


int main(int argc, char* argv[]) {



    auto filen = strtol(argv[1], NULL, 20);

    auto filen = atoi(argv[1]);



    MPI_Init(NULL, NULL);

    int world_size;
@@ -31,18 +29,20 @@ int main(int argc, char* argv[]) { 
        string p = "/tmp/mountdir/file" + to_string(rank) + "_" + to_string(i);

        creat(p.c_str(), 0666);

        if (i % 25000 == 0)

            cout << i << " files processed." << endl;

//        cout << p << endl;

            cout << "Rank " << rank << ": " << i << " files processed." << endl;

    }



    auto end_t = get_time::now();

    auto diff = end_t - start_t;



    MPI_Barrier(MPI_COMM_WORLD);



    if (rank == 0) {

        auto diff_count = chrono::duration_cast<ns>(diff).count();



        cout << diff_count << "ns\t" << (diff_count) / 1000000. << "ms" << endl;

        cout << filen / ((diff_count) / 1000000000.) << " files per second" << endl;



    }



    MPI_Finalize();