test_some_packets.c revision a74702c6
1a74702c6SGeorge Wang/* Copyright (c) 2017 - 2022 LiteSpeed Technologies Inc. See LICENSE. */ 250aadb33SDmitri Tikhonov/* Tests in this file have been migrated out of maintest.c */ 350aadb33SDmitri Tikhonov/* TODO: fix warnings */ 450aadb33SDmitri Tikhonov 550aadb33SDmitri Tikhonov#include <assert.h> 650aadb33SDmitri Tikhonov#include <stdlib.h> 750aadb33SDmitri Tikhonov#include <string.h> 850aadb33SDmitri Tikhonov#include <stdio.h> 950aadb33SDmitri Tikhonov#include <sys/queue.h> 1050aadb33SDmitri Tikhonov 1150aadb33SDmitri Tikhonov#include "lsquic.h" 1250aadb33SDmitri Tikhonov#include "lsquic_types.h" 1350aadb33SDmitri Tikhonov#include "lsquic_parse.h" 1450aadb33SDmitri Tikhonov#include "lsquic_sfcw.h" 155392f7a3SLiteSpeed Tech#include "lsquic_varint.h" 165392f7a3SLiteSpeed Tech#include "lsquic_hq.h" 175392f7a3SLiteSpeed Tech#include "lsquic_hash.h" 1850aadb33SDmitri Tikhonov#include "lsquic_stream.h" 19bfc7bfd8SDmitri Tikhonov#include "lsquic_packet_common.h" 2050aadb33SDmitri Tikhonov#include "lsquic_packet_in.h" 2150aadb33SDmitri Tikhonov 2250aadb33SDmitri Tikhonovstruct lsquic_stream_if; 2350aadb33SDmitri Tikhonov 24052a1c28SDmitri Tikhonovstatic const struct parse_funcs *const pf = select_pf_by_ver(LSQVER_035); 2550aadb33SDmitri Tikhonov 2650aadb33SDmitri Tikhonovlsquic_stream_t * 2750aadb33SDmitri Tikhonovlsquic_stream_new_ext (uint32_t id, 2850aadb33SDmitri Tikhonov struct lsquic_conn_public *conn_pub, 2950aadb33SDmitri Tikhonov const struct lsquic_stream_if *stream_if, 3050aadb33SDmitri Tikhonov void *stream_if_ctx, unsigned initial_sfcw, 3150aadb33SDmitri Tikhonov unsigned initial_send_off, enum stream_ctor_flags ctor_flags) 3250aadb33SDmitri Tikhonov{ 3350aadb33SDmitri Tikhonov lsquic_stream_t *stream = calloc(1, sizeof(*stream)); 3450aadb33SDmitri Tikhonov stream->id = id; 3550aadb33SDmitri Tikhonov return stream; 3650aadb33SDmitri Tikhonov} 3750aadb33SDmitri Tikhonov 3850aadb33SDmitri Tikhonovuint64_t 3950aadb33SDmitri Tikhonovlsquic_stream_tosend_offset (const lsquic_stream_t *stream) 4050aadb33SDmitri Tikhonov{ 4150aadb33SDmitri Tikhonov return 1000; 4250aadb33SDmitri Tikhonov} 4350aadb33SDmitri Tikhonov 4450aadb33SDmitri Tikhonovint 4550aadb33SDmitri Tikhonovlsquic_stream_tosend_fin (const lsquic_stream_t *stream) 4650aadb33SDmitri Tikhonov{ 4750aadb33SDmitri Tikhonov return 0; 4850aadb33SDmitri Tikhonov} 4950aadb33SDmitri Tikhonov 5050aadb33SDmitri Tikhonovsize_t 5150aadb33SDmitri Tikhonovlsquic_stream_tosend_read (lsquic_stream_t *stream, void *buf, size_t len, 5250aadb33SDmitri Tikhonov int *reached_fin) 5350aadb33SDmitri Tikhonov{ 5450aadb33SDmitri Tikhonov memcpy(buf, "123456789012345678901234567890", 30); 5550aadb33SDmitri Tikhonov *reached_fin = lsquic_stream_tosend_fin(stream); 5650aadb33SDmitri Tikhonov return 30; 5750aadb33SDmitri Tikhonov} 5850aadb33SDmitri Tikhonov 5950aadb33SDmitri Tikhonovsize_t 6050aadb33SDmitri Tikhonovlsquic_stream_tosend_sz (const lsquic_stream_t *stream) 6150aadb33SDmitri Tikhonov{ 6250aadb33SDmitri Tikhonov return 30; 6350aadb33SDmitri Tikhonov} 6450aadb33SDmitri Tikhonov 6550aadb33SDmitri Tikhonovstatic int make_complex_packet(unsigned char *pkt_buf, int max_buf_len) 6650aadb33SDmitri Tikhonov{ 679626cfc2SDmitri Tikhonov#if 0 /* What is this function testing? Seems useless. */ 6850aadb33SDmitri Tikhonov unsigned char *p = pkt_buf; 6950aadb33SDmitri Tikhonov unsigned char *const pend = p + 1500; 7050aadb33SDmitri Tikhonov lsquic_stream_t *stream = lsquic_stream_new(12345, NULL, NULL, NULL, 0, 0); 7150aadb33SDmitri Tikhonov uint32_t stream_id = 13989; 7250aadb33SDmitri Tikhonov uint64_t offset = 10000; 7350aadb33SDmitri Tikhonov uint64_t conn_id = 123579; 7450aadb33SDmitri Tikhonov const char nonce[] = "1234567890ABCDEF1234567890abcdef"; /*32 bytes*/ 7550aadb33SDmitri Tikhonov uint64_t packet_num = 1356789; 7650aadb33SDmitri Tikhonov 7750aadb33SDmitri Tikhonov int buf_len = pf->pf_gen_reg_pkt_header(p, 100, &conn_id, NULL, (const unsigned char *) nonce, packet_num, 7850aadb33SDmitri Tikhonov calc_packno_bits(packet_num, 0, 0)); 7950aadb33SDmitri Tikhonov assert(buf_len > 0); 8050aadb33SDmitri Tikhonov p += buf_len; 8150aadb33SDmitri Tikhonov 8250aadb33SDmitri Tikhonov buf_len = pf->pf_gen_stream_frame(p, pend - p, 8350aadb33SDmitri Tikhonov stream->id, lsquic_stream_tosend_offset(stream), 84bfc7bfd8SDmitri Tikhonov lsquic_stream_tosend_fin(stream), 85bfc7bfd8SDmitri Tikhonov lsquic_stream_tosend_sz(stream), 8650aadb33SDmitri Tikhonov (gsf_read_f) lsquic_stream_tosend_read, 8750aadb33SDmitri Tikhonov stream); 8850aadb33SDmitri Tikhonov p += buf_len; 8950aadb33SDmitri Tikhonov 9050aadb33SDmitri Tikhonov buf_len = pf->pf_gen_window_update_frame(p, pend - p, stream_id, offset); 9150aadb33SDmitri Tikhonov p += buf_len; 9250aadb33SDmitri Tikhonov 9350aadb33SDmitri Tikhonov free(stream); 9450aadb33SDmitri Tikhonov 9550aadb33SDmitri Tikhonov return p - pkt_buf; 969626cfc2SDmitri Tikhonov#endif 979626cfc2SDmitri Tikhonov return 0; 9850aadb33SDmitri Tikhonov} 9950aadb33SDmitri Tikhonov 10050aadb33SDmitri Tikhonov 10150aadb33SDmitri Tikhonovvoid test_stream_frame() 10250aadb33SDmitri Tikhonov{ 10350aadb33SDmitri Tikhonov const uint8_t data[] = "123456789012345678901234567890"; 10450aadb33SDmitri Tikhonov lsquic_stream_t *stream = lsquic_stream_new(12345, NULL, NULL, NULL, 0, 0); 10550aadb33SDmitri Tikhonov uint8_t buf[1500]; 10650aadb33SDmitri Tikhonov int buf_len = pf->pf_gen_stream_frame(buf, 1500, 10750aadb33SDmitri Tikhonov stream->id, lsquic_stream_tosend_offset(stream), 108bfc7bfd8SDmitri Tikhonov lsquic_stream_tosend_fin(stream), 109bfc7bfd8SDmitri Tikhonov lsquic_stream_tosend_sz(stream), 11050aadb33SDmitri Tikhonov (gsf_read_f) lsquic_stream_tosend_read, 11150aadb33SDmitri Tikhonov stream); 11250aadb33SDmitri Tikhonov stream_frame_t stream_frame2; 11350aadb33SDmitri Tikhonov pf->pf_parse_stream_frame(buf, buf_len, &stream_frame2); 11450aadb33SDmitri Tikhonov assert(0 == stream_frame2.data_frame.df_fin ); 11550aadb33SDmitri Tikhonov assert(30 == stream_frame2.data_frame.df_size ); 11650aadb33SDmitri Tikhonov assert(1000 == stream_frame2.data_frame.df_offset ); 11750aadb33SDmitri Tikhonov assert(12345 == stream_frame2.stream_id); 11850aadb33SDmitri Tikhonov assert(memcmp(data,stream_frame2.data_frame.df_data, stream_frame2.data_frame.df_size) == 0); 11950aadb33SDmitri Tikhonov printf("test_stream_frame passed.\n"); 12050aadb33SDmitri Tikhonov free(stream); 12150aadb33SDmitri Tikhonov} 12250aadb33SDmitri Tikhonov 12350aadb33SDmitri Tikhonov 12450aadb33SDmitri Tikhonovint 12550aadb33SDmitri Tikhonovmain (void) 12650aadb33SDmitri Tikhonov{ 12750aadb33SDmitri Tikhonov uint8_t pkt_buf[1500]; 12850aadb33SDmitri Tikhonov size_t buf_len; 12950aadb33SDmitri Tikhonov buf_len = make_complex_packet(pkt_buf, 1500); 13050aadb33SDmitri Tikhonov (void) buf_len; 13150aadb33SDmitri Tikhonov test_stream_frame(); 13250aadb33SDmitri Tikhonov return 0; 13350aadb33SDmitri Tikhonov} 134