Searched refs:corrId (Results 1 – 4 of 4) sorted by relevance
448 if(hdr.corrId != this.id) { in receiveMessage()450 log.trace(new StringBuilder("id of request correlator header (").append(hdr.corrId). in receiveMessage()667 public short corrId; field in RequestCorrelator.Header687 this.corrId = corr_id; in Header()694 ret.append("id=" + corrId + ", type="); in toString()706 out.writeShort(corrId); in writeTo()713 corrId=in.readShort(); in readFrom()
717 Assert.assertEquals((short)356, hdr.corrId); in testRequestCorrelatorHeader()739 Assert.assertEquals(356, hdr.corrId); in testRequestCorrelatorHeader()
2122 u_int32_t corrId; in processMAUP() local2123 if (SIGAdaptation::getTag(msg,0x0013,corrId)) { in processMAUP()2126 SIGAdaptation::addTag(buf,0x0013,corrId); in processMAUP()
1701 TValue corrId = firstCorrectionForRead[readId]; in applyReadErrorCorrections() local1702 if (corrId == std::numeric_limits<TValue>::max()) in applyReadErrorCorrections()1709 appendValue(possibleCorrections, correctionList[corrId]); in applyReadErrorCorrections()1719 corrId = correction.nextCorrection; in applyReadErrorCorrections()1720 } while (corrId != std::numeric_limits<TValue>::max()); in applyReadErrorCorrections()