1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19#include <linux/delay.h>
20#include <linux/list.h>
21#include <linux/sched.h>
22#include <linux/semaphore.h>
23#include <linux/pci.h>
24#include <linux/slab.h>
25#include <linux/kthread.h>
26#include <asm/eeh_event.h>
27#include <asm/ppc-pci.h>
28
29
30
31
32
33
34
35
36
37static DEFINE_SPINLOCK(eeh_eventlist_lock);
38static struct semaphore eeh_eventlist_sem;
39LIST_HEAD(eeh_eventlist);
40
41
42
43
44
45
46
47
48
49
50
51static int eeh_event_handler(void * dummy)
52{
53 unsigned long flags;
54 struct eeh_event *event;
55 struct eeh_pe *pe;
56
57 while (!kthread_should_stop()) {
58 if (down_interruptible(&eeh_eventlist_sem))
59 break;
60
61
62 spin_lock_irqsave(&eeh_eventlist_lock, flags);
63 event = NULL;
64 if (!list_empty(&eeh_eventlist)) {
65 event = list_entry(eeh_eventlist.next,
66 struct eeh_event, list);
67 list_del(&event->list);
68 }
69 spin_unlock_irqrestore(&eeh_eventlist_lock, flags);
70 if (!event)
71 continue;
72
73
74 pe = event->pe;
75 if (pe) {
76 eeh_pe_state_mark(pe, EEH_PE_RECOVERING);
77 if (pe->type & EEH_PE_PHB)
78 pr_info("EEH: Detected error on PHB#%d\n",
79 pe->phb->global_number);
80 else
81 pr_info("EEH: Detected PCI bus error on "
82 "PHB#%d-PE#%x\n",
83 pe->phb->global_number, pe->addr);
84 eeh_handle_event(pe);
85 eeh_pe_state_clear(pe, EEH_PE_RECOVERING);
86 } else {
87 eeh_handle_event(NULL);
88 }
89
90 kfree(event);
91 }
92
93 return 0;
94}
95
96
97
98
99
100
101
102int eeh_event_init(void)
103{
104 struct task_struct *t;
105 int ret = 0;
106
107
108 sema_init(&eeh_eventlist_sem, 0);
109
110 t = kthread_run(eeh_event_handler, NULL, "eehd");
111 if (IS_ERR(t)) {
112 ret = PTR_ERR(t);
113 pr_err("%s: Failed to start EEH daemon (%d)\n",
114 __func__, ret);
115 return ret;
116 }
117
118 return 0;
119}
120
121
122
123
124
125
126
127
128
129int eeh_send_failure_event(struct eeh_pe *pe)
130{
131 unsigned long flags;
132 struct eeh_event *event;
133
134 event = kzalloc(sizeof(*event), GFP_ATOMIC);
135 if (!event) {
136 pr_err("EEH: out of memory, event not handled\n");
137 return -ENOMEM;
138 }
139 event->pe = pe;
140
141
142 spin_lock_irqsave(&eeh_eventlist_lock, flags);
143 list_add(&event->list, &eeh_eventlist);
144 spin_unlock_irqrestore(&eeh_eventlist_lock, flags);
145
146
147 up(&eeh_eventlist_sem);
148
149 return 0;
150}
151
152
153
154
155
156
157
158
159
160
161
162void eeh_remove_event(struct eeh_pe *pe, bool force)
163{
164 unsigned long flags;
165 struct eeh_event *event, *tmp;
166
167
168
169
170
171
172
173
174
175
176 spin_lock_irqsave(&eeh_eventlist_lock, flags);
177 list_for_each_entry_safe(event, tmp, &eeh_eventlist, list) {
178 if (!force && event->pe &&
179 (event->pe->state & EEH_PE_ISOLATED))
180 continue;
181
182 if (!pe) {
183 list_del(&event->list);
184 kfree(event);
185 } else if (pe->type & EEH_PE_PHB) {
186 if (event->pe && event->pe->phb == pe->phb) {
187 list_del(&event->list);
188 kfree(event);
189 }
190 } else if (event->pe == pe) {
191 list_del(&event->list);
192 kfree(event);
193 }
194 }
195 spin_unlock_irqrestore(&eeh_eventlist_lock, flags);
196}
197