medfall

#include "libs/relacy/relacy/pch.hpp"
#include "libs/relacy/relacy/relacy_std.hpp"
#include "intrinsics.h"
#include "nonblocking_fixed_spsc_queue.h"

#define QUEUE_SIZE 67
#define ITERS 256

struct NonblockingFixedSPSCQueueTest : rl::test_suite< NonblockingFixedSPSCQueueTest, 2 > {
	NonblockingFixedSPSCQueue< int, QUEUE_SIZE > q;

	void thread( unsigned int thread_index ) {
		if( thread_index == 0 ) {
			for( int i = 0; i < ITERS; i++ ) {
				int x;
				while( !q.dequeue( &x ) ) continue;
				RL_ASSERT( x == i );
			}
		}
		else {
			for( int i = 0; i < ITERS; i++ ) {
				while( !q.enqueue( i ) ) continue;
			}
		}
	}
};

struct NonblockingFixedSPSCQueueTestNoCopy : rl::test_suite< NonblockingFixedSPSCQueueTestNoCopy, 2 > {
	NonblockingFixedSPSCQueue< int, QUEUE_SIZE > q;

	void thread( unsigned int thread_index ) {
		if( thread_index == 0 ) {
			for( int i = 0; i < ITERS; i++ ) {
				for( ;; ) {
					int * x = q.dequeue_acquire();
					if( x == NULL ) continue;
					RL_ASSERT( *x == i );
					q.dequeue_release();
					break;
				}
			}
		}
		else {
			for( int i = 0; i < ITERS; i++ ) {
				while( !q.enqueue( i ) ) continue;
			}
		}
	}
};

int main() {
	rl::simulate< NonblockingFixedSPSCQueueTest >();
	rl::simulate< NonblockingFixedSPSCQueueTestNoCopy >();

	return 0;
}