Lines Matching defs:clnt
2 * net/9p/clnt.c
62 inline int p9_is_proto_dotl(struct p9_client *clnt)
64 return (clnt->proto_version == p9_proto_2000L);
68 inline int p9_is_proto_dotu(struct p9_client *clnt)
70 return (clnt->proto_version == p9_proto_2000u);
101 * @clnt: existing v9fs client information
106 static int parse_opts(char *opts, struct p9_client *clnt)
114 clnt->proto_version = p9_proto_2000u;
115 clnt->msize = 8192;
144 clnt->msize = option;
147 clnt->trans_mod = v9fs_get_trans_by_name(&args[0]);
148 if(clnt->trans_mod == NULL) {
157 clnt->proto_version = p9_proto_legacy;
163 clnt->proto_version = ret;
361 P9_DPRINTK(P9_DEBUG_MUX, "clnt %p req %p tag: %d\n", c, r, tag);
625 static struct p9_fid *p9_fid_create(struct p9_client *clnt)
631 P9_DPRINTK(P9_DEBUG_FID, "clnt %p\n", clnt);
636 ret = p9_idpool_get(clnt->fidpool);
646 fid->clnt = clnt;
648 spin_lock_irqsave(&clnt->lock, flags);
649 list_add(&fid->flist, &clnt->fidlist);
650 spin_unlock_irqrestore(&clnt->lock, flags);
661 struct p9_client *clnt;
665 clnt = fid->clnt;
666 p9_idpool_put(fid->fid, clnt->fidpool);
667 spin_lock_irqsave(&clnt->lock, flags);
669 spin_unlock_irqrestore(&clnt->lock, flags);
738 struct p9_client *clnt;
741 clnt = kmalloc(sizeof(struct p9_client), GFP_KERNEL);
742 if (!clnt)
745 clnt->trans_mod = NULL;
746 clnt->trans = NULL;
747 spin_lock_init(&clnt->lock);
748 INIT_LIST_HEAD(&clnt->fidlist);
750 p9_tag_init(clnt);
752 err = parse_opts(options, clnt);
756 if (!clnt->trans_mod)
757 clnt->trans_mod = v9fs_get_default_trans();
759 if (clnt->trans_mod == NULL) {
766 clnt->fidpool = p9_idpool_create();
767 if (IS_ERR(clnt->fidpool)) {
768 err = PTR_ERR(clnt->fidpool);
769 clnt->fidpool = NULL;
773 P9_DPRINTK(P9_DEBUG_MUX, "clnt %p trans %p msize %d protocol %d\n",
774 clnt, clnt->trans_mod, clnt->msize, clnt->proto_version);
776 err = clnt->trans_mod->create(clnt, dev_name, options);
780 if ((clnt->msize+P9_IOHDRSZ) > clnt->trans_mod->maxsize)
781 clnt->msize = clnt->trans_mod->maxsize-P9_IOHDRSZ;
783 err = p9_client_version(clnt);
787 return clnt;
790 clnt->trans_mod->close(clnt);
792 p9_idpool_destroy(clnt->fidpool);
794 v9fs_put_trans(clnt->trans_mod);
796 kfree(clnt);
801 void p9_client_destroy(struct p9_client *clnt)
805 P9_DPRINTK(P9_DEBUG_MUX, "clnt %p\n", clnt);
807 if (clnt->trans_mod)
808 clnt->trans_mod->close(clnt);
810 v9fs_put_trans(clnt->trans_mod);
812 list_for_each_entry_safe(fid, fidptr, &clnt->fidlist, flist) {
817 if (clnt->fidpool)
818 p9_idpool_destroy(clnt->fidpool);
820 p9_tag_cleanup(clnt);
822 kfree(clnt);
826 void p9_client_disconnect(struct p9_client *clnt)
828 P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
829 clnt->status = Disconnected;
833 void p9_client_begin_disconnect(struct p9_client *clnt)
835 P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
836 clnt->status = BeginDisconnect;
840 struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
852 fid = p9_fid_create(clnt);
859 req = p9_client_rpc(clnt, P9_TATTACH, "ddss?d", fid->fid,
866 err = p9pdu_readf(req->rc, clnt->proto_version, "Q", &qid);
869 p9_free_req(clnt, req);
880 p9_free_req(clnt, req);
891 p9_client_auth(struct p9_client *clnt, char *uname, u32 n_uname, char *aname)
901 afid = p9_fid_create(clnt);
908 req = p9_client_rpc(clnt, P9_TAUTH, "dss?d",
915 err = p9pdu_readf(req->rc, clnt->proto_version, "Q", &qid);
918 p9_free_req(clnt, req);
928 p9_free_req(clnt, req);
942 struct p9_client *clnt;
950 clnt = oldfid->clnt;
952 fid = p9_fid_create(clnt);
967 req = p9_client_rpc(clnt, P9_TWALK, "ddT", oldfid->fid, fid->fid,
974 err = p9pdu_readf(req->rc, clnt->proto_version, "R", &nwqids, &wqids);
977 p9_free_req(clnt, req);
980 p9_free_req(clnt, req);
1019 struct p9_client *clnt;
1024 clnt = fid->clnt;
1026 p9_is_proto_dotl(clnt) ? "TLOPEN" : "TOPEN", fid->fid, mode);
1032 if (p9_is_proto_dotl(clnt))
1033 req = p9_client_rpc(clnt, P9_TLOPEN, "dd", fid->fid, mode);
1035 req = p9_client_rpc(clnt, P9_TOPEN, "db", fid->fid, mode);
1041 err = p9pdu_readf(req->rc, clnt->proto_version, "Qd", &qid, &iounit);
1048 p9_is_proto_dotl(clnt) ? "RLOPEN" : "ROPEN", qid.type,
1055 p9_free_req(clnt, req);
1065 struct p9_client *clnt;
1072 clnt = ofid->clnt;
1077 req = p9_client_rpc(clnt, P9_TLCREATE, "dsddd", ofid->fid, name, flags,
1084 err = p9pdu_readf(req->rc, clnt->proto_version, "Qd", qid, &iounit);
1099 p9_free_req(clnt, req);
1109 struct p9_client *clnt;
1117 clnt = fid->clnt;
1122 req = p9_client_rpc(clnt, P9_TCREATE, "dsdb?s", fid->fid, name, perm,
1129 err = p9pdu_readf(req->rc, clnt->proto_version, "Qd", &qid, &iounit);
1144 p9_free_req(clnt, req);
1154 struct p9_client *clnt;
1159 clnt = dfid->clnt;
1161 req = p9_client_rpc(clnt, P9_TSYMLINK, "dssd", dfid->fid, name, symtgt,
1168 err = p9pdu_readf(req->rc, clnt->proto_version, "Q", qid);
1178 p9_free_req(clnt, req);
1186 struct p9_client *clnt;
1191 clnt = dfid->clnt;
1192 req = p9_client_rpc(clnt, P9_TLINK, "dds", dfid->fid, oldfid->fid,
1198 p9_free_req(clnt, req);
1206 struct p9_client *clnt;
1211 clnt = fid->clnt;
1213 req = p9_client_rpc(clnt, P9_TCLUNK, "d", fid->fid);
1221 p9_free_req(clnt, req);
1232 struct p9_client *clnt;
1237 clnt = fid->clnt;
1239 req = p9_client_rpc(clnt, P9_TREMOVE, "d", fid->fid);
1247 p9_free_req(clnt, req);
1259 struct p9_client *clnt;
1266 clnt = fid->clnt;
1270 if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
1271 rsize = clnt->msize - P9_IOHDRSZ;
1276 req = p9_client_rpc(clnt, P9_TREAD, "dqd", fid->fid, offset, rsize);
1282 err = p9pdu_readf(req->rc, clnt->proto_version, "D", &count, &dataptr);
1302 p9_free_req(clnt, req);
1306 p9_free_req(clnt, req);
1317 struct p9_client *clnt;
1323 clnt = fid->clnt;
1327 if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
1328 rsize = clnt->msize - P9_IOHDRSZ;
1333 req = p9_client_rpc(clnt, P9_TWRITE, "dqD", fid->fid, offset,
1336 req = p9_client_rpc(clnt, P9_TWRITE, "dqU", fid->fid, offset,
1343 err = p9pdu_readf(req->rc, clnt->proto_version, "d", &count);
1351 p9_free_req(clnt, req);
1355 p9_free_req(clnt, req);
1364 struct p9_client *clnt;
1375 clnt = fid->clnt;
1377 req = p9_client_rpc(clnt, P9_TSTAT, "d", fid->fid);
1383 err = p9pdu_readf(req->rc, clnt->proto_version, "wS", &ignored, ret);
1386 p9_free_req(clnt, req);
1401 p9_free_req(clnt, req);
1414 struct p9_client *clnt;
1426 clnt = fid->clnt;
1428 req = p9_client_rpc(clnt, P9_TGETATTR, "dq", fid->fid, request_mask);
1434 err = p9pdu_readf(req->rc, clnt->proto_version, "A", ret);
1437 p9_free_req(clnt, req);
1460 p9_free_req(clnt, req);
1502 struct p9_client *clnt;
1505 clnt = fid->clnt;
1506 wst->size = p9_client_statsize(wst, clnt->proto_version);
1519 req = p9_client_rpc(clnt, P9_TWSTAT, "dwS", fid->fid, wst->size+2, wst);
1527 p9_free_req(clnt, req);
1537 struct p9_client *clnt;
1540 clnt = fid->clnt;
1550 req = p9_client_rpc(clnt, P9_TSETATTR, "dI", fid->fid, p9attr);
1557 p9_free_req(clnt, req);
1567 struct p9_client *clnt;
1570 clnt = fid->clnt;
1574 req = p9_client_rpc(clnt, P9_TSTATFS, "d", fid->fid);
1580 err = p9pdu_readf(req->rc, clnt->proto_version, "ddqqqqqqd", &sb->type,
1585 p9_free_req(clnt, req);
1596 p9_free_req(clnt, req);
1606 struct p9_client *clnt;
1609 clnt = fid->clnt;
1614 req = p9_client_rpc(clnt, P9_TRENAME, "dds", fid->fid,
1623 p9_free_req(clnt, req);
1637 struct p9_client *clnt;
1641 clnt = file_fid->clnt;
1642 attr_fid = p9_fid_create(clnt);
1652 req = p9_client_rpc(clnt, P9_TXATTRWALK, "dds",
1658 err = p9pdu_readf(req->rc, clnt->proto_version, "q", attr_size);
1661 p9_free_req(clnt, req);
1664 p9_free_req(clnt, req);
1684 struct p9_client *clnt;
1690 clnt = fid->clnt;
1691 req = p9_client_rpc(clnt, P9_TXATTRCREATE, "dsqd",
1698 p9_free_req(clnt, req);
1707 struct p9_client *clnt;
1715 clnt = fid->clnt;
1719 if (!rsize || rsize > clnt->msize-P9_READDIRHDRSZ)
1720 rsize = clnt->msize - P9_READDIRHDRSZ;
1725 req = p9_client_rpc(clnt, P9_TREADDIR, "dqd", fid->fid, offset, rsize);
1731 err = p9pdu_readf(req->rc, clnt->proto_version, "D", &count, &dataptr);
1742 p9_free_req(clnt, req);
1746 p9_free_req(clnt, req);
1756 struct p9_client *clnt;
1760 clnt = fid->clnt;
1763 req = p9_client_rpc(clnt, P9_TMKNOD, "dsdddd", fid->fid, name, mode,
1768 err = p9pdu_readf(req->rc, clnt->proto_version, "Q", qid);
1777 p9_free_req(clnt, req);
1787 struct p9_client *clnt;
1791 clnt = fid->clnt;
1794 req = p9_client_rpc(clnt, P9_TMKDIR, "dsdd", fid->fid, name, mode,
1799 err = p9pdu_readf(req->rc, clnt->proto_version, "Q", qid);
1808 p9_free_req(clnt, req);