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#include <linux/fs.h>
28#include <linux/types.h>
29#include <linux/slab.h>
30#include <linux/highmem.h>
31
32#define MLOG_MASK_PREFIX ML_SUPER
33#include <cluster/masklog.h>
34
35#include "ocfs2.h"
36
37#include "alloc.h"
38#include "heartbeat.h"
39#include "inode.h"
40#include "journal.h"
41
42#include "buffer_head_io.h"
43
44static inline void __ocfs2_node_map_set_bit(struct ocfs2_node_map *map,
45 int bit);
46static inline void __ocfs2_node_map_clear_bit(struct ocfs2_node_map *map,
47 int bit);
48
49
50
51static void ocfs2_node_map_init(struct ocfs2_node_map *map)
52{
53 map->num_nodes = OCFS2_NODE_MAP_MAX_NODES;
54 memset(map->map, 0, BITS_TO_LONGS(OCFS2_NODE_MAP_MAX_NODES) *
55 sizeof(unsigned long));
56}
57
58void ocfs2_init_node_maps(struct ocfs2_super *osb)
59{
60 spin_lock_init(&osb->node_map_lock);
61 ocfs2_node_map_init(&osb->osb_recovering_orphan_dirs);
62}
63
64void ocfs2_do_node_down(int node_num, void *data)
65{
66 struct ocfs2_super *osb = data;
67
68 BUG_ON(osb->node_num == node_num);
69
70 mlog(0, "ocfs2: node down event for %d\n", node_num);
71
72 if (!osb->cconn) {
73
74
75
76
77
78
79 return;
80 }
81
82 ocfs2_recovery_thread(osb, node_num);
83}
84
85static inline void __ocfs2_node_map_set_bit(struct ocfs2_node_map *map,
86 int bit)
87{
88 set_bit(bit, map->map);
89}
90
91void ocfs2_node_map_set_bit(struct ocfs2_super *osb,
92 struct ocfs2_node_map *map,
93 int bit)
94{
95 if (bit==-1)
96 return;
97 BUG_ON(bit >= map->num_nodes);
98 spin_lock(&osb->node_map_lock);
99 __ocfs2_node_map_set_bit(map, bit);
100 spin_unlock(&osb->node_map_lock);
101}
102
103static inline void __ocfs2_node_map_clear_bit(struct ocfs2_node_map *map,
104 int bit)
105{
106 clear_bit(bit, map->map);
107}
108
109void ocfs2_node_map_clear_bit(struct ocfs2_super *osb,
110 struct ocfs2_node_map *map,
111 int bit)
112{
113 if (bit==-1)
114 return;
115 BUG_ON(bit >= map->num_nodes);
116 spin_lock(&osb->node_map_lock);
117 __ocfs2_node_map_clear_bit(map, bit);
118 spin_unlock(&osb->node_map_lock);
119}
120
121int ocfs2_node_map_test_bit(struct ocfs2_super *osb,
122 struct ocfs2_node_map *map,
123 int bit)
124{
125 int ret;
126 if (bit >= map->num_nodes) {
127 mlog(ML_ERROR, "bit=%d map->num_nodes=%d\n", bit, map->num_nodes);
128 BUG();
129 }
130 spin_lock(&osb->node_map_lock);
131 ret = test_bit(bit, map->map);
132 spin_unlock(&osb->node_map_lock);
133 return ret;
134}
135
136