-/* Copyright (c) 2007-2020. The SimGrid Team. All rights reserved. */
+/* Copyright (c) 2007-2021. The SimGrid Team. All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_io, smpi, "Logging specific to SMPI (RMA operations)");
-MPI_Errhandler SMPI_default_File_Errhandler = MPI_ERRORS_RETURN;
+MPI_Errhandler SMPI_default_File_Errhandler = _smpi_cfg_default_errhandler_is_error ? MPI_ERRORS_ARE_FATAL : MPI_ERRORS_RETURN;;
namespace simgrid{
namespace smpi{
if (info_ != MPI_INFO_NULL)
info_->ref();
std::string fullname=filename;
- if (simgrid::s4u::Host::current()->get_disks().empty())
- xbt_die("SMPI/IO : Trying to open file on a diskless host ! Add one to your platform file");
+ xbt_assert(not simgrid::s4u::Host::current()->get_disks().empty(),
+ "SMPI/IO : Trying to open file on a diskless host ! Add one to your platform file");
size_t found=fullname.find('/');
//in case no fullpath is provided ... just pick the first mountpoint.
simgrid::smpi::colls::bcast(&shared_mutex_, 1, MPI_AINT, 0, comm);
if(comm_->rank() != 0)
intrusive_ptr_add_ref(&*shared_mutex_);
+ this->add_f();
}
File::~File(){
}
delete win_;
delete file_;
+ F2C::free_f(this->f2c_id());
if (info_ != MPI_INFO_NULL)
simgrid::smpi::Info::unref(info_);
if (errhandler_ != MPI_ERRHANDLER_NULL)
int File::del(const char* filename, const Info*)
{
//get the file with MPI_MODE_DELETE_ON_CLOSE and then close it
- File* f = new File(MPI_COMM_SELF,filename,MPI_MODE_DELETE_ON_CLOSE|MPI_MODE_RDWR, nullptr);
+ auto* f = new File(MPI_COMM_SELF, filename, MPI_MODE_DELETE_ON_CLOSE | MPI_MODE_RDWR, nullptr);
close(&f);
return MPI_SUCCESS;
}
int File::seek(MPI_Offset offset, int whence){
switch(whence){
- case(MPI_SEEK_SET):
+ case MPI_SEEK_SET:
XBT_VERB("Seeking in MPI_File %s, setting offset %lld", file_->get_path(), offset);
file_->seek(offset,SEEK_SET);
break;
- case(MPI_SEEK_CUR):
+ case MPI_SEEK_CUR:
XBT_VERB("Seeking in MPI_File %s, current offset + %lld", file_->get_path(), offset);
file_->seek(offset,SEEK_CUR);
break;
- case(MPI_SEEK_END):
+ case MPI_SEEK_END:
XBT_VERB("Seeking in MPI_File %s, end offset + %lld", file_->get_path(), offset);
file_->seek(offset,SEEK_END);
break;
return file_->size();
}
+ void File::set_size(int size)
+ {
+ file_->write(size, true);
+ }
+
int File::flags() const
{
return flags_;
MPI_Info File::info()
{
- if (info_ == MPI_INFO_NULL)
- info_ = new Info();
- info_->ref();
return info_;
}