|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
#include <winpr/crt.h>
|
|
Packit |
1fb8d4 |
#include <winpr/stream.h>
|
|
Packit |
1fb8d4 |
#include <winpr/collections.h>
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
#define BUFFER_SIZE 16384
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
int TestStreamPool(int argc, char* argv[])
|
|
Packit |
1fb8d4 |
{
|
|
Packit |
1fb8d4 |
wStream* s[5];
|
|
Packit |
1fb8d4 |
wStreamPool* pool;
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
pool = StreamPool_New(TRUE, BUFFER_SIZE);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
s[0] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
s[1] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
s[2] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_Release(s[0]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[1]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[2]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
s[3] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
s[4] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_Release(s[3]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[4]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
s[2] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
s[3] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
s[4] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_AddRef(s[2]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_AddRef(s[3]);
|
|
Packit |
1fb8d4 |
Stream_AddRef(s[3]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_AddRef(s[4]);
|
|
Packit |
1fb8d4 |
Stream_AddRef(s[4]);
|
|
Packit |
1fb8d4 |
Stream_AddRef(s[4]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_Release(s[2]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[2]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_Release(s[3]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[3]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[3]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
Stream_Release(s[4]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[4]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[4]);
|
|
Packit |
1fb8d4 |
Stream_Release(s[4]);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
s[2] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
s[3] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
s[4] = StreamPool_Take(pool, 0);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
StreamPool_AddRef(pool, s[2]->buffer + 1024);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
StreamPool_AddRef(pool, s[3]->buffer + 1024);
|
|
Packit |
1fb8d4 |
StreamPool_AddRef(pool, s[3]->buffer + 1024 * 2);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
StreamPool_AddRef(pool, s[4]->buffer + 1024);
|
|
Packit |
1fb8d4 |
StreamPool_AddRef(pool, s[4]->buffer + 1024 * 2);
|
|
Packit |
1fb8d4 |
StreamPool_AddRef(pool, s[4]->buffer + 1024 * 3);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[2]->buffer + 2048);
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[2]->buffer + 2048 * 2);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[3]->buffer + 2048);
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[3]->buffer + 2048 * 2);
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[3]->buffer + 2048 * 3);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[4]->buffer + 2048);
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[4]->buffer + 2048 * 2);
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[4]->buffer + 2048 * 3);
|
|
Packit |
1fb8d4 |
StreamPool_Release(pool, s[4]->buffer + 2048 * 4);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
printf("StreamPool: aSize: %d uSize: %d\n", pool->aSize, pool->uSize);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
StreamPool_Free(pool);
|
|
Packit |
1fb8d4 |
|
|
Packit |
1fb8d4 |
return 0;
|
|
Packit |
1fb8d4 |
}
|
|
Packit |
1fb8d4 |
|