From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from EUR03-VE1-obe.outbound.protection.outlook.com (mail-eopbgr50062.outbound.protection.outlook.com [40.107.5.62]) by dpdk.org (Postfix) with ESMTP id 6A12D1B42D for ; Wed, 10 Oct 2018 09:03:24 +0200 (CEST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=Mellanox.com; s=selector1; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version:X-MS-Exchange-SenderADCheck; bh=QUNPql+IJ/ZkvfCz3GKwPorIO1esfSMlWFu16gOUl+8=; b=WCD+BfCVgejs7pB93qXB72tixHA0ieq/FDHUrMcg8OjFKFMx5lontVfpSEqw8UzkKPYSmZmVnAYvhR8S0YziVy/ctuOGJVV2EQ9J3eCdioi7S8Yeb1vNz3weHObzSGLHYfO/Z+8+exVtfZt2euVai+FxCRiilQDDQbmAsRsgDuM= Received: from DB5PR05MB1254.eurprd05.prod.outlook.com (10.162.157.140) by DB5PR05MB1894.eurprd05.prod.outlook.com (10.166.173.139) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384) id 15.20.1207.28; Wed, 10 Oct 2018 07:03:22 +0000 Received: from DB5PR05MB1254.eurprd05.prod.outlook.com ([fe80::3516:b329:5c35:51a5]) by DB5PR05MB1254.eurprd05.prod.outlook.com ([fe80::3516:b329:5c35:51a5%2]) with mapi id 15.20.1207.029; Wed, 10 Oct 2018 07:03:22 +0000 From: Raslan Darawsheh To: "keith.wiles@intel.com" CC: Thomas Monjalon , "dev@dpdk.org" , Shahaf Shuler , Raslan Darawsheh , Ori Kam , "ferruh.yigit@intel.com" Thread-Topic: [PATCH v5 2/3] net/tap: move fds of Rx/Tx queues to be in process private Thread-Index: AQHUYGdU43WG64osCE+F7rmOSdMuQQ== Date: Wed, 10 Oct 2018 07:03:22 +0000 Message-ID: <1539154988-20652-2-git-send-email-rasland@mellanox.com> References: <1539154988-20652-1-git-send-email-rasland@mellanox.com> In-Reply-To: <1539154988-20652-1-git-send-email-rasland@mellanox.com> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-mailer: git-send-email 2.7.4 x-clientproxiedby: AM5PR0701CA0017.eurprd07.prod.outlook.com (2603:10a6:203:51::27) To DB5PR05MB1254.eurprd05.prod.outlook.com (2a01:111:e400:51cc::12) authentication-results: spf=none (sender IP is ) smtp.mailfrom=rasland@mellanox.com; x-ms-exchange-messagesentrepresentingtype: 1 x-originating-ip: [37.142.13.130] x-ms-publictraffictype: Email x-microsoft-exchange-diagnostics: 1; DB5PR05MB1894; 6:JIdBWkR52GsSVYvnxygkHYmklFm1hw0JH4Jr8665+blGfrMsWtL8hm8YN+9Ceqc6kIC6Bpvqo901fEmokZoBOlHoGUFKM6bNXKwobBfY0EBJfdsr+T+CYB8P1/Qh1vq/vHYPnee1kHZgFIOfWiKSkVdxSVvObaemGCP8o5JjrdtPlYPNmfsN4B2jSrPF3pR1Sva+HYqg7P3wLURzdRnOChAzA684T62LMDyx7xabs5/v2LkxSKp24zzksCPwMZQXqlN19xtguN+xu3E1zUg2vHhUz5rqh6xwp/hSfTLcwlUVw8fRDiBuBy06PBuiW4sENWX21WxHWqNMm3rEp3BJXHVxaa76K40SyGtWHK8SBJnFx6w14MDHwBOkGM1LrlQMPoke/iMIQHqEmUCTzxWuqjcGPbQ4UDqMT8lMolh90zlfV/E7gVhb7qz+DXxZ9IaOJHEDkVi0cQP2R6kvZVOsCw==; 5:Z20HLZo4Alekq+9JsEgx+q7TMv1TKSyr4WSvp7s7q9W7vFoDdU8YtTKVHz1INudMkkySsCaog2B/0+9bs9FQjx9QNkGVUbvEcGDHGJBSRFqmKiulIBY75DCQlhgqjLbLWvkQVYaq01qPRWYraRrHh0YoyKhxPBLIWfNa4fiJQRA=; 7:p0K8lBD8MYvaRr/wiRekMT5LhPdXYNXnsMY1tbvzHJrOYlSop86y6N4QjTTxt1TYDzB0FyHjBUas3ru7gzB00VHx/Rey0WZOTMx7tRt9txG4M8l5jqX1AqxXq/AXGw7eVwVkVKfcm6cRlwmg6GttmrO4SYrRzRWXS88U55LNDOHkPmVCes0stIchKTYNeFIfCxRc3SGsikMFSXrSdw6X3wjkUmMIRelxMhRVjrYGEHHaZQMjZqf0gAqvyxM4keI/ x-ms-office365-filtering-correlation-id: 90b6144b-7b9b-4a60-1841-08d62e7e773b x-ms-office365-filtering-ht: Tenant x-microsoft-antispam: BCL:0; PCL:0; RULEID:(7020095)(4652040)(8989299)(4534185)(4627221)(201703031133081)(201702281549075)(8990200)(5600074)(711020)(4618075)(2017052603328)(7153060)(7193020); SRVR:DB5PR05MB1894; x-ms-traffictypediagnostic: DB5PR05MB1894: x-ld-processed: a652971c-7d2e-4d9b-a6a4-d149256f461b,ExtAddr x-microsoft-antispam-prvs: x-exchange-antispam-report-test: UriScan:; x-ms-exchange-senderadcheck: 1 x-exchange-antispam-report-cfa-test: BCL:0; PCL:0; RULEID:(8211001083)(6040522)(2401047)(5005006)(8121501046)(3002001)(93006095)(93001095)(10201501046)(3231355)(944501410)(52105095)(6055026)(149066)(150057)(6041310)(20161123560045)(20161123562045)(201703131423095)(201702281528075)(20161123555045)(201703061421075)(201703061406153)(20161123564045)(20161123558120)(201708071742011)(7699051); SRVR:DB5PR05MB1894; BCL:0; PCL:0; RULEID:; SRVR:DB5PR05MB1894; x-forefront-prvs: 08213D42D3 x-forefront-antispam-report: SFV:NSPM; SFS:(10009020)(376002)(39860400002)(396003)(366004)(136003)(346002)(189003)(199004)(66066001)(4744004)(305945005)(478600001)(8936002)(71200400001)(71190400001)(14444005)(52116002)(5660300001)(76176011)(316002)(4326008)(7736002)(11346002)(446003)(2900100001)(2616005)(26005)(97736004)(476003)(186003)(386003)(6486002)(99286004)(6436002)(6116002)(3846002)(6512007)(2351001)(2906002)(53936002)(6506007)(81166006)(105586002)(25786009)(81156014)(106356001)(5640700003)(14454004)(68736007)(6916009)(36756003)(2501003)(102836004)(5250100002)(8676002)(86362001)(50226002)(486006)(256004)(54906003); DIR:OUT; SFP:1101; SCL:1; SRVR:DB5PR05MB1894; H:DB5PR05MB1254.eurprd05.prod.outlook.com; FPR:; SPF:None; LANG:en; PTR:InfoNoRecords; MX:1; A:1; received-spf: None (protection.outlook.com: mellanox.com does not designate permitted sender hosts) x-microsoft-antispam-message-info: WCFIjCc/dEMAuIoeCLjnJWmLBjXt8qRvBkwjjJzzZ236AM+J3UM11wsbaXNznVM3vcSeydTYnW49/l5G39sPbnSe8cfuHYGQsYUOQIwEOIwqDwl5uFkobF6Ri8CrcS1Z1ep2mBf+VTRNadNwwXEQVhqhSCax/AeRqCXzw7DDh/3NNCQSwhpHFP+0sTCcR1sMUf+jzj109+kPcvlKgxrDChfan+UydV7NLPfDzVE58a3QCcZMLh5DfDCkvSFLKrth56bGc/nRlWl75oZhbfqQuDmyXP/slhAxa+ZX92PIrlLc5XDgQgsiS/QQp9EX0zM5PH8nOTWkB1yKNR25LJq7SEMgIaMLX6Lbohaf0ijdKDY= spamdiagnosticoutput: 1:99 spamdiagnosticmetadata: NSPM Content-Type: text/plain; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 X-OriginatorOrg: Mellanox.com X-MS-Exchange-CrossTenant-Network-Message-Id: 90b6144b-7b9b-4a60-1841-08d62e7e773b X-MS-Exchange-CrossTenant-originalarrivaltime: 10 Oct 2018 07:03:22.6176 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: a652971c-7d2e-4d9b-a6a4-d149256f461b X-MS-Exchange-Transport-CrossTenantHeadersStamped: DB5PR05MB1894 Subject: [dpdk-dev] [PATCH v5 2/3] net/tap: move fds of Rx/Tx queues to be in process private X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Wed, 10 Oct 2018 07:03:24 -0000 fd's cannot be shared between processes, and each process need to have it's own fd's pointer. Signed-off-by: Raslan Darawsheh --- drivers/net/tap/rte_eth_tap.c | 93 +++++++++++++++++++++++++++++----------= ---- drivers/net/tap/rte_eth_tap.h | 7 +++- drivers/net/tap/tap_flow.c | 3 +- drivers/net/tap/tap_intr.c | 5 ++- 4 files changed, 73 insertions(+), 35 deletions(-) diff --git a/drivers/net/tap/rte_eth_tap.c b/drivers/net/tap/rte_eth_tap.c index edfb7da..3372d54 100644 --- a/drivers/net/tap/rte_eth_tap.c +++ b/drivers/net/tap/rte_eth_tap.c @@ -315,6 +315,7 @@ static uint16_t pmd_rx_burst(void *queue, struct rte_mbuf **bufs, uint16_t nb_pkts) { struct rx_queue *rxq =3D queue; + struct pmd_process_private *process_private; uint16_t num_rx; unsigned long num_rx_bytes =3D 0; uint32_t trigger =3D tap_trigger; @@ -323,6 +324,7 @@ pmd_rx_burst(void *queue, struct rte_mbuf **bufs, uint1= 6_t nb_pkts) return 0; if (trigger) rxq->trigger_seen =3D trigger; + process_private =3D rte_eth_devices[rxq->in_port].process_private; rte_compiler_barrier(); for (num_rx =3D 0; num_rx < nb_pkts; ) { struct rte_mbuf *mbuf =3D rxq->pool; @@ -331,9 +333,9 @@ pmd_rx_burst(void *queue, struct rte_mbuf **bufs, uint1= 6_t nb_pkts) uint16_t data_off =3D rte_pktmbuf_headroom(mbuf); int len; =20 - len =3D readv(rxq->fd, *rxq->iovecs, - 1 + - (rxq->rxmode->offloads & DEV_RX_OFFLOAD_SCATTER ? + len =3D readv(process_private->rxq_fds[rxq->queue_id], + *rxq->iovecs, + 1 + (rxq->rxmode->offloads & DEV_RX_OFFLOAD_SCATTER ? rxq->nb_rx_desc : 1)); if (len < (int)sizeof(struct tun_pi)) break; @@ -494,6 +496,9 @@ tap_write_mbufs(struct tx_queue *txq, uint16_t num_mbuf= s, { int i; uint16_t l234_hlen; + struct pmd_process_private *process_private; + + process_private =3D rte_eth_devices[txq->out_port].process_private; =20 for (i =3D 0; i < num_mbufs; i++) { struct rte_mbuf *mbuf =3D pmbufs[i]; @@ -595,7 +600,7 @@ tap_write_mbufs(struct tx_queue *txq, uint16_t num_mbuf= s, tap_tx_l4_cksum(l4_cksum, l4_phdr_cksum, l4_raw_cksum); =20 /* copy the tx frame data */ - n =3D writev(txq->fd, iovecs, j); + n =3D writev(process_private->txq_fds[txq->queue_id], iovecs, j); if (n <=3D 0) break; (*num_packets)++; @@ -970,19 +975,20 @@ tap_dev_close(struct rte_eth_dev *dev) { int i; struct pmd_internals *internals =3D dev->data->dev_private; + struct pmd_process_private *process_private =3D dev->process_private; =20 tap_link_set_down(dev); tap_flow_flush(dev, NULL); tap_flow_implicit_flush(internals, NULL); =20 for (i =3D 0; i < RTE_PMD_TAP_MAX_QUEUES; i++) { - if (internals->rxq[i].fd !=3D -1) { - close(internals->rxq[i].fd); - internals->rxq[i].fd =3D -1; + if (process_private->rxq_fds[i] !=3D -1) { + close(process_private->rxq_fds[i]); + process_private->rxq_fds[i] =3D -1; } - if (internals->txq[i].fd !=3D -1) { - close(internals->txq[i].fd); - internals->txq[i].fd =3D -1; + if (process_private->txq_fds[i] !=3D -1) { + close(process_private->txq_fds[i]); + process_private->txq_fds[i] =3D -1; } } =20 @@ -1006,10 +1012,14 @@ static void tap_rx_queue_release(void *queue) { struct rx_queue *rxq =3D queue; + struct pmd_process_private *process_private; =20 - if (rxq && (rxq->fd > 0)) { - close(rxq->fd); - rxq->fd =3D -1; + if (!rxq) + return; + process_private =3D rte_eth_devices[rxq->in_port].process_private; + if (process_private->rxq_fds[rxq->queue_id] > 0) { + close(process_private->rxq_fds[rxq->queue_id]); + process_private->rxq_fds[rxq->queue_id] =3D -1; rte_pktmbuf_free(rxq->pool); rte_free(rxq->iovecs); rxq->pool =3D NULL; @@ -1021,10 +1031,15 @@ static void tap_tx_queue_release(void *queue) { struct tx_queue *txq =3D queue; + struct pmd_process_private *process_private; + + if (!txq) + return; + process_private =3D rte_eth_devices[txq->out_port].process_private; =20 - if (txq && (txq->fd > 0)) { - close(txq->fd); - txq->fd =3D -1; + if (process_private->txq_fds[txq->queue_id] > 0) { + close(process_private->txq_fds[txq->queue_id]); + process_private->txq_fds[txq->queue_id] =3D -1; } } =20 @@ -1209,18 +1224,19 @@ tap_setup_queue(struct rte_eth_dev *dev, int *other_fd; const char *dir; struct pmd_internals *pmd =3D dev->data->dev_private; + struct pmd_process_private *process_private =3D dev->process_private; struct rx_queue *rx =3D &internals->rxq[qid]; struct tx_queue *tx =3D &internals->txq[qid]; struct rte_gso_ctx *gso_ctx; =20 if (is_rx) { - fd =3D &rx->fd; - other_fd =3D &tx->fd; + fd =3D &process_private->rxq_fds[qid]; + other_fd =3D &process_private->txq_fds[qid]; dir =3D "rx"; gso_ctx =3D NULL; } else { - fd =3D &tx->fd; - other_fd =3D &rx->fd; + fd =3D &process_private->txq_fds[qid]; + other_fd =3D &process_private->rxq_fds[qid]; dir =3D "tx"; gso_ctx =3D &tx->gso_ctx; } @@ -1273,6 +1289,7 @@ tap_rx_queue_setup(struct rte_eth_dev *dev, struct rte_mempool *mp) { struct pmd_internals *internals =3D dev->data->dev_private; + struct pmd_process_private *process_private =3D dev->process_private; struct rx_queue *rxq =3D &internals->rxq[rx_queue_id]; struct rte_mbuf **tmp =3D &rxq->pool; long iov_max =3D sysconf(_SC_IOV_MAX); @@ -1332,7 +1349,8 @@ tap_rx_queue_setup(struct rte_eth_dev *dev, } =20 TAP_LOG(DEBUG, " RX TUNTAP device name %s, qid %d on fd %d", - internals->name, rx_queue_id, internals->rxq[rx_queue_id].fd); + internals->name, rx_queue_id, + process_private->rxq_fds[rx_queue_id]); =20 return 0; =20 @@ -1352,6 +1370,7 @@ tap_tx_queue_setup(struct rte_eth_dev *dev, const struct rte_eth_txconf *tx_conf) { struct pmd_internals *internals =3D dev->data->dev_private; + struct pmd_process_private *process_private =3D dev->process_private; struct tx_queue *txq; int ret; uint64_t offloads; @@ -1374,7 +1393,8 @@ tap_tx_queue_setup(struct rte_eth_dev *dev, return -1; TAP_LOG(DEBUG, " TX TUNTAP device name %s, qid %d on fd %d csum %s", - internals->name, tx_queue_id, internals->txq[tx_queue_id].fd, + internals->name, tx_queue_id, + process_private->txq_fds[tx_queue_id], txq->csum ? "on" : "off"); =20 return 0; @@ -1622,6 +1642,7 @@ eth_dev_tap_create(struct rte_vdev_device *vdev, char= *tap_name, int numa_node =3D rte_socket_id(); struct rte_eth_dev *dev; struct pmd_internals *pmd; + struct pmd_process_private *process_private; struct rte_eth_dev_data *data; struct ifreq ifr; int i; @@ -1636,7 +1657,16 @@ eth_dev_tap_create(struct rte_vdev_device *vdev, cha= r *tap_name, goto error_exit_nodev; } =20 + process_private =3D (struct pmd_process_private *) + rte_zmalloc_socket(tap_name, sizeof(struct pmd_process_private), + RTE_CACHE_LINE_SIZE, dev->device->numa_node); + + if (process_private =3D=3D NULL) { + TAP_LOG(ERR, "Failed to alloc memory for process private"); + return -1; + } pmd =3D dev->data->dev_private; + dev->process_private =3D process_private; pmd->dev =3D dev; snprintf(pmd->name, sizeof(pmd->name), "%s", tap_name); pmd->type =3D type; @@ -1672,8 +1702,8 @@ eth_dev_tap_create(struct rte_vdev_device *vdev, char= *tap_name, /* Presetup the fds to -1 as being not valid */ pmd->ka_fd =3D -1; for (i =3D 0; i < RTE_PMD_TAP_MAX_QUEUES; i++) { - pmd->rxq[i].fd =3D -1; - pmd->txq[i].fd =3D -1; + process_private->rxq_fds[i] =3D -1; + process_private->txq_fds[i] =3D -1; } =20 if (pmd->type =3D=3D ETH_TUNTAP_TYPE_TAP) { @@ -2073,6 +2103,7 @@ rte_pmd_tap_remove(struct rte_vdev_device *dev) { struct rte_eth_dev *eth_dev =3D NULL; struct pmd_internals *internals; + struct pmd_process_private *process_private; int i; =20 /* find the ethdev entry */ @@ -2081,6 +2112,7 @@ rte_pmd_tap_remove(struct rte_vdev_device *dev) return 0; =20 internals =3D eth_dev->data->dev_private; + process_private =3D eth_dev->process_private; =20 TAP_LOG(DEBUG, "Closing %s Ethernet device on numa %u", (internals->type =3D=3D ETH_TUNTAP_TYPE_TAP) ? "TAP" : "TUN", @@ -2092,18 +2124,19 @@ rte_pmd_tap_remove(struct rte_vdev_device *dev) tap_nl_final(internals->nlsk_fd); } for (i =3D 0; i < RTE_PMD_TAP_MAX_QUEUES; i++) { - if (internals->rxq[i].fd !=3D -1) { - close(internals->rxq[i].fd); - internals->rxq[i].fd =3D -1; + if (process_private->rxq_fds[i] !=3D -1) { + close(process_private->rxq_fds[i]); + process_private->rxq_fds[i] =3D -1; } - if (internals->txq[i].fd !=3D -1) { - close(internals->txq[i].fd); - internals->txq[i].fd =3D -1; + if (process_private->txq_fds[i] !=3D -1) { + close(process_private->txq_fds[i]); + process_private->txq_fds[i] =3D -1; } } =20 close(internals->ioctl_sock); rte_free(eth_dev->data->dev_private); + rte_free(eth_dev->process_private); rte_eth_dev_release_port(eth_dev); =20 if (internals->ka_fd !=3D -1) { diff --git a/drivers/net/tap/rte_eth_tap.h b/drivers/net/tap/rte_eth_tap.h index 4502e24..dc3579a 100644 --- a/drivers/net/tap/rte_eth_tap.h +++ b/drivers/net/tap/rte_eth_tap.h @@ -47,7 +47,6 @@ struct rx_queue { uint32_t trigger_seen; /* Last seen Rx trigger value */ uint16_t in_port; /* Port ID */ uint16_t queue_id; /* queue ID*/ - int fd; struct pkt_stats stats; /* Stats for this RX queue */ uint16_t nb_rx_desc; /* max number of mbufs available */ struct rte_eth_rxmode *rxmode; /* RX features */ @@ -57,7 +56,6 @@ struct rx_queue { }; =20 struct tx_queue { - int fd; int type; /* Type field - TUN|TAP */ uint16_t *mtu; /* Pointer to MTU from dev_data */ uint16_t csum:1; /* Enable checksum offloading */ @@ -95,6 +93,11 @@ struct pmd_internals { int ka_fd; /* keep-alive file descriptor */ }; =20 +struct pmd_process_private { + int rxq_fds[RTE_PMD_TAP_MAX_QUEUES]; + int txq_fds[RTE_PMD_TAP_MAX_QUEUES]; +}; + /* tap_intr.c */ =20 int tap_rx_intr_vec_set(struct rte_eth_dev *dev, int set); diff --git a/drivers/net/tap/tap_flow.c b/drivers/net/tap/tap_flow.c index 0e01af6..3ba6945 100644 --- a/drivers/net/tap/tap_flow.c +++ b/drivers/net/tap/tap_flow.c @@ -1567,6 +1567,7 @@ tap_flow_isolate(struct rte_eth_dev *dev, struct rte_flow_error *error __rte_unused) { struct pmd_internals *pmd =3D dev->data->dev_private; + struct pmd_process_private *process_private =3D dev->process_private; =20 /* normalize 'set' variable to contain 0 or 1 values */ if (set) @@ -1580,7 +1581,7 @@ tap_flow_isolate(struct rte_eth_dev *dev, * If netdevice is there, setup appropriate flow rules immediately. * Otherwise it will be set when bringing up the netdevice (tun_alloc). */ - if (!pmd->rxq[0].fd) + if (!process_private->rxq_fds[0]) return 0; if (set) { struct rte_flow *remote_flow; diff --git a/drivers/net/tap/tap_intr.c b/drivers/net/tap/tap_intr.c index fc59018..7af0010 100644 --- a/drivers/net/tap/tap_intr.c +++ b/drivers/net/tap/tap_intr.c @@ -51,6 +51,7 @@ static int tap_rx_intr_vec_install(struct rte_eth_dev *dev) { struct pmd_internals *pmd =3D dev->data->dev_private; + struct pmd_process_private *process_private =3D dev->process_private; unsigned int rxqs_n =3D pmd->dev->data->nb_rx_queues; struct rte_intr_handle *intr_handle =3D &pmd->intr_handle; unsigned int n =3D RTE_MIN(rxqs_n, (uint32_t)RTE_MAX_RXTX_INTR_VEC_ID); @@ -71,7 +72,7 @@ tap_rx_intr_vec_install(struct rte_eth_dev *dev) struct rx_queue *rxq =3D pmd->dev->data->rx_queues[i]; =20 /* Skip queues that cannot request interrupts. */ - if (!rxq || rxq->fd <=3D 0) { + if (!rxq || process_private->rxq_fds[i] <=3D 0) { /* Use invalid intr_vec[] index to disable entry. */ intr_handle->intr_vec[i] =3D RTE_INTR_VEC_RXTX_OFFSET + @@ -79,7 +80,7 @@ tap_rx_intr_vec_install(struct rte_eth_dev *dev) continue; } intr_handle->intr_vec[i] =3D RTE_INTR_VEC_RXTX_OFFSET + count; - intr_handle->efds[count] =3D rxq->fd; + intr_handle->efds[count] =3D process_private->rxq_fds[i]; count++; } if (!count) --=20 2.7.4