1/* 2 * IBM eServer eHCA Infiniband device driver for Linux on POWER 3 * 4 * Event queue handling 5 * 6 * Authors: Waleri Fomin <fomin@de.ibm.com> 7 * Khadija Souissi <souissi@de.ibm.com> 8 * Reinhard Ernst <rernst@de.ibm.com> 9 * Heiko J Schick <schickhj@de.ibm.com> 10 * Hoang-Nam Nguyen <hnguyen@de.ibm.com> 11 * 12 * 13 * Copyright (c) 2005 IBM Corporation 14 * 15 * All rights reserved. 16 * 17 * This source code is distributed under a dual license of GPL v2.0 and OpenIB 18 * BSD. 19 * 20 * OpenIB BSD License 21 * 22 * Redistribution and use in source and binary forms, with or without 23 * modification, are permitted provided that the following conditions are met: 24 * 25 * Redistributions of source code must retain the above copyright notice, this 26 * list of conditions and the following disclaimer. 27 * 28 * Redistributions in binary form must reproduce the above copyright notice, 29 * this list of conditions and the following disclaimer in the documentation 30 * and/or other materials 31 * provided with the distribution. 32 * 33 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 34 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 35 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 36 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE 37 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 38 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 39 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR 40 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER 41 * IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 42 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 43 * POSSIBILITY OF SUCH DAMAGE. 44 */ 45 46#include "ehca_classes.h" 47#include "ehca_irq.h" 48#include "ehca_iverbs.h" 49#include "ehca_qes.h" 50#include "hcp_if.h" 51#include "ipz_pt_fn.h" 52 53int ehca_create_eq(struct ehca_shca *shca, 54 struct ehca_eq *eq, 55 const enum ehca_eq_type type, const u32 length) 56{ 57 u64 ret; 58 u32 nr_pages; 59 u32 i; 60 void *vpage; 61 struct ib_device *ib_dev = &shca->ib_device; 62 63 spin_lock_init(&eq->spinlock); 64 spin_lock_init(&eq->irq_spinlock); 65 eq->is_initialized = 0; 66 67 if (type != EHCA_EQ && type != EHCA_NEQ) { 68 ehca_err(ib_dev, "Invalid EQ type %x. eq=%p", type, eq); 69 return -EINVAL; 70 } 71 if (!length) { 72 ehca_err(ib_dev, "EQ length must not be zero. eq=%p", eq); 73 return -EINVAL; 74 } 75 76 ret = hipz_h_alloc_resource_eq(shca->ipz_hca_handle, 77 &eq->pf, 78 type, 79 length, 80 &eq->ipz_eq_handle, 81 &eq->length, 82 &nr_pages, &eq->ist); 83 84 if (ret != H_SUCCESS) { 85 ehca_err(ib_dev, "Can't allocate EQ/NEQ. eq=%p", eq); 86 return -EINVAL; 87 } 88 89 ret = ipz_queue_ctor(&eq->ipz_queue, nr_pages, 90 EHCA_PAGESIZE, sizeof(struct ehca_eqe), 0); 91 if (!ret) { 92 ehca_err(ib_dev, "Can't allocate EQ pages eq=%p", eq); 93 goto create_eq_exit1; 94 } 95 96 for (i = 0; i < nr_pages; i++) { 97 u64 rpage; 98 99 if (!(vpage = ipz_qpageit_get_inc(&eq->ipz_queue))) { 100 ret = H_RESOURCE; 101 goto create_eq_exit2; 102 } 103 104 rpage = virt_to_abs(vpage); 105 ret = hipz_h_register_rpage_eq(shca->ipz_hca_handle, 106 eq->ipz_eq_handle, 107 &eq->pf, 108 0, 0, rpage, 1); 109 110 if (i == (nr_pages - 1)) { 111 /* last page */ 112 vpage = ipz_qpageit_get_inc(&eq->ipz_queue); 113 if (ret != H_SUCCESS || vpage) 114 goto create_eq_exit2; 115 } else { 116 if (ret != H_PAGE_REGISTERED || !vpage) 117 goto create_eq_exit2; 118 } 119 } 120 121 ipz_qeit_reset(&eq->ipz_queue); 122 123 /* register interrupt handlers and initialize work queues */ 124 if (type == EHCA_EQ) { 125 ret = ibmebus_request_irq(NULL, eq->ist, ehca_interrupt_eq, 126 IRQF_DISABLED, "ehca_eq", 127 (void *)shca); 128 if (ret < 0) 129 ehca_err(ib_dev, "Can't map interrupt handler."); 130 131 tasklet_init(&eq->interrupt_task, ehca_tasklet_eq, (long)shca); 132 } else if (type == EHCA_NEQ) { 133 ret = ibmebus_request_irq(NULL, eq->ist, ehca_interrupt_neq, 134 IRQF_DISABLED, "ehca_neq", 135 (void *)shca); 136 if (ret < 0) 137 ehca_err(ib_dev, "Can't map interrupt handler."); 138 139 tasklet_init(&eq->interrupt_task, ehca_tasklet_neq, (long)shca); 140 } 141 142 eq->is_initialized = 1; 143 144 return 0; 145 146create_eq_exit2: 147 ipz_queue_dtor(&eq->ipz_queue); 148 149create_eq_exit1: 150 hipz_h_destroy_eq(shca->ipz_hca_handle, eq); 151 152 return -EINVAL; 153} 154 155void *ehca_poll_eq(struct ehca_shca *shca, struct ehca_eq *eq) 156{ 157 unsigned long flags; 158 void *eqe; 159 160 spin_lock_irqsave(&eq->spinlock, flags); 161 eqe = ipz_eqit_eq_get_inc_valid(&eq->ipz_queue); 162 spin_unlock_irqrestore(&eq->spinlock, flags); 163 164 return eqe; 165} 166 167int ehca_destroy_eq(struct ehca_shca *shca, struct ehca_eq *eq) 168{ 169 unsigned long flags; 170 u64 h_ret; 171 172 spin_lock_irqsave(&eq->spinlock, flags); 173 ibmebus_free_irq(NULL, eq->ist, (void *)shca); 174 175 h_ret = hipz_h_destroy_eq(shca->ipz_hca_handle, eq); 176 177 spin_unlock_irqrestore(&eq->spinlock, flags); 178 179 if (h_ret != H_SUCCESS) { 180 ehca_err(&shca->ib_device, "Can't free EQ resources."); 181 return -EINVAL; 182 } 183 ipz_queue_dtor(&eq->ipz_queue); 184 185 return 0; 186} 187