1 /* Prototype stuff for parsing Level-II data */
3 * TODO: ARGG, the packet sizses are all wrong..
4 * Check sizes of decompressed bzip files
5 * Split things back up to seperate files
6 * The second bzip contains different size packets?
17 /* Not used in favor of RSL */
18 level2_packet_t **level2_split_packets(char *data, int *num_packets, int data_size)
21 level2_packet_t *packet = (level2_packet_t *)data;
22 int max_packets = 128;
23 level2_packet_t **packets = malloc(sizeof(level2_packet_t *)*max_packets);
24 while ((void *)packet < (void *)(data+data_size)) {
25 /* Increase packets size if necessasairy */
26 if (packet_i >= max_packets) {
28 packets = realloc(packets, sizeof(level2_packet_t *)*max_packets);
31 /* Fix byte order for packet */
32 packet->size = g_ntohs(packet->size);
33 packet->seq = g_ntohs(packet->seq);
34 // TODO: Convert the rest of the bytes
36 /* Save packet location */
37 packets[packet_i] = packet;
39 /* Increment packet and packet_i */
40 // new = old + CTM + 2*size + fcs
41 //packet = (level2_packet_t *)( ((char *)packet) + 12 + 2*packet->size + 4 );
45 packets = realloc(packets, sizeof(level2_packet_t *)*packet_i);
46 *num_packets = packet_i;
50 /* Not used in favor of RSL */
51 level2_packet_t *level2_decompress(char *raw_data, int *num_packets)
54 FILE *fd = fopen(raw_data, "r");
56 error(1, errno, "Error opening files `%s'", raw_data);
57 level2_header_t header;
58 if (1 != fread(&header, sizeof(level2_header_t), 1, fd))
59 error(1, errno, "Error reading header");
61 /* Decompress the bzips
62 * store the entire sequence starting at data
63 * cur_data is for each individual bzip and is the last chunk of data */
65 int data_size = 0; // size of previously decmpressed data
66 char *bz2 = NULL; // temp buf for bzipped data
67 unsigned int _bz2_size = 0;
68 while ((int)_bz2_size >= 0) {
69 if (1 != fread(&_bz2_size, 4, 1, fd))
70 break; //error(1, errno, "Error reading _bz2_size, pos=%x", (unsigned int)ftell(fd));
71 _bz2_size = g_ntohl(_bz2_size);
72 int bz2_size = abs(_bz2_size);
75 if (NULL == (bz2 = (char *)realloc(bz2, bz2_size)))
76 error(1, errno, "cannot allocate `%d' bytes for buffer", bz2_size);
77 if (bz2_size != fread(bz2, 1, bz2_size, fd))
78 error(1, errno, "error reading from input file");
80 /* Decompress on individual bzip to the end of the sequence */
81 unsigned int cur_data_size = 1<<17;
82 int status = BZ_OUTBUFF_FULL;
83 while (status == BZ_OUTBUFF_FULL) {
85 data = realloc(data, data_size + cur_data_size);
86 status = BZ2_bzBuffToBuffDecompress(data + data_size, &cur_data_size, bz2, bz2_size, 0, 0);
89 error(1, 1, "Error decompressing data");
90 data_size += cur_data_size; // Add current chunk to decompressed data
93 printf("data_size = %d, cur_data_size = %d\n", data_size, cur_data_size);
95 data = realloc(data, data_size); // free unused space at the end
97 return (level2_packet_t *)data;
98 //return level2_split_packets(data, num_packets, data_size);
103 int main(int argc, char **argv)
106 printf("usage: %s <level2-data>\n", argv[0]);
111 level2_packet_t *packets = level2_decompress(argv[1], &num_packets);
112 printf("read %d packets\n", num_packets);
114 //FILE *output = fopen("output.dat", "w+");
115 //fwrite(packets[i], 1, 18470816, output);
118 FILE *output = fopen("output.dat", "w+");
120 for (i = 0; i < 10000; i++) {
121 printf("packet: size=%x, seq=%d\n", g_ntohs(packets[i].size), g_ntohs(packets[i].seq));
122 fwrite("################", 1, 16, output);
123 fwrite(packets+i, 1, sizeof(level2_packet_t), output);