/* Copyright 2015 The ChromiumOS Authors
 * Use of this source code is governed by a BSD-style license that can be
 * found in the LICENSE file.
 *
 * Queue policies.
 */
#ifndef __CROS_EC_QUEUE_POLICIES_H
#define __CROS_EC_QUEUE_POLICIES_H

#include "queue.h"
#include "consumer.h"
#include "producer.h"

/*
 * The direct notification policy manages a 1-to-1 producer consumer model.
 * When new units are added to the queue the consumer is notified directly, in
 * whatever context (interrupt, deferred, task...) that the queue addition
 * happened.  Similarly, queue removals directly notify the producer.
 */
struct queue_policy_direct {
	struct queue_policy policy;

	struct producer const *producer;
	struct consumer const *consumer;
};

void queue_add_direct(struct queue_policy const *policy, size_t count);
void queue_remove_direct(struct queue_policy const *policy, size_t count);

#define QUEUE_POLICY_DIRECT(PRODUCER, CONSUMER)			\
	((struct queue_policy_direct const) {			\
		.policy = {					\
			.add    = queue_add_direct,		\
			.remove = queue_remove_direct,		\
		},						\
		.producer = &PRODUCER,				\
		.consumer = &CONSUMER,				\
	})

#define QUEUE_DIRECT(SIZE, TYPE, PRODUCER, CONSUMER)			\
	QUEUE(SIZE, TYPE, QUEUE_POLICY_DIRECT(PRODUCER, CONSUMER).policy)

/*
 * The null_producer and null_consumer are useful when constructing a queue
 * where one end needs notification, but the other end doesn't care.  These
 * producer and consumer structs just ignore all notifications.
 */
extern struct producer const null_producer;
extern struct consumer const null_consumer;

#endif /* __CROS_EC_QUEUE_POLICIES_H */