Lines Matching defs:qrtr_ns
27 } qrtr_ns;
130 return kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
157 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
188 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
201 node = node_get(qrtr_ns.local_node);
289 if (srv->node == qrtr_ns.local_node && bcast)
290 service_announce_del(&qrtr_ns.bcast_sq, srv);
293 list_for_each(li, &qrtr_ns.lookups) {
324 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
381 local_node = node_get(qrtr_ns.local_node);
408 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
446 if (from->sq_node == qrtr_ns.local_node && from->sq_port != port)
450 list_for_each_safe(li, tmp, &qrtr_ns.lookups) {
470 local_node = node_get(qrtr_ns.local_node);
498 ret = kernel_sendmsg(qrtr_ns.sock, &msg, &iv, 1, sizeof(pkt));
521 if (from->sq_node == qrtr_ns.local_node) {
534 if (srv->node == qrtr_ns.local_node) {
535 ret = service_announce_new(&qrtr_ns.bcast_sq, srv);
543 list_for_each(li, &qrtr_ns.lookups) {
563 if (from->sq_node == qrtr_ns.local_node) {
573 if (from->sq_node == qrtr_ns.local_node && from->sq_port != port)
597 if (from->sq_node != qrtr_ns.local_node)
607 list_add_tail(&lookup->li, &qrtr_ns.lookups);
661 list_for_each_safe(li, tmp, &qrtr_ns.lookups) {
700 msglen = kernel_recvmsg(qrtr_ns.sock, &msg, &iv, 1,
771 queue_work(qrtr_ns.workqueue, &qrtr_ns.work);
779 INIT_LIST_HEAD(&qrtr_ns.lookups);
780 INIT_WORK(&qrtr_ns.work, qrtr_ns_worker);
783 PF_QIPCRTR, &qrtr_ns.sock);
787 ret = kernel_getsockname(qrtr_ns.sock, (struct sockaddr *)&sq);
793 qrtr_ns.workqueue = alloc_workqueue("qrtr_ns_handler", WQ_UNBOUND, 1);
794 if (!qrtr_ns.workqueue) {
799 qrtr_ns.sock->sk->sk_data_ready = qrtr_ns_data_ready;
802 qrtr_ns.local_node = sq.sq_node;
804 ret = kernel_bind(qrtr_ns.sock, (struct sockaddr *)&sq, sizeof(sq));
810 qrtr_ns.bcast_sq.sq_family = AF_QIPCRTR;
811 qrtr_ns.bcast_sq.sq_node = QRTR_NODE_BCAST;
812 qrtr_ns.bcast_sq.sq_port = QRTR_PORT_CTRL;
814 ret = say_hello(&qrtr_ns.bcast_sq);
821 destroy_workqueue(qrtr_ns.workqueue);
823 sock_release(qrtr_ns.sock);
829 cancel_work_sync(&qrtr_ns.work);
830 destroy_workqueue(qrtr_ns.workqueue);
831 sock_release(qrtr_ns.sock);