Searched refs:p_ptr (Results 1 – 3 of 3) sorted by relevance
62 static u32 port_peernode(struct tipc_port *p_ptr) in port_peernode() argument64 return msg_destnode(&p_ptr->phdr); in port_peernode()67 static u32 port_peerport(struct tipc_port *p_ptr) in port_peerport() argument69 return msg_destport(&p_ptr->phdr); in port_peerport()200 struct tipc_port *p_ptr; in tipc_createport_raw() local204 p_ptr = kzalloc(sizeof(*p_ptr), GFP_ATOMIC); in tipc_createport_raw()205 if (!p_ptr) { in tipc_createport_raw()209 ref = tipc_ref_acquire(p_ptr, &p_ptr->lock); in tipc_createport_raw()212 kfree(p_ptr); in tipc_createport_raw()216 p_ptr->usr_handle = usr_handle; in tipc_createport_raw()[all …]
222 int tipc_port_reject_sections(struct tipc_port *p_ptr, struct tipc_msg *hdr,245 static inline void tipc_port_unlock(struct tipc_port *p_ptr) in tipc_port_unlock() argument247 spin_unlock_bh(p_ptr->lock); in tipc_port_unlock()255 static inline u32 tipc_peer_port(struct tipc_port *p_ptr) in tipc_peer_port() argument257 return msg_destport(&p_ptr->phdr); in tipc_peer_port()260 static inline u32 tipc_peer_node(struct tipc_port *p_ptr) in tipc_peer_node() argument262 return msg_destnode(&p_ptr->phdr); in tipc_peer_node()265 static inline int tipc_port_congested(struct tipc_port *p_ptr) in tipc_port_congested() argument267 return (p_ptr->sent - p_ptr->acked) >= (TIPC_FLOW_CONTROL_WIN * 2); in tipc_port_congested()276 struct tipc_port *p_ptr; in tipc_port_recv_msg() local[all …]
421 struct tipc_port *p_ptr; in link_schedule_port() local424 p_ptr = tipc_port_lock(origport); in link_schedule_port()425 if (p_ptr) { in link_schedule_port()426 if (!p_ptr->wakeup) in link_schedule_port()428 if (!list_empty(&p_ptr->wait_list)) in link_schedule_port()430 p_ptr->congested = 1; in link_schedule_port()431 p_ptr->waiting_pkts = 1 + ((sz - 1) / l_ptr->max_pkt); in link_schedule_port()432 list_add_tail(&p_ptr->wait_list, &l_ptr->waiting_ports); in link_schedule_port()435 tipc_port_unlock(p_ptr); in link_schedule_port()443 struct tipc_port *p_ptr; in tipc_link_wakeup_ports() local[all …]