/*
 * Copyright (C) 2014 Philippe Gerum <rpm@xenomai.org>.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.

 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA.
 */
#ifndef _COPPERPLATE_REGISTRY_OBSTACK_H
#define _COPPERPLATE_REGISTRY_OBSTACK_H

#include <copperplate/registry.h>

#ifdef CONFIG_XENO_REGISTRY

#include <stdlib.h>
#include <boilerplate/obstack.h>
#include <copperplate/heapobj.h>

struct threadobj;
struct syncobj;

/*
 * Obstacks are grown from handlers called by the fusefs server
 * thread, which has no real-time requirement: malloc/free is fine for
 * memory management.
 */
#define obstack_chunk_alloc	malloc
#define obstack_chunk_free	free

struct threadobj;

struct fsobstack {
	struct obstack obstack;
	void *data;
	size_t len;
};

struct fsobstack_syncops {
	int (*prepare_cache)(struct fsobstack *o,
			     struct obstack *cache, int item_count);
	size_t (*collect_data)(void *p, struct threadobj *thobj);
	size_t (*format_data)(struct fsobstack *o, void *p);
};

struct syncobj;

#ifdef __cplusplus
extern "C" {
#endif

void fsobstack_grow_string(struct fsobstack *o,
			   const char *s);

void fsobstack_grow_char(struct fsobstack *o,
			 char c);

int fsobstack_grow_format(struct fsobstack *o,
			  const char *fmt, ...);

int fsobstack_grow_file(struct fsobstack *o,
			const char *path);

int fsobstack_grow_syncobj_grant(struct fsobstack *o,
				 struct syncobj *sobj,
				 struct fsobstack_syncops *ops);

int fsobstack_grow_syncobj_drain(struct fsobstack *o,
				 struct syncobj *sobj,
				 struct fsobstack_syncops *ops);

ssize_t fsobstack_pull(struct fsobstack *o,
		       char *buf, size_t size);

ssize_t fsobj_obstack_read(struct fsobj *fsobj,
			   char *buf, size_t size, off_t offset,
			   void *priv);

int fsobj_obstack_release(struct fsobj *fsobj, void *priv);

#ifdef __cplusplus
}
#endif

static inline void fsobstack_init(struct fsobstack *o)
{
	obstack_init(&o->obstack);
	o->data = NULL;
	o->len = 0;
}

static inline void fsobstack_destroy(struct fsobstack *o)
{
	obstack_free(&o->obstack, NULL);
}

static inline void fsobstack_finish(struct fsobstack *o)
{
	o->len = obstack_object_size(&o->obstack);
	o->data = obstack_finish(&o->obstack);
}

static inline
void registry_init_file_obstack(struct fsobj *fsobj, 
				const struct registry_operations *ops)
{
	registry_init_file(fsobj, ops, sizeof(struct fsobstack));
}

#else /* !CONFIG_XENO_REGISTRY */

static inline
void registry_init_file_obstack(struct fsobj *fsobj, 
				const struct registry_operations *ops)
{ }

#endif /* !CONFIG_XENO_REGISTRY */

#endif /* !_COPPERPLATE_REGISTRY_OBSTACK_H */