[SCSI] libsas: export sas_alloc_task()
[deliverable/linux.git] / drivers / scsi / libsas / sas_init.c
CommitLineData
2908d778
JB
1/*
2 * Serial Attached SCSI (SAS) Transport Layer initialization
3 *
4 * Copyright (C) 2005 Adaptec, Inc. All rights reserved.
5 * Copyright (C) 2005 Luben Tuikov <luben_tuikov@adaptec.com>
6 *
7 * This file is licensed under GPLv2.
8 *
9 * This program is free software; you can redistribute it and/or
10 * modify it under the terms of the GNU General Public License as
11 * published by the Free Software Foundation; either version 2 of the
12 * License, or (at your option) any later version.
13 *
14 * This program is distributed in the hope that it will be useful, but
15 * WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 * General Public License for more details.
18 *
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
22 * USA
23 *
24 */
25
26#include <linux/module.h>
5a0e3ad6 27#include <linux/slab.h>
2908d778
JB
28#include <linux/init.h>
29#include <linux/device.h>
30#include <linux/spinlock.h>
31#include <scsi/scsi_host.h>
32#include <scsi/scsi_device.h>
33#include <scsi/scsi_transport.h>
34#include <scsi/scsi_transport_sas.h>
35
36#include "sas_internal.h"
37
38#include "../scsi_sas_internal.h"
39
4fcf812c
DW
40static struct kmem_cache *sas_task_cache;
41
42struct sas_task *sas_alloc_task(gfp_t flags)
43{
44 struct sas_task *task = kmem_cache_zalloc(sas_task_cache, flags);
45
46 if (task) {
47 INIT_LIST_HEAD(&task->list);
48 spin_lock_init(&task->task_state_lock);
49 task->task_state_flags = SAS_TASK_STATE_PENDING;
50 init_timer(&task->timer);
51 init_completion(&task->completion);
52 }
53
54 return task;
55}
56EXPORT_SYMBOL_GPL(sas_alloc_task);
57
58void sas_free_task(struct sas_task *task)
59{
60 if (task) {
61 BUG_ON(!list_empty(&task->list));
62 kmem_cache_free(sas_task_cache, task);
63 }
64}
65EXPORT_SYMBOL_GPL(sas_free_task);
2908d778
JB
66
67/*------------ SAS addr hash -----------*/
68void sas_hash_addr(u8 *hashed, const u8 *sas_addr)
69{
70 const u32 poly = 0x00DB2777;
71 u32 r = 0;
72 int i;
73
74 for (i = 0; i < 8; i++) {
75 int b;
76 for (b = 7; b >= 0; b--) {
77 r <<= 1;
78 if ((1 << b) & sas_addr[i]) {
79 if (!(r & 0x01000000))
80 r ^= poly;
81 } else if (r & 0x01000000)
82 r ^= poly;
83 }
84 }
85
86 hashed[0] = (r >> 16) & 0xFF;
87 hashed[1] = (r >> 8) & 0xFF ;
88 hashed[2] = r & 0xFF;
89}
90
91
92/* ---------- HA events ---------- */
93
c4028958 94void sas_hae_reset(struct work_struct *work)
2908d778 95{
c4028958
DH
96 struct sas_ha_event *ev =
97 container_of(work, struct sas_ha_event, work);
98 struct sas_ha_struct *ha = ev->ha;
2908d778
JB
99
100 sas_begin_event(HAE_RESET, &ha->event_lock,
101 &ha->pending);
102}
103
104int sas_register_ha(struct sas_ha_struct *sas_ha)
105{
106 int error = 0;
107
108 spin_lock_init(&sas_ha->phy_port_lock);
109 sas_hash_addr(sas_ha->hashed_sas_addr, sas_ha->sas_addr);
110
111 if (sas_ha->lldd_queue_size == 0)
112 sas_ha->lldd_queue_size = 1;
113 else if (sas_ha->lldd_queue_size == -1)
114 sas_ha->lldd_queue_size = 128; /* Sanity */
115
6b0efb85
DW
116 sas_ha->state = SAS_HA_REGISTERED;
117 spin_lock_init(&sas_ha->state_lock);
118
2908d778
JB
119 error = sas_register_phys(sas_ha);
120 if (error) {
121 printk(KERN_NOTICE "couldn't register sas phys:%d\n", error);
122 return error;
123 }
124
125 error = sas_register_ports(sas_ha);
126 if (error) {
127 printk(KERN_NOTICE "couldn't register sas ports:%d\n", error);
128 goto Undo_phys;
129 }
130
131 error = sas_init_events(sas_ha);
132 if (error) {
133 printk(KERN_NOTICE "couldn't start event thread:%d\n", error);
134 goto Undo_ports;
135 }
136
137 if (sas_ha->lldd_max_execute_num > 1) {
138 error = sas_init_queue(sas_ha);
139 if (error) {
140 printk(KERN_NOTICE "couldn't start queue thread:%d, "
141 "running in direct mode\n", error);
142 sas_ha->lldd_max_execute_num = 1;
143 }
144 }
145
f456393e
DW
146 INIT_LIST_HEAD(&sas_ha->eh_done_q);
147
2908d778
JB
148 return 0;
149
150Undo_ports:
151 sas_unregister_ports(sas_ha);
152Undo_phys:
153
154 return error;
155}
156
157int sas_unregister_ha(struct sas_ha_struct *sas_ha)
158{
6b0efb85
DW
159 unsigned long flags;
160
161 /* Set the state to unregistered to avoid further
162 * events to be queued */
163 spin_lock_irqsave(&sas_ha->state_lock, flags);
164 sas_ha->state = SAS_HA_UNREGISTERED;
165 spin_unlock_irqrestore(&sas_ha->state_lock, flags);
166 scsi_flush_work(sas_ha->core.shost);
167
cde3f74b
DW
168 sas_unregister_ports(sas_ha);
169
2908d778
JB
170 if (sas_ha->lldd_max_execute_num > 1) {
171 sas_shutdown_queue(sas_ha);
cde3f74b 172 sas_ha->lldd_max_execute_num = 1;
2908d778
JB
173 }
174
2908d778
JB
175 return 0;
176}
177
178static int sas_get_linkerrors(struct sas_phy *phy)
179{
180 if (scsi_is_sas_phy_local(phy))
181 /* FIXME: we have no local phy stats
182 * gathering at this time */
183 return -EINVAL;
184
185 return sas_smp_get_phy_events(phy);
186}
187
acbf167d
DW
188int sas_phy_enable(struct sas_phy *phy, int enable)
189{
190 int ret;
191 enum phy_func command;
192
193 if (enable)
194 command = PHY_FUNC_LINK_RESET;
195 else
196 command = PHY_FUNC_DISABLE;
197
198 if (scsi_is_sas_phy_local(phy)) {
199 struct Scsi_Host *shost = dev_to_shost(phy->dev.parent);
200 struct sas_ha_struct *sas_ha = SHOST_TO_SAS_HA(shost);
201 struct asd_sas_phy *asd_phy = sas_ha->sas_phy[phy->number];
202 struct sas_internal *i =
203 to_sas_internal(sas_ha->core.shost->transportt);
204
205 if (!enable) {
206 sas_phy_disconnected(asd_phy);
207 sas_ha->notify_phy_event(asd_phy, PHYE_LOSS_OF_SIGNAL);
208 }
209 ret = i->dft->lldd_control_phy(asd_phy, command, NULL);
210 } else {
211 struct sas_rphy *rphy = dev_to_rphy(phy->dev.parent);
212 struct domain_device *ddev = sas_find_dev_by_rphy(rphy);
213 ret = sas_smp_phy_control(ddev, phy->number, command, NULL);
214 }
215 return ret;
216}
217
dea22214 218int sas_phy_reset(struct sas_phy *phy, int hard_reset)
2908d778
JB
219{
220 int ret;
221 enum phy_func reset_type;
222
223 if (hard_reset)
224 reset_type = PHY_FUNC_HARD_RESET;
225 else
226 reset_type = PHY_FUNC_LINK_RESET;
227
228 if (scsi_is_sas_phy_local(phy)) {
229 struct Scsi_Host *shost = dev_to_shost(phy->dev.parent);
230 struct sas_ha_struct *sas_ha = SHOST_TO_SAS_HA(shost);
231 struct asd_sas_phy *asd_phy = sas_ha->sas_phy[phy->number];
232 struct sas_internal *i =
233 to_sas_internal(sas_ha->core.shost->transportt);
234
a01e70e5 235 ret = i->dft->lldd_control_phy(asd_phy, reset_type, NULL);
2908d778
JB
236 } else {
237 struct sas_rphy *rphy = dev_to_rphy(phy->dev.parent);
238 struct domain_device *ddev = sas_find_dev_by_rphy(rphy);
a01e70e5 239 ret = sas_smp_phy_control(ddev, phy->number, reset_type, NULL);
2908d778
JB
240 }
241 return ret;
242}
243
acbf167d
DW
244int sas_set_phy_speed(struct sas_phy *phy,
245 struct sas_phy_linkrates *rates)
a01e70e5
JB
246{
247 int ret;
248
249 if ((rates->minimum_linkrate &&
250 rates->minimum_linkrate > phy->maximum_linkrate) ||
251 (rates->maximum_linkrate &&
252 rates->maximum_linkrate < phy->minimum_linkrate))
253 return -EINVAL;
254
255 if (rates->minimum_linkrate &&
256 rates->minimum_linkrate < phy->minimum_linkrate_hw)
257 rates->minimum_linkrate = phy->minimum_linkrate_hw;
258
259 if (rates->maximum_linkrate &&
260 rates->maximum_linkrate > phy->maximum_linkrate_hw)
261 rates->maximum_linkrate = phy->maximum_linkrate_hw;
262
263 if (scsi_is_sas_phy_local(phy)) {
264 struct Scsi_Host *shost = dev_to_shost(phy->dev.parent);
265 struct sas_ha_struct *sas_ha = SHOST_TO_SAS_HA(shost);
266 struct asd_sas_phy *asd_phy = sas_ha->sas_phy[phy->number];
267 struct sas_internal *i =
268 to_sas_internal(sas_ha->core.shost->transportt);
269
270 ret = i->dft->lldd_control_phy(asd_phy, PHY_FUNC_SET_LINK_RATE,
271 rates);
272 } else {
273 struct sas_rphy *rphy = dev_to_rphy(phy->dev.parent);
274 struct domain_device *ddev = sas_find_dev_by_rphy(rphy);
275 ret = sas_smp_phy_control(ddev, phy->number,
276 PHY_FUNC_LINK_RESET, rates);
277
278 }
279
280 return ret;
281}
282
2908d778 283static struct sas_function_template sft = {
acbf167d 284 .phy_enable = sas_phy_enable,
2908d778 285 .phy_reset = sas_phy_reset,
a01e70e5 286 .set_phy_speed = sas_set_phy_speed,
2908d778 287 .get_linkerrors = sas_get_linkerrors,
ba1fc175 288 .smp_handler = sas_smp_handler,
2908d778
JB
289};
290
291struct scsi_transport_template *
292sas_domain_attach_transport(struct sas_domain_function_template *dft)
293{
294 struct scsi_transport_template *stt = sas_attach_transport(&sft);
295 struct sas_internal *i;
296
297 if (!stt)
298 return stt;
299
300 i = to_sas_internal(stt);
301 i->dft = dft;
302 stt->create_work_queue = 1;
303 stt->eh_timed_out = sas_scsi_timed_out;
304 stt->eh_strategy_handler = sas_scsi_recover_host;
305
306 return stt;
307}
308EXPORT_SYMBOL_GPL(sas_domain_attach_transport);
309
310
311void sas_domain_release_transport(struct scsi_transport_template *stt)
312{
313 sas_release_transport(stt);
314}
315EXPORT_SYMBOL_GPL(sas_domain_release_transport);
316
317/* ---------- SAS Class register/unregister ---------- */
318
319static int __init sas_class_init(void)
320{
4fcf812c 321 sas_task_cache = KMEM_CACHE(sas_task, SLAB_HWCACHE_ALIGN);
2908d778
JB
322 if (!sas_task_cache)
323 return -ENOMEM;
324
325 return 0;
326}
327
328static void __exit sas_class_exit(void)
329{
330 kmem_cache_destroy(sas_task_cache);
331}
332
333MODULE_AUTHOR("Luben Tuikov <luben_tuikov@adaptec.com>");
334MODULE_DESCRIPTION("SAS Transport Layer");
335MODULE_LICENSE("GPL v2");
336
337module_init(sas_class_init);
338module_exit(sas_class_exit);
339
340EXPORT_SYMBOL_GPL(sas_register_ha);
341EXPORT_SYMBOL_GPL(sas_unregister_ha);
This page took 0.489412 seconds and 5 git commands to generate.