Lines Matching refs:current_msg

368     if (conn->current_msg && conn->current_msg->msg.sd.polls_left) {
369       conn->current_msg->msg.sd.polls_left--;
515       LWIP_ASSERT("conn->current_msg != NULL", conn->current_msg != NULL);
518         conn->current_msg->err = ERR_OK;
521         conn->current_msg->err = err;
523       op_completed_sem = LWIP_API_MSG_SEM(conn->current_msg);
525       conn->current_msg = NULL;
532     LWIP_ASSERT("conn->current_msg == NULL", conn->current_msg == NULL);
814   conn->current_msg  = NULL;
983   LWIP_ASSERT("conn->current_msg != NULL", conn->current_msg != NULL);
986   shut = conn->current_msg->msg.sd.shut;
1040         } else if ((s32_t)(sys_now() - conn->current_msg->msg.sd.time_started) >=
1089       if ((s32_t)(sys_now() - conn->current_msg->msg.sd.time_started) >= close_timeout) {
1091       if (conn->current_msg->msg.sd.polls_left == 0) {
1107     sys_sem_t *op_completed_sem = LWIP_API_MSG_SEM(conn->current_msg);
1108     conn->current_msg->err = err;
1109     conn->current_msg = NULL;
1176       LWIP_ASSERT("msg->conn->current_msg != NULL", msg->conn->current_msg != NULL);
1177       op_completed_sem = LWIP_API_MSG_SEM(msg->conn->current_msg);
1178       msg->conn->current_msg->err = ERR_CLSD;
1179       msg->conn->current_msg = NULL;
1221           LWIP_ASSERT("already writing or closing", msg->conn->current_msg == NULL);
1224           msg->conn->current_msg = msg;
1376               (conn->current_msg != NULL) || IN_NONBLOCKING_CONNECT(conn));
1378   if (conn->current_msg != NULL) {
1379     conn->current_msg->err = err;
1380     op_completed_sem = LWIP_API_MSG_SEM(conn->current_msg);
1390   conn->current_msg = NULL;
1447               msg->conn->current_msg = msg;
1712   LWIP_ASSERT("conn->current_msg != NULL", conn->current_msg != NULL);
1715               conn->current_msg->msg.w.offset < conn->current_msg->msg.w.len);
1716   LWIP_ASSERT("conn->current_msg->msg.w.vector_cnt > 0", conn->current_msg->msg.w.vector_cnt > 0);
1718   apiflags = conn->current_msg->msg.w.apiflags;
1723       ((s32_t)(sys_now() - conn->current_msg->msg.w.time_started) >= conn->send_timeout)) {
1725     if (conn->current_msg->msg.w.offset == 0) {
1736 …dataptr = (const u8_t *)conn->current_msg->msg.w.vector->ptr + conn->current_msg->msg.w.vector_off;
1737       diff = conn->current_msg->msg.w.vector->len - conn->current_msg->msg.w.vector_off;
1751             err = (conn->current_msg->msg.w.offset == 0) ? ERR_WOULDBLOCK : ERR_OK;
1759 …            ((conn->current_msg->msg.w.vector_off + len) <= conn->current_msg->msg.w.vector->len));
1765           (len == (u16_t)diff && conn->current_msg->msg.w.vector_cnt > 1)) {
1773         conn->current_msg->msg.w.offset += len;
1774         conn->current_msg->msg.w.vector_off += len;
1776         if (conn->current_msg->msg.w.vector_off == conn->current_msg->msg.w.vector->len) {
1777           conn->current_msg->msg.w.vector_cnt--;
1779           if (conn->current_msg->msg.w.vector_cnt > 0) {
1780             conn->current_msg->msg.w.vector++;
1781             conn->current_msg->msg.w.vector_off = 0;
1789       if (dontblock && (conn->current_msg->msg.w.offset < conn->current_msg->msg.w.len)) {
1804       if ((conn->current_msg->msg.w.offset == conn->current_msg->msg.w.len) || dontblock) {
1833         err = (conn->current_msg->msg.w.offset == 0) ? ERR_WOULDBLOCK : ERR_OK;
1845     sys_sem_t *op_completed_sem = LWIP_API_MSG_SEM(conn->current_msg);
1846     conn->current_msg->err = err;
1847     conn->current_msg = NULL;
1886         LWIP_ASSERT("already writing or closing", msg->conn->current_msg == NULL);
1888         msg->conn->current_msg = msg;
2013         LWIP_ASSERT("msg->conn->current_msg != NULL", msg->conn->current_msg != NULL);
2014         write_completed_sem = LWIP_API_MSG_SEM(msg->conn->current_msg);
2015         msg->conn->current_msg->err = ERR_CLSD;
2016         msg->conn->current_msg = NULL;
2040       LWIP_ASSERT("already writing or closing", msg->conn->current_msg == NULL);
2042       msg->conn->current_msg = msg;