| @@ 72-82 (lines=11) @@ | ||
| 69 | raise IOError("Failed to open the hdf5 file") |
|
| 70 | return backing_file |
|
| 71 | ||
| 72 | def _link_datafile_to_nexus_file(self, data): |
|
| 73 | filename = self.exp.meta_data.get('nxs_filename') |
|
| 74 | ||
| 75 | with h5py.File(filename, 'a') as nxs_file: |
|
| 76 | # entry path in nexus file |
|
| 77 | name = data.get_name() |
|
| 78 | group_name = self.exp.meta_data.get(['group_name', name]) |
|
| 79 | link = self.exp.meta_data.get(['link_type', name]) |
|
| 80 | name = data.get_name(orig=True) |
|
| 81 | nxs_entry = self.__add_nxs_entry(nxs_file, link, group_name, name) |
|
| 82 | self.__add_nxs_data(nxs_file, nxs_entry, link, group_name, data) |
|
| 83 | ||
| 84 | def __add_nxs_entry(self, nxs_file, link, group_name, name): |
|
| 85 | nxs_entry = '/entry/' + link |
|
| @@ 376-387 (lines=12) @@ | ||
| 373 | else: |
|
| 374 | entry[name][...] = data |
|
| 375 | ||
| 376 | def _link_datafile_to_nexus_file(self, data): |
|
| 377 | filename = self.exp.meta_data.get('nxs_filename') |
|
| 378 | ||
| 379 | with h5py.File(filename, 'a', driver="mpio", comm = MPI.COMM_WORLD) as nxs_file: |
|
| 380 | #nxs_file = self.hdf5._open_backing_h5(filename, 'a', mpi=False) |
|
| 381 | # entry path in nexus file |
|
| 382 | name = data.get_name() |
|
| 383 | group_name = self.exp.meta_data.get(['group_name', name]) |
|
| 384 | link = self.exp.meta_data.get(['link_type', name]) |
|
| 385 | name = data.get_name(orig=True) |
|
| 386 | nxs_entry = self.__add_nxs_entry(nxs_file, link, group_name, name) |
|
| 387 | self.__add_nxs_data(nxs_file, nxs_entry, link, group_name, data) |
|
| 388 | ||
| 389 | def __add_nxs_entry(self, nxs_file, link, group_name, name): |
|
| 390 | if name == 'phantom': |
|