Function WriteAMFField

src/brpc/amf.cpp:1059–1112

}

static void WriteAMFField(const AMFField& field, AMFOutputStream* stream) {
    switch (field.type()) {
    case AMF_MARKER_NUMBER: {
        stream->put_u8(AMF_MARKER_NUMBER);
        const double val = field.AsNumber();
        uint64_t* uptr = (uint64_t*)&val;
        stream->put_u64(*uptr);
    } break;
    case AMF_MARKER_BOOLEAN:
        stream->put_u8(AMF_MARKER_BOOLEAN);
        stream->put_u8(field.AsBool());
        break;
    case AMF_MARKER_STRING: {
        stream->put_u8(AMF_MARKER_STRING);
        const butil::StringPiece str = field.AsString();
        stream->put_u16(str.size());
        stream->putn(str.data(), str.size());
    } break;
    case AMF_MARKER_LONG_STRING: {
        stream->put_u8(AMF_MARKER_LONG_STRING);
        const butil::StringPiece str = field.AsString();
        stream->put_u32(str.size());
        stream->putn(str.data(), str.size());
    } break;
    case AMF_MARKER_OBJECT:
    case AMF_MARKER_ECMA_ARRAY:
        WriteAMFObject(field.AsObject(), stream);
        break;
    case AMF_MARKER_STRICT_ARRAY:
        WriteAMFArray(field.AsArray(), stream);
        break;
    case AMF_MARKER_NULL:
        stream->put_u8(AMF_MARKER_NULL);
        break;
    case AMF_MARKER_UNDEFINED:
        stream->put_u8(AMF_MARKER_UNDEFINED);
        break;
    case AMF_MARKER_UNSUPPORTED:
        stream->put_u8(AMF_MARKER_UNSUPPORTED);
        break;
    case AMF_MARKER_MOVIECLIP:
    case AMF_MARKER_REFERENCE:        
    case AMF_MARKER_DATE:
    case AMF_MARKER_RECORDSET:
    case AMF_MARKER_XML_DOCUMENT:
    case AMF_MARKER_TYPED_OBJECT:
    case AMF_MARKER_AVMPLUS_OBJECT:
        LOG(ERROR) << marker2str(field.type()) << " is not supported yet";
        break;
    case AMF_MARKER_OBJECT_END:
        CHECK(false) << "object-end shouldn't be present here";
        break;
    } // switch
}

void WriteAMFObject(const AMFObject& obj, AMFOutputStream* stream) {
    stream->put_u8(AMF_MARKER_OBJECT);