Lines Matching defs:call
144 rxrpc_notify_new_call_t notify_new_call; /* Func to notify of new call */
145 rxrpc_discard_new_call_t discard_new_call; /* Func to discard a new call */
148 spinlock_t incoming_lock; /* Incoming call vs service shutdown lock */
155 struct rb_root calls; /* User ID -> call mapping */
181 u32 callNumber; /* call ID (0 for connection-level packets) */
182 u32 seq; /* sequence number of pkt in call stream */
261 /* Free crypto request on a call */
387 RXRPC_CALL_REMOTELY_ABORTED, /* - call aborted by peer */
388 RXRPC_CALL_LOCALLY_ABORTED, /* - call aborted locally on error or close */
389 RXRPC_CALL_LOCAL_ERROR, /* - call failed due to local error */
390 RXRPC_CALL_NETWORK_ERROR, /* - call terminated by network error */
467 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */
479 struct rxrpc_call *call; /* Active call */
480 unsigned int call_debug_id; /* call->debug_id */
481 u32 call_id; /* ID of current call */
483 u32 last_call; /* ID of last call */
541 * Flags in call->flags.
544 RXRPC_CALL_RELEASED, /* call has been released - no more message to userspace */
546 RXRPC_CALL_IS_SERVICE, /* Call is service call */
547 RXRPC_CALL_EXPOSED, /* The call was exposed to the world */
554 RXRPC_CALL_RX_HEARD, /* The peer responded at least once to this call */
555 RXRPC_CALL_DISCONNECTED, /* The call has been disconnected */
556 RXRPC_CALL_KERNEL, /* The call was made by the kernel */
557 RXRPC_CALL_UPGRADE, /* Service upgrade was requested for the call */
558 RXRPC_CALL_EXCLUSIVE, /* The call uses a once-only connection */
564 * Events that can be raised on a call.
568 RXRPC_CALL_EV_INITIAL_PING, /* Send initial ping for a new service call */
572 * The states that a call can be in.
586 RXRPC_CALL_COMPLETE, /* - call complete */
602 * RxRPC call definition
607 struct rxrpc_connection *conn; /* connection carrying call */
612 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */
624 unsigned long expect_term_by; /* When we expect call termination by */
631 struct list_head link; /* link in master call list */
642 unsigned long user_call_ID; /* user-defined call ID */
652 enum rxrpc_call_state _state; /* Current state of call (needs barrier) */
656 enum rxrpc_interruptibility interruptibility; /* At what point call may be interrupted */
657 u32 call_id; /* call ID on connection */
683 rxrpc_serial_t rx_serial; /* Highest serial received for this call */
758 RXRPC_CMD_REJECT_BUSY, /* [server] reject a call as busy */
764 unsigned long user_call_ID; /* User's call ID */
768 u32 normal; /* Max time since last call packet (msec) */
771 bool kernel; /* T if kernel is making the call */
772 enum rxrpc_interruptibility interruptibility; /* How is interruptible is the call? */
776 struct rxrpc_call_params call;
779 bool exclusive; /* Shared or exclusive call */
788 struct list_head call_link; /* Link in call->tx_sendmsg/tx_buffer */
866 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial,
872 void rxrpc_resend(struct rxrpc_call *call, struct sk_buff *ack_skb);
874 void rxrpc_reduce_call_timer(struct rxrpc_call *call,
879 bool rxrpc_input_call_event(struct rxrpc_call *call, struct sk_buff *skb);
888 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what);
896 void rxrpc_start_call_timer(struct rxrpc_call *call);
908 static inline bool rxrpc_is_service_call(const struct rxrpc_call *call)
910 return test_bit(RXRPC_CALL_IS_SERVICE, &call->flags);
913 static inline bool rxrpc_is_client_call(const struct rxrpc_call *call)
915 return !rxrpc_is_service_call(call);
921 bool rxrpc_set_call_completion(struct rxrpc_call *call,
925 bool rxrpc_call_completed(struct rxrpc_call *call);
926 bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,
928 void rxrpc_prefail_call(struct rxrpc_call *call, enum rxrpc_call_completion compl,
931 static inline void rxrpc_set_call_state(struct rxrpc_call *call,
935 smp_store_release(&call->_state, state);
936 wake_up(&call->waitq);
939 static inline enum rxrpc_call_state __rxrpc_call_state(const struct rxrpc_call *call)
941 return call->_state; /* Only inside I/O thread */
944 static inline bool __rxrpc_call_is_complete(const struct rxrpc_call *call)
946 return __rxrpc_call_state(call) == RXRPC_CALL_COMPLETE;
949 static inline enum rxrpc_call_state rxrpc_call_state(const struct rxrpc_call *call)
952 return smp_load_acquire(&call->_state);
955 static inline bool rxrpc_call_is_complete(const struct rxrpc_call *call)
957 return rxrpc_call_state(call) == RXRPC_CALL_COMPLETE;
960 static inline bool rxrpc_call_has_failed(const struct rxrpc_call *call)
962 return rxrpc_call_is_complete(call) && call->completion != RXRPC_CALL_SUCCEEDED;
975 int rxrpc_look_up_bundle(struct rxrpc_call *call, gfp_t gfp);
1160 int rxrpc_send_ack_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb);
1166 void rxrpc_transmit_one(struct rxrpc_call *call, struct rxrpc_txbuf *txb);
1204 * Abort a call due to a protocol error.
1206 static inline int rxrpc_abort_eproto(struct rxrpc_call *call,
1213 rxrpc_abort_call(call, sp->hdr.seq, abort_code, -EPROTO, why);
1248 bool rxrpc_propose_abort(struct rxrpc_call *call, s32 abort_code, int error,
1294 struct rxrpc_txbuf *rxrpc_alloc_txbuf(struct rxrpc_call *call, u8 packet_type,