Method PsiEncode

src/brpc/ts.cpp:860–886

}

int TsPayloadPAT::PsiEncode(void* data) const {
    char*  p = (char*)data;

    policy::WriteBigEndian2Bytes(&p, transport_stream_id);
    
    int8_t cniv = current_next_indicator & 0x01;
    cniv |= (version_number << 1) & 0x3E;
    cniv |= (const1_value << 6) & 0xC0;
    policy::Write1Byte(&p, cniv);
    
    policy::Write1Byte(&p, section_number);
    policy::Write1Byte(&p, last_section_number);

    for (size_t i = 0; i < programs.size(); ++i) {
        if (programs[i].Encode(p) != 0) {
            LOG(ERROR) << "Fail to encode TsPayloadPAT.programs[" << i << ']';
            return -1;
        }
        p += programs[i].ByteSize();
        // update the apply pid table.
        packet()->channel_group()->set(programs[i].pid);
    }

    // update the apply pid table.
    packet()->channel_group()->set(packet()->pid());
    return 0;
}

TsPayloadPMTESInfo::TsPayloadPMTESInfo(TsStream st, TsPid epid)
    : stream_type(st)