Fixed to correctly support velocities in gadget. Fixed on-disk format on kdtree

This commit is contained in:
Guilhem Lavaux 2011-03-17 13:39:20 -05:00
parent f04e7dd41b
commit 247fc4db6b
4 changed files with 50 additions and 15 deletions

View File

@ -1,3 +1,4 @@
#include <cmath>
#include <iostream> #include <iostream>
#include <assert.h> #include <assert.h>
#include <stdio.h> #include <stdio.h>
@ -63,12 +64,13 @@ PurePositionData *CosmoTool::loadGadgetPosition(const char *fname)
SimuData *CosmoTool::loadGadgetMulti(const char *fname, int id, int loadflags) SimuData *CosmoTool::loadGadgetMulti(const char *fname, int id, int loadflags, int GadgetFormat)
{ {
SimuData *data; SimuData *data;
int p, n; int p, n;
UnformattedRead *f; UnformattedRead *f;
GadgetHeader h; GadgetHeader h;
float velmul;
if (id >= 0) { if (id >= 0) {
int k = snprintf(0, 0, "%s.%d", fname, id)+1; int k = snprintf(0, 0, "%s.%d", fname, id)+1;
@ -113,9 +115,9 @@ SimuData *CosmoTool::loadGadgetMulti(const char *fname, int id, int loadflags)
h.flag_cooling = f->readInt32(); h.flag_cooling = f->readInt32();
h.num_files = f->readInt32(); h.num_files = f->readInt32();
data->BoxSize = h.BoxSize = f->readReal64(); data->BoxSize = h.BoxSize = f->readReal64();
h.Omega0 = f->readReal64(); data->Omega_M = h.Omega0 = f->readReal64();
h.OmegaLambda = f->readReal64(); data->Omega_Lambda = h.OmegaLambda = f->readReal64();
h.HubbleParam = f->readReal64(); data->Hubble = h.HubbleParam = f->readReal64();
f->endCheckpoint(true); f->endCheckpoint(true);
for(int k=0; k<6; k++) for(int k=0; k<6; k++)
@ -125,6 +127,14 @@ SimuData *CosmoTool::loadGadgetMulti(const char *fname, int id, int loadflags)
} }
data->NumPart = NumPart; data->NumPart = NumPart;
data->TotalNumPart = NumPartTotal; data->TotalNumPart = NumPartTotal;
if (GadgetFormat == 1)
velmul = sqrt(h.time);
else if (GadgetFormat == 2)
velmul = 1/(h.time);
else {
cerr << "unknown gadget format" << endl;
abort();
}
} }
catch (const InvalidUnformattedAccess& e) catch (const InvalidUnformattedAccess& e)
{ {
@ -197,9 +207,10 @@ SimuData *CosmoTool::loadGadgetMulti(const char *fname, int id, int loadflags)
f->beginCheckpoint(); f->beginCheckpoint();
for(int k = 0, p = 0; k < 6; k++) { for(int k = 0, p = 0; k < 6; k++) {
for(int n = 0; n < h.npart[k]; n++) { for(int n = 0; n < h.npart[k]; n++) {
data->Vel[0][p] = f->readReal32(); // THIS IS GADGET 1
data->Vel[1][p] = f->readReal32(); data->Vel[0][p] = f->readReal32()*velmul;
data->Vel[2][p] = f->readReal32(); data->Vel[1][p] = f->readReal32()*velmul;
data->Vel[2][p] = f->readReal32()*velmul;
p++; p++;
} }
} }
@ -213,7 +224,8 @@ SimuData *CosmoTool::loadGadgetMulti(const char *fname, int id, int loadflags)
return 0; return 0;
} }
// TODO: FIX THE UNITS OF THESE FUNKY VELOCITIES !!! // THE VELOCITIES ARE IN PHYSICAL COORDINATES
/// // TODO: FIX THE UNITS OF THESE FUNKY VELOCITIES !!!
} else { } else {
// Skip velocities // Skip velocities
f->skip(NumPart*3*sizeof(float)+2*4); f->skip(NumPart*3*sizeof(float)+2*4);

View File

@ -8,7 +8,7 @@ namespace CosmoTool {
PurePositionData *loadGadgetPosition(const char *fname); PurePositionData *loadGadgetPosition(const char *fname);
SimuData *loadGadgetMulti(const char *fname, int id, int flags); SimuData *loadGadgetMulti(const char *fname, int id, int flags, int GadgetFormat = 1);
}; };

View File

@ -243,7 +243,6 @@ int readInfoFile(const char *basename, int outputId, InfoData& info)
iss >> unitLength; iss >> unitLength;
infoMap[keyword] = unitLength; infoMap[keyword] = unitLength;
} }
} }

View File

@ -446,6 +446,7 @@ namespace CosmoTool {
{ {
char id[KDTREE_DISK_SIGNATURE_LEN]; char id[KDTREE_DISK_SIGNATURE_LEN];
long nodesUsed, numCells; long nodesUsed, numCells;
long rootId;
}; };
template<int N, typename ValType, typename CType> template<int N, typename ValType, typename CType>
@ -456,6 +457,7 @@ namespace CosmoTool {
strncpy(h.id, KDTREE_DISK_SIGNATURE, KDTREE_DISK_SIGNATURE_LEN); strncpy(h.id, KDTREE_DISK_SIGNATURE, KDTREE_DISK_SIGNATURE_LEN);
h.nodesUsed = lastNode; h.nodesUsed = lastNode;
h.numCells = numNodes; h.numCells = numNodes;
h.rootId = root - nodes;
o.write((char*)&h, sizeof(h)); o.write((char*)&h, sizeof(h));
for (long i = 0; i < lastNode; i++) for (long i = 0; i < lastNode; i++)
@ -464,13 +466,17 @@ namespace CosmoTool {
node_on_disk.cell_id = nodes[i].value - base_cell; node_on_disk.cell_id = nodes[i].value - base_cell;
if (nodes[i].children[0] == 0) if (nodes[i].children[0] == 0)
node_on_disk.children_node[0] = -1; node_on_disk.children_node[0] = -1L;
else else
node_on_disk.children_node[0] = nodes[i].children[0] - nodes; node_on_disk.children_node[0] = nodes[i].children[0] - nodes;
assert((node_on_disk.children_node[0] == -1) || ((node_on_disk.children_node[0] >= 0) && (node_on_disk.children_node[0] < lastNode)));
if (nodes[i].children[1] == 0) if (nodes[i].children[1] == 0)
node_on_disk.children_node[1] = -1; node_on_disk.children_node[1] = -1L;
else else
node_on_disk.children_node[1] = nodes[i].children[1] - nodes; node_on_disk.children_node[1] = nodes[i].children[1] - nodes;
assert((node_on_disk.children_node[1] == -1) || ((node_on_disk.children_node[1] >= 0) && (node_on_disk.children_node[1] < lastNode)));
memcpy(node_on_disk.minBound, nodes[i].minBound, sizeof(coords)); memcpy(node_on_disk.minBound, nodes[i].minBound, sizeof(coords));
memcpy(node_on_disk.maxBound, nodes[i].maxBound, sizeof(coords)); memcpy(node_on_disk.maxBound, nodes[i].maxBound, sizeof(coords));
@ -489,10 +495,15 @@ namespace CosmoTool {
in.read((char *)&h, sizeof(h)); in.read((char *)&h, sizeof(h));
if (!in || strncmp(h.id, KDTREE_DISK_SIGNATURE, KDTREE_DISK_SIGNATURE_LEN) != 0) if (!in || strncmp(h.id, KDTREE_DISK_SIGNATURE, KDTREE_DISK_SIGNATURE_LEN) != 0)
throw InvalidOnDiskKDTree(); {
std::cerr << "KDTree Signature invalid" << std::endl;
throw InvalidOnDiskKDTree();
}
if (h.numCells != Ncells || h.nodesUsed < 0) if (h.numCells != Ncells || h.nodesUsed < 0) {
std::cerr << "The number of cells has changed (" << h.numCells << " != " << Ncells << ") or nodesUsed=" << h.nodesUsed << std::endl;
throw InvalidOnDiskKDTree(); throw InvalidOnDiskKDTree();
}
base_cell = cells; base_cell = cells;
nodes = new Node[h.nodesUsed]; nodes = new Node[h.nodesUsed];
@ -505,11 +516,18 @@ namespace CosmoTool {
in.read((char *)&node_on_disk, sizeof(node_on_disk)); in.read((char *)&node_on_disk, sizeof(node_on_disk));
if (!in || node_on_disk.cell_id > numNodes || node_on_disk.cell_id < 0 || if (!in) {
std::cerr << "End-of-file reached" << std::endl;
delete[] nodes;
throw InvalidOnDiskKDTree();
}
if (node_on_disk.cell_id > numNodes || node_on_disk.cell_id < 0 ||
node_on_disk.children_node[0] > lastNode || node_on_disk.children_node[0] < -1 || node_on_disk.children_node[0] > lastNode || node_on_disk.children_node[0] < -1 ||
node_on_disk.children_node[1] > lastNode || node_on_disk.children_node[1] < -1) node_on_disk.children_node[1] > lastNode || node_on_disk.children_node[1] < -1)
{ {
delete[] nodes; delete[] nodes;
std::cerr << "Invalid cell id or children node id invalid" << std::endl;
std::cerr << node_on_disk.cell_id << std::endl << node_on_disk.children_node[0] << std::endl << node_on_disk.children_node[1] << std::endl;
throw InvalidOnDiskKDTree(); throw InvalidOnDiskKDTree();
} }
@ -535,10 +553,16 @@ namespace CosmoTool {
if (c != N) if (c != N)
{ {
delete[] nodes; delete[] nodes;
std::cerr << "Coordinates of the cell inconsistent with the boundaries" << std::endl
<< " X=" << nodes[i].value->coord[0] << " B=[" << nodes[i].minBound[0] << "," << nodes[i].maxBound[0] << "]" << std::endl
<< " Y=" << nodes[i].value->coord[1] << " B=[" << nodes[i].minBound[1] << "," << nodes[i].maxBound[1] << "]" << std::endl
<< " Z=" << nodes[i].value->coord[2] << " B=[" << nodes[i].minBound[2] << "," << nodes[i].maxBound[2] << "]" << std::endl;
throw InvalidOnDiskKDTree(); throw InvalidOnDiskKDTree();
} }
} }
root = &nodes[h.rootId];
sortingHelper = new Cell *[Ncells]; sortingHelper = new Cell *[Ncells];
for (uint32_t i = 0; i < Ncells; i++) for (uint32_t i = 0; i < Ncells; i++)
sortingHelper[i] = &cells[i]; sortingHelper[i] = &cells[i];