/usr/lib/python2.7/dist-packages/Scientific/MPI/IO.py is in python-mpi 2.9.4-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 | # Coordinated I/O for parallel systems
#
# Written by Konrad Hinsen <hinsen@cnrs-orleans.fr>
# last revision: 2006-6-23
#
"""
I/O utilities for use with MPI programs
"""
class LogFile:
"""
File for logging events from all processes
The purpose of LogFile objects is to collect short text output from
all processors into a single file. All processes can write whatever
they want at any time; the date is simply stored locally.
After the file has been closed by all processes, the
data is sent to process 0, which then writes everything to one
text file, neatly separated by process rank number.
Note that due to the intermediate storage of the data, LogFile
objects should not be used for large amounts of data. Also
note that all data is lost if a process crashes before closing
the file.
"""
def __init__(self, filename, communicator = None):
"""
@param filename: the name of the log file
@type filename: C{str}
@param communicator: the communicator in which the file is accessible.
The default value of C{None} means to use the
global world communicator, i.e. all possible
processes.
@type communicator: L{Scientific.MPI.MPICommunicator}
"""
self.filename = filename
if communicator is None:
from Scientific.MPI import world
self.communicator = world
else:
self.communicator = communicator
self.data = ''
self.first_chunk = 1
def write(self, string):
"""
Write a string to the file
@param string: the string data
@type string: C{str}
"""
self.data = self.data + string
def flush(self):
"""
Write buffered data to the text file
"""
if self.communicator.rank == 0:
if self.filename is None:
import sys
file = sys.stdout
else:
if self.first_chunk:
file = open(self.filename, 'w')
else:
file = open(self.filename, 'a')
if not self.first_chunk:
file.write(75*'='+'\n')
file.write("Rank 0:\n\n")
file.write(self.data)
file.write("\n\n")
for i in range(1, self.communicator.size):
file.write("Rank %d:\n\n" % i)
data = self.communicator.receiveString(i, 0)[0]
file.write(data)
file.write("\n\n")
if self.filename is not None:
file.close()
else:
self.communicator.send(self.data, 0, 0)
self.data = ''
self.first_chunk = 0
def close(self):
"""
Close the file, causing the real text file to be written
"""
self.flush()
|