diff options
Diffstat (limited to 'drivers/s390/scsi')
-rw-r--r-- | drivers/s390/scsi/zfcp_aux.c | 4 | ||||
-rw-r--r-- | drivers/s390/scsi/zfcp_def.h | 8 | ||||
-rw-r--r-- | drivers/s390/scsi/zfcp_erp.c | 228 | ||||
-rw-r--r-- | drivers/s390/scsi/zfcp_ext.h | 13 | ||||
-rw-r--r-- | drivers/s390/scsi/zfcp_fsf.c | 257 | ||||
-rw-r--r-- | drivers/s390/scsi/zfcp_scsi.c | 25 |
6 files changed, 191 insertions, 344 deletions
diff --git a/drivers/s390/scsi/zfcp_aux.c b/drivers/s390/scsi/zfcp_aux.c index 504c9219961c..5d39b2df0cc4 100644 --- a/drivers/s390/scsi/zfcp_aux.c +++ b/drivers/s390/scsi/zfcp_aux.c | |||
@@ -1135,9 +1135,6 @@ zfcp_adapter_enqueue(struct ccw_device *ccw_device) | |||
1135 | /* initialize lock of associated request queue */ | 1135 | /* initialize lock of associated request queue */ |
1136 | rwlock_init(&adapter->request_queue.queue_lock); | 1136 | rwlock_init(&adapter->request_queue.queue_lock); |
1137 | 1137 | ||
1138 | /* intitialise SCSI ER timer */ | ||
1139 | init_timer(&adapter->scsi_er_timer); | ||
1140 | |||
1141 | /* mark adapter unusable as long as sysfs registration is not complete */ | 1138 | /* mark adapter unusable as long as sysfs registration is not complete */ |
1142 | atomic_set_mask(ZFCP_STATUS_COMMON_REMOVE, &adapter->status); | 1139 | atomic_set_mask(ZFCP_STATUS_COMMON_REMOVE, &adapter->status); |
1143 | 1140 | ||
@@ -1653,7 +1650,6 @@ zfcp_ns_gid_pn_request(struct zfcp_erp_action *erp_action) | |||
1653 | gid_pn->ct.handler = zfcp_ns_gid_pn_handler; | 1650 | gid_pn->ct.handler = zfcp_ns_gid_pn_handler; |
1654 | gid_pn->ct.handler_data = (unsigned long) gid_pn; | 1651 | gid_pn->ct.handler_data = (unsigned long) gid_pn; |
1655 | gid_pn->ct.timeout = ZFCP_NS_GID_PN_TIMEOUT; | 1652 | gid_pn->ct.timeout = ZFCP_NS_GID_PN_TIMEOUT; |
1656 | gid_pn->ct.timer = &erp_action->timer; | ||
1657 | gid_pn->port = erp_action->port; | 1653 | gid_pn->port = erp_action->port; |
1658 | 1654 | ||
1659 | ret = zfcp_fsf_send_ct(&gid_pn->ct, adapter->pool.fsf_req_erp, | 1655 | ret = zfcp_fsf_send_ct(&gid_pn->ct, adapter->pool.fsf_req_erp, |
diff --git a/drivers/s390/scsi/zfcp_def.h b/drivers/s390/scsi/zfcp_def.h index ef1cd49184e8..8f882690994d 100644 --- a/drivers/s390/scsi/zfcp_def.h +++ b/drivers/s390/scsi/zfcp_def.h | |||
@@ -137,7 +137,7 @@ zfcp_address_to_sg(void *address, struct scatterlist *list) | |||
137 | #define ZFCP_EXCHANGE_CONFIG_DATA_RETRIES 7 | 137 | #define ZFCP_EXCHANGE_CONFIG_DATA_RETRIES 7 |
138 | 138 | ||
139 | /* timeout value for "default timer" for fsf requests */ | 139 | /* timeout value for "default timer" for fsf requests */ |
140 | #define ZFCP_FSF_REQUEST_TIMEOUT (60*HZ); | 140 | #define ZFCP_FSF_REQUEST_TIMEOUT (60*HZ) |
141 | 141 | ||
142 | /*************** FIBRE CHANNEL PROTOCOL SPECIFIC DEFINES ********************/ | 142 | /*************** FIBRE CHANNEL PROTOCOL SPECIFIC DEFINES ********************/ |
143 | 143 | ||
@@ -779,7 +779,6 @@ typedef void (*zfcp_send_ct_handler_t)(unsigned long); | |||
779 | * @handler_data: data passed to handler function | 779 | * @handler_data: data passed to handler function |
780 | * @pool: pointer to memory pool for ct request structure | 780 | * @pool: pointer to memory pool for ct request structure |
781 | * @timeout: FSF timeout for this request | 781 | * @timeout: FSF timeout for this request |
782 | * @timer: timer (e.g. for request initiated by erp) | ||
783 | * @completion: completion for synchronization purposes | 782 | * @completion: completion for synchronization purposes |
784 | * @status: used to pass error status to calling function | 783 | * @status: used to pass error status to calling function |
785 | */ | 784 | */ |
@@ -793,7 +792,6 @@ struct zfcp_send_ct { | |||
793 | unsigned long handler_data; | 792 | unsigned long handler_data; |
794 | mempool_t *pool; | 793 | mempool_t *pool; |
795 | int timeout; | 794 | int timeout; |
796 | struct timer_list *timer; | ||
797 | struct completion *completion; | 795 | struct completion *completion; |
798 | int status; | 796 | int status; |
799 | }; | 797 | }; |
@@ -821,7 +819,6 @@ typedef void (*zfcp_send_els_handler_t)(unsigned long); | |||
821 | * @resp_count: number of elements in response scatter-gather list | 819 | * @resp_count: number of elements in response scatter-gather list |
822 | * @handler: handler function (called for response to the request) | 820 | * @handler: handler function (called for response to the request) |
823 | * @handler_data: data passed to handler function | 821 | * @handler_data: data passed to handler function |
824 | * @timer: timer (e.g. for request initiated by erp) | ||
825 | * @completion: completion for synchronization purposes | 822 | * @completion: completion for synchronization purposes |
826 | * @ls_code: hex code of ELS command | 823 | * @ls_code: hex code of ELS command |
827 | * @status: used to pass error status to calling function | 824 | * @status: used to pass error status to calling function |
@@ -836,7 +833,6 @@ struct zfcp_send_els { | |||
836 | unsigned int resp_count; | 833 | unsigned int resp_count; |
837 | zfcp_send_els_handler_t handler; | 834 | zfcp_send_els_handler_t handler; |
838 | unsigned long handler_data; | 835 | unsigned long handler_data; |
839 | struct timer_list *timer; | ||
840 | struct completion *completion; | 836 | struct completion *completion; |
841 | int ls_code; | 837 | int ls_code; |
842 | int status; | 838 | int status; |
@@ -886,7 +882,6 @@ struct zfcp_adapter { | |||
886 | struct list_head port_remove_lh; /* head of ports to be | 882 | struct list_head port_remove_lh; /* head of ports to be |
887 | removed */ | 883 | removed */ |
888 | u32 ports; /* number of remote ports */ | 884 | u32 ports; /* number of remote ports */ |
889 | struct timer_list scsi_er_timer; /* SCSI err recovery watch */ | ||
890 | atomic_t reqs_active; /* # active FSF reqs */ | 885 | atomic_t reqs_active; /* # active FSF reqs */ |
891 | unsigned long req_no; /* unique FSF req number */ | 886 | unsigned long req_no; /* unique FSF req number */ |
892 | struct list_head *req_list; /* list of pending reqs */ | 887 | struct list_head *req_list; /* list of pending reqs */ |
@@ -1003,6 +998,7 @@ struct zfcp_fsf_req { | |||
1003 | struct fsf_qtcb *qtcb; /* address of associated QTCB */ | 998 | struct fsf_qtcb *qtcb; /* address of associated QTCB */ |
1004 | u32 seq_no; /* Sequence number of request */ | 999 | u32 seq_no; /* Sequence number of request */ |
1005 | unsigned long data; /* private data of request */ | 1000 | unsigned long data; /* private data of request */ |
1001 | struct timer_list timer; /* used for erp or scsi er */ | ||
1006 | struct zfcp_erp_action *erp_action; /* used if this request is | 1002 | struct zfcp_erp_action *erp_action; /* used if this request is |
1007 | issued on behalf of erp */ | 1003 | issued on behalf of erp */ |
1008 | mempool_t *pool; /* used if request was alloacted | 1004 | mempool_t *pool; /* used if request was alloacted |
diff --git a/drivers/s390/scsi/zfcp_erp.c b/drivers/s390/scsi/zfcp_erp.c index 7f60b6fdf724..af42a0eadf03 100644 --- a/drivers/s390/scsi/zfcp_erp.c +++ b/drivers/s390/scsi/zfcp_erp.c | |||
@@ -64,8 +64,6 @@ static int zfcp_erp_strategy_check_action(struct zfcp_erp_action *, int); | |||
64 | static int zfcp_erp_adapter_strategy(struct zfcp_erp_action *); | 64 | static int zfcp_erp_adapter_strategy(struct zfcp_erp_action *); |
65 | static int zfcp_erp_adapter_strategy_generic(struct zfcp_erp_action *, int); | 65 | static int zfcp_erp_adapter_strategy_generic(struct zfcp_erp_action *, int); |
66 | static int zfcp_erp_adapter_strategy_close(struct zfcp_erp_action *); | 66 | static int zfcp_erp_adapter_strategy_close(struct zfcp_erp_action *); |
67 | static void zfcp_erp_adapter_strategy_close_qdio(struct zfcp_erp_action *); | ||
68 | static void zfcp_erp_adapter_strategy_close_fsf(struct zfcp_erp_action *); | ||
69 | static int zfcp_erp_adapter_strategy_open(struct zfcp_erp_action *); | 67 | static int zfcp_erp_adapter_strategy_open(struct zfcp_erp_action *); |
70 | static int zfcp_erp_adapter_strategy_open_qdio(struct zfcp_erp_action *); | 68 | static int zfcp_erp_adapter_strategy_open_qdio(struct zfcp_erp_action *); |
71 | static int zfcp_erp_adapter_strategy_open_fsf(struct zfcp_erp_action *); | 69 | static int zfcp_erp_adapter_strategy_open_fsf(struct zfcp_erp_action *); |
@@ -111,64 +109,86 @@ static inline void zfcp_erp_action_to_ready(struct zfcp_erp_action *); | |||
111 | static inline void zfcp_erp_action_to_running(struct zfcp_erp_action *); | 109 | static inline void zfcp_erp_action_to_running(struct zfcp_erp_action *); |
112 | 110 | ||
113 | static void zfcp_erp_memwait_handler(unsigned long); | 111 | static void zfcp_erp_memwait_handler(unsigned long); |
114 | static void zfcp_erp_timeout_handler(unsigned long); | ||
115 | static inline void zfcp_erp_timeout_init(struct zfcp_erp_action *); | ||
116 | 112 | ||
117 | /** | 113 | /** |
118 | * zfcp_fsf_request_timeout_handler - called if a request timed out | 114 | * zfcp_close_qdio - close qdio queues for an adapter |
119 | * @data: pointer to adapter for handler function | ||
120 | * | ||
121 | * This function needs to be called if requests (ELS, Generic Service, | ||
122 | * or SCSI commands) exceed a certain time limit. The assumption is | ||
123 | * that after the time limit the adapter get stuck. So we trigger a reopen of | ||
124 | * the adapter. This should not be used for error recovery, SCSI abort | ||
125 | * commands and SCSI requests from SCSI mid-layer. | ||
126 | */ | 115 | */ |
127 | void | 116 | static void zfcp_close_qdio(struct zfcp_adapter *adapter) |
128 | zfcp_fsf_request_timeout_handler(unsigned long data) | ||
129 | { | 117 | { |
130 | struct zfcp_adapter *adapter; | 118 | struct zfcp_qdio_queue *req_queue; |
119 | int first, count; | ||
131 | 120 | ||
132 | adapter = (struct zfcp_adapter *) data; | 121 | if (!atomic_test_mask(ZFCP_STATUS_ADAPTER_QDIOUP, &adapter->status)) |
122 | return; | ||
133 | 123 | ||
134 | zfcp_erp_adapter_reopen(adapter, 0); | 124 | /* clear QDIOUP flag, thus do_QDIO is not called during qdio_shutdown */ |
125 | req_queue = &adapter->request_queue; | ||
126 | write_lock_irq(&req_queue->queue_lock); | ||
127 | atomic_clear_mask(ZFCP_STATUS_ADAPTER_QDIOUP, &adapter->status); | ||
128 | write_unlock_irq(&req_queue->queue_lock); | ||
129 | |||
130 | debug_text_event(adapter->erp_dbf, 3, "qdio_down2a"); | ||
131 | while (qdio_shutdown(adapter->ccw_device, | ||
132 | QDIO_FLAG_CLEANUP_USING_CLEAR) == -EINPROGRESS) | ||
133 | msleep(1000); | ||
134 | debug_text_event(adapter->erp_dbf, 3, "qdio_down2b"); | ||
135 | |||
136 | /* cleanup used outbound sbals */ | ||
137 | count = atomic_read(&req_queue->free_count); | ||
138 | if (count < QDIO_MAX_BUFFERS_PER_Q) { | ||
139 | first = (req_queue->free_index+count) % QDIO_MAX_BUFFERS_PER_Q; | ||
140 | count = QDIO_MAX_BUFFERS_PER_Q - count; | ||
141 | zfcp_qdio_zero_sbals(req_queue->buffer, first, count); | ||
142 | } | ||
143 | req_queue->free_index = 0; | ||
144 | atomic_set(&req_queue->free_count, 0); | ||
145 | req_queue->distance_from_int = 0; | ||
146 | adapter->response_queue.free_index = 0; | ||
147 | atomic_set(&adapter->response_queue.free_count, 0); | ||
135 | } | 148 | } |
136 | 149 | ||
137 | /** | 150 | /** |
138 | * zfcp_fsf_scsi_er_timeout_handler - timeout handler for scsi eh tasks | 151 | * zfcp_close_fsf - stop FSF operations for an adapter |
139 | * | 152 | * |
140 | * This function needs to be called whenever a SCSI error recovery | 153 | * Dismiss and cleanup all pending fsf_reqs (this wakes up all initiators of |
141 | * action (abort/reset) does not return. Re-opening the adapter means | 154 | * requests waiting for completion; especially this returns SCSI commands |
142 | * that the abort/reset command can be returned by zfcp. It won't complete | 155 | * with error state). |
143 | * via the adapter anymore (because qdio queues are closed). If ERP is | ||
144 | * already running on this adapter it will be stopped. | ||
145 | */ | 156 | */ |
146 | void zfcp_fsf_scsi_er_timeout_handler(unsigned long data) | 157 | static void zfcp_close_fsf(struct zfcp_adapter *adapter) |
147 | { | 158 | { |
148 | struct zfcp_adapter *adapter = (struct zfcp_adapter *) data; | 159 | /* close queues to ensure that buffers are not accessed by adapter */ |
149 | unsigned long flags; | 160 | zfcp_close_qdio(adapter); |
150 | 161 | zfcp_fsf_req_dismiss_all(adapter); | |
151 | ZFCP_LOG_NORMAL("warning: SCSI error recovery timed out. " | 162 | /* reset FSF request sequence number */ |
152 | "Restarting all operations on the adapter %s\n", | 163 | adapter->fsf_req_seq_no = 0; |
153 | zfcp_get_busid_by_adapter(adapter)); | 164 | /* all ports and units are closed */ |
154 | debug_text_event(adapter->erp_dbf, 1, "eh_lmem_tout"); | 165 | zfcp_erp_modify_adapter_status(adapter, |
166 | ZFCP_STATUS_COMMON_OPEN, ZFCP_CLEAR); | ||
167 | } | ||
155 | 168 | ||
156 | write_lock_irqsave(&adapter->erp_lock, flags); | 169 | /** |
157 | if (atomic_test_mask(ZFCP_STATUS_ADAPTER_ERP_PENDING, | 170 | * zfcp_fsf_request_timeout_handler - called if a request timed out |
158 | &adapter->status)) { | 171 | * @data: pointer to adapter for handler function |
159 | zfcp_erp_modify_adapter_status(adapter, | 172 | * |
160 | ZFCP_STATUS_COMMON_UNBLOCKED|ZFCP_STATUS_COMMON_OPEN, | 173 | * This function needs to be called if requests (ELS, Generic Service, |
161 | ZFCP_CLEAR); | 174 | * or SCSI commands) exceed a certain time limit. The assumption is |
162 | zfcp_erp_action_dismiss_adapter(adapter); | 175 | * that after the time limit the adapter get stuck. So we trigger a reopen of |
163 | write_unlock_irqrestore(&adapter->erp_lock, flags); | 176 | * the adapter. |
164 | /* dismiss all pending requests including requests for ERP */ | 177 | */ |
165 | zfcp_fsf_req_dismiss_all(adapter); | 178 | static void zfcp_fsf_request_timeout_handler(unsigned long data) |
166 | adapter->fsf_req_seq_no = 0; | 179 | { |
167 | } else | 180 | struct zfcp_adapter *adapter = (struct zfcp_adapter *) data; |
168 | write_unlock_irqrestore(&adapter->erp_lock, flags); | ||
169 | zfcp_erp_adapter_reopen(adapter, 0); | 181 | zfcp_erp_adapter_reopen(adapter, 0); |
170 | } | 182 | } |
171 | 183 | ||
184 | void zfcp_fsf_start_timer(struct zfcp_fsf_req *fsf_req, unsigned long timeout) | ||
185 | { | ||
186 | fsf_req->timer.function = zfcp_fsf_request_timeout_handler; | ||
187 | fsf_req->timer.data = (unsigned long) fsf_req->adapter; | ||
188 | fsf_req->timer.expires = timeout; | ||
189 | add_timer(&fsf_req->timer); | ||
190 | } | ||
191 | |||
172 | /* | 192 | /* |
173 | * function: | 193 | * function: |
174 | * | 194 | * |
@@ -282,7 +302,6 @@ zfcp_erp_adisc(struct zfcp_port *port) | |||
282 | struct zfcp_ls_adisc *adisc; | 302 | struct zfcp_ls_adisc *adisc; |
283 | void *address = NULL; | 303 | void *address = NULL; |
284 | int retval = 0; | 304 | int retval = 0; |
285 | struct timer_list *timer; | ||
286 | 305 | ||
287 | send_els = kzalloc(sizeof(struct zfcp_send_els), GFP_ATOMIC); | 306 | send_els = kzalloc(sizeof(struct zfcp_send_els), GFP_ATOMIC); |
288 | if (send_els == NULL) | 307 | if (send_els == NULL) |
@@ -329,22 +348,11 @@ zfcp_erp_adisc(struct zfcp_port *port) | |||
329 | (wwn_t) adisc->wwnn, adisc->hard_nport_id, | 348 | (wwn_t) adisc->wwnn, adisc->hard_nport_id, |
330 | adisc->nport_id); | 349 | adisc->nport_id); |
331 | 350 | ||
332 | timer = kmalloc(sizeof(struct timer_list), GFP_ATOMIC); | ||
333 | if (!timer) | ||
334 | goto nomem; | ||
335 | |||
336 | init_timer(timer); | ||
337 | timer->function = zfcp_fsf_request_timeout_handler; | ||
338 | timer->data = (unsigned long) adapter; | ||
339 | timer->expires = ZFCP_FSF_REQUEST_TIMEOUT; | ||
340 | send_els->timer = timer; | ||
341 | |||
342 | retval = zfcp_fsf_send_els(send_els); | 351 | retval = zfcp_fsf_send_els(send_els); |
343 | if (retval != 0) { | 352 | if (retval != 0) { |
344 | ZFCP_LOG_NORMAL("error: initiation of Send ELS failed for port " | 353 | ZFCP_LOG_NORMAL("error: initiation of Send ELS failed for port " |
345 | "0x%08x on adapter %s\n", send_els->d_id, | 354 | "0x%08x on adapter %s\n", send_els->d_id, |
346 | zfcp_get_busid_by_adapter(adapter)); | 355 | zfcp_get_busid_by_adapter(adapter)); |
347 | del_timer(send_els->timer); | ||
348 | goto freemem; | 356 | goto freemem; |
349 | } | 357 | } |
350 | 358 | ||
@@ -356,7 +364,6 @@ zfcp_erp_adisc(struct zfcp_port *port) | |||
356 | if (address != NULL) | 364 | if (address != NULL) |
357 | __free_pages(send_els->req->page, 0); | 365 | __free_pages(send_els->req->page, 0); |
358 | if (send_els != NULL) { | 366 | if (send_els != NULL) { |
359 | kfree(send_els->timer); | ||
360 | kfree(send_els->req); | 367 | kfree(send_els->req); |
361 | kfree(send_els->resp); | 368 | kfree(send_els->resp); |
362 | kfree(send_els); | 369 | kfree(send_els); |
@@ -382,9 +389,6 @@ zfcp_erp_adisc_handler(unsigned long data) | |||
382 | struct zfcp_ls_adisc_acc *adisc; | 389 | struct zfcp_ls_adisc_acc *adisc; |
383 | 390 | ||
384 | send_els = (struct zfcp_send_els *) data; | 391 | send_els = (struct zfcp_send_els *) data; |
385 | |||
386 | del_timer(send_els->timer); | ||
387 | |||
388 | adapter = send_els->adapter; | 392 | adapter = send_els->adapter; |
389 | port = send_els->port; | 393 | port = send_els->port; |
390 | d_id = send_els->d_id; | 394 | d_id = send_els->d_id; |
@@ -433,7 +437,6 @@ zfcp_erp_adisc_handler(unsigned long data) | |||
433 | out: | 437 | out: |
434 | zfcp_port_put(port); | 438 | zfcp_port_put(port); |
435 | __free_pages(send_els->req->page, 0); | 439 | __free_pages(send_els->req->page, 0); |
436 | kfree(send_els->timer); | ||
437 | kfree(send_els->req); | 440 | kfree(send_els->req); |
438 | kfree(send_els->resp); | 441 | kfree(send_els->resp); |
439 | kfree(send_els); | 442 | kfree(send_els); |
@@ -909,8 +912,6 @@ static void zfcp_erp_async_handler_nolock(struct zfcp_erp_action *erp_action, | |||
909 | debug_text_event(adapter->erp_dbf, 2, "a_asyh_ex"); | 912 | debug_text_event(adapter->erp_dbf, 2, "a_asyh_ex"); |
910 | debug_event(adapter->erp_dbf, 2, &erp_action->action, | 913 | debug_event(adapter->erp_dbf, 2, &erp_action->action, |
911 | sizeof (int)); | 914 | sizeof (int)); |
912 | if (!(set_mask & ZFCP_STATUS_ERP_TIMEDOUT)) | ||
913 | del_timer(&erp_action->timer); | ||
914 | erp_action->status |= set_mask; | 915 | erp_action->status |= set_mask; |
915 | zfcp_erp_action_ready(erp_action); | 916 | zfcp_erp_action_ready(erp_action); |
916 | } else { | 917 | } else { |
@@ -957,8 +958,7 @@ zfcp_erp_memwait_handler(unsigned long data) | |||
957 | * action gets an appropriate flag and will be processed | 958 | * action gets an appropriate flag and will be processed |
958 | * accordingly | 959 | * accordingly |
959 | */ | 960 | */ |
960 | static void | 961 | void zfcp_erp_timeout_handler(unsigned long data) |
961 | zfcp_erp_timeout_handler(unsigned long data) | ||
962 | { | 962 | { |
963 | struct zfcp_erp_action *erp_action = (struct zfcp_erp_action *) data; | 963 | struct zfcp_erp_action *erp_action = (struct zfcp_erp_action *) data; |
964 | struct zfcp_adapter *adapter = erp_action->adapter; | 964 | struct zfcp_adapter *adapter = erp_action->adapter; |
@@ -1934,8 +1934,7 @@ zfcp_erp_adapter_strategy_generic(struct zfcp_erp_action *erp_action, int close) | |||
1934 | &erp_action->adapter->status); | 1934 | &erp_action->adapter->status); |
1935 | 1935 | ||
1936 | failed_openfcp: | 1936 | failed_openfcp: |
1937 | zfcp_erp_adapter_strategy_close_qdio(erp_action); | 1937 | zfcp_close_fsf(erp_action->adapter); |
1938 | zfcp_erp_adapter_strategy_close_fsf(erp_action); | ||
1939 | failed_qdio: | 1938 | failed_qdio: |
1940 | out: | 1939 | out: |
1941 | return retval; | 1940 | return retval; |
@@ -2040,59 +2039,6 @@ zfcp_erp_adapter_strategy_open_qdio(struct zfcp_erp_action *erp_action) | |||
2040 | return retval; | 2039 | return retval; |
2041 | } | 2040 | } |
2042 | 2041 | ||
2043 | /** | ||
2044 | * zfcp_erp_adapter_strategy_close_qdio - close qdio queues for an adapter | ||
2045 | */ | ||
2046 | static void | ||
2047 | zfcp_erp_adapter_strategy_close_qdio(struct zfcp_erp_action *erp_action) | ||
2048 | { | ||
2049 | int first_used; | ||
2050 | int used_count; | ||
2051 | struct zfcp_adapter *adapter = erp_action->adapter; | ||
2052 | |||
2053 | if (!atomic_test_mask(ZFCP_STATUS_ADAPTER_QDIOUP, &adapter->status)) { | ||
2054 | ZFCP_LOG_DEBUG("error: attempt to shut down inactive QDIO " | ||
2055 | "queues on adapter %s\n", | ||
2056 | zfcp_get_busid_by_adapter(adapter)); | ||
2057 | return; | ||
2058 | } | ||
2059 | |||
2060 | /* | ||
2061 | * Get queue_lock and clear QDIOUP flag. Thus it's guaranteed that | ||
2062 | * do_QDIO won't be called while qdio_shutdown is in progress. | ||
2063 | */ | ||
2064 | write_lock_irq(&adapter->request_queue.queue_lock); | ||
2065 | atomic_clear_mask(ZFCP_STATUS_ADAPTER_QDIOUP, &adapter->status); | ||
2066 | write_unlock_irq(&adapter->request_queue.queue_lock); | ||
2067 | |||
2068 | debug_text_event(adapter->erp_dbf, 3, "qdio_down2a"); | ||
2069 | while (qdio_shutdown(adapter->ccw_device, | ||
2070 | QDIO_FLAG_CLEANUP_USING_CLEAR) == -EINPROGRESS) | ||
2071 | msleep(1000); | ||
2072 | debug_text_event(adapter->erp_dbf, 3, "qdio_down2b"); | ||
2073 | |||
2074 | /* | ||
2075 | * First we had to stop QDIO operation. | ||
2076 | * Now it is safe to take the following actions. | ||
2077 | */ | ||
2078 | |||
2079 | /* Cleanup only necessary when there are unacknowledged buffers */ | ||
2080 | if (atomic_read(&adapter->request_queue.free_count) | ||
2081 | < QDIO_MAX_BUFFERS_PER_Q) { | ||
2082 | first_used = (adapter->request_queue.free_index + | ||
2083 | atomic_read(&adapter->request_queue.free_count)) | ||
2084 | % QDIO_MAX_BUFFERS_PER_Q; | ||
2085 | used_count = QDIO_MAX_BUFFERS_PER_Q - | ||
2086 | atomic_read(&adapter->request_queue.free_count); | ||
2087 | zfcp_qdio_zero_sbals(adapter->request_queue.buffer, | ||
2088 | first_used, used_count); | ||
2089 | } | ||
2090 | adapter->response_queue.free_index = 0; | ||
2091 | atomic_set(&adapter->response_queue.free_count, 0); | ||
2092 | adapter->request_queue.free_index = 0; | ||
2093 | atomic_set(&adapter->request_queue.free_count, 0); | ||
2094 | adapter->request_queue.distance_from_int = 0; | ||
2095 | } | ||
2096 | 2042 | ||
2097 | static int | 2043 | static int |
2098 | zfcp_erp_adapter_strategy_open_fsf(struct zfcp_erp_action *erp_action) | 2044 | zfcp_erp_adapter_strategy_open_fsf(struct zfcp_erp_action *erp_action) |
@@ -2127,7 +2073,6 @@ zfcp_erp_adapter_strategy_open_fsf_xconfig(struct zfcp_erp_action *erp_action) | |||
2127 | write_lock_irq(&adapter->erp_lock); | 2073 | write_lock_irq(&adapter->erp_lock); |
2128 | zfcp_erp_action_to_running(erp_action); | 2074 | zfcp_erp_action_to_running(erp_action); |
2129 | write_unlock_irq(&adapter->erp_lock); | 2075 | write_unlock_irq(&adapter->erp_lock); |
2130 | zfcp_erp_timeout_init(erp_action); | ||
2131 | if (zfcp_fsf_exchange_config_data(erp_action)) { | 2076 | if (zfcp_fsf_exchange_config_data(erp_action)) { |
2132 | retval = ZFCP_ERP_FAILED; | 2077 | retval = ZFCP_ERP_FAILED; |
2133 | debug_text_event(adapter->erp_dbf, 5, "a_fstx_xf"); | 2078 | debug_text_event(adapter->erp_dbf, 5, "a_fstx_xf"); |
@@ -2196,7 +2141,6 @@ zfcp_erp_adapter_strategy_open_fsf_xport(struct zfcp_erp_action *erp_action) | |||
2196 | zfcp_erp_action_to_running(erp_action); | 2141 | zfcp_erp_action_to_running(erp_action); |
2197 | write_unlock_irq(&adapter->erp_lock); | 2142 | write_unlock_irq(&adapter->erp_lock); |
2198 | 2143 | ||
2199 | zfcp_erp_timeout_init(erp_action); | ||
2200 | ret = zfcp_fsf_exchange_port_data(erp_action, adapter, NULL); | 2144 | ret = zfcp_fsf_exchange_port_data(erp_action, adapter, NULL); |
2201 | if (ret == -EOPNOTSUPP) { | 2145 | if (ret == -EOPNOTSUPP) { |
2202 | debug_text_event(adapter->erp_dbf, 3, "a_xport_notsupp"); | 2146 | debug_text_event(adapter->erp_dbf, 3, "a_xport_notsupp"); |
@@ -2248,27 +2192,6 @@ zfcp_erp_adapter_strategy_open_fsf_statusread(struct zfcp_erp_action | |||
2248 | return retval; | 2192 | return retval; |
2249 | } | 2193 | } |
2250 | 2194 | ||
2251 | /** | ||
2252 | * zfcp_erp_adapter_strategy_close_fsf - stop FSF operations for an adapter | ||
2253 | */ | ||
2254 | static void | ||
2255 | zfcp_erp_adapter_strategy_close_fsf(struct zfcp_erp_action *erp_action) | ||
2256 | { | ||
2257 | struct zfcp_adapter *adapter = erp_action->adapter; | ||
2258 | |||
2259 | /* | ||
2260 | * wake waiting initiators of requests, | ||
2261 | * return SCSI commands (with error status), | ||
2262 | * clean up all requests (synchronously) | ||
2263 | */ | ||
2264 | zfcp_fsf_req_dismiss_all(adapter); | ||
2265 | /* reset FSF request sequence number */ | ||
2266 | adapter->fsf_req_seq_no = 0; | ||
2267 | /* all ports and units are closed */ | ||
2268 | zfcp_erp_modify_adapter_status(adapter, | ||
2269 | ZFCP_STATUS_COMMON_OPEN, ZFCP_CLEAR); | ||
2270 | } | ||
2271 | |||
2272 | /* | 2195 | /* |
2273 | * function: | 2196 | * function: |
2274 | * | 2197 | * |
@@ -2605,7 +2528,6 @@ zfcp_erp_port_forced_strategy_close(struct zfcp_erp_action *erp_action) | |||
2605 | struct zfcp_adapter *adapter = erp_action->adapter; | 2528 | struct zfcp_adapter *adapter = erp_action->adapter; |
2606 | struct zfcp_port *port = erp_action->port; | 2529 | struct zfcp_port *port = erp_action->port; |
2607 | 2530 | ||
2608 | zfcp_erp_timeout_init(erp_action); | ||
2609 | retval = zfcp_fsf_close_physical_port(erp_action); | 2531 | retval = zfcp_fsf_close_physical_port(erp_action); |
2610 | if (retval == -ENOMEM) { | 2532 | if (retval == -ENOMEM) { |
2611 | debug_text_event(adapter->erp_dbf, 5, "o_pfstc_nomem"); | 2533 | debug_text_event(adapter->erp_dbf, 5, "o_pfstc_nomem"); |
@@ -2662,7 +2584,6 @@ zfcp_erp_port_strategy_close(struct zfcp_erp_action *erp_action) | |||
2662 | struct zfcp_adapter *adapter = erp_action->adapter; | 2584 | struct zfcp_adapter *adapter = erp_action->adapter; |
2663 | struct zfcp_port *port = erp_action->port; | 2585 | struct zfcp_port *port = erp_action->port; |
2664 | 2586 | ||
2665 | zfcp_erp_timeout_init(erp_action); | ||
2666 | retval = zfcp_fsf_close_port(erp_action); | 2587 | retval = zfcp_fsf_close_port(erp_action); |
2667 | if (retval == -ENOMEM) { | 2588 | if (retval == -ENOMEM) { |
2668 | debug_text_event(adapter->erp_dbf, 5, "p_pstc_nomem"); | 2589 | debug_text_event(adapter->erp_dbf, 5, "p_pstc_nomem"); |
@@ -2700,7 +2621,6 @@ zfcp_erp_port_strategy_open_port(struct zfcp_erp_action *erp_action) | |||
2700 | struct zfcp_adapter *adapter = erp_action->adapter; | 2621 | struct zfcp_adapter *adapter = erp_action->adapter; |
2701 | struct zfcp_port *port = erp_action->port; | 2622 | struct zfcp_port *port = erp_action->port; |
2702 | 2623 | ||
2703 | zfcp_erp_timeout_init(erp_action); | ||
2704 | retval = zfcp_fsf_open_port(erp_action); | 2624 | retval = zfcp_fsf_open_port(erp_action); |
2705 | if (retval == -ENOMEM) { | 2625 | if (retval == -ENOMEM) { |
2706 | debug_text_event(adapter->erp_dbf, 5, "p_psto_nomem"); | 2626 | debug_text_event(adapter->erp_dbf, 5, "p_psto_nomem"); |
@@ -2738,7 +2658,6 @@ zfcp_erp_port_strategy_open_common_lookup(struct zfcp_erp_action *erp_action) | |||
2738 | struct zfcp_adapter *adapter = erp_action->adapter; | 2658 | struct zfcp_adapter *adapter = erp_action->adapter; |
2739 | struct zfcp_port *port = erp_action->port; | 2659 | struct zfcp_port *port = erp_action->port; |
2740 | 2660 | ||
2741 | zfcp_erp_timeout_init(erp_action); | ||
2742 | retval = zfcp_ns_gid_pn_request(erp_action); | 2661 | retval = zfcp_ns_gid_pn_request(erp_action); |
2743 | if (retval == -ENOMEM) { | 2662 | if (retval == -ENOMEM) { |
2744 | debug_text_event(adapter->erp_dbf, 5, "p_pstn_nomem"); | 2663 | debug_text_event(adapter->erp_dbf, 5, "p_pstn_nomem"); |
@@ -2864,7 +2783,6 @@ zfcp_erp_unit_strategy_close(struct zfcp_erp_action *erp_action) | |||
2864 | struct zfcp_adapter *adapter = erp_action->adapter; | 2783 | struct zfcp_adapter *adapter = erp_action->adapter; |
2865 | struct zfcp_unit *unit = erp_action->unit; | 2784 | struct zfcp_unit *unit = erp_action->unit; |
2866 | 2785 | ||
2867 | zfcp_erp_timeout_init(erp_action); | ||
2868 | retval = zfcp_fsf_close_unit(erp_action); | 2786 | retval = zfcp_fsf_close_unit(erp_action); |
2869 | if (retval == -ENOMEM) { | 2787 | if (retval == -ENOMEM) { |
2870 | debug_text_event(adapter->erp_dbf, 5, "u_ustc_nomem"); | 2788 | debug_text_event(adapter->erp_dbf, 5, "u_ustc_nomem"); |
@@ -2905,7 +2823,6 @@ zfcp_erp_unit_strategy_open(struct zfcp_erp_action *erp_action) | |||
2905 | struct zfcp_adapter *adapter = erp_action->adapter; | 2823 | struct zfcp_adapter *adapter = erp_action->adapter; |
2906 | struct zfcp_unit *unit = erp_action->unit; | 2824 | struct zfcp_unit *unit = erp_action->unit; |
2907 | 2825 | ||
2908 | zfcp_erp_timeout_init(erp_action); | ||
2909 | retval = zfcp_fsf_open_unit(erp_action); | 2826 | retval = zfcp_fsf_open_unit(erp_action); |
2910 | if (retval == -ENOMEM) { | 2827 | if (retval == -ENOMEM) { |
2911 | debug_text_event(adapter->erp_dbf, 5, "u_usto_nomem"); | 2828 | debug_text_event(adapter->erp_dbf, 5, "u_usto_nomem"); |
@@ -2930,14 +2847,13 @@ zfcp_erp_unit_strategy_open(struct zfcp_erp_action *erp_action) | |||
2930 | return retval; | 2847 | return retval; |
2931 | } | 2848 | } |
2932 | 2849 | ||
2933 | static inline void | 2850 | void zfcp_erp_start_timer(struct zfcp_fsf_req *fsf_req) |
2934 | zfcp_erp_timeout_init(struct zfcp_erp_action *erp_action) | ||
2935 | { | 2851 | { |
2936 | init_timer(&erp_action->timer); | 2852 | BUG_ON(!fsf_req->erp_action); |
2937 | erp_action->timer.function = zfcp_erp_timeout_handler; | 2853 | fsf_req->timer.function = zfcp_erp_timeout_handler; |
2938 | erp_action->timer.data = (unsigned long) erp_action; | 2854 | fsf_req->timer.data = (unsigned long) fsf_req->erp_action; |
2939 | /* jiffies will be added in zfcp_fsf_req_send */ | 2855 | fsf_req->timer.expires = jiffies + ZFCP_ERP_FSFREQ_TIMEOUT; |
2940 | erp_action->timer.expires = ZFCP_ERP_FSFREQ_TIMEOUT; | 2856 | add_timer(&fsf_req->timer); |
2941 | } | 2857 | } |
2942 | 2858 | ||
2943 | /* | 2859 | /* |
diff --git a/drivers/s390/scsi/zfcp_ext.h b/drivers/s390/scsi/zfcp_ext.h index 710ebbf89929..3125a42a6343 100644 --- a/drivers/s390/scsi/zfcp_ext.h +++ b/drivers/s390/scsi/zfcp_ext.h | |||
@@ -87,8 +87,8 @@ extern int zfcp_fsf_exchange_port_data(struct zfcp_erp_action *, | |||
87 | struct fsf_qtcb_bottom_port *); | 87 | struct fsf_qtcb_bottom_port *); |
88 | extern int zfcp_fsf_control_file(struct zfcp_adapter *, struct zfcp_fsf_req **, | 88 | extern int zfcp_fsf_control_file(struct zfcp_adapter *, struct zfcp_fsf_req **, |
89 | u32, u32, struct zfcp_sg_list *); | 89 | u32, u32, struct zfcp_sg_list *); |
90 | extern void zfcp_fsf_request_timeout_handler(unsigned long); | 90 | extern void zfcp_fsf_start_timer(struct zfcp_fsf_req *, unsigned long); |
91 | extern void zfcp_fsf_scsi_er_timeout_handler(unsigned long); | 91 | extern void zfcp_erp_start_timer(struct zfcp_fsf_req *); |
92 | extern int zfcp_fsf_req_dismiss_all(struct zfcp_adapter *); | 92 | extern int zfcp_fsf_req_dismiss_all(struct zfcp_adapter *); |
93 | extern int zfcp_fsf_status_read(struct zfcp_adapter *, int); | 93 | extern int zfcp_fsf_status_read(struct zfcp_adapter *, int); |
94 | extern int zfcp_fsf_req_create(struct zfcp_adapter *, u32, int, mempool_t *, | 94 | extern int zfcp_fsf_req_create(struct zfcp_adapter *, u32, int, mempool_t *, |
@@ -98,8 +98,7 @@ extern int zfcp_fsf_send_ct(struct zfcp_send_ct *, mempool_t *, | |||
98 | extern int zfcp_fsf_send_els(struct zfcp_send_els *); | 98 | extern int zfcp_fsf_send_els(struct zfcp_send_els *); |
99 | extern int zfcp_fsf_send_fcp_command_task(struct zfcp_adapter *, | 99 | extern int zfcp_fsf_send_fcp_command_task(struct zfcp_adapter *, |
100 | struct zfcp_unit *, | 100 | struct zfcp_unit *, |
101 | struct scsi_cmnd *, | 101 | struct scsi_cmnd *, int, int); |
102 | struct timer_list*, int); | ||
103 | extern int zfcp_fsf_req_complete(struct zfcp_fsf_req *); | 102 | extern int zfcp_fsf_req_complete(struct zfcp_fsf_req *); |
104 | extern void zfcp_fsf_incoming_els(struct zfcp_fsf_req *); | 103 | extern void zfcp_fsf_incoming_els(struct zfcp_fsf_req *); |
105 | extern void zfcp_fsf_req_free(struct zfcp_fsf_req *); | 104 | extern void zfcp_fsf_req_free(struct zfcp_fsf_req *); |
@@ -123,13 +122,11 @@ extern char *zfcp_get_fcp_rsp_info_ptr(struct fcp_rsp_iu *); | |||
123 | extern void set_host_byte(u32 *, char); | 122 | extern void set_host_byte(u32 *, char); |
124 | extern void set_driver_byte(u32 *, char); | 123 | extern void set_driver_byte(u32 *, char); |
125 | extern char *zfcp_get_fcp_sns_info_ptr(struct fcp_rsp_iu *); | 124 | extern char *zfcp_get_fcp_sns_info_ptr(struct fcp_rsp_iu *); |
126 | extern void zfcp_fsf_start_scsi_er_timer(struct zfcp_adapter *); | ||
127 | extern fcp_dl_t zfcp_get_fcp_dl(struct fcp_cmnd_iu *); | 125 | extern fcp_dl_t zfcp_get_fcp_dl(struct fcp_cmnd_iu *); |
128 | 126 | ||
129 | extern int zfcp_scsi_command_async(struct zfcp_adapter *,struct zfcp_unit *, | 127 | extern int zfcp_scsi_command_async(struct zfcp_adapter *,struct zfcp_unit *, |
130 | struct scsi_cmnd *, struct timer_list *); | 128 | struct scsi_cmnd *, int); |
131 | extern int zfcp_scsi_command_sync(struct zfcp_unit *, struct scsi_cmnd *, | 129 | extern int zfcp_scsi_command_sync(struct zfcp_unit *, struct scsi_cmnd *, int); |
132 | struct timer_list *); | ||
133 | extern struct fc_function_template zfcp_transport_functions; | 130 | extern struct fc_function_template zfcp_transport_functions; |
134 | 131 | ||
135 | /******************************** ERP ****************************************/ | 132 | /******************************** ERP ****************************************/ |
diff --git a/drivers/s390/scsi/zfcp_fsf.c b/drivers/s390/scsi/zfcp_fsf.c index a66b5193b70e..277826cdd0c8 100644 --- a/drivers/s390/scsi/zfcp_fsf.c +++ b/drivers/s390/scsi/zfcp_fsf.c | |||
@@ -42,7 +42,7 @@ static inline int zfcp_fsf_req_sbal_check( | |||
42 | static inline int zfcp_use_one_sbal( | 42 | static inline int zfcp_use_one_sbal( |
43 | struct scatterlist *, int, struct scatterlist *, int); | 43 | struct scatterlist *, int, struct scatterlist *, int); |
44 | static struct zfcp_fsf_req *zfcp_fsf_req_alloc(mempool_t *, int); | 44 | static struct zfcp_fsf_req *zfcp_fsf_req_alloc(mempool_t *, int); |
45 | static int zfcp_fsf_req_send(struct zfcp_fsf_req *, struct timer_list *); | 45 | static int zfcp_fsf_req_send(struct zfcp_fsf_req *); |
46 | static int zfcp_fsf_protstatus_eval(struct zfcp_fsf_req *); | 46 | static int zfcp_fsf_protstatus_eval(struct zfcp_fsf_req *); |
47 | static int zfcp_fsf_fsfstatus_eval(struct zfcp_fsf_req *); | 47 | static int zfcp_fsf_fsfstatus_eval(struct zfcp_fsf_req *); |
48 | static int zfcp_fsf_fsfstatus_qual_eval(struct zfcp_fsf_req *); | 48 | static int zfcp_fsf_fsfstatus_qual_eval(struct zfcp_fsf_req *); |
@@ -225,8 +225,10 @@ zfcp_fsf_req_complete(struct zfcp_fsf_req *fsf_req) | |||
225 | */ | 225 | */ |
226 | zfcp_fsf_status_read_handler(fsf_req); | 226 | zfcp_fsf_status_read_handler(fsf_req); |
227 | goto out; | 227 | goto out; |
228 | } else | 228 | } else { |
229 | del_timer(&fsf_req->timer); | ||
229 | zfcp_fsf_protstatus_eval(fsf_req); | 230 | zfcp_fsf_protstatus_eval(fsf_req); |
231 | } | ||
230 | 232 | ||
231 | /* | 233 | /* |
232 | * fsf_req may be deleted due to waking up functions, so | 234 | * fsf_req may be deleted due to waking up functions, so |
@@ -785,8 +787,7 @@ zfcp_fsf_status_read(struct zfcp_adapter *adapter, int req_flags) | |||
785 | sbale->addr = (void *) status_buffer; | 787 | sbale->addr = (void *) status_buffer; |
786 | sbale->length = sizeof(struct fsf_status_read_buffer); | 788 | sbale->length = sizeof(struct fsf_status_read_buffer); |
787 | 789 | ||
788 | /* start QDIO request for this FSF request */ | 790 | retval = zfcp_fsf_req_send(fsf_req); |
789 | retval = zfcp_fsf_req_send(fsf_req, NULL); | ||
790 | if (retval) { | 791 | if (retval) { |
791 | ZFCP_LOG_DEBUG("error: Could not set-up unsolicited status " | 792 | ZFCP_LOG_DEBUG("error: Could not set-up unsolicited status " |
792 | "environment.\n"); | 793 | "environment.\n"); |
@@ -1112,8 +1113,8 @@ zfcp_fsf_abort_fcp_command(unsigned long old_req_id, | |||
1112 | struct zfcp_unit *unit, int req_flags) | 1113 | struct zfcp_unit *unit, int req_flags) |
1113 | { | 1114 | { |
1114 | volatile struct qdio_buffer_element *sbale; | 1115 | volatile struct qdio_buffer_element *sbale; |
1115 | unsigned long lock_flags; | ||
1116 | struct zfcp_fsf_req *fsf_req = NULL; | 1116 | struct zfcp_fsf_req *fsf_req = NULL; |
1117 | unsigned long lock_flags; | ||
1117 | int retval = 0; | 1118 | int retval = 0; |
1118 | 1119 | ||
1119 | /* setup new FSF request */ | 1120 | /* setup new FSF request */ |
@@ -1143,12 +1144,9 @@ zfcp_fsf_abort_fcp_command(unsigned long old_req_id, | |||
1143 | /* set handle of request which should be aborted */ | 1144 | /* set handle of request which should be aborted */ |
1144 | fsf_req->qtcb->bottom.support.req_handle = (u64) old_req_id; | 1145 | fsf_req->qtcb->bottom.support.req_handle = (u64) old_req_id; |
1145 | 1146 | ||
1146 | /* start QDIO request for this FSF request */ | 1147 | zfcp_fsf_start_timer(fsf_req, ZFCP_SCSI_ER_TIMEOUT); |
1147 | 1148 | retval = zfcp_fsf_req_send(fsf_req); | |
1148 | zfcp_fsf_start_scsi_er_timer(adapter); | ||
1149 | retval = zfcp_fsf_req_send(fsf_req, NULL); | ||
1150 | if (retval) { | 1149 | if (retval) { |
1151 | del_timer(&adapter->scsi_er_timer); | ||
1152 | ZFCP_LOG_INFO("error: Failed to send abort command request " | 1150 | ZFCP_LOG_INFO("error: Failed to send abort command request " |
1153 | "on adapter %s, port 0x%016Lx, unit 0x%016Lx\n", | 1151 | "on adapter %s, port 0x%016Lx, unit 0x%016Lx\n", |
1154 | zfcp_get_busid_by_adapter(adapter), | 1152 | zfcp_get_busid_by_adapter(adapter), |
@@ -1184,8 +1182,6 @@ zfcp_fsf_abort_fcp_command_handler(struct zfcp_fsf_req *new_fsf_req) | |||
1184 | unsigned char status_qual = | 1182 | unsigned char status_qual = |
1185 | new_fsf_req->qtcb->header.fsf_status_qual.word[0]; | 1183 | new_fsf_req->qtcb->header.fsf_status_qual.word[0]; |
1186 | 1184 | ||
1187 | del_timer(&new_fsf_req->adapter->scsi_er_timer); | ||
1188 | |||
1189 | if (new_fsf_req->status & ZFCP_STATUS_FSFREQ_ERROR) { | 1185 | if (new_fsf_req->status & ZFCP_STATUS_FSFREQ_ERROR) { |
1190 | /* do not set ZFCP_STATUS_FSFREQ_ABORTSUCCEEDED */ | 1186 | /* do not set ZFCP_STATUS_FSFREQ_ABORTSUCCEEDED */ |
1191 | goto skip_fsfstatus; | 1187 | goto skip_fsfstatus; |
@@ -1391,11 +1387,6 @@ zfcp_fsf_send_ct(struct zfcp_send_ct *ct, mempool_t *pool, | |||
1391 | goto failed_req; | 1387 | goto failed_req; |
1392 | } | 1388 | } |
1393 | 1389 | ||
1394 | if (erp_action != NULL) { | ||
1395 | erp_action->fsf_req = fsf_req; | ||
1396 | fsf_req->erp_action = erp_action; | ||
1397 | } | ||
1398 | |||
1399 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); | 1390 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); |
1400 | if (zfcp_use_one_sbal(ct->req, ct->req_count, | 1391 | if (zfcp_use_one_sbal(ct->req, ct->req_count, |
1401 | ct->resp, ct->resp_count)){ | 1392 | ct->resp, ct->resp_count)){ |
@@ -1462,8 +1453,14 @@ zfcp_fsf_send_ct(struct zfcp_send_ct *ct, mempool_t *pool, | |||
1462 | 1453 | ||
1463 | zfcp_san_dbf_event_ct_request(fsf_req); | 1454 | zfcp_san_dbf_event_ct_request(fsf_req); |
1464 | 1455 | ||
1465 | /* start QDIO request for this FSF request */ | 1456 | if (erp_action) { |
1466 | ret = zfcp_fsf_req_send(fsf_req, ct->timer); | 1457 | erp_action->fsf_req = fsf_req; |
1458 | fsf_req->erp_action = erp_action; | ||
1459 | zfcp_erp_start_timer(fsf_req); | ||
1460 | } else | ||
1461 | zfcp_fsf_start_timer(fsf_req, ZFCP_FSF_REQUEST_TIMEOUT); | ||
1462 | |||
1463 | ret = zfcp_fsf_req_send(fsf_req); | ||
1467 | if (ret) { | 1464 | if (ret) { |
1468 | ZFCP_LOG_DEBUG("error: initiation of CT request failed " | 1465 | ZFCP_LOG_DEBUG("error: initiation of CT request failed " |
1469 | "(adapter %s, port 0x%016Lx)\n", | 1466 | "(adapter %s, port 0x%016Lx)\n", |
@@ -1760,8 +1757,8 @@ zfcp_fsf_send_els(struct zfcp_send_els *els) | |||
1760 | 1757 | ||
1761 | zfcp_san_dbf_event_els_request(fsf_req); | 1758 | zfcp_san_dbf_event_els_request(fsf_req); |
1762 | 1759 | ||
1763 | /* start QDIO request for this FSF request */ | 1760 | zfcp_fsf_start_timer(fsf_req, ZFCP_FSF_REQUEST_TIMEOUT); |
1764 | ret = zfcp_fsf_req_send(fsf_req, els->timer); | 1761 | ret = zfcp_fsf_req_send(fsf_req); |
1765 | if (ret) { | 1762 | if (ret) { |
1766 | ZFCP_LOG_DEBUG("error: initiation of ELS request failed " | 1763 | ZFCP_LOG_DEBUG("error: initiation of ELS request failed " |
1767 | "(adapter %s, port d_id: 0x%08x)\n", | 1764 | "(adapter %s, port d_id: 0x%08x)\n", |
@@ -1958,6 +1955,7 @@ int | |||
1958 | zfcp_fsf_exchange_config_data(struct zfcp_erp_action *erp_action) | 1955 | zfcp_fsf_exchange_config_data(struct zfcp_erp_action *erp_action) |
1959 | { | 1956 | { |
1960 | volatile struct qdio_buffer_element *sbale; | 1957 | volatile struct qdio_buffer_element *sbale; |
1958 | struct zfcp_fsf_req *fsf_req; | ||
1961 | unsigned long lock_flags; | 1959 | unsigned long lock_flags; |
1962 | int retval = 0; | 1960 | int retval = 0; |
1963 | 1961 | ||
@@ -1966,7 +1964,7 @@ zfcp_fsf_exchange_config_data(struct zfcp_erp_action *erp_action) | |||
1966 | FSF_QTCB_EXCHANGE_CONFIG_DATA, | 1964 | FSF_QTCB_EXCHANGE_CONFIG_DATA, |
1967 | ZFCP_REQ_AUTO_CLEANUP, | 1965 | ZFCP_REQ_AUTO_CLEANUP, |
1968 | erp_action->adapter->pool.fsf_req_erp, | 1966 | erp_action->adapter->pool.fsf_req_erp, |
1969 | &lock_flags, &(erp_action->fsf_req)); | 1967 | &lock_flags, &fsf_req); |
1970 | if (retval < 0) { | 1968 | if (retval < 0) { |
1971 | ZFCP_LOG_INFO("error: Could not create exchange configuration " | 1969 | ZFCP_LOG_INFO("error: Could not create exchange configuration " |
1972 | "data request for adapter %s.\n", | 1970 | "data request for adapter %s.\n", |
@@ -1974,26 +1972,26 @@ zfcp_fsf_exchange_config_data(struct zfcp_erp_action *erp_action) | |||
1974 | goto out; | 1972 | goto out; |
1975 | } | 1973 | } |
1976 | 1974 | ||
1977 | sbale = zfcp_qdio_sbale_req(erp_action->fsf_req, | 1975 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); |
1978 | erp_action->fsf_req->sbal_curr, 0); | ||
1979 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; | 1976 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; |
1980 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; | 1977 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; |
1981 | 1978 | ||
1982 | erp_action->fsf_req->erp_action = erp_action; | 1979 | fsf_req->qtcb->bottom.config.feature_selection = |
1983 | erp_action->fsf_req->qtcb->bottom.config.feature_selection = | ||
1984 | FSF_FEATURE_CFDC | | 1980 | FSF_FEATURE_CFDC | |
1985 | FSF_FEATURE_LUN_SHARING | | 1981 | FSF_FEATURE_LUN_SHARING | |
1986 | FSF_FEATURE_NOTIFICATION_LOST | | 1982 | FSF_FEATURE_NOTIFICATION_LOST | |
1987 | FSF_FEATURE_UPDATE_ALERT; | 1983 | FSF_FEATURE_UPDATE_ALERT; |
1984 | fsf_req->erp_action = erp_action; | ||
1985 | erp_action->fsf_req = fsf_req; | ||
1988 | 1986 | ||
1989 | /* start QDIO request for this FSF request */ | 1987 | zfcp_erp_start_timer(fsf_req); |
1990 | retval = zfcp_fsf_req_send(erp_action->fsf_req, &erp_action->timer); | 1988 | retval = zfcp_fsf_req_send(fsf_req); |
1991 | if (retval) { | 1989 | if (retval) { |
1992 | ZFCP_LOG_INFO | 1990 | ZFCP_LOG_INFO |
1993 | ("error: Could not send exchange configuration data " | 1991 | ("error: Could not send exchange configuration data " |
1994 | "command on the adapter %s\n", | 1992 | "command on the adapter %s\n", |
1995 | zfcp_get_busid_by_adapter(erp_action->adapter)); | 1993 | zfcp_get_busid_by_adapter(erp_action->adapter)); |
1996 | zfcp_fsf_req_free(erp_action->fsf_req); | 1994 | zfcp_fsf_req_free(fsf_req); |
1997 | erp_action->fsf_req = NULL; | 1995 | erp_action->fsf_req = NULL; |
1998 | goto out; | 1996 | goto out; |
1999 | } | 1997 | } |
@@ -2223,10 +2221,9 @@ zfcp_fsf_exchange_port_data(struct zfcp_erp_action *erp_action, | |||
2223 | struct fsf_qtcb_bottom_port *data) | 2221 | struct fsf_qtcb_bottom_port *data) |
2224 | { | 2222 | { |
2225 | volatile struct qdio_buffer_element *sbale; | 2223 | volatile struct qdio_buffer_element *sbale; |
2226 | int retval = 0; | ||
2227 | unsigned long lock_flags; | ||
2228 | struct zfcp_fsf_req *fsf_req; | 2224 | struct zfcp_fsf_req *fsf_req; |
2229 | struct timer_list *timer; | 2225 | unsigned long lock_flags; |
2226 | int retval = 0; | ||
2230 | 2227 | ||
2231 | if (!(adapter->adapter_features & FSF_FEATURE_HBAAPI_MANAGEMENT)) { | 2228 | if (!(adapter->adapter_features & FSF_FEATURE_HBAAPI_MANAGEMENT)) { |
2232 | ZFCP_LOG_INFO("error: exchange port data " | 2229 | ZFCP_LOG_INFO("error: exchange port data " |
@@ -2259,22 +2256,11 @@ zfcp_fsf_exchange_port_data(struct zfcp_erp_action *erp_action, | |||
2259 | if (erp_action) { | 2256 | if (erp_action) { |
2260 | erp_action->fsf_req = fsf_req; | 2257 | erp_action->fsf_req = fsf_req; |
2261 | fsf_req->erp_action = erp_action; | 2258 | fsf_req->erp_action = erp_action; |
2262 | timer = &erp_action->timer; | 2259 | zfcp_erp_start_timer(fsf_req); |
2263 | } else { | 2260 | } else |
2264 | timer = kmalloc(sizeof(struct timer_list), GFP_ATOMIC); | 2261 | zfcp_fsf_start_timer(fsf_req, ZFCP_FSF_REQUEST_TIMEOUT); |
2265 | if (!timer) { | ||
2266 | write_unlock_irqrestore(&adapter->request_queue.queue_lock, | ||
2267 | lock_flags); | ||
2268 | zfcp_fsf_req_free(fsf_req); | ||
2269 | return -ENOMEM; | ||
2270 | } | ||
2271 | init_timer(timer); | ||
2272 | timer->function = zfcp_fsf_request_timeout_handler; | ||
2273 | timer->data = (unsigned long) adapter; | ||
2274 | timer->expires = ZFCP_FSF_REQUEST_TIMEOUT; | ||
2275 | } | ||
2276 | 2262 | ||
2277 | retval = zfcp_fsf_req_send(fsf_req, timer); | 2263 | retval = zfcp_fsf_req_send(fsf_req); |
2278 | if (retval) { | 2264 | if (retval) { |
2279 | ZFCP_LOG_INFO("error: Could not send an exchange port data " | 2265 | ZFCP_LOG_INFO("error: Could not send an exchange port data " |
2280 | "command on the adapter %s\n", | 2266 | "command on the adapter %s\n", |
@@ -2282,8 +2268,6 @@ zfcp_fsf_exchange_port_data(struct zfcp_erp_action *erp_action, | |||
2282 | zfcp_fsf_req_free(fsf_req); | 2268 | zfcp_fsf_req_free(fsf_req); |
2283 | if (erp_action) | 2269 | if (erp_action) |
2284 | erp_action->fsf_req = NULL; | 2270 | erp_action->fsf_req = NULL; |
2285 | else | ||
2286 | kfree(timer); | ||
2287 | write_unlock_irqrestore(&adapter->request_queue.queue_lock, | 2271 | write_unlock_irqrestore(&adapter->request_queue.queue_lock, |
2288 | lock_flags); | 2272 | lock_flags); |
2289 | return retval; | 2273 | return retval; |
@@ -2294,9 +2278,7 @@ zfcp_fsf_exchange_port_data(struct zfcp_erp_action *erp_action, | |||
2294 | if (!erp_action) { | 2278 | if (!erp_action) { |
2295 | wait_event(fsf_req->completion_wq, | 2279 | wait_event(fsf_req->completion_wq, |
2296 | fsf_req->status & ZFCP_STATUS_FSFREQ_COMPLETED); | 2280 | fsf_req->status & ZFCP_STATUS_FSFREQ_COMPLETED); |
2297 | del_timer_sync(timer); | ||
2298 | zfcp_fsf_req_free(fsf_req); | 2281 | zfcp_fsf_req_free(fsf_req); |
2299 | kfree(timer); | ||
2300 | } | 2282 | } |
2301 | return retval; | 2283 | return retval; |
2302 | } | 2284 | } |
@@ -2378,6 +2360,7 @@ int | |||
2378 | zfcp_fsf_open_port(struct zfcp_erp_action *erp_action) | 2360 | zfcp_fsf_open_port(struct zfcp_erp_action *erp_action) |
2379 | { | 2361 | { |
2380 | volatile struct qdio_buffer_element *sbale; | 2362 | volatile struct qdio_buffer_element *sbale; |
2363 | struct zfcp_fsf_req *fsf_req; | ||
2381 | unsigned long lock_flags; | 2364 | unsigned long lock_flags; |
2382 | int retval = 0; | 2365 | int retval = 0; |
2383 | 2366 | ||
@@ -2386,7 +2369,7 @@ zfcp_fsf_open_port(struct zfcp_erp_action *erp_action) | |||
2386 | FSF_QTCB_OPEN_PORT_WITH_DID, | 2369 | FSF_QTCB_OPEN_PORT_WITH_DID, |
2387 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, | 2370 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, |
2388 | erp_action->adapter->pool.fsf_req_erp, | 2371 | erp_action->adapter->pool.fsf_req_erp, |
2389 | &lock_flags, &(erp_action->fsf_req)); | 2372 | &lock_flags, &fsf_req); |
2390 | if (retval < 0) { | 2373 | if (retval < 0) { |
2391 | ZFCP_LOG_INFO("error: Could not create open port request " | 2374 | ZFCP_LOG_INFO("error: Could not create open port request " |
2392 | "for port 0x%016Lx on adapter %s.\n", | 2375 | "for port 0x%016Lx on adapter %s.\n", |
@@ -2395,24 +2378,24 @@ zfcp_fsf_open_port(struct zfcp_erp_action *erp_action) | |||
2395 | goto out; | 2378 | goto out; |
2396 | } | 2379 | } |
2397 | 2380 | ||
2398 | sbale = zfcp_qdio_sbale_req(erp_action->fsf_req, | 2381 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); |
2399 | erp_action->fsf_req->sbal_curr, 0); | ||
2400 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; | 2382 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; |
2401 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; | 2383 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; |
2402 | 2384 | ||
2403 | erp_action->fsf_req->qtcb->bottom.support.d_id = erp_action->port->d_id; | 2385 | fsf_req->qtcb->bottom.support.d_id = erp_action->port->d_id; |
2404 | atomic_set_mask(ZFCP_STATUS_COMMON_OPENING, &erp_action->port->status); | 2386 | atomic_set_mask(ZFCP_STATUS_COMMON_OPENING, &erp_action->port->status); |
2405 | erp_action->fsf_req->data = (unsigned long) erp_action->port; | 2387 | fsf_req->data = (unsigned long) erp_action->port; |
2406 | erp_action->fsf_req->erp_action = erp_action; | 2388 | fsf_req->erp_action = erp_action; |
2389 | erp_action->fsf_req = fsf_req; | ||
2407 | 2390 | ||
2408 | /* start QDIO request for this FSF request */ | 2391 | zfcp_erp_start_timer(fsf_req); |
2409 | retval = zfcp_fsf_req_send(erp_action->fsf_req, &erp_action->timer); | 2392 | retval = zfcp_fsf_req_send(fsf_req); |
2410 | if (retval) { | 2393 | if (retval) { |
2411 | ZFCP_LOG_INFO("error: Could not send open port request for " | 2394 | ZFCP_LOG_INFO("error: Could not send open port request for " |
2412 | "port 0x%016Lx on adapter %s.\n", | 2395 | "port 0x%016Lx on adapter %s.\n", |
2413 | erp_action->port->wwpn, | 2396 | erp_action->port->wwpn, |
2414 | zfcp_get_busid_by_adapter(erp_action->adapter)); | 2397 | zfcp_get_busid_by_adapter(erp_action->adapter)); |
2415 | zfcp_fsf_req_free(erp_action->fsf_req); | 2398 | zfcp_fsf_req_free(fsf_req); |
2416 | erp_action->fsf_req = NULL; | 2399 | erp_action->fsf_req = NULL; |
2417 | goto out; | 2400 | goto out; |
2418 | } | 2401 | } |
@@ -2634,6 +2617,7 @@ int | |||
2634 | zfcp_fsf_close_port(struct zfcp_erp_action *erp_action) | 2617 | zfcp_fsf_close_port(struct zfcp_erp_action *erp_action) |
2635 | { | 2618 | { |
2636 | volatile struct qdio_buffer_element *sbale; | 2619 | volatile struct qdio_buffer_element *sbale; |
2620 | struct zfcp_fsf_req *fsf_req; | ||
2637 | unsigned long lock_flags; | 2621 | unsigned long lock_flags; |
2638 | int retval = 0; | 2622 | int retval = 0; |
2639 | 2623 | ||
@@ -2642,7 +2626,7 @@ zfcp_fsf_close_port(struct zfcp_erp_action *erp_action) | |||
2642 | FSF_QTCB_CLOSE_PORT, | 2626 | FSF_QTCB_CLOSE_PORT, |
2643 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, | 2627 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, |
2644 | erp_action->adapter->pool.fsf_req_erp, | 2628 | erp_action->adapter->pool.fsf_req_erp, |
2645 | &lock_flags, &(erp_action->fsf_req)); | 2629 | &lock_flags, &fsf_req); |
2646 | if (retval < 0) { | 2630 | if (retval < 0) { |
2647 | ZFCP_LOG_INFO("error: Could not create a close port request " | 2631 | ZFCP_LOG_INFO("error: Could not create a close port request " |
2648 | "for port 0x%016Lx on adapter %s.\n", | 2632 | "for port 0x%016Lx on adapter %s.\n", |
@@ -2651,25 +2635,25 @@ zfcp_fsf_close_port(struct zfcp_erp_action *erp_action) | |||
2651 | goto out; | 2635 | goto out; |
2652 | } | 2636 | } |
2653 | 2637 | ||
2654 | sbale = zfcp_qdio_sbale_req(erp_action->fsf_req, | 2638 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); |
2655 | erp_action->fsf_req->sbal_curr, 0); | ||
2656 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; | 2639 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; |
2657 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; | 2640 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; |
2658 | 2641 | ||
2659 | atomic_set_mask(ZFCP_STATUS_COMMON_CLOSING, &erp_action->port->status); | 2642 | atomic_set_mask(ZFCP_STATUS_COMMON_CLOSING, &erp_action->port->status); |
2660 | erp_action->fsf_req->data = (unsigned long) erp_action->port; | 2643 | fsf_req->data = (unsigned long) erp_action->port; |
2661 | erp_action->fsf_req->erp_action = erp_action; | 2644 | fsf_req->erp_action = erp_action; |
2662 | erp_action->fsf_req->qtcb->header.port_handle = | 2645 | fsf_req->qtcb->header.port_handle = erp_action->port->handle; |
2663 | erp_action->port->handle; | 2646 | fsf_req->erp_action = erp_action; |
2664 | 2647 | erp_action->fsf_req = fsf_req; | |
2665 | /* start QDIO request for this FSF request */ | 2648 | |
2666 | retval = zfcp_fsf_req_send(erp_action->fsf_req, &erp_action->timer); | 2649 | zfcp_erp_start_timer(fsf_req); |
2650 | retval = zfcp_fsf_req_send(fsf_req); | ||
2667 | if (retval) { | 2651 | if (retval) { |
2668 | ZFCP_LOG_INFO("error: Could not send a close port request for " | 2652 | ZFCP_LOG_INFO("error: Could not send a close port request for " |
2669 | "port 0x%016Lx on adapter %s.\n", | 2653 | "port 0x%016Lx on adapter %s.\n", |
2670 | erp_action->port->wwpn, | 2654 | erp_action->port->wwpn, |
2671 | zfcp_get_busid_by_adapter(erp_action->adapter)); | 2655 | zfcp_get_busid_by_adapter(erp_action->adapter)); |
2672 | zfcp_fsf_req_free(erp_action->fsf_req); | 2656 | zfcp_fsf_req_free(fsf_req); |
2673 | erp_action->fsf_req = NULL; | 2657 | erp_action->fsf_req = NULL; |
2674 | goto out; | 2658 | goto out; |
2675 | } | 2659 | } |
@@ -2766,16 +2750,17 @@ zfcp_fsf_close_port_handler(struct zfcp_fsf_req *fsf_req) | |||
2766 | int | 2750 | int |
2767 | zfcp_fsf_close_physical_port(struct zfcp_erp_action *erp_action) | 2751 | zfcp_fsf_close_physical_port(struct zfcp_erp_action *erp_action) |
2768 | { | 2752 | { |
2769 | int retval = 0; | ||
2770 | unsigned long lock_flags; | ||
2771 | volatile struct qdio_buffer_element *sbale; | 2753 | volatile struct qdio_buffer_element *sbale; |
2754 | struct zfcp_fsf_req *fsf_req; | ||
2755 | unsigned long lock_flags; | ||
2756 | int retval = 0; | ||
2772 | 2757 | ||
2773 | /* setup new FSF request */ | 2758 | /* setup new FSF request */ |
2774 | retval = zfcp_fsf_req_create(erp_action->adapter, | 2759 | retval = zfcp_fsf_req_create(erp_action->adapter, |
2775 | FSF_QTCB_CLOSE_PHYSICAL_PORT, | 2760 | FSF_QTCB_CLOSE_PHYSICAL_PORT, |
2776 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, | 2761 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, |
2777 | erp_action->adapter->pool.fsf_req_erp, | 2762 | erp_action->adapter->pool.fsf_req_erp, |
2778 | &lock_flags, &erp_action->fsf_req); | 2763 | &lock_flags, &fsf_req); |
2779 | if (retval < 0) { | 2764 | if (retval < 0) { |
2780 | ZFCP_LOG_INFO("error: Could not create close physical port " | 2765 | ZFCP_LOG_INFO("error: Could not create close physical port " |
2781 | "request (adapter %s, port 0x%016Lx)\n", | 2766 | "request (adapter %s, port 0x%016Lx)\n", |
@@ -2785,8 +2770,7 @@ zfcp_fsf_close_physical_port(struct zfcp_erp_action *erp_action) | |||
2785 | goto out; | 2770 | goto out; |
2786 | } | 2771 | } |
2787 | 2772 | ||
2788 | sbale = zfcp_qdio_sbale_req(erp_action->fsf_req, | 2773 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); |
2789 | erp_action->fsf_req->sbal_curr, 0); | ||
2790 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; | 2774 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; |
2791 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; | 2775 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; |
2792 | 2776 | ||
@@ -2794,20 +2778,19 @@ zfcp_fsf_close_physical_port(struct zfcp_erp_action *erp_action) | |||
2794 | atomic_set_mask(ZFCP_STATUS_PORT_PHYS_CLOSING, | 2778 | atomic_set_mask(ZFCP_STATUS_PORT_PHYS_CLOSING, |
2795 | &erp_action->port->status); | 2779 | &erp_action->port->status); |
2796 | /* save a pointer to this port */ | 2780 | /* save a pointer to this port */ |
2797 | erp_action->fsf_req->data = (unsigned long) erp_action->port; | 2781 | fsf_req->data = (unsigned long) erp_action->port; |
2798 | /* port to be closed */ | 2782 | fsf_req->qtcb->header.port_handle = erp_action->port->handle; |
2799 | erp_action->fsf_req->qtcb->header.port_handle = | 2783 | fsf_req->erp_action = erp_action; |
2800 | erp_action->port->handle; | 2784 | erp_action->fsf_req = fsf_req; |
2801 | erp_action->fsf_req->erp_action = erp_action; | 2785 | |
2802 | 2786 | zfcp_erp_start_timer(fsf_req); | |
2803 | /* start QDIO request for this FSF request */ | 2787 | retval = zfcp_fsf_req_send(fsf_req); |
2804 | retval = zfcp_fsf_req_send(erp_action->fsf_req, &erp_action->timer); | ||
2805 | if (retval) { | 2788 | if (retval) { |
2806 | ZFCP_LOG_INFO("error: Could not send close physical port " | 2789 | ZFCP_LOG_INFO("error: Could not send close physical port " |
2807 | "request (adapter %s, port 0x%016Lx)\n", | 2790 | "request (adapter %s, port 0x%016Lx)\n", |
2808 | zfcp_get_busid_by_adapter(erp_action->adapter), | 2791 | zfcp_get_busid_by_adapter(erp_action->adapter), |
2809 | erp_action->port->wwpn); | 2792 | erp_action->port->wwpn); |
2810 | zfcp_fsf_req_free(erp_action->fsf_req); | 2793 | zfcp_fsf_req_free(fsf_req); |
2811 | erp_action->fsf_req = NULL; | 2794 | erp_action->fsf_req = NULL; |
2812 | goto out; | 2795 | goto out; |
2813 | } | 2796 | } |
@@ -2972,6 +2955,7 @@ int | |||
2972 | zfcp_fsf_open_unit(struct zfcp_erp_action *erp_action) | 2955 | zfcp_fsf_open_unit(struct zfcp_erp_action *erp_action) |
2973 | { | 2956 | { |
2974 | volatile struct qdio_buffer_element *sbale; | 2957 | volatile struct qdio_buffer_element *sbale; |
2958 | struct zfcp_fsf_req *fsf_req; | ||
2975 | unsigned long lock_flags; | 2959 | unsigned long lock_flags; |
2976 | int retval = 0; | 2960 | int retval = 0; |
2977 | 2961 | ||
@@ -2980,7 +2964,7 @@ zfcp_fsf_open_unit(struct zfcp_erp_action *erp_action) | |||
2980 | FSF_QTCB_OPEN_LUN, | 2964 | FSF_QTCB_OPEN_LUN, |
2981 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, | 2965 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, |
2982 | erp_action->adapter->pool.fsf_req_erp, | 2966 | erp_action->adapter->pool.fsf_req_erp, |
2983 | &lock_flags, &(erp_action->fsf_req)); | 2967 | &lock_flags, &fsf_req); |
2984 | if (retval < 0) { | 2968 | if (retval < 0) { |
2985 | ZFCP_LOG_INFO("error: Could not create open unit request for " | 2969 | ZFCP_LOG_INFO("error: Could not create open unit request for " |
2986 | "unit 0x%016Lx on port 0x%016Lx on adapter %s.\n", | 2970 | "unit 0x%016Lx on port 0x%016Lx on adapter %s.\n", |
@@ -2990,24 +2974,22 @@ zfcp_fsf_open_unit(struct zfcp_erp_action *erp_action) | |||
2990 | goto out; | 2974 | goto out; |
2991 | } | 2975 | } |
2992 | 2976 | ||
2993 | sbale = zfcp_qdio_sbale_req(erp_action->fsf_req, | 2977 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); |
2994 | erp_action->fsf_req->sbal_curr, 0); | ||
2995 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; | 2978 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; |
2996 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; | 2979 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; |
2997 | 2980 | ||
2998 | erp_action->fsf_req->qtcb->header.port_handle = | 2981 | fsf_req->qtcb->header.port_handle = erp_action->port->handle; |
2999 | erp_action->port->handle; | 2982 | fsf_req->qtcb->bottom.support.fcp_lun = erp_action->unit->fcp_lun; |
3000 | erp_action->fsf_req->qtcb->bottom.support.fcp_lun = | ||
3001 | erp_action->unit->fcp_lun; | ||
3002 | if (!(erp_action->adapter->connection_features & FSF_FEATURE_NPIV_MODE)) | 2983 | if (!(erp_action->adapter->connection_features & FSF_FEATURE_NPIV_MODE)) |
3003 | erp_action->fsf_req->qtcb->bottom.support.option = | 2984 | fsf_req->qtcb->bottom.support.option = |
3004 | FSF_OPEN_LUN_SUPPRESS_BOXING; | 2985 | FSF_OPEN_LUN_SUPPRESS_BOXING; |
3005 | atomic_set_mask(ZFCP_STATUS_COMMON_OPENING, &erp_action->unit->status); | 2986 | atomic_set_mask(ZFCP_STATUS_COMMON_OPENING, &erp_action->unit->status); |
3006 | erp_action->fsf_req->data = (unsigned long) erp_action->unit; | 2987 | fsf_req->data = (unsigned long) erp_action->unit; |
3007 | erp_action->fsf_req->erp_action = erp_action; | 2988 | fsf_req->erp_action = erp_action; |
2989 | erp_action->fsf_req = fsf_req; | ||
3008 | 2990 | ||
3009 | /* start QDIO request for this FSF request */ | 2991 | zfcp_erp_start_timer(fsf_req); |
3010 | retval = zfcp_fsf_req_send(erp_action->fsf_req, &erp_action->timer); | 2992 | retval = zfcp_fsf_req_send(erp_action->fsf_req); |
3011 | if (retval) { | 2993 | if (retval) { |
3012 | ZFCP_LOG_INFO("error: Could not send an open unit request " | 2994 | ZFCP_LOG_INFO("error: Could not send an open unit request " |
3013 | "on the adapter %s, port 0x%016Lx for " | 2995 | "on the adapter %s, port 0x%016Lx for " |
@@ -3015,7 +2997,7 @@ zfcp_fsf_open_unit(struct zfcp_erp_action *erp_action) | |||
3015 | zfcp_get_busid_by_adapter(erp_action->adapter), | 2997 | zfcp_get_busid_by_adapter(erp_action->adapter), |
3016 | erp_action->port->wwpn, | 2998 | erp_action->port->wwpn, |
3017 | erp_action->unit->fcp_lun); | 2999 | erp_action->unit->fcp_lun); |
3018 | zfcp_fsf_req_free(erp_action->fsf_req); | 3000 | zfcp_fsf_req_free(fsf_req); |
3019 | erp_action->fsf_req = NULL; | 3001 | erp_action->fsf_req = NULL; |
3020 | goto out; | 3002 | goto out; |
3021 | } | 3003 | } |
@@ -3308,6 +3290,7 @@ int | |||
3308 | zfcp_fsf_close_unit(struct zfcp_erp_action *erp_action) | 3290 | zfcp_fsf_close_unit(struct zfcp_erp_action *erp_action) |
3309 | { | 3291 | { |
3310 | volatile struct qdio_buffer_element *sbale; | 3292 | volatile struct qdio_buffer_element *sbale; |
3293 | struct zfcp_fsf_req *fsf_req; | ||
3311 | unsigned long lock_flags; | 3294 | unsigned long lock_flags; |
3312 | int retval = 0; | 3295 | int retval = 0; |
3313 | 3296 | ||
@@ -3316,7 +3299,7 @@ zfcp_fsf_close_unit(struct zfcp_erp_action *erp_action) | |||
3316 | FSF_QTCB_CLOSE_LUN, | 3299 | FSF_QTCB_CLOSE_LUN, |
3317 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, | 3300 | ZFCP_WAIT_FOR_SBAL | ZFCP_REQ_AUTO_CLEANUP, |
3318 | erp_action->adapter->pool.fsf_req_erp, | 3301 | erp_action->adapter->pool.fsf_req_erp, |
3319 | &lock_flags, &(erp_action->fsf_req)); | 3302 | &lock_flags, &fsf_req); |
3320 | if (retval < 0) { | 3303 | if (retval < 0) { |
3321 | ZFCP_LOG_INFO("error: Could not create close unit request for " | 3304 | ZFCP_LOG_INFO("error: Could not create close unit request for " |
3322 | "unit 0x%016Lx on port 0x%016Lx on adapter %s.\n", | 3305 | "unit 0x%016Lx on port 0x%016Lx on adapter %s.\n", |
@@ -3326,27 +3309,26 @@ zfcp_fsf_close_unit(struct zfcp_erp_action *erp_action) | |||
3326 | goto out; | 3309 | goto out; |
3327 | } | 3310 | } |
3328 | 3311 | ||
3329 | sbale = zfcp_qdio_sbale_req(erp_action->fsf_req, | 3312 | sbale = zfcp_qdio_sbale_req(fsf_req, fsf_req->sbal_curr, 0); |
3330 | erp_action->fsf_req->sbal_curr, 0); | ||
3331 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; | 3313 | sbale[0].flags |= SBAL_FLAGS0_TYPE_READ; |
3332 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; | 3314 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; |
3333 | 3315 | ||
3334 | erp_action->fsf_req->qtcb->header.port_handle = | 3316 | fsf_req->qtcb->header.port_handle = erp_action->port->handle; |
3335 | erp_action->port->handle; | 3317 | fsf_req->qtcb->header.lun_handle = erp_action->unit->handle; |
3336 | erp_action->fsf_req->qtcb->header.lun_handle = erp_action->unit->handle; | ||
3337 | atomic_set_mask(ZFCP_STATUS_COMMON_CLOSING, &erp_action->unit->status); | 3318 | atomic_set_mask(ZFCP_STATUS_COMMON_CLOSING, &erp_action->unit->status); |
3338 | erp_action->fsf_req->data = (unsigned long) erp_action->unit; | 3319 | fsf_req->data = (unsigned long) erp_action->unit; |
3339 | erp_action->fsf_req->erp_action = erp_action; | 3320 | fsf_req->erp_action = erp_action; |
3321 | erp_action->fsf_req = fsf_req; | ||
3340 | 3322 | ||
3341 | /* start QDIO request for this FSF request */ | 3323 | zfcp_erp_start_timer(fsf_req); |
3342 | retval = zfcp_fsf_req_send(erp_action->fsf_req, &erp_action->timer); | 3324 | retval = zfcp_fsf_req_send(erp_action->fsf_req); |
3343 | if (retval) { | 3325 | if (retval) { |
3344 | ZFCP_LOG_INFO("error: Could not send a close unit request for " | 3326 | ZFCP_LOG_INFO("error: Could not send a close unit request for " |
3345 | "unit 0x%016Lx on port 0x%016Lx onadapter %s.\n", | 3327 | "unit 0x%016Lx on port 0x%016Lx onadapter %s.\n", |
3346 | erp_action->unit->fcp_lun, | 3328 | erp_action->unit->fcp_lun, |
3347 | erp_action->port->wwpn, | 3329 | erp_action->port->wwpn, |
3348 | zfcp_get_busid_by_adapter(erp_action->adapter)); | 3330 | zfcp_get_busid_by_adapter(erp_action->adapter)); |
3349 | zfcp_fsf_req_free(erp_action->fsf_req); | 3331 | zfcp_fsf_req_free(fsf_req); |
3350 | erp_action->fsf_req = NULL; | 3332 | erp_action->fsf_req = NULL; |
3351 | goto out; | 3333 | goto out; |
3352 | } | 3334 | } |
@@ -3499,7 +3481,7 @@ int | |||
3499 | zfcp_fsf_send_fcp_command_task(struct zfcp_adapter *adapter, | 3481 | zfcp_fsf_send_fcp_command_task(struct zfcp_adapter *adapter, |
3500 | struct zfcp_unit *unit, | 3482 | struct zfcp_unit *unit, |
3501 | struct scsi_cmnd * scsi_cmnd, | 3483 | struct scsi_cmnd * scsi_cmnd, |
3502 | struct timer_list *timer, int req_flags) | 3484 | int use_timer, int req_flags) |
3503 | { | 3485 | { |
3504 | struct zfcp_fsf_req *fsf_req = NULL; | 3486 | struct zfcp_fsf_req *fsf_req = NULL; |
3505 | struct fcp_cmnd_iu *fcp_cmnd_iu; | 3487 | struct fcp_cmnd_iu *fcp_cmnd_iu; |
@@ -3640,11 +3622,10 @@ zfcp_fsf_send_fcp_command_task(struct zfcp_adapter *adapter, | |||
3640 | ZFCP_HEX_DUMP(ZFCP_LOG_LEVEL_DEBUG, | 3622 | ZFCP_HEX_DUMP(ZFCP_LOG_LEVEL_DEBUG, |
3641 | (char *) scsi_cmnd->cmnd, scsi_cmnd->cmd_len); | 3623 | (char *) scsi_cmnd->cmnd, scsi_cmnd->cmd_len); |
3642 | 3624 | ||
3643 | /* | 3625 | if (use_timer) |
3644 | * start QDIO request for this FSF request | 3626 | zfcp_fsf_start_timer(fsf_req, ZFCP_FSF_REQUEST_TIMEOUT); |
3645 | * covered by an SBALE) | 3627 | |
3646 | */ | 3628 | retval = zfcp_fsf_req_send(fsf_req); |
3647 | retval = zfcp_fsf_req_send(fsf_req, timer); | ||
3648 | if (unlikely(retval < 0)) { | 3629 | if (unlikely(retval < 0)) { |
3649 | ZFCP_LOG_INFO("error: Could not send FCP command request " | 3630 | ZFCP_LOG_INFO("error: Could not send FCP command request " |
3650 | "on adapter %s, port 0x%016Lx, unit 0x%016Lx\n", | 3631 | "on adapter %s, port 0x%016Lx, unit 0x%016Lx\n", |
@@ -3729,11 +3710,9 @@ zfcp_fsf_send_fcp_command_task_management(struct zfcp_adapter *adapter, | |||
3729 | fcp_cmnd_iu->fcp_lun = unit->fcp_lun; | 3710 | fcp_cmnd_iu->fcp_lun = unit->fcp_lun; |
3730 | fcp_cmnd_iu->task_management_flags = tm_flags; | 3711 | fcp_cmnd_iu->task_management_flags = tm_flags; |
3731 | 3712 | ||
3732 | /* start QDIO request for this FSF request */ | 3713 | zfcp_fsf_start_timer(fsf_req, ZFCP_SCSI_ER_TIMEOUT); |
3733 | zfcp_fsf_start_scsi_er_timer(adapter); | 3714 | retval = zfcp_fsf_req_send(fsf_req); |
3734 | retval = zfcp_fsf_req_send(fsf_req, NULL); | ||
3735 | if (retval) { | 3715 | if (retval) { |
3736 | del_timer(&adapter->scsi_er_timer); | ||
3737 | ZFCP_LOG_INFO("error: Could not send an FCP-command (task " | 3716 | ZFCP_LOG_INFO("error: Could not send an FCP-command (task " |
3738 | "management) on adapter %s, port 0x%016Lx for " | 3717 | "management) on adapter %s, port 0x%016Lx for " |
3739 | "unit LUN 0x%016Lx\n", | 3718 | "unit LUN 0x%016Lx\n", |
@@ -4237,7 +4216,6 @@ zfcp_fsf_send_fcp_command_task_management_handler(struct zfcp_fsf_req *fsf_req) | |||
4237 | char *fcp_rsp_info = zfcp_get_fcp_rsp_info_ptr(fcp_rsp_iu); | 4216 | char *fcp_rsp_info = zfcp_get_fcp_rsp_info_ptr(fcp_rsp_iu); |
4238 | struct zfcp_unit *unit = (struct zfcp_unit *) fsf_req->data; | 4217 | struct zfcp_unit *unit = (struct zfcp_unit *) fsf_req->data; |
4239 | 4218 | ||
4240 | del_timer(&fsf_req->adapter->scsi_er_timer); | ||
4241 | if (fsf_req->status & ZFCP_STATUS_FSFREQ_ERROR) { | 4219 | if (fsf_req->status & ZFCP_STATUS_FSFREQ_ERROR) { |
4242 | fsf_req->status |= ZFCP_STATUS_FSFREQ_TMFUNCFAILED; | 4220 | fsf_req->status |= ZFCP_STATUS_FSFREQ_TMFUNCFAILED; |
4243 | goto skip_fsfstatus; | 4221 | goto skip_fsfstatus; |
@@ -4306,7 +4284,6 @@ zfcp_fsf_control_file(struct zfcp_adapter *adapter, | |||
4306 | struct zfcp_fsf_req *fsf_req; | 4284 | struct zfcp_fsf_req *fsf_req; |
4307 | struct fsf_qtcb_bottom_support *bottom; | 4285 | struct fsf_qtcb_bottom_support *bottom; |
4308 | volatile struct qdio_buffer_element *sbale; | 4286 | volatile struct qdio_buffer_element *sbale; |
4309 | struct timer_list *timer; | ||
4310 | unsigned long lock_flags; | 4287 | unsigned long lock_flags; |
4311 | int req_flags = 0; | 4288 | int req_flags = 0; |
4312 | int direction; | 4289 | int direction; |
@@ -4338,12 +4315,6 @@ zfcp_fsf_control_file(struct zfcp_adapter *adapter, | |||
4338 | goto out; | 4315 | goto out; |
4339 | } | 4316 | } |
4340 | 4317 | ||
4341 | timer = kmalloc(sizeof(struct timer_list), GFP_KERNEL); | ||
4342 | if (!timer) { | ||
4343 | retval = -ENOMEM; | ||
4344 | goto out; | ||
4345 | } | ||
4346 | |||
4347 | retval = zfcp_fsf_req_create(adapter, fsf_command, req_flags, | 4318 | retval = zfcp_fsf_req_create(adapter, fsf_command, req_flags, |
4348 | NULL, &lock_flags, &fsf_req); | 4319 | NULL, &lock_flags, &fsf_req); |
4349 | if (retval < 0) { | 4320 | if (retval < 0) { |
@@ -4378,12 +4349,8 @@ zfcp_fsf_control_file(struct zfcp_adapter *adapter, | |||
4378 | } else | 4349 | } else |
4379 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; | 4350 | sbale[1].flags |= SBAL_FLAGS_LAST_ENTRY; |
4380 | 4351 | ||
4381 | init_timer(timer); | 4352 | zfcp_fsf_start_timer(fsf_req, ZFCP_FSF_REQUEST_TIMEOUT); |
4382 | timer->function = zfcp_fsf_request_timeout_handler; | 4353 | retval = zfcp_fsf_req_send(fsf_req); |
4383 | timer->data = (unsigned long) adapter; | ||
4384 | timer->expires = ZFCP_FSF_REQUEST_TIMEOUT; | ||
4385 | |||
4386 | retval = zfcp_fsf_req_send(fsf_req, timer); | ||
4387 | if (retval < 0) { | 4354 | if (retval < 0) { |
4388 | ZFCP_LOG_INFO("initiation of cfdc up/download failed" | 4355 | ZFCP_LOG_INFO("initiation of cfdc up/download failed" |
4389 | "(adapter %s)\n", | 4356 | "(adapter %s)\n", |
@@ -4403,15 +4370,12 @@ zfcp_fsf_control_file(struct zfcp_adapter *adapter, | |||
4403 | fsf_req->status & ZFCP_STATUS_FSFREQ_COMPLETED); | 4370 | fsf_req->status & ZFCP_STATUS_FSFREQ_COMPLETED); |
4404 | 4371 | ||
4405 | *fsf_req_ptr = fsf_req; | 4372 | *fsf_req_ptr = fsf_req; |
4406 | del_timer_sync(timer); | 4373 | goto out; |
4407 | goto free_timer; | ||
4408 | 4374 | ||
4409 | free_fsf_req: | 4375 | free_fsf_req: |
4410 | zfcp_fsf_req_free(fsf_req); | 4376 | zfcp_fsf_req_free(fsf_req); |
4411 | unlock_queue_lock: | 4377 | unlock_queue_lock: |
4412 | write_unlock_irqrestore(&adapter->request_queue.queue_lock, lock_flags); | 4378 | write_unlock_irqrestore(&adapter->request_queue.queue_lock, lock_flags); |
4413 | free_timer: | ||
4414 | kfree(timer); | ||
4415 | out: | 4379 | out: |
4416 | return retval; | 4380 | return retval; |
4417 | } | 4381 | } |
@@ -4688,7 +4652,8 @@ zfcp_fsf_req_create(struct zfcp_adapter *adapter, u32 fsf_cmd, int req_flags, | |||
4688 | adapter->req_no++; | 4652 | adapter->req_no++; |
4689 | fsf_req->req_id = adapter->req_no++; | 4653 | fsf_req->req_id = adapter->req_no++; |
4690 | 4654 | ||
4691 | zfcp_fsf_req_qtcb_init(fsf_req); | 4655 | init_timer(&fsf_req->timer); |
4656 | zfcp_fsf_req_qtcb_init(fsf_req); | ||
4692 | 4657 | ||
4693 | /* initialize waitqueue which may be used to wait on | 4658 | /* initialize waitqueue which may be used to wait on |
4694 | this request completion */ | 4659 | this request completion */ |
@@ -4758,8 +4723,7 @@ zfcp_fsf_req_create(struct zfcp_adapter *adapter, u32 fsf_cmd, int req_flags, | |||
4758 | * returns: 0 - request transfer succesfully started | 4723 | * returns: 0 - request transfer succesfully started |
4759 | * !0 - start of request transfer failed | 4724 | * !0 - start of request transfer failed |
4760 | */ | 4725 | */ |
4761 | static int | 4726 | static int zfcp_fsf_req_send(struct zfcp_fsf_req *fsf_req) |
4762 | zfcp_fsf_req_send(struct zfcp_fsf_req *fsf_req, struct timer_list *timer) | ||
4763 | { | 4727 | { |
4764 | struct zfcp_adapter *adapter; | 4728 | struct zfcp_adapter *adapter; |
4765 | struct zfcp_qdio_queue *req_queue; | 4729 | struct zfcp_qdio_queue *req_queue; |
@@ -4787,12 +4751,6 @@ zfcp_fsf_req_send(struct zfcp_fsf_req *fsf_req, struct timer_list *timer) | |||
4787 | 4751 | ||
4788 | inc_seq_no = (fsf_req->qtcb != NULL); | 4752 | inc_seq_no = (fsf_req->qtcb != NULL); |
4789 | 4753 | ||
4790 | /* figure out expiration time of timeout and start timeout */ | ||
4791 | if (unlikely(timer)) { | ||
4792 | timer->expires += jiffies; | ||
4793 | add_timer(timer); | ||
4794 | } | ||
4795 | |||
4796 | ZFCP_LOG_TRACE("request queue of adapter %s: " | 4754 | ZFCP_LOG_TRACE("request queue of adapter %s: " |
4797 | "next free SBAL is %i, %i free SBALs\n", | 4755 | "next free SBAL is %i, %i free SBALs\n", |
4798 | zfcp_get_busid_by_adapter(adapter), | 4756 | zfcp_get_busid_by_adapter(adapter), |
@@ -4829,12 +4787,7 @@ zfcp_fsf_req_send(struct zfcp_fsf_req *fsf_req, struct timer_list *timer) | |||
4829 | if (unlikely(retval)) { | 4787 | if (unlikely(retval)) { |
4830 | /* Queues are down..... */ | 4788 | /* Queues are down..... */ |
4831 | retval = -EIO; | 4789 | retval = -EIO; |
4832 | /* | 4790 | del_timer(&fsf_req->timer); |
4833 | * FIXME(potential race): | ||
4834 | * timer might be expired (absolutely unlikely) | ||
4835 | */ | ||
4836 | if (timer) | ||
4837 | del_timer(timer); | ||
4838 | spin_lock(&adapter->req_list_lock); | 4791 | spin_lock(&adapter->req_list_lock); |
4839 | zfcp_reqlist_remove(adapter, fsf_req->req_id); | 4792 | zfcp_reqlist_remove(adapter, fsf_req->req_id); |
4840 | spin_unlock(&adapter->req_list_lock); | 4793 | spin_unlock(&adapter->req_list_lock); |
diff --git a/drivers/s390/scsi/zfcp_scsi.c b/drivers/s390/scsi/zfcp_scsi.c index 043ed7c0a7ed..753bb9b2fe74 100644 --- a/drivers/s390/scsi/zfcp_scsi.c +++ b/drivers/s390/scsi/zfcp_scsi.c | |||
@@ -231,7 +231,7 @@ zfcp_scsi_command_fail(struct scsi_cmnd *scpnt, int result) | |||
231 | */ | 231 | */ |
232 | int | 232 | int |
233 | zfcp_scsi_command_async(struct zfcp_adapter *adapter, struct zfcp_unit *unit, | 233 | zfcp_scsi_command_async(struct zfcp_adapter *adapter, struct zfcp_unit *unit, |
234 | struct scsi_cmnd *scpnt, struct timer_list *timer) | 234 | struct scsi_cmnd *scpnt, int use_timer) |
235 | { | 235 | { |
236 | int tmp; | 236 | int tmp; |
237 | int retval; | 237 | int retval; |
@@ -267,7 +267,7 @@ zfcp_scsi_command_async(struct zfcp_adapter *adapter, struct zfcp_unit *unit, | |||
267 | goto out; | 267 | goto out; |
268 | } | 268 | } |
269 | 269 | ||
270 | tmp = zfcp_fsf_send_fcp_command_task(adapter, unit, scpnt, timer, | 270 | tmp = zfcp_fsf_send_fcp_command_task(adapter, unit, scpnt, use_timer, |
271 | ZFCP_REQ_AUTO_CLEANUP); | 271 | ZFCP_REQ_AUTO_CLEANUP); |
272 | 272 | ||
273 | if (unlikely(tmp < 0)) { | 273 | if (unlikely(tmp < 0)) { |
@@ -291,21 +291,22 @@ zfcp_scsi_command_sync_handler(struct scsi_cmnd *scpnt) | |||
291 | * zfcp_scsi_command_sync - send a SCSI command and wait for completion | 291 | * zfcp_scsi_command_sync - send a SCSI command and wait for completion |
292 | * @unit: unit where command is sent to | 292 | * @unit: unit where command is sent to |
293 | * @scpnt: scsi command to be sent | 293 | * @scpnt: scsi command to be sent |
294 | * @timer: timer to be started if request is successfully initiated | 294 | * @use_timer: indicates whether timer should be setup or not |
295 | * Return: 0 | 295 | * Return: 0 |
296 | * | 296 | * |
297 | * Errors are indicated in scpnt->result | 297 | * Errors are indicated in scpnt->result |
298 | */ | 298 | */ |
299 | int | 299 | int |
300 | zfcp_scsi_command_sync(struct zfcp_unit *unit, struct scsi_cmnd *scpnt, | 300 | zfcp_scsi_command_sync(struct zfcp_unit *unit, struct scsi_cmnd *scpnt, |
301 | struct timer_list *timer) | 301 | int use_timer) |
302 | { | 302 | { |
303 | int ret; | 303 | int ret; |
304 | DECLARE_COMPLETION(wait); | 304 | DECLARE_COMPLETION(wait); |
305 | 305 | ||
306 | scpnt->SCp.ptr = (void *) &wait; /* silent re-use */ | 306 | scpnt->SCp.ptr = (void *) &wait; /* silent re-use */ |
307 | scpnt->scsi_done = zfcp_scsi_command_sync_handler; | 307 | scpnt->scsi_done = zfcp_scsi_command_sync_handler; |
308 | ret = zfcp_scsi_command_async(unit->port->adapter, unit, scpnt, timer); | 308 | ret = zfcp_scsi_command_async(unit->port->adapter, unit, scpnt, |
309 | use_timer); | ||
309 | if (ret == 0) | 310 | if (ret == 0) |
310 | wait_for_completion(&wait); | 311 | wait_for_completion(&wait); |
311 | 312 | ||
@@ -341,7 +342,7 @@ zfcp_scsi_queuecommand(struct scsi_cmnd *scpnt, | |||
341 | adapter = (struct zfcp_adapter *) scpnt->device->host->hostdata[0]; | 342 | adapter = (struct zfcp_adapter *) scpnt->device->host->hostdata[0]; |
342 | unit = (struct zfcp_unit *) scpnt->device->hostdata; | 343 | unit = (struct zfcp_unit *) scpnt->device->hostdata; |
343 | 344 | ||
344 | return zfcp_scsi_command_async(adapter, unit, scpnt, NULL); | 345 | return zfcp_scsi_command_async(adapter, unit, scpnt, 0); |
345 | } | 346 | } |
346 | 347 | ||
347 | static struct zfcp_unit * | 348 | static struct zfcp_unit * |
@@ -538,8 +539,6 @@ zfcp_task_management_function(struct zfcp_unit *unit, u8 tm_flags, | |||
538 | 539 | ||
539 | /** | 540 | /** |
540 | * zfcp_scsi_eh_host_reset_handler - handler for host and bus reset | 541 | * zfcp_scsi_eh_host_reset_handler - handler for host and bus reset |
541 | * | ||
542 | * If ERP is already running it will be stopped. | ||
543 | */ | 542 | */ |
544 | int zfcp_scsi_eh_host_reset_handler(struct scsi_cmnd *scpnt) | 543 | int zfcp_scsi_eh_host_reset_handler(struct scsi_cmnd *scpnt) |
545 | { | 544 | { |
@@ -638,16 +637,6 @@ zfcp_adapter_scsi_unregister(struct zfcp_adapter *adapter) | |||
638 | return; | 637 | return; |
639 | } | 638 | } |
640 | 639 | ||
641 | |||
642 | void | ||
643 | zfcp_fsf_start_scsi_er_timer(struct zfcp_adapter *adapter) | ||
644 | { | ||
645 | adapter->scsi_er_timer.function = zfcp_fsf_scsi_er_timeout_handler; | ||
646 | adapter->scsi_er_timer.data = (unsigned long) adapter; | ||
647 | adapter->scsi_er_timer.expires = jiffies + ZFCP_SCSI_ER_TIMEOUT; | ||
648 | add_timer(&adapter->scsi_er_timer); | ||
649 | } | ||
650 | |||
651 | /* | 640 | /* |
652 | * Support functions for FC transport class | 641 | * Support functions for FC transport class |
653 | */ | 642 | */ |