Skip to content

Commit f046d20

Browse files
committed
[CPP]: Address aeron-io#98
1 parent bbe6e96 commit f046d20

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

main/cpp/otf_api/IrCollection.h

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ class IrCollection
5151
{
5252
public:
5353
/// Construct a collection
54-
IrCollection() : buffer_(NULL), header_(NULL)
54+
IrCollection() : buffer_(NULL), irId_(-1), header_(NULL)
5555
{
5656
}
5757

@@ -205,14 +205,15 @@ class IrCollection
205205
frame.wrapForDecode(buffer_, offset, frame.sbeBlockLength(), frame.sbeSchemaVersion());
206206

207207
tmpLen = frame.getPackageName(tmp, sizeof(tmp));
208-
::std::cout << "Reading IR package=\"" << std::string(tmp, tmpLen) << "\"" << ::std::endl;
208+
::std::cout << "Reading IR package=\"" << std::string(tmp, tmpLen) << "\" id=" << frame.irId() << ::std::endl;
209209

210210
frame.getNamespaceName(tmp, sizeof(tmp));
211211
frame.getSemanticVersion(tmp, sizeof(tmp));
212212

213213
offset += frame.size();
214214

215215
headerLength_ = readHeader(offset);
216+
irId_ = frame.irId();
216217

217218
offset += headerLength_;
218219

@@ -307,7 +308,7 @@ class IrCollection
307308

308309
// save buffer_ + offset as start of message and size as length
309310

310-
map_.insert(std::pair<int, Ir *>(token.fieldId(), new Ir(buffer_ + offset, size, token.fieldId(), token.sbeSchemaId(), token.tokenVersion())));
311+
map_.insert(std::pair<int, Ir *>(token.fieldId(), new Ir(buffer_ + offset, size, token.fieldId(), irId_, token.tokenVersion())));
311312

312313
// map_[token.schemaID()] = new Ir(buffer_ + offset, size);
313314

@@ -319,6 +320,7 @@ class IrCollection
319320

320321
char *buffer_;
321322
int length_;
323+
int irId_;
322324

323325
Ir *header_;
324326
int headerLength_;

0 commit comments

Comments
 (0)