Lines Matching refs:p
463 static int rxrpc_sendmsg_cmsg(struct msghdr *msg, struct rxrpc_send_params *p) in rxrpc_sendmsg_cmsg() argument
488 p->call.user_call_ID = *(u32 *)CMSG_DATA(cmsg); in rxrpc_sendmsg_cmsg()
492 p->call.user_call_ID = *(unsigned long *) in rxrpc_sendmsg_cmsg()
499 if (p->command != RXRPC_CMD_SEND_DATA) in rxrpc_sendmsg_cmsg()
501 p->command = RXRPC_CMD_SEND_ABORT; in rxrpc_sendmsg_cmsg()
502 if (len != sizeof(p->abort_code)) in rxrpc_sendmsg_cmsg()
504 p->abort_code = *(unsigned int *)CMSG_DATA(cmsg); in rxrpc_sendmsg_cmsg()
505 if (p->abort_code == 0) in rxrpc_sendmsg_cmsg()
510 if (p->command != RXRPC_CMD_SEND_DATA) in rxrpc_sendmsg_cmsg()
512 p->command = RXRPC_CMD_CHARGE_ACCEPT; in rxrpc_sendmsg_cmsg()
518 p->exclusive = true; in rxrpc_sendmsg_cmsg()
524 p->upgrade = true; in rxrpc_sendmsg_cmsg()
530 if (p->call.tx_total_len != -1 || len != sizeof(__s64)) in rxrpc_sendmsg_cmsg()
532 p->call.tx_total_len = *(__s64 *)CMSG_DATA(cmsg); in rxrpc_sendmsg_cmsg()
533 if (p->call.tx_total_len < 0) in rxrpc_sendmsg_cmsg()
540 memcpy(&p->call.timeouts, CMSG_DATA(cmsg), len); in rxrpc_sendmsg_cmsg()
541 p->call.nr_timeouts = len / 4; in rxrpc_sendmsg_cmsg()
542 if (p->call.timeouts.hard > INT_MAX / HZ) in rxrpc_sendmsg_cmsg()
544 if (p->call.nr_timeouts >= 2 && p->call.timeouts.idle > 60 * 60 * 1000) in rxrpc_sendmsg_cmsg()
546 if (p->call.nr_timeouts >= 3 && p->call.timeouts.normal > 60 * 60 * 1000) in rxrpc_sendmsg_cmsg()
557 if (p->call.tx_total_len != -1 && p->command != RXRPC_CMD_SEND_DATA) in rxrpc_sendmsg_cmsg()
570 struct rxrpc_send_params *p) in rxrpc_new_client_call_for_sendmsg() argument
595 cp.exclusive = rx->exclusive | p->exclusive; in rxrpc_new_client_call_for_sendmsg()
596 cp.upgrade = p->upgrade; in rxrpc_new_client_call_for_sendmsg()
598 call = rxrpc_new_client_call(rx, &cp, srx, &p->call, GFP_KERNEL, in rxrpc_new_client_call_for_sendmsg()
619 struct rxrpc_send_params p = { in rxrpc_do_sendmsg() local
632 ret = rxrpc_sendmsg_cmsg(msg, &p); in rxrpc_do_sendmsg()
636 if (p.command == RXRPC_CMD_CHARGE_ACCEPT) { in rxrpc_do_sendmsg()
640 ret = rxrpc_user_charge_accept(rx, p.call.user_call_ID); in rxrpc_do_sendmsg()
644 call = rxrpc_find_call_by_user_ID(rx, p.call.user_call_ID); in rxrpc_do_sendmsg()
647 if (p.command != RXRPC_CMD_SEND_DATA) in rxrpc_do_sendmsg()
649 call = rxrpc_new_client_call_for_sendmsg(rx, msg, &p); in rxrpc_do_sendmsg()
654 p.call.nr_timeouts = 0; in rxrpc_do_sendmsg()
662 if (p.command == RXRPC_CMD_SEND_ABORT) in rxrpc_do_sendmsg()
681 if (p.call.tx_total_len != -1) { in rxrpc_do_sendmsg()
687 call->tx_total_len = p.call.tx_total_len; in rxrpc_do_sendmsg()
691 switch (p.call.nr_timeouts) { in rxrpc_do_sendmsg()
693 j = msecs_to_jiffies(p.call.timeouts.normal); in rxrpc_do_sendmsg()
694 if (p.call.timeouts.normal > 0 && j == 0) in rxrpc_do_sendmsg()
699 j = msecs_to_jiffies(p.call.timeouts.idle); in rxrpc_do_sendmsg()
700 if (p.call.timeouts.idle > 0 && j == 0) in rxrpc_do_sendmsg()
705 if (p.call.timeouts.hard > 0) { in rxrpc_do_sendmsg()
706 j = p.call.timeouts.hard * HZ; in rxrpc_do_sendmsg()
719 } else if (p.command == RXRPC_CMD_SEND_ABORT) { in rxrpc_do_sendmsg()
720 rxrpc_propose_abort(call, p.abort_code, -ECONNABORTED, in rxrpc_do_sendmsg()
723 } else if (p.command != RXRPC_CMD_SEND_DATA) { in rxrpc_do_sendmsg()