mirror of
https://github.com/Genymobile/scrcpy.git
synced 2025-04-23 04:55:04 +00:00
bb935764ae
If there is exactly one producer, then it can assume that the remaining space in the buffer will only increase until it write something. This assumption may allow the producer to write to the buffer (up to a known safe size) without any synchronization mechanism, thus allowing to read and write different parts of the buffer in parallel. The producer can then commit the write with lock held, and update its knowledge of the safe empty remaining space.
154 lines
4.5 KiB
C
154 lines
4.5 KiB
C
#include "common.h"
|
|
|
|
#include <assert.h>
|
|
#include <string.h>
|
|
|
|
#include "util/bytebuf.h"
|
|
|
|
void test_bytebuf_simple(void) {
|
|
struct sc_bytebuf buf;
|
|
uint8_t data[20];
|
|
|
|
bool ok = sc_bytebuf_init(&buf, 20);
|
|
assert(ok);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "hello", sizeof("hello") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 5);
|
|
|
|
sc_bytebuf_read(&buf, data, 4);
|
|
assert(!strncmp((char *) data, "hell", 4));
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) " world", sizeof(" world") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 7);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "!", 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 8);
|
|
|
|
sc_bytebuf_read(&buf, &data[4], 8);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 0);
|
|
|
|
data[12] = '\0';
|
|
assert(!strcmp((char *) data, "hello world!"));
|
|
assert(sc_bytebuf_read_remaining(&buf) == 0);
|
|
|
|
sc_bytebuf_destroy(&buf);
|
|
}
|
|
|
|
void test_bytebuf_boundaries(void) {
|
|
struct sc_bytebuf buf;
|
|
uint8_t data[20];
|
|
|
|
bool ok = sc_bytebuf_init(&buf, 20);
|
|
assert(ok);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "hello ", sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 6);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "hello ", sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 12);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "hello ", sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 18);
|
|
|
|
sc_bytebuf_read(&buf, data, 9);
|
|
assert(!strncmp((char *) data, "hello hel", 9));
|
|
assert(sc_bytebuf_read_remaining(&buf) == 9);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "world", sizeof("world") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 14);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "!", 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 15);
|
|
|
|
sc_bytebuf_skip(&buf, 3);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 12);
|
|
|
|
sc_bytebuf_read(&buf, data, 12);
|
|
data[12] = '\0';
|
|
assert(!strcmp((char *) data, "hello world!"));
|
|
assert(sc_bytebuf_read_remaining(&buf) == 0);
|
|
|
|
sc_bytebuf_destroy(&buf);
|
|
}
|
|
|
|
void test_bytebuf_overwrite(void) {
|
|
struct sc_bytebuf buf;
|
|
uint8_t data[10];
|
|
|
|
bool ok = sc_bytebuf_init(&buf, 10); // so actual capacity is 9
|
|
assert(ok);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "hello ", sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 6);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "abcdef", sizeof("abcdef") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 9);
|
|
|
|
sc_bytebuf_read(&buf, data, 9);
|
|
assert(!strncmp((char *) data, "lo abcdef", 9));
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "a very big buffer",
|
|
sizeof("a very big buffer") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 9);
|
|
|
|
sc_bytebuf_read(&buf, data, 9);
|
|
assert(!strncmp((char *) data, "ig buffer", 9));
|
|
assert(sc_bytebuf_read_remaining(&buf) == 0);
|
|
|
|
sc_bytebuf_destroy(&buf);
|
|
}
|
|
|
|
void test_bytebuf_two_steps_write(void) {
|
|
struct sc_bytebuf buf;
|
|
uint8_t data[20];
|
|
|
|
bool ok = sc_bytebuf_init(&buf, 20);
|
|
assert(ok);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "hello ", sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 6);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "hello ", sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 12);
|
|
|
|
sc_bytebuf_prepare_write(&buf, (uint8_t *) "hello ", sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 12); // write not committed yet
|
|
|
|
sc_bytebuf_read(&buf, data, 9);
|
|
assert(!strncmp((char *) data, "hello hel", 3));
|
|
assert(sc_bytebuf_read_remaining(&buf) == 3);
|
|
|
|
sc_bytebuf_commit_write(&buf, sizeof("hello ") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 9);
|
|
|
|
sc_bytebuf_prepare_write(&buf, (uint8_t *) "world", sizeof("world") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 9); // write not committed yet
|
|
|
|
sc_bytebuf_commit_write(&buf, sizeof("world") - 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 14);
|
|
|
|
sc_bytebuf_write(&buf, (uint8_t *) "!", 1);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 15);
|
|
|
|
sc_bytebuf_skip(&buf, 3);
|
|
assert(sc_bytebuf_read_remaining(&buf) == 12);
|
|
|
|
sc_bytebuf_read(&buf, data, 12);
|
|
data[12] = '\0';
|
|
assert(!strcmp((char *) data, "hello world!"));
|
|
assert(sc_bytebuf_read_remaining(&buf) == 0);
|
|
|
|
sc_bytebuf_destroy(&buf);
|
|
}
|
|
|
|
int main(int argc, char *argv[]) {
|
|
(void) argc;
|
|
(void) argv;
|
|
|
|
test_bytebuf_simple();
|
|
test_bytebuf_boundaries();
|
|
test_bytebuf_overwrite();
|
|
test_bytebuf_two_steps_write();
|
|
|
|
return 0;
|
|
}
|