/*
|
* 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 */
|
