Lines Matching defs:qrtr_ns
28 } qrtr_ns;
132 return kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
159 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
190 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
202 node = node_get(qrtr_ns.local_node);
277 if (srv->node == qrtr_ns.local_node && bcast)
278 service_announce_del(&qrtr_ns.bcast_sq, srv);
281 list_for_each(li, &qrtr_ns.lookups) {
312 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
355 local_node = node_get(qrtr_ns.local_node);
371 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
404 if (from->sq_node == qrtr_ns.local_node && from->sq_port != port)
408 list_for_each_safe(li, tmp, &qrtr_ns.lookups) {
428 local_node = node_get(qrtr_ns.local_node);
445 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
464 if (from->sq_node == qrtr_ns.local_node) {
473 if (srv->node == qrtr_ns.local_node) {
474 ret = service_announce_new(&qrtr_ns.bcast_sq, srv);
482 list_for_each(li, &qrtr_ns.lookups) {
502 if (from->sq_node == qrtr_ns.local_node) {
508 if (from->sq_node == qrtr_ns.local_node && from->sq_port != port)
531 if (from->sq_node != qrtr_ns.local_node)
541 list_add_tail(&lookup->li, &qrtr_ns.lookups);
569 list_for_each_safe(li, tmp, &qrtr_ns.lookups) {
608 msglen = kernel_recvmsg(qrtr_ns.sock, &msg, &iv, 1,
681 queue_work(qrtr_ns.workqueue, &qrtr_ns.work);
689 INIT_LIST_HEAD(&qrtr_ns.lookups);
690 INIT_WORK(&qrtr_ns.work, qrtr_ns_worker);
693 PF_QIPCRTR, &qrtr_ns.sock);
697 ret = kernel_getsockname(qrtr_ns.sock, (struct sockaddr *)&sq);
703 qrtr_ns.workqueue = alloc_ordered_workqueue("qrtr_ns_handler", 0);
704 if (!qrtr_ns.workqueue) {
709 qrtr_ns.sock->sk->sk_data_ready = qrtr_ns_data_ready;
712 qrtr_ns.local_node = sq.sq_node;
714 ret = kernel_bind(qrtr_ns.sock, (struct sockaddr *)&sq, sizeof(sq));
720 qrtr_ns.bcast_sq.sq_family = AF_QIPCRTR;
721 qrtr_ns.bcast_sq.sq_node = QRTR_NODE_BCAST;
722 qrtr_ns.bcast_sq.sq_port = QRTR_PORT_CTRL;
724 ret = say_hello(&qrtr_ns.bcast_sq);
731 destroy_workqueue(qrtr_ns.workqueue);
733 sock_release(qrtr_ns.sock);
740 cancel_work_sync(&qrtr_ns.work);
741 destroy_workqueue(qrtr_ns.workqueue);
742 sock_release(qrtr_ns.sock);