X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/abc6c695d534ee87fe91c84038ebbf6b9226575d..cf6a47ee6e6c3b4b884c577ba9d7324ae4f32783:/examples/msg/io/file.c diff --git a/examples/msg/io/file.c b/examples/msg/io/file.c index 91c8ee80f8..9e07765119 100644 --- a/examples/msg/io/file.c +++ b/examples/msg/io/file.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2008, 2009, 2010. The SimGrid Team. +/* Copyright (c) 2008-2010, 2012-2013. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -15,10 +15,16 @@ * - io/file.c Example with the disk resource */ +#define FILENAME1 "./doc/simgrid/examples/platforms/g5k.xml" +#define FILENAME2 ".\\Windows\\setupact.log" +#define FILENAME3 "./doc/simgrid/examples/platforms/g5k_cabinets.xml" +#define FILENAME4 "./doc/simgrid/examples/platforms/nancy.xml" + #include #include #include "msg/msg.h" #include "surf/surf_private.h" +#include "inttypes.h" int host(int argc, char *argv[]); @@ -27,23 +33,37 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(io_file, int host(int argc, char *argv[]) { - m_file_t file; - char* mount = bprintf("C:"); - - file = MSG_file_open(mount,"test.txt","rw"); - XBT_INFO("Host '%s' open %p",MSG_host_get_name(MSG_host_self()), file); - - size_t read = MSG_file_read(mount,NULL,0,0,file); - XBT_INFO("Host '%s' read %zu", MSG_host_get_name(MSG_host_self()), read); - - size_t write = MSG_file_write(mount,NULL,0,0,file); - XBT_INFO("Host '%s' write %zu", MSG_host_get_name(MSG_host_self()), write); - - int res = MSG_file_stat(mount,0,NULL); - XBT_INFO("Host '%s' stat %d",MSG_host_get_name(MSG_host_self()), res); - - res = MSG_file_close(mount,file); - XBT_INFO("Host '%s' close %d",MSG_host_get_name(MSG_host_self()), res); + msg_file_t file = NULL; + char* mount = xbt_strdup("/home"); + sg_storage_size_t read,write; + + if(!strcmp(MSG_process_get_name(MSG_process_self()),"0")){ + file = MSG_file_open(mount,FILENAME1, NULL); + MSG_file_dump(file); + } else if(!strcmp(MSG_process_get_name(MSG_process_self()),"1")) { + free(mount); + mount = xbt_strdup("/windows"); + file = MSG_file_open(mount,FILENAME2, NULL); + } else if(!strcmp(MSG_process_get_name(MSG_process_self()),"2")){ + file = MSG_file_open(mount,FILENAME3, NULL); + } else if(!strcmp(MSG_process_get_name(MSG_process_self()),"3")) + file = MSG_file_open(mount,FILENAME4, NULL); + else xbt_die("FILENAME NOT DEFINED %s",MSG_process_get_name(MSG_process_self())); + + XBT_INFO("\tOpen file '%s'",file->fullname); + + read = MSG_file_read(file, 10000000); // Read for 10MB + XBT_INFO("\tHave read %" PRIu64 " on %s",read,file->fullname); + + write = MSG_file_write(file, 100000); // Write for 100KB + XBT_INFO("\tHave written %" PRIu64 " on %s",write,file->fullname); + + read = MSG_file_read(file, 110000); // Read for 110KB + XBT_INFO("\tHave read %" PRIu64 " on %s (of size %" PRIu64 ")",read,file->fullname, + MSG_file_get_size(file)); + + XBT_INFO("\tClose file '%s'",file->fullname); + MSG_file_close(file); free(mount); return 0; @@ -51,24 +71,23 @@ int host(int argc, char *argv[]) int main(int argc, char **argv) { - int i,res; - MSG_global_init(&argc, argv); + int i,res; + MSG_init(&argc, argv); MSG_create_environment(argv[1]); xbt_dynar_t hosts = MSG_hosts_as_dynar(); MSG_function_register("host", host); - - XBT_INFO("Number of host '%lu'",xbt_dynar_length(hosts)); - for(i = 0 ; i