Lines Matching refs:call
19 * removal a call's user ID from the socket tree to make the user ID available
20 * again and so that it won't be seen again in association with that call
22 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call)
24 _debug("RELEASE CALL %d", call->debug_id);
26 if (test_bit(RXRPC_CALL_HAS_USERID, &call->flags)) {
28 rb_erase(&call->sock_node, &call->socket->calls);
29 clear_bit(RXRPC_CALL_HAS_USERID, &call->flags);
33 read_lock_bh(&call->state_lock);
34 if (!test_bit(RXRPC_CALL_RELEASED, &call->flags) &&
35 !test_and_set_bit(RXRPC_CALL_RELEASE, &call->events))
36 rxrpc_queue_call(call);
37 read_unlock_bh(&call->state_lock);
49 struct rxrpc_call *call = NULL, *continue_call = NULL;
112 call = sp->call;
113 ASSERT(call != NULL);
117 /* make sure we wait for the state to be updated in this call */
118 spin_lock_bh(&call->lock);
119 spin_unlock_bh(&call->lock);
121 if (test_bit(RXRPC_CALL_RELEASED, &call->flags)) {
122 _debug("packet from released call");
132 if (call != continue_call ||
141 rxrpc_get_call(call);
147 &call->conn->trans->peer->srx,
148 sizeof(call->conn->trans->peer->srx));
162 ullen, &call->user_call_ID);
165 ASSERT(test_bit(RXRPC_CALL_HAS_USERID, &call->flags));
168 ASSERTCMP(ntohl(sp->hdr.seq), >=, call->rx_data_recv);
169 ASSERTCMP(ntohl(sp->hdr.seq), <=, call->rx_data_recv + 1);
170 call->rx_data_recv = ntohl(sp->hdr.seq);
172 ASSERTCMP(ntohl(sp->hdr.seq), >, call->rx_data_eaten);
210 if (call->conn->out_clientflag) {
231 continue_call = sp->call;
233 rxrpc_put_call(call);
234 call = NULL;
254 if (call)
255 rxrpc_put_call(call);
280 ullen, &call->user_call_ID);
283 ASSERT(test_bit(RXRPC_CALL_HAS_USERID, &call->flags));
295 abort_code = call->abort_code;
327 rxrpc_remove_user_ID(rx, call);
331 rxrpc_put_call(call);
340 rxrpc_put_call(call);
353 rxrpc_put_call(call);
379 struct rxrpc_call *call = sp->call;
381 ASSERTCMP(ntohl(sp->hdr.seq), >=, call->rx_data_recv);
382 ASSERTCMP(ntohl(sp->hdr.seq), <=, call->rx_data_recv + 1);
383 call->rx_data_recv = ntohl(sp->hdr.seq);
385 ASSERTCMP(ntohl(sp->hdr.seq), >, call->rx_data_eaten);
395 * Determine if data message is last one for the parent call.
420 return sp->call->abort_code;