arldatastream.cc 10.2 KB
Newer Older
1
2
3
4
#include "radixio/arldatastream.hh"

#include "radixbug/bug.hh"
#include "radixcore/stringfunctions.hh"
5
6
#include "radixio/eafstream.hh"
#include "radixmath/util.hh"
7
8
9
10
11
12
13
14

#include <fstream>
namespace radix
{
class ARLDataStream::PImpl
{
 public:
  std::string file;
15
16
  std::shared_ptr<radix::eafstream> stream;
  int recordSize = 0;
17
18
19
20
};

void ARLDataStream::expand(const std::string& val, ARLIndexHeader& index)
{
21
  if (val.size() < indexHeaderLength)
22
23
  {
    throw std::runtime_error(
24
        "Incorrect size for string expansion to ARLIndexHeader.");
25
26
27
28
29
30
31
32
33
34
35
36
37
38
  }
  index.year  = std::atoi(val.substr(0, 2).c_str());
  index.month = std::atoi(val.substr(2, 2).c_str());
  index.day   = std::atoi(val.substr(4, 2).c_str());
  index.hour  = std::atoi(val.substr(6, 2).c_str());
  index.ic    = std::atoi(val.substr(8, 2).c_str());
  index.il    = std::atoi(val.substr(10, 2).c_str());
  index.cgrid = val.substr(12, 2).c_str();
  index.kvar  = val.substr(14, 4);
  index.nexp  = std::atoi(val.substr(18, 4).c_str());
  index.prec  = float(std::atof(val.substr(22, 14).c_str()));
  index.var1  = float(std::atof(val.substr(36, 14).c_str()));
}
void ARLDataStream::expand(const std::string& val, const ARLIndexHeader& index,
39
                           ARLRecordHeader& header)
40
{
41
  if (val.size() < recordHeaderLength)
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
  {
    throw std::runtime_error(
        "Incorrect size for string expansion to ARLHeader.");
  }
  header.model_id = val.substr(0, 4);
  header.icx      = std::atoi(val.substr(4, 3).c_str());
  header.mn       = std::atoi(val.substr(7, 2).c_str());
  header.pole_lat = float(std::atof(val.substr(9, 7).c_str()));
  header.pole_lon = float(std::atof(val.substr(16, 7).c_str()));
  header.ref_lat  = float(std::atof(val.substr(23, 7).c_str()));
  header.ref_lon  = float(std::atof(val.substr(30, 7).c_str()));
  header.size     = float(std::atof(val.substr(37, 7).c_str()));
  header.orient   = float(std::atof(val.substr(44, 7).c_str()));
  header.tang_lat = float(std::atof(val.substr(51, 7).c_str()));
  header.sync_xp  = float(std::atof(val.substr(58, 7).c_str()));
  header.sync_yp  = float(std::atof(val.substr(65, 7).c_str()));
  header.sync_lat = float(std::atof(val.substr(72, 7).c_str()));
  header.sync_lon = float(std::atof(val.substr(79, 7).c_str()));
  header.dummy    = float(std::atof(val.substr(86, 7).c_str()));
  header.nx       = std::atoi(val.substr(93, 3).c_str());
  header.ny       = std::atoi(val.substr(96, 3).c_str());
  header.nz       = std::atoi(val.substr(99, 3).c_str());
  header.z_flag   = std::atoi(val.substr(102, 2).c_str());
  header.lenh     = std::atoi(val.substr(104, 4).c_str());

  int knx = ordinal(index.cgrid[0]);
  int kny = ordinal(index.cgrid[1]);
  // Check for the grid domain extending beyond 3 digits
  if (knx >= 64 || kny >= 64)
  {
    header.nx = (knx - 64) * 1000 + header.nx;
    header.ny = (kny - 64) * 1000 + header.ny;
  }
}

77
78
ARLDataStream::ARLDataStream(const std::string& file,
                             std::ios_base::openmode mode)
79
80
    : p(new PImpl(), [](PImpl* impl) { delete impl; })
{
81
  p->file   = file;
82
83
  p->stream = std::make_shared<radix::eafstream>(p->file.c_str(),
                                                 mode | std::ios::binary);
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
  if (!p->stream->is_open())
  {
    radix_line("Failed to open ARL file: " << file);
  }
}

bool ARLDataStream::read_index_header(ARLIndexHeader& iheader)
{
  std::string headerString = p->stream->readString(indexHeaderLength);
  expand(headerString, iheader);

  radix_line("Read index header: year = " << iheader.year);
  radix_line("                  month = " << iheader.month);
  radix_line("                    day = " << iheader.day);
  radix_line("                   hour = " << iheader.hour);
  radix_line("               variable = " << iheader.kvar);
  radix_line("       scaling exponent = " << iheader.nexp);
  radix_line("          initial value = " << iheader.var1);
102
  radix_line("  header as string:\n  " << headerString);
103
104
105
  return true;
}

106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
bool ARLDataStream::write_index_header(const ARLIndexHeader& iheader)
{
  radix_line("Write index header: year = " << iheader.year);
  radix_line("                   month = " << iheader.month);
  radix_line("                     day = " << iheader.day);
  radix_line("                    hour = " << iheader.hour);
  radix_line("                variable = " << iheader.kvar);
  radix_line("        scaling exponent = " << iheader.nexp);
  radix_line("           initial value = " << iheader.var1);

  // Construct index header string
  char indexHeader[50];
  sprintf(indexHeader, "%2d%2d%2d%2d%2d%2d%2d%4s%4d%14.7E%14.7E", iheader.year,
          iheader.month, iheader.day, iheader.hour, iheader.ic, iheader.il,
          std::stoi(iheader.cgrid.c_str()), iheader.kvar.c_str(), iheader.nexp,
          iheader.prec, iheader.var1);

  p->stream->writeString(std::string(indexHeader), 50);

  radix_line("  header as string:\n  " << indexHeader);

  return true;
}
129

130
131
132
133
bool ARLDataStream::read_next_index_header(ARLIndexHeader& iheader)
{
  int bytesToSkip = roundUpInt(p->stream->bytesRead(), p->recordSize) -
                    p->stream->bytesRead();
Purves, Murray's avatar
Purves, Murray committed
134
  radix_line("Skipping " << bytesToSkip << " bytes to the next index header");
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154

  p->stream->skipBytes(bytesToSkip);

  return read_index_header(iheader);
}

bool ARLDataStream::read_record_header(const ARLIndexHeader& iheader,
                                       ARLRecordHeader& rheader)
{
  std::string headerString = p->stream->readString(recordHeaderLength);
  expand(headerString, iheader, rheader);

  // Calculate and save record size
  p->recordSize = (rheader.nx * rheader.ny) + indexHeaderLength;

  radix_line("  Read record header: model = " << rheader.model_id);
  radix_line("                         nx = " << rheader.nx);
  radix_line("                         ny = " << rheader.ny);
  radix_line("                         nz = " << rheader.nz);
  radix_line("        Size of each record = " << p->recordSize);
155
  radix_line("    header as string:\n    " << headerString);
156
157
158
  return true;
}

159
160
161
bool ARLDataStream::write_record_header(const ARLIndexHeader& iheader,
                                        const ARLRecordHeader& rheader)
{
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
  // Calculate and save record size
  p->recordSize = (rheader.nx * rheader.ny) + indexHeaderLength;

  radix_line("  Write record header: model = " << rheader.model_id);
  radix_line("                          nx = " << rheader.nx);
  radix_line("                          ny = " << rheader.ny);
  radix_line("                          nz = " << rheader.nz);
  radix_line("         Size of each record = " << p->recordSize);

  char recordHeader[108];
  sprintf(recordHeader,
          "%4s%3d%2d%7.2f%7.2f%7.2f%7.2f%7.2f%7.2f%7.2f%7.2f%7.2f%7.2f%7.2f%7."
          "2f%3d%3d%3d%2d%4d",
          rheader.model_id.c_str(), rheader.icx, rheader.mn, rheader.pole_lat,
          rheader.pole_lon, rheader.ref_lat, rheader.ref_lon, rheader.size,
          rheader.orient, rheader.tang_lat, rheader.sync_xp, rheader.sync_yp,
          rheader.sync_lat, rheader.sync_lon, rheader.dummy, rheader.nx,
          rheader.ny, rheader.nz, rheader.z_flag, rheader.lenh);

  p->stream->writeString(std::string(recordHeader), 108);

  // Skip enough bytes to get to the next index header
  int bytesToSkip = roundUpInt(p->stream->bytesWritten(), p->recordSize) -
                    p->stream->bytesWritten();
  radix_line("    Write complete: skipping "
             << bytesToSkip << " bytes to the next index header");

  p->stream->writeString("", bytesToSkip);

  radix_line("    header as string:\n    " << recordHeader);

  return true;
194
195
}

196
197
198
199
200
bool ARLDataStream::read_record(const ARLIndexHeader& iheader,
                                const ARLRecordHeader& rheader,
                                std::vector<std::vector<double> >& record)
{
  // Set up the vector size
Purves, Murray's avatar
Purves, Murray committed
201
  record.clear();
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
  record.resize(rheader.nx);
  for (std::vector<double>& vec : record)
  {
    vec.resize(rheader.ny);
  }

  // Calculate the scaling factor
  double scaleFactor = pow(2.0, 7.0 - (double)iheader.nexp), lastValue = 0.0;

  radix_line("    Reading record data:");
  for (int y = 0; y < rheader.ny; ++y)
  {
    for (int x = 0; x < rheader.nx; ++x)
    {
      // Read the raw value
      unsigned char ch = (unsigned char)p->stream->readChar();
      int packedValue  = ch - 127;

      // Calculate the unpacked value
      double unpackedValue = 0.0;
      // Get the correct 'last value' if we are at a 0 index
      if (x == 0)
      {
        if (y == 0)
        {
          lastValue = iheader.var1;
        }
        else
        {
          lastValue = record[x][y - 1];
        }
      }

      unpackedValue = (packedValue / scaleFactor) + lastValue;
      record[x][y]  = unpackedValue;
      lastValue     = unpackedValue;

      if ((x < 2 && y < 2) || ((rheader.nx - x < 3) && (rheader.ny - y < 3)))
      {
        radix_line("      [" << x << "," << y << "]: packed = " << packedValue
                             << ", unpacked = " << unpackedValue);
      }
    }
  }

  return true;
248
249
}

250
251
252
bool ARLDataStream::write_record(
    const ARLIndexHeader& iheader, const ARLRecordHeader& rheader,
    const std::vector<std::vector<double> >& record)
253
{
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
  if (record.size() == 0)
  {
    radix_line("No data here - returning false");
    return false;
  }

  // Calculate the scaling factor
  double scaleFactor = pow(2.0, 7.0 - (double)iheader.nexp), lastValue = 0.0;

  radix_line("    Writing record data:");
  for (int y = 0; y < rheader.ny; ++y)
  {
    for (int x = 0; x < rheader.nx; ++x)
    {
      // Get the correct 'last value' if we are at a 0 index
      if (x == 0)
      {
        if (y == 0)
        {
          lastValue = iheader.var1;
        }
        else
        {
          lastValue = record[x][y - 1];
        }
      }

      // Calculate the packed value
      double unpackedValue = record[x][y];
      int packedInt        = (int)((unpackedValue - lastValue) * scaleFactor);

      unsigned char packedValue = (unsigned char)(packedInt + 127);

      p->stream->writeChar(packedValue);

      lastValue = unpackedValue;

      if ((x < 2 && y < 2) || ((rheader.nx - x < 3) && (rheader.ny - y < 3)))
      {
        radix_line("      [" << x << "," << y << "]: packed = " << packedInt
                             << ", unpacked = " << unpackedValue);
      }
    }
  }

  return true;
300
301
}

302
303
void ARLDataStream::close_stream() { p->stream->close(); }

304
}  // namespace radix