Lines Matching refs:rcv
105 schedule_work(&server->rcv.tq); in ncp_tcp_data_ready()
113 schedule_work(&server->rcv.tq); in ncp_tcp_error_report()
156 req = server->rcv.creq; in __abort_ncp_connection()
158 server->rcv.creq = NULL; in __abort_ncp_connection()
160 server->rcv.ptr = NULL; in __abort_ncp_connection()
161 server->rcv.state = 0; in __abort_ncp_connection()
196 mutex_lock(&server->rcv.creq_mutex); in ncp_abort_request()
198 mutex_unlock(&server->rcv.creq_mutex); in ncp_abort_request()
240 server->rcv.creq = rq; in __ncptcp_try_send()
282 server->rcv.creq = req; in ncpdgram_start_request()
333 mutex_lock(&server->rcv.creq_mutex); in ncp_add_request()
335 mutex_unlock(&server->rcv.creq_mutex); in ncp_add_request()
340 if (server->tx.creq || server->rcv.creq) { in ncp_add_request()
343 mutex_unlock(&server->rcv.creq_mutex); in ncp_add_request()
347 mutex_unlock(&server->rcv.creq_mutex); in ncp_add_request()
355 server->rcv.creq = NULL; in __ncp_next_request()
385 container_of(work, struct ncp_server, rcv.tq); in ncpdgram_rcv_proc()
432 mutex_lock(&server->rcv.creq_mutex); in ncpdgram_rcv_proc()
433 req = server->rcv.creq; in ncpdgram_rcv_proc()
459 server->rcv.creq = NULL; in ncpdgram_rcv_proc()
462 mutex_unlock(&server->rcv.creq_mutex); in ncpdgram_rcv_proc()
466 mutex_unlock(&server->rcv.creq_mutex); in ncpdgram_rcv_proc()
479 req = server->rcv.creq; in __ncpdgram_timeout_proc()
505 mutex_lock(&server->rcv.creq_mutex); in ncpdgram_timeout_proc()
507 mutex_unlock(&server->rcv.creq_mutex); in ncpdgram_timeout_proc()
543 while (server->rcv.len) { in __ncptcp_rcv_proc()
544 result = do_tcp_rcv(server, server->rcv.ptr, server->rcv.len); in __ncptcp_rcv_proc()
549 req = server->rcv.creq; in __ncptcp_rcv_proc()
562 if (server->rcv.ptr) { in __ncptcp_rcv_proc()
563 server->rcv.ptr += result; in __ncptcp_rcv_proc()
565 server->rcv.len -= result; in __ncptcp_rcv_proc()
567 switch (server->rcv.state) { in __ncptcp_rcv_proc()
569 if (server->rcv.buf.magic != htonl(NCP_TCP_RCVD_MAGIC)) { in __ncptcp_rcv_proc()
570 pr_err("tcp: Unexpected reply type %08X\n", ntohl(server->rcv.buf.magic)); in __ncptcp_rcv_proc()
574 datalen = ntohl(server->rcv.buf.len) & 0x0FFFFFFF; in __ncptcp_rcv_proc()
587 server->rcv.buf.len = datalen - 8; in __ncptcp_rcv_proc()
588 server->rcv.ptr = (unsigned char*)&server->rcv.buf.p1; in __ncptcp_rcv_proc()
589 server->rcv.len = 8; in __ncptcp_rcv_proc()
590 server->rcv.state = 4; in __ncptcp_rcv_proc()
594 type = ntohs(server->rcv.buf.type); in __ncptcp_rcv_proc()
603 server->rcv.state = 5; in __ncptcp_rcv_proc()
604 server->rcv.ptr = server->unexpected_packet.data + 2; in __ncptcp_rcv_proc()
605 server->rcv.len = datalen - 10; in __ncptcp_rcv_proc()
610 server->rcv.state = 2; in __ncptcp_rcv_proc()
612 server->rcv.ptr = NULL; in __ncptcp_rcv_proc()
613 server->rcv.len = datalen - 10; in __ncptcp_rcv_proc()
616 req = server->rcv.creq; in __ncptcp_rcv_proc()
623 server->rcv.state = 3; in __ncptcp_rcv_proc()
628 server->rcv.ptr = server->rxbuf + 2; in __ncptcp_rcv_proc()
629 server->rcv.len = datalen - 10; in __ncptcp_rcv_proc()
630 server->rcv.state = 1; in __ncptcp_rcv_proc()
634 datalen = server->rcv.buf.len; in __ncptcp_rcv_proc()
635 type = ntohs(server->rcv.buf.type2); in __ncptcp_rcv_proc()
639 req = server->rcv.creq; in __ncptcp_rcv_proc()
654 …ver, server->rxbuf + 6, req->datalen - 6, cpu_to_be32(req->datalen + 16), &server->rcv.buf.type)) { in __ncptcp_rcv_proc()
666 server->rcv.ptr = (unsigned char*)&server->rcv.buf; in __ncptcp_rcv_proc()
667 server->rcv.len = 10; in __ncptcp_rcv_proc()
668 server->rcv.state = 0; in __ncptcp_rcv_proc()
671 ncp_finish_request(server, server->rcv.creq, -EIO); in __ncptcp_rcv_proc()
683 container_of(work, struct ncp_server, rcv.tq); in ncp_tcp_rcv_proc()
685 mutex_lock(&server->rcv.creq_mutex); in ncp_tcp_rcv_proc()
687 mutex_unlock(&server->rcv.creq_mutex); in ncp_tcp_rcv_proc()
695 mutex_lock(&server->rcv.creq_mutex); in ncp_tcp_tx_proc()
697 mutex_unlock(&server->rcv.creq_mutex); in ncp_tcp_tx_proc()