/*
 * Copyright (C) 2010 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_CLUSTER_H
#define _COPPERPLATE_CLUSTER_H

#include <boilerplate/hash.h>
#include <copperplate/syncobj.h>

#ifdef CONFIG_XENO_PSHARED

struct clusterobj {
	pid_t cnode;
	struct hashobj hobj;
};

struct dictionary {
	struct hash_table table;
	struct hashobj hobj;
};

struct cluster {
	struct dictionary *d;
};

struct syndictionary {
	struct hash_table table;
	struct syncobj sobj;
	struct hashobj hobj;
};

struct syncluster {
	struct syndictionary *d;
};

struct pvclusterobj {
	struct pvhashobj hobj;
};

struct pvcluster {
	struct pvhash_table table;
};

struct pvsyncluster {
	struct pvcluster c;
	struct syncobj sobj;
};

static inline
const void *clusterobj_key(const struct clusterobj *cobj)
{
	return __memptr(__main_heap, cobj->hobj.key);
}

static inline
size_t clusterobj_keylen(const struct clusterobj *cobj)
{
	return cobj->hobj.len;
}

static inline
pid_t clusterobj_cnode(const struct clusterobj *cobj)
{
	return cobj->cnode;
}

static inline
const void *pvclusterobj_key(const struct pvclusterobj *cobj)
{
	return cobj->hobj.key;
}

static inline
size_t pvclusterobj_keylen(const struct pvclusterobj *cobj)
{
	return cobj->hobj.len;
}

static inline
pid_t pvclusterobj_cnode(const struct pvclusterobj *cobj)
{
	return -1;
}

#else /* !CONFIG_XENO_PSHARED */

struct clusterobj {
	struct pvhashobj hobj;
};

struct cluster {
	struct pvhash_table table;
};

struct syncluster {
	struct cluster c;
	struct syncobj sobj;
};

#define pvclusterobj  clusterobj
#define pvcluster     cluster
#define pvsyncluster  syncluster

static inline
const void *clusterobj_key(const struct pvclusterobj *cobj)
{
	return cobj->hobj.key;
}

static inline
size_t clusterobj_keylen(const struct pvclusterobj *cobj)
{
	return cobj->hobj.len;
}

static inline
pid_t clusterobj_cnode(const struct pvclusterobj *cobj)
{
	return -1;
}

static inline
const void *pvclusterobj_key(const struct pvclusterobj *cobj)
{
	return clusterobj_key(cobj);
}

static inline
size_t pvclusterobj_keylen(const struct pvclusterobj *cobj)
{
	return clusterobj_keylen(cobj);
}

static inline
pid_t pvclusterobj_cnode(const struct pvclusterobj *cobj)
{
	return clusterobj_cnode(cobj);
}

#endif /* !CONFIG_XENO_PSHARED */

struct syncluster_wait_struct {
	union {
		dref_type(char *) name_ref;
		const char *name;
	};
};

#ifdef __cplusplus
extern "C" {
#endif

int pvcluster_init(struct pvcluster *c, const char *name);

void pvcluster_destroy(struct pvcluster *c);

int pvcluster_addobj(struct pvcluster *c, const char *name,
		     struct pvclusterobj *cobj);

int pvcluster_addobj_dup(struct pvcluster *c, const char *name,
			 struct pvclusterobj *cobj);

int pvcluster_delobj(struct pvcluster *c,
		     struct pvclusterobj *cobj);

struct pvclusterobj *pvcluster_findobj(struct pvcluster *c,
				       const char *name);

int pvcluster_walk(struct pvcluster *c,
		   int (*walk)(struct pvcluster *c,
			       struct pvclusterobj *cobj));
  
int pvsyncluster_init(struct pvsyncluster *sc, const char *name);

void pvsyncluster_destroy(struct pvsyncluster *sc);

int pvsyncluster_addobj(struct pvsyncluster *sc, const char *name,
			struct pvclusterobj *cobj);

int pvsyncluster_delobj(struct pvsyncluster *sc,
			struct pvclusterobj *cobj);

int pvsyncluster_findobj(struct pvsyncluster *sc,
			 const char *name,
			 const struct timespec *timeout,
			 struct pvclusterobj **cobjp) __must_check;

#ifdef CONFIG_XENO_PSHARED

int cluster_init(struct cluster *c, const char *name);

int cluster_addobj(struct cluster *c, const char *name,
		   struct clusterobj *cobj);

int cluster_addobj_dup(struct cluster *c, const char *name,
		       struct clusterobj *cobj);

int cluster_delobj(struct cluster *c,
		   struct clusterobj *cobj);

struct clusterobj *cluster_findobj(struct cluster *c,
				   const char *name);

int cluster_walk(struct cluster *c,
		 int (*walk)(struct cluster *c,
			     struct clusterobj *cobj));

int syncluster_init(struct syncluster *sc, const char *name);

int syncluster_addobj(struct syncluster *sc, const char *name,
		      struct clusterobj *cobj);

int syncluster_delobj(struct syncluster *sc,
		      struct clusterobj *cobj);

int syncluster_findobj(struct syncluster *sc,
		       const char *name,
		       const struct timespec *timeout,
		       struct clusterobj **cobjp) __must_check;

#else /* !CONFIG_XENO_PSHARED */

static inline int cluster_init(struct cluster *c, const char *name)
{
	return pvcluster_init(c, name);
}

static inline int cluster_addobj(struct cluster *c, const char *name,
				 struct clusterobj *cobj)
{
	return pvcluster_addobj(c, name, cobj);
}

static inline int cluster_addobj_dup(struct cluster *c, const char *name,
				     struct clusterobj *cobj)
{
	return pvcluster_addobj_dup(c, name, cobj);
}

static inline int cluster_delobj(struct cluster *c,
				 struct clusterobj *cobj)
{
	return pvcluster_delobj(c, cobj);
}

static inline struct clusterobj *cluster_findobj(struct cluster *c,
						 const char *name)
{
	return pvcluster_findobj(c, name);
}

static inline int cluster_walk(struct cluster *c,
			       int (*walk)(struct cluster *c,
					   struct clusterobj *cobj))
{
	return pvcluster_walk(c, walk);
}

static inline int syncluster_init(struct syncluster *sc,
				  const char *name)
{
	return pvsyncluster_init(sc, name);
}

static inline int syncluster_addobj(struct syncluster *sc,
				    const char *name,
				    struct clusterobj *cobj)
{
	return pvsyncluster_addobj(sc, name, cobj);
}

static inline int syncluster_delobj(struct syncluster *sc,
				    struct clusterobj *cobj)
{
	return pvsyncluster_delobj(sc, cobj);
}

static inline  __must_check
int syncluster_findobj(struct syncluster *sc,
		       const char *name,
		       const struct timespec *timeout,
		       struct clusterobj **cobjp)
{
	return pvsyncluster_findobj(sc, name, timeout, cobjp);
}

#endif /* !CONFIG_XENO_PSHARED */

#ifdef __cplusplus
}
#endif

#endif /* _COPPERPLATE_CLUSTER_H */