Method Encode

src/brpc/ts.cpp:308–345

}

int TsPacket::Encode(void* data) const {
    char* p = (char*)data;

    policy::Write1Byte(&p, TS_SYNC_BYTE);

    int16_t pidv = _pid & 0x1FFF;
    pidv |= (_transport_priority << 13) & 0x2000;
    pidv |= (_transport_error_indicator << 15) & 0x8000;
    pidv |= (_payload_unit_start_indicator << 14) & 0x4000;
    policy::WriteBigEndian2Bytes(&p, pidv);

    int8_t ccv = _continuity_counter & 0x0F;
    ccv |= (_transport_scrambling_control << 6) & 0xC0;
    TsAdaptationFieldType af_control = _adaptation_field_control;
    if (af_control == TS_AF_RESERVED) {
        // In the case of a null packet, af_control shall be set to '01'.
        af_control = TS_AF_PAYLOAD_ONLY;
    }
    ccv |= (af_control << 4) & 0x30;
    policy::Write1Byte(&p, ccv);
    
    if (_adaptation_field) {
        if (_adaptation_field->Encode(p, af_control) != 0) {
            LOG(ERROR) << "Fail to encode _adaptation_field";
            return -1;
        }
        p += _adaptation_field->ByteSize();
    }
    
    if (_payload) {
        if (_payload->Encode(p) != 0) {
            LOG(ERROR) << "Fail to encode _payload";
            return -1;
        }
        p += _payload->ByteSize();
    }
    return 0;
}

void TsPacket::AddPadding(size_t num_stuffings) {
    const bool no_af_before = (_adaptation_field == NULL);