Commit 56fe53e8 authored by gerd's avatar gerd

better names


git-svn-id: https://gps.dynxs.de/private/svn/app-plasma/[email protected] 55289a75-7b90-4627-9e07-ffb4263930b2
parent 63f46af8
/* $Id$ -*- c -*- */
#define SERVER_CONTEXT
#include "types.x"
#include "datanode.x"
#include "dn_internal.x"
#include "namenode.x"
#include "nn_internal.x"
/* $Id$ -*- c -*- */
#include "types.x"
#include "datanode.x"
#include "namenode.x"
/* $Id$ -*- c -*- */
#include "pfs_types.x"
#include "pfs_datanode.x"
#include "pfs_nn_fsys.x"
#include "pfs_nn_coord.x"
#include "pfs_nn_dnadmin.x"
#include "pfs_nn_inodecache.x"
/* $Id$ -*- c -*- */
#include "types.x"
#include "pfs_types.x"
#ifndef DATANODE_X
#define DATANODE_X
#ifndef PFS_DATANODE_X
#define PFS_DATANODE_X
program Datanode {
version V1 {
......
/* $Id$ */
#ifndef DN_INTERNAL_X
#define DN_INTERNAL_X
#ifndef PFS_DN_INTERNAL_X
#define PFS_DN_INTERNAL_X
#include "types.x"
#include "pfs_types.x"
/* The Datanode_ctrl program is only invoked by the namenode */
program Datanode_ctrl {
......
......@@ -4,8 +4,8 @@
editing it for brevity and for better output of ocamlrpcgen
*/
#ifndef NFS3_X
#define NFS3_X
#ifndef PFS_NFS3_X
#define PFS_NFS3_X
/* -- Types for NFS protocol -- */
......
/* $Id$ -*- -c -*- */
#include "pfs_types.x"
#ifndef PFS_NN_COORD
#define PFS_NN_COORD
program Coordination {
version V1 {
void null(void) = 0;
longstring_opt find_coordinator(longstring) = 1;
/* Returns the current coordinator as host:port string. The Filesystem
requests must be sent to the coordinator.
The arg is the clustername. If this node is not part of this
cluster the RPC will return NULL.
*/
longstrings find_namenodes(longstring) = 2;
/* Return all name nodes, including the coordinator and the slaves.
The arg is the clustername. If this node is not part of this
cluster the RPC will return an empty array.
*/
bool is_coordinator(longstring) = 3;
/* Whether this node is the coordinator
The arg is the clustername. If this node is not part of this
cluster the RPC will return false.
*/
longstring clustername(void) = 4;
/* Returns the clustername */
longstrings find_inodecaches(longstring) = 5;
/* Return all inodecaches for this clustername */
longstrings local_identities(longstring) = 6;
/* Returns the identities of the data nodes running on the machine
of the caller. Only available data nodes are returned.
The arg is the clustername.
*/
} = 1;
} = 0x8000e002;
#endif
/* $Id$ -*- c -*- */
#include "pfs_types.x"
#ifndef PFS_NN_DNADMIN
#define PFS_NN_DNADMIN
program Dn_admin {
version V1 {
void null(void) = 0;
void add_datanode(longstring, hyper) = 1;
/* add_datanode(identity, size):
adds a new datanode. It is in disabled state initially
*/
void enable_datanode(longstring, longstring) = 2;
/* enable_datanode(identity, hostport): Enables the data node for
identity on hostport.
// FIXME: "At enable time, the datanode is checked whether it was enlarged." - probably another RPC
*/
void disable_datanode(longstring) = 3;
/* disable_datanode(identity):
This means blocks
are not allocated on the node, and if [all=false] blocks from
this node are suppressed by get_blocks. This datanode state is
considered temporary (e.g. while moving a disk from one node to
another).
The coordinator pings the datanodes anyway, and finds quickly
out whether nodes are down. This RPC is more useful for
administratively taking nodes down, e.g. for maintenance.
*/
bool is_enabled(longstring) = 4;
/* whether this identity is enabled */
longstring lookup(longstring) = 5;
/* looks the identity up and returns hostport. Only for enabled
nodes that could be at least contacted once. The node may be
unresponsive now, though.
Returns the empty string if the identity is known, but no
address is associated with it, or if the node is disabled.
Fails if the identity is unknown.
*/
longstrings datanodes(void) = 6;
/* Returns the identities of all datanodes */
void destroy_datanode(longstring) = 7;
/* destroy_datanode(identity):
The datanode is considered permanently as non-available.
For all files storing blocks on this node the replication
number is reduced by 1.
*/
} = 1;
} = 0x8000e003;
#endif
/* $Id$ -*- c -*- */
/* These are the namenode interfaces for the user */
#include "pfs_types.x"
#include "types.x"
#ifndef NAMENODE_X
#define NAMENODE_X
#ifndef PFS_NN_FSYS
#define PFS_NN_FSYS
program Filesystem {
version V1 {
......@@ -179,129 +177,4 @@ program Filesystem {
} = 1;
} = 0x8000e001;
program Coordination {
version V1 {
void null(void) = 0;
longstring_opt find_coordinator(longstring) = 1;
/* Returns the current coordinator as host:port string. The Filesystem
requests must be sent to the coordinator.
The arg is the clustername. If this node is not part of this
cluster the RPC will return NULL.
*/
longstrings find_namenodes(longstring) = 2;
/* Return all name nodes, including the coordinator and the slaves.
The arg is the clustername. If this node is not part of this
cluster the RPC will return an empty array.
*/
bool is_coordinator(longstring) = 3;
/* Whether this node is the coordinator
The arg is the clustername. If this node is not part of this
cluster the RPC will return false.
*/
longstring clustername(void) = 4;
/* Returns the clustername */
longstrings find_inodecaches(longstring) = 5;
/* Return all inodecaches for this clustername */
longstrings local_identities(longstring) = 6;
/* Returns the identities of the data nodes running on the machine
of the caller. Only available data nodes are returned.
The arg is the clustername.
*/
} = 1;
} = 0x8000e002;
program Dn_admin {
version V1 {
void null(void) = 0;
void add_datanode(longstring, hyper) = 1;
/* add_datanode(identity, size):
adds a new datanode. It is in disabled state initially
*/
void enable_datanode(longstring, longstring) = 2;
/* enable_datanode(identity, hostport): Enables the data node for
identity on hostport.
// FIXME: "At enable time, the datanode is checked whether it was enlarged." - probably another RPC
*/
void disable_datanode(longstring) = 3;
/* disable_datanode(identity):
This means blocks
are not allocated on the node, and if [all=false] blocks from
this node are suppressed by get_blocks. This datanode state is
considered temporary (e.g. while moving a disk from one node to
another).
The coordinator pings the datanodes anyway, and finds quickly
out whether nodes are down. This RPC is more useful for
administratively taking nodes down, e.g. for maintenance.
*/
bool is_enabled(longstring) = 4;
/* whether this identity is enabled */
longstring lookup(longstring) = 5;
/* looks the identity up and returns hostport. Only for enabled
nodes that could be at least contacted once. The node may be
unresponsive now, though.
Returns the empty string if the identity is known, but no
address is associated with it, or if the node is disabled.
Fails if the identity is unknown.
*/
longstrings datanodes(void) = 6;
/* Returns the identities of all datanodes */
void destroy_datanode(longstring) = 7;
/* destroy_datanode(identity):
The datanode is considered permanently as non-available.
For all files storing blocks on this node the replication
number is reduced by 1.
*/
} = 1;
} = 0x8000e003;
program Inode_cache {
version V1 {
void null(void) = 0;
bool is_up_to_date(hyper, inodeinfo) = 1;
/* is_up_to_date(inode,ii): Checks whether ii is the current
version of the inode metadata for [inode]. Returns [true]
if so.
Returns [false] if the inode is not known, if an error
occurs, or if it cannot be quickly determined that the inode
is actually up to date.
*/
bool is_up_to_date_seqno(hyper, hyper) = 2;
/* is_up_to_date(inode,seqno): Same check but only for the
seqno
*/
} = 1;
} = 0x8000e004;
#endif
/* $Id$ -*- c -*- */
#include "pfs_types.x"
#ifndef PFS_NN_INODECACHE
#define PFS_NN_INODECACHE
program Inode_cache {
version V1 {
void null(void) = 0;
bool is_up_to_date(hyper, inodeinfo) = 1;
/* is_up_to_date(inode,ii): Checks whether ii is the current
version of the inode metadata for [inode]. Returns [true]
if so.
Returns [false] if the inode is not known, if an error
occurs, or if it cannot be quickly determined that the inode
is actually up to date.
*/
bool is_up_to_date_seqno(hyper, hyper) = 2;
/* is_up_to_date(inode,seqno): Same check but only for the
seqno
*/
} = 1;
} = 0x8000e004;
#endif
......@@ -2,10 +2,10 @@
/* Internal interfaces uses by the namenodes */
#include "types.x"
#include "pfs_types.x"
#ifndef NN_INTERNAL_X
#define NN_INTERNAL_X
#ifndef PFS_NN_INTERNAL_X
#define PFS_NN_INTERNAL_X
program Elect {
version V1 {
......
/* $Id$ -*- c -*- */
#define SERVER_CONTEXT
#include "pfs_types.x"
#include "pfs_datanode.x"
#include "pfs_dn_internal.x"
#include "pfs_nn_fsys.x"
#include "pfs_nn_coord.x"
#include "pfs_nn_dnadmin.x"
#include "pfs_nn_inodecache.x"
#include "pfs_nn_internal.x"
/* $Id$ -*- c -*- */
#ifndef TYPES_X
#define TYPES_X
#ifndef PFS_TYPES_X
#define PFS_TYPES_X
typedef string longstring<>;
/* A string up to 4G length */
......
......@@ -2,10 +2,13 @@
/* The easy-going interface of task servers */
#ifndef PMR_TASK
#define PMR_TASK
typedef string longstring<>;
typedef longstring longstrings<>;
program Mapred {
program Mapred_task {
version V1 {
void null (void) = 0;
......@@ -32,3 +35,4 @@ program Mapred {
*/
} = 1;
} = 0x80013001;
#endif
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment