Lines Matching defs:gen_buf
46 lm_tcp_gen_buf_t * gen_buf,
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)
799 (gen_buf)? "TRUE" : "FALSE");
816 if (gen_buf /* add */) {
817 DbgBreakIf(SIG(gen_buf->buf_virt) != L4GEN_BUFFER_SIG);
818 DbgBreakIf(END_SIG(gen_buf->buf_virt, LM_TCP_GEN_BUF_SIZE(pdev)) != L4GEN_BUFFER_SIG_END);
820 d_list_push_tail(&gen_info->dpc_peninsula_list, &gen_buf->link);
825 void lm_tcp_rx_gen_isle_create(lm_device_t * pdev, lm_tcp_state_t * tcp, lm_tcp_gen_buf_t * gen_buf, u8_t sb_idx, u8_t isle_num)
849 d_list_push_head(¤t_isle->isle_gen_bufs_list_head, &gen_buf->link);
855 d_list_push_head(&gen_info->first_isle.isle_gen_bufs_list_head, &gen_buf->link);
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)
909 DbgBreakIf(gen_buf == NULL);
913 if (gen_buf) {
914 DbgBreakIf(SIG(gen_buf->buf_virt) != L4GEN_BUFFER_SIG);
915 DbgBreakIf(END_SIG(gen_buf->buf_virt, LM_TCP_GEN_BUF_SIZE(pdev)) != L4GEN_BUFFER_SIG_END);
917 d_list_push_tail(&requested_isle->isle_gen_bufs_list_head, &gen_buf->link);
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)
951 DbgBreakIf(gen_buf != NULL);
967 DbgBreakIf(gen_buf == NULL);
968 DbgBreakIf(SIG(gen_buf->buf_virt) != L4GEN_BUFFER_SIG);
969 DbgBreakIf(END_SIG(gen_buf->buf_virt, LM_TCP_GEN_BUF_SIZE(pdev)) != L4GEN_BUFFER_SIG_END);
971 d_list_push_head(&requested_isle->isle_gen_bufs_list_head, &gen_buf->link);
1033 lm_tcp_gen_buf_t * gen_buf;
1040 gen_buf = (lm_tcp_gen_buf_t *)d_list_pop_head(&pdev->toe_info.grqs[sb_idx].active_gen_list);
1041 if (ERR_IF(gen_buf == NULL)) {
1045 DbgBreakIf(!gen_buf);
1046 DbgBreakIf(SIG(gen_buf->buf_virt) != L4GEN_BUFFER_SIG);
1047 DbgBreakIf(END_SIG(gen_buf->buf_virt, LM_TCP_GEN_BUF_SIZE(pdev)) != L4GEN_BUFFER_SIG_END);
1054 return gen_buf;
1102 lm_tcp_gen_buf_t * gen_buf;
1103 gen_buf = (lm_tcp_gen_buf_t *)d_list_pop_tail(&con->u.rx.gen_info.peninsula_list);
1104 if CHK_NULL(gen_buf)
1106 DbgBreakIfAll( !gen_buf ) ;
1109 d_list_init(&con->u.rx.gen_info.dpc_peninsula_list, &gen_buf->link, &gen_buf->link, 1);
1283 lm_tcp_gen_buf_t * gen_buf;
1284 gen_buf = (lm_tcp_gen_buf_t *)d_list_peek_tail(&tcp->rx_con->u.rx.gen_info.dpc_peninsula_list);
1285 if(gen_buf && (gen_buf->placed_bytes == 0)) {
2003 lm_tcp_gen_buf_t ** gen_buf
2092 *gen_buf = head_of_indication;
2103 lm_tcp_gen_buf_t ** gen_buf
2209 _lm_tcp_rx_get_buffered_data(pdev, tcp, frag_list, gen_buf);
2215 gen_info->num_buffers_indicated += (*gen_buf)->ind_nbufs;
2224 if (*gen_buf) {
2227 (*gen_buf)->flags &= ~GEN_FLAG_SWS_UPDATE;
2237 lm_tcp_gen_buf_t ** gen_buf
2254 lm_status = _lm_tcp_rx_get_buffered_data(pdev, tcp, frag_list, gen_buf);
2255 if (*gen_buf) {
2257 gen_info->pending_indicated_bytes += (*gen_buf)->ind_bytes;
2263 (*gen_buf)->flags |= GEN_FLAG_SWS_UPDATE;
2265 (*gen_buf)->flags &= ~GEN_FLAG_SWS_UPDATE;
2276 lm_tcp_gen_buf_t * gen_buf /* head of indications generic buffer NULL if indication succeeded */
2288 if (gen_buf == NULL) { /* succesfull indication */
2296 } else { /* complete rejection / partial success, gen_buf remains in our control */
2302 DbgBreakIf(accepted_bytes > gen_buf->ind_bytes);
2303 gen_info->peninsula_nbytes += gen_buf->ind_bytes - accepted_bytes;
2307 gen_info->bytes_indicated_rejected+= gen_buf->ind_bytes - accepted_bytes;
2315 DbgBreakIf(gen_buf->tcp->rx_con->flags & TCP_INDICATE_REJECTED);
2319 gen_buf->tcp->rx_con->flags |= TCP_INDICATE_REJECTED;
2322 curr_gen_buf = gen_buf;
2330 if (gen_buf->flags & GEN_FLAG_SWS_UPDATE) {
2332 gen_info->pending_indicated_bytes-=gen_buf->ind_bytes;
2380 void lm_tcp_return_gen_bufs(struct _lm_device_t * pdev, lm_tcp_state_t * tcp, lm_tcp_gen_buf_t * gen_buf,u32_t flags, u8_t grq_idx)
2382 lm_tcp_gen_buf_t * curr_gen_buf = gen_buf;
2385 gen_buf->ind_nbufs = 0; /* for debugging purposes will count how many buffers are in our list */
2392 gen_buf->ind_nbufs++;
2396 mm_tcp_return_gen_bufs(pdev, gen_buf,flags,grq_idx);
2404 lm_tcp_gen_buf_t * gen_buf = (lm_tcp_gen_buf_t *)d_list_peek_head(gen_buf_list);
2405 lm_tcp_gen_buf_t * curr_gen_buf = gen_buf;
2408 gen_buf->ind_nbufs = 0; /* for debugging purposes will count how many buffers are in our list */
2415 gen_buf->ind_nbufs++;
2422 void lm_tcp_rx_indication_returned(struct _lm_device_t *pdev, lm_tcp_state_t * tcp, lm_tcp_gen_buf_t * gen_buf)
2426 DbgBreakIf(tcp != gen_buf->tcp);
2430 DbgBreakIf(gen_buf->refcnt != 0);
2433 tcp->rx_con->u.rx.gen_info.pending_indicated_bytes -= gen_buf->ind_bytes;
2437 DbgBreakIfAll(!(gen_buf->flags & GEN_FLAG_SWS_UPDATE));
2438 lm_tcp_rx_post_sws(pdev, tcp, tcp->rx_con, gen_buf->ind_bytes, TCP_RX_POST_SWS_INC);
2439 lm_tcp_return_gen_bufs(pdev, tcp, gen_buf, MM_TCP_RGB_COMPENSATE_GRQS, NON_EXISTENT_SB_IDX);