Lines Matching refs:tcp
47 #include "lwip/tcp.h"
213 * @see tcp.h (struct tcp_pcb.recv) for parameters and return value
225 LWIP_ASSERT("recv_tcp: recv for wrong pcb!", conn->pcb.tcp == pcb);
274 * @see tcp.h (struct tcp_pcb.poll) for parameters and return value
295 if ((conn->pcb.tcp != NULL) && (tcp_sndbuf(conn->pcb.tcp) > TCP_SNDLOWAT) &&
296 (tcp_sndqueuelen(conn->pcb.tcp) < TCP_SNDQUEUELOWAT)) {
310 * @see tcp.h (struct tcp_pcb.sent) for parameters and return value
329 if ((conn->pcb.tcp != NULL) && (tcp_sndbuf(conn->pcb.tcp) > TCP_SNDLOWAT) &&
330 (tcp_sndqueuelen(conn->pcb.tcp) < TCP_SNDQUEUELOWAT)) {
344 * @see tcp.h (struct tcp_pcb.err) for parameters
356 conn->pcb.tcp = NULL;
417 pcb = conn->pcb.tcp;
429 * @see tcp.h (struct tcp_pcb_listen.accept) for parameters and return value
450 newconn->pcb.tcp = newpcb;
460 struct tcp_pcb* pcb = newconn->pcb.tcp;
467 newconn->pcb.tcp = NULL;
492 LWIP_ASSERT("pcb_new: pcb already allocated", msg->conn->pcb.tcp == NULL);
526 msg->conn->pcb.tcp = tcp_new();
527 if(msg->conn->pcb.tcp == NULL) {
551 if(msg->conn->pcb.tcp == NULL) {
584 conn->pcb.tcp = NULL;
659 LWIP_ASSERT("PCB must be deallocated outside this function", conn->pcb.tcp == NULL);
699 if (conn->pcb.tcp != NULL) {
700 tcp_recved(conn->pcb.tcp, p->tot_len);
719 /* Only tcp pcbs have an acceptmbox, so no need to check conn->type */
721 if (conn->pcb.tcp != NULL) {
722 tcp_accepted(conn->pcb.tcp);
726 if (newconn->pcb.tcp != NULL) {
727 tcp_abort(newconn->pcb.tcp);
728 newconn->pcb.tcp = NULL;
753 LWIP_ASSERT("this is for tcp netconns only", (conn->type == NETCONN_TCP));
755 LWIP_ASSERT("pcb already closed", (conn->pcb.tcp != NULL));
766 tcp_arg(conn->pcb.tcp, NULL);
768 if (conn->pcb.tcp->state == LISTEN) {
769 tcp_accept(conn->pcb.tcp, NULL);
773 tcp_recv(conn->pcb.tcp, NULL);
774 tcp_accept(conn->pcb.tcp, NULL);
777 tcp_sent(conn->pcb.tcp, NULL);
780 tcp_poll(conn->pcb.tcp, NULL, 4);
781 tcp_err(conn->pcb.tcp, NULL);
786 err = tcp_close(conn->pcb.tcp);
788 err = tcp_shutdown(conn->pcb.tcp, shut_rx, shut_tx);
797 conn->pcb.tcp = NULL;
813 LWIP_ASSERT("Closing a listen pcb may not fail!", (conn->pcb.tcp->state != LISTEN));
814 tcp_sent(conn->pcb.tcp, sent_tcp);
815 tcp_poll(conn->pcb.tcp, poll_tcp, 4);
816 tcp_err(conn->pcb.tcp, err_tcp);
817 tcp_arg(conn->pcb.tcp, conn);
847 if (msg->conn->pcb.tcp != NULL) {
876 msg->conn->pcb.tcp = NULL;
878 /* tcp netconns don't come here! */
904 if (msg->conn->pcb.tcp != NULL) {
918 msg->err = tcp_bind(msg->conn->pcb.tcp, msg->msg.bc.ipaddr, msg->msg.bc.port);
934 * @see tcp.h (struct tcp_pcb.connected) for parameters and return values
986 if (msg->conn->pcb.tcp == NULL) {
1008 msg->err = tcp_connect(msg->conn->pcb.tcp, msg->msg.bc.ipaddr,
1070 if (msg->conn->pcb.tcp != NULL) {
1074 struct tcp_pcb* lpcb = tcp_listen_with_backlog(msg->conn->pcb.tcp, msg->msg.lb.backlog);
1076 struct tcp_pcb* lpcb = tcp_listen(msg->conn->pcb.tcp);
1094 msg->conn->pcb.tcp = lpcb;
1095 tcp_arg(msg->conn->pcb.tcp, msg->conn);
1096 tcp_accept(msg->conn->pcb.tcp, accept_function);
1100 msg->conn->pcb.tcp = NULL;
1126 if (msg->conn->pcb.tcp != NULL) {
1176 if (msg->conn->pcb.tcp != NULL) {
1179 if (msg->conn->pcb.tcp->state == LISTEN) {
1180 tcp_accepted(msg->conn->pcb.tcp);
1187 tcp_recved(msg->conn->pcb.tcp, recved);
1222 LWIP_ASSERT("conn->pcb.tcp != NULL", conn->pcb.tcp != NULL);
1253 available = tcp_sndbuf(conn->pcb.tcp);
1270 err = tcp_write(conn->pcb.tcp, dataptr, len, apiflags);
1279 } else if ((tcp_sndbuf(conn->pcb.tcp) <= TCP_SNDLOWAT) ||
1280 (tcp_sndqueuelen(conn->pcb.tcp) >= TCP_SNDQUEUELOWAT)) {
1296 tcp_output(conn->pcb.tcp);
1303 tcp_output(conn->pcb.tcp);
1353 } else if (msg->conn->pcb.tcp != NULL) {
1431 *(msg->msg.ad.port) = (msg->msg.ad.local?msg->conn->pcb.tcp->local_port:msg->conn->pcb.tcp->remote_port);
1459 } else if ((msg->conn->pcb.tcp != NULL) && (msg->conn->type == NETCONN_TCP)) {
1473 /* for tcp netconns, do_close_internal ACKs the message */
1497 if (msg->conn->pcb.tcp != NULL) {