Pfs_dn_internal

/* $Id: pfs_dn_internal.x 450 2011-10-11 12:30:40Z gerd $ -*- c -*- */

Internal stuff.

#ifndef PFS_DN_INTERNAL_X
#define PFS_DN_INTERNAL_X

#include "pfs_types.x"

Datanode_ctrl

The Datanode_ctrl program is running on each datanode, but only invoked by the coordinator to push and revoke safetrans tickets.

	 

program Datanode_ctrl {
    version V1 {

null

    
	void null(void) = 0;

reset_all_safetrans

	
	void reset_all_safetrans(void) = 1;

Revokes all safetrans tickets. This is called when the coordinator starts up.

cancel_safetrans

	void cancel_safetrans(hypers) = 2;

Cancel the safetrans ticket with these st_id

safetrans

	void safetrans(enable_tickets) = 3;

safetrans(st_id, st_tmo, st_secret): Enables all safetrans tickets with ID st_id. The secret st_secret is used for securing the ticket system.

    } = 1;
} = 0x8000d002;

Datanode_io

The Datanode_io program is running in the I/O processes of the datanodes

program Datanode_io {
    version V1 {

null

	void null(void) = 0;

read

	void read(int, hyper, int, int) = 1;

read(slot, block, pos, len): Reads the block (or part of it) to the shm slot

read_shm

	void read_shm(dn_channel_shm_obj, hyper, int, int) = 7;

read_shm(shm, block, pos, len): Reads the block (or part of it) to the passed shm object. It is an error if the oject is not large enough.

write

	void write(int, hyper) = 2;

write(slot, block): Writes the contents of slot to block

write_shm

	void write_shm(dn_channel_shm_obj, hyper) = 8;

write_shm(shm, block): Writes the contents of shm to block. Exactly blocksize bytes are written.

copy

	void copy(hyper, mediumstring, mediumstring, hyper, ticket, int) = 3;

copy(block, dest_node, dest_identity, dest_block, dest_ticket, slot)

sync

	void sync(void) = 4;

syncs everything to disk

size

	hyper size(void) = 5;

same as in Datanode

identity

	mediumstring identity(void) = 6;

same as in Datanode

    } = 1;
} = 0x8000d003;

Datanode_discover

This is a UDP program used for discovering datanodes (multicasting), and for monitoring the liveliness of datanodes.

program Datanode_discover {
    version V1 {

null

	void null(void) = 0;

identity

	mediumstring identity(mediumstring) = 1;

Returns the identity of this node (an ID which is assigned anew when the datanode is initialized). The arg is the clustername. If the node belongs to the wrong cluster, this RPC must be silent.

    } = 1;
} = 0x8000d004;

#endif

This web site is published by Informatikbüro Gerd Stolpmann