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 pr_info("EEH: Detected PCI bus error on PHB#%d-PE#%x\n",
78 pe->phb->global_number, pe->addr);
79 eeh_handle_event(pe);
80 eeh_pe_state_clear(pe, EEH_PE_RECOVERING);
81 } else {
82 eeh_handle_event(NULL);
83 }
84
85 kfree(event);
86 }
87
88 return 0;
89}
90
91
92
93
94
95
96
97int eeh_event_init(void)
98{
99 struct task_struct *t;
100 int ret = 0;
101
102
103 sema_init(&eeh_eventlist_sem, 0);
104
105 t = kthread_run(eeh_event_handler, NULL, "eehd");
106 if (IS_ERR(t)) {
107 ret = PTR_ERR(t);
108 pr_err("%s: Failed to start EEH daemon (%d)\n",
109 __func__, ret);
110 return ret;
111 }
112
113 return 0;
114}
115
116
117
118
119
120
121
122
123
124int eeh_send_failure_event(struct eeh_pe *pe)
125{
126 unsigned long flags;
127 struct eeh_event *event;
128
129 event = kzalloc(sizeof(*event), GFP_ATOMIC);
130 if (!event) {
131 pr_err("EEH: out of memory, event not handled\n");
132 return -ENOMEM;
133 }
134 event->pe = pe;
135
136
137 spin_lock_irqsave(&eeh_eventlist_lock, flags);
138 list_add(&event->list, &eeh_eventlist);
139 spin_unlock_irqrestore(&eeh_eventlist_lock, flags);
140
141
142 up(&eeh_eventlist_sem);
143
144 return 0;
145}
146
147
148
149
150
151
152
153
154
155
156void eeh_remove_event(struct eeh_pe *pe)
157{
158 unsigned long flags;
159 struct eeh_event *event, *tmp;
160
161 spin_lock_irqsave(&eeh_eventlist_lock, flags);
162 list_for_each_entry_safe(event, tmp, &eeh_eventlist, list) {
163
164
165
166
167
168 if (!pe) {
169 list_del(&event->list);
170 kfree(event);
171 } else if (pe->type & EEH_PE_PHB) {
172 if (event->pe && event->pe->phb == pe->phb) {
173 list_del(&event->list);
174 kfree(event);
175 }
176 } else if (event->pe == pe) {
177 list_del(&event->list);
178 kfree(event);
179 }
180 }
181 spin_unlock_irqrestore(&eeh_eventlist_lock, flags);
182}
183