1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
/*
* The Spread Toolkit.
*
* The contents of this file are subject to the Spread Open-Source
* License, Version 1.0 (the ``License''); you may not use
* this file except in compliance with the License. You may obtain a
* copy of the License at:
*
* http://www.spread.org/license/
*
* or in the file ``license.txt'' found in this distribution.
*
* Software distributed under the License is distributed on an AS IS basis,
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
* for the specific language governing rights and limitations under the
* License.
*
* The Creators of Spread are:
* Yair Amir, Michal Miskin-Amir, Jonathan Stanton.
*
* Copyright (C) 1993-2004 Spread Concepts LLC <spread@spreadconcepts.com>
*
* All Rights Reserved.
*
* Major Contributor(s):
* ---------------
* Cristina Nita-Rotaru crisn@cs.purdue.edu - group communication security.
* Theo Schlossnagle jesus@omniti.com - Perl, skiplists, autoconf.
* Dan Schoenblum dansch@cnds.jhu.edu - Java interface.
* John Schultz jschultz@cnds.jhu.edu - contribution to process group membership.
*
*/
#ifndef INC_NET_TYPES
#define INC_NET_TYPES
#include "arch.h" /* For int32, etc */
#include "data_link.h" /* For MAX_PACKET_SIZE */
/* Dont forget that 0x80000080 is kept for endians */
#define UNRELIABLE_TYPE 0x00000001
#define RELIABLE_TYPE 0x00000002
#define FIFO_TYPE 0x00000004
#define AGREED_TYPE 0x00000008
#define SAFE_TYPE 0x00000010
#define REGULAR_TYPE 0x0000001f
#define ROUTED_TYPE 0x00000020
#define HURRY_TYPE 0x00000040
#define ALIVE_TYPE 0x00000100
#define JOIN_TYPE 0x00000200
#define REFER_TYPE 0x00000400
#define MEMBERSHIP_TYPE 0x00000700
#define FORM1_TYPE 0x00001000
#define FORM2_TYPE 0x00002000
#define FORM_TYPE 0x00003000
#define ARQ_TYPE 0x000f0000
#define RETRANS_TYPE 0x00f00000
#define STATUS_TYPE 0x01000000
#define PARTITION_TYPE 0x02000000
#define FC_TYPE 0x04000000
#define CONTROL_TYPE 0x0f000000
#define Is_unreliable( type ) ( type & UNRELIABLE_TYPE )
#define Is_reliable( type ) ( type & RELIABLE_TYPE )
#define Is_fifo( type ) ( type & FIFO_TYPE )
#define Is_agreed( type ) ( type & AGREED_TYPE )
#define Is_safe( type ) ( type & SAFE_TYPE )
#define Is_regular( type ) ( type & REGULAR_TYPE )
#define Is_routed( type ) ( type & ROUTED_TYPE )
#define Set_routed( type ) ( type | ROUTED_TYPE )
#define Clear_routed( type ) ( type & ~ROUTED_TYPE )
#define Is_hurry( type ) ( type & HURRY_TYPE )
#define Is_alive( type ) ( type & ALIVE_TYPE )
#define Is_join( type ) ( type & JOIN_TYPE )
#define Is_refer( type ) ( type & REFER_TYPE )
#define Is_membership( type ) ( type & MEMBERSHIP_TYPE )
#define Is_form( type ) ( type & FORM_TYPE )
#define Is_form1( type ) ( type & FORM1_TYPE )
#define Is_form2( type ) ( type & FORM2_TYPE )
#define Get_arq( type ) ( (type & ARQ_TYPE) >> 16)
#define Set_arq( type, val ) ( (type & ~ARQ_TYPE) | ((val << 16)&ARQ_TYPE) )
#define Get_retrans( type ) ( (type & RETRANS_TYPE) >> 20)
#define Set_retrans( type, val) ( (type & ~RETRANS_TYPE) | ((val << 20)&RETRANS_TYPE) )
#define Is_status( type ) ( type & STATUS_TYPE )
#define Is_partition( type ) ( type & PARTITION_TYPE )
#define Is_fc( type ) ( type & FC_TYPE )
#define Is_control( type ) ( type & CONTROL_TYPE )
typedef struct dummy_packet_header {
int32 type;
int32 transmiter_id;
int32 proc_id;
membership_id memb_id;
int32 seq;
int32 fifo_seq;
int16 packet_index;
int16 data_len;
} packet_header;
typedef char packet_body[MAX_PACKET_SIZE-sizeof(packet_header)];
typedef struct dummy_token_header {
int32 type;
int32 transmiter_id;
int32 seq;
int32 proc_id;
int32 aru;
int32 aru_last_id;
int16 flow_control;
int16 rtr_len;
} token_header;
typedef char token_body[MAX_PACKET_SIZE-sizeof(token_header)];
typedef struct dummy_ring_rtr {
membership_id memb_id;
int32 proc_id;
int16 seg_index;
int16 num_seq;
} ring_rtr;
#endif /* INC_NET_TYPES */
|
