Lines Matching refs:publ
72 return msg_destnode(&p_ptr->publ.phdr);
77 return msg_destport(&p_ptr->publ.phdr);
82 return msg_transp_seqno(&p_ptr->publ.phdr);
87 struct tipc_msg *m = &p_ptr->publ.phdr;
114 hdr = &oport->publ.phdr;
234 ref = tipc_ref_acquire(p_ptr, &p_ptr->publ.lock);
242 p_ptr->publ.ref = ref;
243 msg = &p_ptr->publ.phdr;
251 p_ptr->publ.usr_handle = usr_handle;
283 if (p_ptr->publ.connected) {
326 handle = p_ptr->publ.usr_handle;
333 return msg_src_droppable(&p_ptr->publ.phdr);
344 spin_unlock_bh(p_ptr->publ.lock);
355 msg_set_src_droppable(&p_ptr->publ.phdr, (isunreliable != 0));
362 return msg_dest_droppable(&p_ptr->publ.phdr);
373 spin_unlock_bh(p_ptr->publ.lock);
384 msg_set_dest_droppable(&p_ptr->publ.phdr, (isunrejectable != 0));
475 if (p_ptr->publ.connected)
511 if (!p_ptr->publ.connected) {
522 p_ptr->publ.ref,
553 u32 imp = msg_importance(&p_ptr->publ.phdr);
555 if (!p_ptr->publ.connected)
559 return port_build_proto_msg(p_ptr->publ.ref,
573 u32 imp = msg_importance(&p_ptr->publ.phdr);
575 if (!p_ptr->publ.connected)
581 p_ptr->publ.ref,
602 } else if (p_ptr->publ.connected) {
617 p_ptr->publ.congested &&
622 p_ptr->publ.congested = 0;
625 p_ptr->wakeup(&p_ptr->publ);
628 } else if (p_ptr->publ.published) {
668 struct publication *publ;
673 tipc_node(tipc_own_addr), p_ptr->publ.ref);
675 tipc_printf(buf, "%-10u:", p_ptr->publ.ref);
677 if (p_ptr->publ.connected) {
684 if (p_ptr->publ.conn_type != 0)
686 p_ptr->publ.conn_type,
687 p_ptr->publ.conn_instance);
689 else if (p_ptr->publ.published) {
691 list_for_each_entry(publ, &p_ptr->publications, pport_list) {
692 if (publ->lower == publ->upper)
693 tipc_printf(buf, " {%u,%u}", publ->type,
694 publ->lower);
696 tipc_printf(buf, " {%u,%u,%u}", publ->type,
697 publ->lower, publ->upper);
721 spin_lock_bh(p_ptr->publ.lock);
723 spin_unlock_bh(p_ptr->publ.lock);
742 msg = &p_ptr->publ.phdr;
791 connected = p_ptr->publ.connected;
792 published = p_ptr->publ.published;
804 spin_unlock_bh(p_ptr->publ.lock);
816 if (unlikely(++p_ptr->publ.conn_unacked >=
819 p_ptr->publ.conn_unacked);
828 spin_unlock_bh(p_ptr->publ.lock);
843 spin_unlock_bh(p_ptr->publ.lock);
874 spin_unlock_bh(p_ptr->publ.lock);
890 spin_unlock_bh(p_ptr->publ.lock);
903 spin_unlock_bh(p_ptr->publ.lock);
985 if (p_ptr->publ.connected) {
986 p_ptr->publ.conn_unacked -= ack;
1037 up_ptr->ref = p_ptr->publ.ref;
1047 *portref = p_ptr->publ.ref;
1048 dbg(" tipc_createport: %x with ref %u\n", p_ptr, p_ptr->publ.ref);
1067 *importance = (unsigned int)msg_importance(&p_ptr->publ.phdr);
1068 spin_unlock_bh(p_ptr->publ.lock);
1082 msg_set_importance(&p_ptr->publ.phdr, (u32)imp);
1083 spin_unlock_bh(p_ptr->publ.lock);
1091 struct publication *publ;
1101 ref, p_ptr, p_ptr->publ.connected, scope, seq->lower, seq->upper);
1102 if (p_ptr->publ.connected)
1113 publ = tipc_nametbl_publish(seq->type, seq->lower, seq->upper,
1114 scope, p_ptr->publ.ref, key);
1115 if (publ) {
1116 list_add(&publ->pport_list, &p_ptr->publications);
1118 p_ptr->publ.published = 1;
1129 struct publication *publ;
1137 list_for_each_entry_safe(publ, tpubl,
1139 tipc_nametbl_withdraw(publ->type, publ->lower,
1140 publ->ref, publ->key);
1144 list_for_each_entry_safe(publ, tpubl,
1146 if (publ->scope != scope)
1148 if (publ->type != seq->type)
1150 if (publ->lower != seq->lower)
1152 if (publ->upper != seq->upper)
1154 tipc_nametbl_withdraw(publ->type, publ->lower,
1155 publ->ref, publ->key);
1161 p_ptr->publ.published = 0;
1175 if (p_ptr->publ.published || p_ptr->publ.connected)
1180 msg = &p_ptr->publ.phdr;
1184 msg_set_origport(msg, p_ptr->publ.ref);
1194 p_ptr->publ.connected = 1;
1220 if (p_ptr->publ.connected) {
1221 p_ptr->publ.connected = 0;
1242 if (p_ptr->publ.connected) {
1243 u32 imp = msg_importance(&p_ptr->publ.phdr);
1268 *isconnected = p_ptr->publ.connected;
1281 if (p_ptr->publ.connected) {
1309 res = msg_build(&sender->publ.phdr, msg_sect, num_sect,
1327 if (!p_ptr || !p_ptr->publ.connected)
1330 p_ptr->publ.congested = 1;
1341 p_ptr->publ.congested = 0;
1347 p_ptr->publ.congested = 0;
1368 if (!p_ptr || !p_ptr->publ.connected)
1371 msg = &p_ptr->publ.phdr;
1381 p_ptr->publ.congested = 1;
1392 p_ptr->publ.congested = 0;
1397 p_ptr->publ.congested = 0;
1422 if (!p_ptr || p_ptr->publ.connected)
1425 msg = &p_ptr->publ.phdr;
1494 if (!p_ptr || p_ptr->publ.connected)
1497 msg = &p_ptr->publ.phdr;
1565 if (!p_ptr || p_ptr->publ.connected)
1568 msg = &p_ptr->publ.phdr;
1622 if (!p_ptr || p_ptr->publ.connected)
1625 msg = &p_ptr->publ.phdr;