Plasma GitLab Archive
Projects Blog Knowledge

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
Powered by Caml