Changeset 28384

Timestamp:

01/13/09 19:12:58 (4 years ago)

Author:

itkz

Message:

add AMF number serialize

Location:

lang/c/librtmp

Files:

• amf_packet.c (modified) (2 diffs)
• data_rw.c (modified) (2 diffs)
• data_rw.h (modified) (1 diff)
• main.c (modified) (1 diff)

lang/c/librtmp/amf_packet.c

@@ -440 +440 @@
     switch (amf->datatype) {
     case AMF_DATATYPE_NUMBER:
-        amf_packet_serialize_number(
+        return amf_packet_serialize_number(
             amf, output_buffer, output_buffer_size);
-        break;
     case AMF_DATATYPE_BOOLEAN:
         break;
@@ -466 +465 @@
     unsigned char *output_buffer, size_t output_buffer_size)
 {
-//    unsigned char number_data[8];
-
     if (output_buffer_size < 9) {
         return 0;
     }
 
+    output_buffer[0] = 0x00;
+    write_be64double(output_buffer + 1, amf->number.value);
+
     return 9;
 }

lang/c/librtmp/data_rw.c

@@ -80 +80 @@
 }
 
+
 double read_be64double(unsigned char *data)
 {
@@ -101 +102 @@
     return value;
 }
+
+
+void write_be64double(unsigned char *data, double value)
+{
+    unsigned char number_data[8];
+
+    if (is_little_endian()) {
+        memmove(number_data, &value, 8);
+        data[0] = number_data[7];
+        data[1] = number_data[6];
+        data[2] = number_data[5];
+        data[3] = number_data[4];
+        data[4] = number_data[3];
+        data[5] = number_data[2];
+        data[6] = number_data[1];
+        data[7] = number_data[0];
+    } else {
+        memmove(data, &value, 8);
+    }
+}

lang/c/librtmp/data_rw.h

@@ -9 +9 @@
 extern double read_be64double(unsigned char *data);
 
+extern void write_be64double(unsigned char *data, double value);
+

lang/c/librtmp/main.c

@@ -27 +27 @@
     amf = amf_packet_analyze_data(number_temp, sizeof(number_temp), NULL);
     outputed_size = amf_packet_serialize(
-        amf, output_buffer, sizeof(output_buffer));
+        amf, output_buffer, 1024);
     for (i = 0; i < outputed_size; ++i) {
         printf("%02x, ", output_buffer[i]);
     }
-    printf("\n");
+    printf("\n%d\n", outputed_size);
     amf_packet_free(amf);
     // boolean