Lines Matching refs:nbytes
40 u32_t nbytes
112 u32_t nbytes = 0;
146 nbytes = isle->isle_nbytes;
174 return nbytes;
203 db_data->bds_prod += rx_con->db_more_bds; /* nbds should be written before nbytes (FW assumption) */
207 "_lm_tcp_rx_write_db: cid=%d, (nbytes+=%d, nbds+=%d)\n",
233 u32_t nbytes,
243 /*DbgMessage(pdev, FATAL, "lm_tcp_rx_post_sws() INC: OLD drv_rcv_win_right_edge=%d, nbytes=%d, NEW drv_rcv_win_right_edge=%d FW right_edge=%d \n", rx_con->u.rx.sws_info.drv_rcv_win_right_edge, nbytes, rx_con->u.rx.sws_info.drv_rcv_win_right_edge + nbytes, db_data->rcv_win_right_edge);*/
244 if (rx_con->u.rx.sws_info.extra_bytes > nbytes) {
245 rx_con->u.rx.sws_info.extra_bytes -= nbytes;
246 nbytes = 0;
248 nbytes -= rx_con->u.rx.sws_info.extra_bytes;
250 rx_con->u.rx.sws_info.drv_rcv_win_right_edge += nbytes;
258 rx_con->u.rx.sws_info.extra_bytes += nbytes;
259 nbytes = 0;
261 /*DbgMessage(pdev, FATAL, "lm_tcp_rx_post_sws() DEC: OLD drv_rcv_win_right_edge=%d, nbytes=%d, NEW drv_rcv_win_right_edge=%d\n", rx_con->u.rx.sws_info.drv_rcv_win_right_edge, nbytes, rx_con->u.rx.sws_info.drv_rcv_win_right_edge - nbytes);*/
262 rx_con->u.rx.sws_info.drv_rcv_win_right_edge -= nbytes;
266 /*DbgMessage(pdev, FATAL, "lm_tcp_rx_post_sws() SET: nbytes=%d\n", nbytes);*/
267 db_data->rcv_win_right_edge = nbytes;
280 //DbgMessage(pdev, WARNl4, "###lm_tcp_rx_post_sws cid=%d num_bytes=%d diff_to_fw=%d \n", tcp->cid, nbytes, diff_to_fw );
293 "_lm_tcp_adv_wnd_write_db: cid=%d, nbytes=%d\n",
329 * function completes nbytes on a single tcp buffer and completes the buffer if it is
456 /* complete nbytes on buffers (dpc-flow ) */
564 u32_t nbytes
569 db_data->consumed_grq_bytes += nbytes;
577 if (nbytes < tcp->rx_con->u.rx.sws_info.mss) {
757 /* complete nbytes on buffers (dpc-flow ) */
787 * GA: add a buffer to the peninsula - nbytes represents the number of bytes in the previous buffer.
788 * GR: release a buffer from the peninsula - nbytes represents the number of bytes in the current buffer.
792 void lm_tcp_rx_gen_peninsula_process(lm_device_t * pdev, lm_tcp_state_t * tcp, u32_t nbytes, lm_tcp_gen_buf_t * gen_buf)
798 DbgMessage(pdev, VERBOSEl4rx, "##lm_tcp_rx_gen_peninsula_process, nbytes=%d, cid=%d add=%s\n", nbytes, tcp->cid,
807 if (nbytes) {
808 gen_info->dpc_peninsula_nbytes += nbytes;
812 DbgBreakIfAll(nbytes > LM_TCP_GEN_BUF_SIZE(pdev));
813 last_gen_buf->placed_bytes = (u16_t)nbytes;
886 void lm_tcp_rx_gen_isle_right_process(lm_device_t * pdev, lm_tcp_state_t * tcp, u32_t nbytes, lm_tcp_gen_buf_t * gen_buf, u8_t sb_idx, u8_t isle_num)
893 DbgMessage(pdev, VERBOSEl4rx, "##lm_tcp_rx_gen_isle_process nbytes = %d cid=%d\n", nbytes, tcp->cid);
902 if (nbytes) {
903 gen_info->isle_nbytes += nbytes;
904 requested_isle->isle_nbytes += nbytes;
906 DbgBreakIf(nbytes > 0xffff);
907 last_gen_buf->placed_bytes = (u16_t)nbytes;
929 SET_DEBUG_OOO_INFO(requested_isle, CMP_OPCODE_TOE_GAIR, nbytes);
931 SET_DEBUG_OOO_INFO(requested_isle, CMP_OPCODE_TOE_GRI, nbytes);
936 void lm_tcp_rx_gen_isle_left_process(lm_device_t * pdev, lm_tcp_state_t * tcp, u32_t nbytes, lm_tcp_gen_buf_t * gen_buf, u8_t sb_idx, u8_t isle_num)
943 DbgMessage(pdev, VERBOSEl4rx, "##lm_tcp_rx_gen_isle_process nbytes = %d cid=%d\n", nbytes, tcp->cid);
949 if (nbytes) {
953 gen_info->isle_nbytes += nbytes;
954 requested_isle->isle_nbytes += nbytes;
957 #pragma prefast (disable:28182) // If nbytes is larger that zero than ((returned_list_of_gen_bufs))->head is not NULL.
961 last_gen_buf->placed_bytes = (u16_t)nbytes;
975 SET_DEBUG_OOO_INFO(requested_isle, CMP_OPCODE_TOE_GAIL, nbytes);
1075 /* complete nbytes on buffers (dpc-flow ) */
1187 u32_t nbytes;
1194 /* Check that the cqe nbytes make sense, we could have got here by chance... */
1197 nbytes = (cqe->data.ooo_params.ooo_params & TOE_RX_CQE_OOO_PARAMS_NBYTES) >> TOE_RX_CQE_OOO_PARAMS_NBYTES_SHIFT;
1204 nbytes = cqe->data.raw_data;
1206 nbytes = (cqe->data.in_order_params.in_order_params & TOE_RX_CQE_IN_ORDER_PARAMS_NBYTES) >> TOE_RX_CQE_IN_ORDER_PARAMS_NBYTES_SHIFT;
1207 DbgBreakIfAll(nbytes & 0xc0000000); /* two upper bits on show a completion larger than 1GB - a bit odd...*/
1208 DbgBreakIf(nbytes && tcp->rx_con->dpc_info.dpc_comp_blocked);
1221 //DbgMessage(pdev, WARN, "GenericAdd cid=%d nbytes=%d!\n", tcp->cid, cqe->nbytes);
1222 lm_tcp_rx_gen_peninsula_process(pdev, tcp, nbytes,
1227 DbgBreakIf(nbytes);
1232 //DbgMessage(pdev, WARN, "GenericAddIsleR cid=%d isle_num=%d nbytes=%d!\n", tcp->cid, isle_num, nbytes);
1233 lm_tcp_rx_gen_isle_right_process(pdev, tcp, nbytes,
1237 DbgMessage(pdev, WARN, "GenericAddIsleL cid=%d isle_num=%d nbytes=%d!\n", tcp->cid, isle_num, nbytes);
1238 if (nbytes)
1240 lm_tcp_rx_gen_isle_left_process(pdev, tcp, nbytes,
1250 // DbgMessage(pdev, WARN, "GenericReleaseIsle cid=%d isle_num=%d nbytes=%d!\n", tcp->cid, isle_num, nbytes);
1251 lm_tcp_rx_gen_isle_right_process(pdev, tcp, nbytes, NULL, sb_idx, isle_num);
1254 //DbgMessage(pdev, WARN, "GenericRelease cid=%d nbytes=%d!\n", tcp->cid, cqe->nbytes);
1255 lm_tcp_rx_gen_peninsula_process(pdev, tcp, nbytes, NULL);
1258 //DbgMessage(pdev, WARN, "GenericJoin cid=%d nbytes=%d!\n", tcp->cid, cqe->nbytes);
1262 //DbgMessage(pdev, WARN, "Cmp(push) cid=%d nbytes=%d!\n", tcp->cid, cqe->nbytes);
1264 lm_tcp_rx_cmp_process(pdev, tcp, nbytes, 1);
1267 //DbgMessage(pdev, WARN, "Rel(nopush) cid=%d nbytes=%d!\n", tcp->cid, cqe->nbytes);
1268 lm_tcp_rx_cmp_process(pdev, tcp, nbytes, 0);
1271 //DbgMessage(pdev, WARN, "Skp cid=%d nbytes=%d!\n", tcp->cid, cqe->nbytes);
1272 lm_tcp_rx_skp_process(pdev, tcp, nbytes, sb_idx);
1276 lm_tcp_rx_delete_isle(pdev, tcp, sb_idx, isle_num, nbytes);
1280 /* for the rest of the commands, if we have nbytes, we need to complete them (generic/app) */
1281 /* unless it's an update completion, in which case the nbytes has a different meaning. */
1282 if ((cmd != RAMROD_OPCODE_TOE_UPDATE) && nbytes) {
1286 lm_tcp_rx_gen_peninsula_process(pdev, tcp, nbytes, NULL);
1288 /* if we're here - we will no longer see a RQ_SKP so, let's simulate one...note if we didn't get nbytes here.. we still need
1297 lm_tcp_rx_cmp_process(pdev, tcp, nbytes, 2 /* push as result of sp-completion*/);
1323 /*DbgMessage(pdev, FATAL, "lm_tcp_rx_process_cqe() RAMROD_OPCODE_TOE_UPDATE: IGNORE_WND_UPDATES=%d, cqe->nbytes=%d\n", GET_FLAGS(tcp->rx_con->db_data.rx->flags, TOE_RX_DB_DATA_IGNORE_WND_UPDATES), cqe->nbytes);*/
1327 tcp->rx_con->dpc_info.dpc_fw_wnd_after_dec = nbytes;
1394 DbgBreakIf(nbytes);
1402 DbgBreakIf(nbytes);
1860 /* this function completes nbytes on the tcp buf and may complete the buffer if more_to_comp = 0*/
1874 /* this function completes nbytes on the tcp buf and may complete the buffer if more_to_comp = 0*/
2301 u32_t nbytes;
2338 nbytes = ((lm_tcp_gen_buf_t *)curr_gen_buf)->placed_bytes - gen_info->first_buf_offset;
2339 if (accepted_bytes >= nbytes) {
2341 accepted_bytes -= nbytes;