diff options
author | Eric Van Hensbergen <ericvh@ericvh-desktop.(none)> | 2008-03-05 08:08:09 -0500 |
---|---|---|
committer | Eric Van Hensbergen <ericvh@opteron.9grid.us> | 2008-05-14 20:23:25 -0400 |
commit | ee443996a35c1e04f210cafd43d5a98d41e46085 (patch) | |
tree | 58ee72b69a02d9dbb3a98e402a4561baba0eb9a8 /net | |
parent | b32a09db4fb9a87246ba4e7726a979ac4709ad97 (diff) |
9p: Documentation updates
The kernel-doc comments of much of the 9p system have been in disarray since
reorganization. This patch fixes those problems, adds additional documentation
and a template book which collects the 9p information.
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
Diffstat (limited to 'net')
-rw-r--r-- | net/9p/conv.c | 128 | ||||
-rw-r--r-- | net/9p/error.c | 11 | ||||
-rw-r--r-- | net/9p/fcprint.c | 8 | ||||
-rw-r--r-- | net/9p/mod.c | 7 | ||||
-rw-r--r-- | net/9p/trans_fd.c | 146 | ||||
-rw-r--r-- | net/9p/trans_virtio.c | 155 | ||||
-rw-r--r-- | net/9p/util.c | 32 |
7 files changed, 441 insertions, 46 deletions
diff --git a/net/9p/conv.c b/net/9p/conv.c index 3fe35d532c87..44547201f5bc 100644 --- a/net/9p/conv.c +++ b/net/9p/conv.c | |||
@@ -197,7 +197,7 @@ static void buf_get_qid(struct cbuf *bufp, struct p9_qid *qid) | |||
197 | 197 | ||
198 | /** | 198 | /** |
199 | * p9_size_wstat - calculate the size of a variable length stat struct | 199 | * p9_size_wstat - calculate the size of a variable length stat struct |
200 | * @stat: metadata (stat) structure | 200 | * @wstat: metadata (stat) structure |
201 | * @dotu: non-zero if 9P2000.u | 201 | * @dotu: non-zero if 9P2000.u |
202 | * | 202 | * |
203 | */ | 203 | */ |
@@ -511,6 +511,12 @@ p9_create_common(struct cbuf *bufp, u32 size, u8 id) | |||
511 | return fc; | 511 | return fc; |
512 | } | 512 | } |
513 | 513 | ||
514 | /** | ||
515 | * p9_set_tag - set the tag field of an &p9_fcall structure | ||
516 | * @fc: fcall structure to set tag within | ||
517 | * @tag: tag id to set | ||
518 | */ | ||
519 | |||
514 | void p9_set_tag(struct p9_fcall *fc, u16 tag) | 520 | void p9_set_tag(struct p9_fcall *fc, u16 tag) |
515 | { | 521 | { |
516 | fc->tag = tag; | 522 | fc->tag = tag; |
@@ -518,6 +524,12 @@ void p9_set_tag(struct p9_fcall *fc, u16 tag) | |||
518 | } | 524 | } |
519 | EXPORT_SYMBOL(p9_set_tag); | 525 | EXPORT_SYMBOL(p9_set_tag); |
520 | 526 | ||
527 | /** | ||
528 | * p9_create_tversion - allocates and creates a T_VERSION request | ||
529 | * @msize: requested maximum data size | ||
530 | * @version: version string to negotiate | ||
531 | * | ||
532 | */ | ||
521 | struct p9_fcall *p9_create_tversion(u32 msize, char *version) | 533 | struct p9_fcall *p9_create_tversion(u32 msize, char *version) |
522 | { | 534 | { |
523 | int size; | 535 | int size; |
@@ -542,6 +554,16 @@ error: | |||
542 | } | 554 | } |
543 | EXPORT_SYMBOL(p9_create_tversion); | 555 | EXPORT_SYMBOL(p9_create_tversion); |
544 | 556 | ||
557 | /** | ||
558 | * p9_create_tauth - allocates and creates a T_AUTH request | ||
559 | * @afid: handle to use for authentication protocol | ||
560 | * @uname: user name attempting to authenticate | ||
561 | * @aname: mount specifier for remote server | ||
562 | * @n_uname: numeric id for user attempting to authneticate | ||
563 | * @dotu: 9P2000.u extension flag | ||
564 | * | ||
565 | */ | ||
566 | |||
545 | struct p9_fcall *p9_create_tauth(u32 afid, char *uname, char *aname, | 567 | struct p9_fcall *p9_create_tauth(u32 afid, char *uname, char *aname, |
546 | u32 n_uname, int dotu) | 568 | u32 n_uname, int dotu) |
547 | { | 569 | { |
@@ -580,6 +602,18 @@ error: | |||
580 | } | 602 | } |
581 | EXPORT_SYMBOL(p9_create_tauth); | 603 | EXPORT_SYMBOL(p9_create_tauth); |
582 | 604 | ||
605 | /** | ||
606 | * p9_create_tattach - allocates and creates a T_ATTACH request | ||
607 | * @fid: handle to use for the new mount point | ||
608 | * @afid: handle to use for authentication protocol | ||
609 | * @uname: user name attempting to attach | ||
610 | * @aname: mount specifier for remote server | ||
611 | * @n_uname: numeric id for user attempting to attach | ||
612 | * @n_uname: numeric id for user attempting to attach | ||
613 | * @dotu: 9P2000.u extension flag | ||
614 | * | ||
615 | */ | ||
616 | |||
583 | struct p9_fcall * | 617 | struct p9_fcall * |
584 | p9_create_tattach(u32 fid, u32 afid, char *uname, char *aname, | 618 | p9_create_tattach(u32 fid, u32 afid, char *uname, char *aname, |
585 | u32 n_uname, int dotu) | 619 | u32 n_uname, int dotu) |
@@ -616,6 +650,12 @@ error: | |||
616 | } | 650 | } |
617 | EXPORT_SYMBOL(p9_create_tattach); | 651 | EXPORT_SYMBOL(p9_create_tattach); |
618 | 652 | ||
653 | /** | ||
654 | * p9_create_tflush - allocates and creates a T_FLUSH request | ||
655 | * @oldtag: tag id for the transaction we are attempting to cancel | ||
656 | * | ||
657 | */ | ||
658 | |||
619 | struct p9_fcall *p9_create_tflush(u16 oldtag) | 659 | struct p9_fcall *p9_create_tflush(u16 oldtag) |
620 | { | 660 | { |
621 | int size; | 661 | int size; |
@@ -639,6 +679,15 @@ error: | |||
639 | } | 679 | } |
640 | EXPORT_SYMBOL(p9_create_tflush); | 680 | EXPORT_SYMBOL(p9_create_tflush); |
641 | 681 | ||
682 | /** | ||
683 | * p9_create_twalk - allocates and creates a T_FLUSH request | ||
684 | * @fid: handle we are traversing from | ||
685 | * @newfid: a new handle for this transaction | ||
686 | * @nwname: number of path elements to traverse | ||
687 | * @wnames: array of path elements | ||
688 | * | ||
689 | */ | ||
690 | |||
642 | struct p9_fcall *p9_create_twalk(u32 fid, u32 newfid, u16 nwname, | 691 | struct p9_fcall *p9_create_twalk(u32 fid, u32 newfid, u16 nwname, |
643 | char **wnames) | 692 | char **wnames) |
644 | { | 693 | { |
@@ -677,6 +726,13 @@ error: | |||
677 | } | 726 | } |
678 | EXPORT_SYMBOL(p9_create_twalk); | 727 | EXPORT_SYMBOL(p9_create_twalk); |
679 | 728 | ||
729 | /** | ||
730 | * p9_create_topen - allocates and creates a T_OPEN request | ||
731 | * @fid: handle we are trying to open | ||
732 | * @mode: what mode we are trying to open the file in | ||
733 | * | ||
734 | */ | ||
735 | |||
680 | struct p9_fcall *p9_create_topen(u32 fid, u8 mode) | 736 | struct p9_fcall *p9_create_topen(u32 fid, u8 mode) |
681 | { | 737 | { |
682 | int size; | 738 | int size; |
@@ -701,6 +757,19 @@ error: | |||
701 | } | 757 | } |
702 | EXPORT_SYMBOL(p9_create_topen); | 758 | EXPORT_SYMBOL(p9_create_topen); |
703 | 759 | ||
760 | /** | ||
761 | * p9_create_tcreate - allocates and creates a T_CREATE request | ||
762 | * @fid: handle of directory we are trying to create in | ||
763 | * @name: name of the file we are trying to create | ||
764 | * @perm: permissions for the file we are trying to create | ||
765 | * @mode: what mode we are trying to open the file in | ||
766 | * @extension: 9p2000.u extension string (for special files) | ||
767 | * @dotu: 9p2000.u enabled flag | ||
768 | * | ||
769 | * Note: Plan 9 create semantics include opening the resulting file | ||
770 | * which is why mode is included. | ||
771 | */ | ||
772 | |||
704 | struct p9_fcall *p9_create_tcreate(u32 fid, char *name, u32 perm, u8 mode, | 773 | struct p9_fcall *p9_create_tcreate(u32 fid, char *name, u32 perm, u8 mode, |
705 | char *extension, int dotu) | 774 | char *extension, int dotu) |
706 | { | 775 | { |
@@ -736,6 +805,13 @@ error: | |||
736 | } | 805 | } |
737 | EXPORT_SYMBOL(p9_create_tcreate); | 806 | EXPORT_SYMBOL(p9_create_tcreate); |
738 | 807 | ||
808 | /** | ||
809 | * p9_create_tread - allocates and creates a T_READ request | ||
810 | * @fid: handle of the file we are trying to read | ||
811 | * @offset: offset to start reading from | ||
812 | * @count: how many bytes to read | ||
813 | */ | ||
814 | |||
739 | struct p9_fcall *p9_create_tread(u32 fid, u64 offset, u32 count) | 815 | struct p9_fcall *p9_create_tread(u32 fid, u64 offset, u32 count) |
740 | { | 816 | { |
741 | int size; | 817 | int size; |
@@ -761,6 +837,17 @@ error: | |||
761 | } | 837 | } |
762 | EXPORT_SYMBOL(p9_create_tread); | 838 | EXPORT_SYMBOL(p9_create_tread); |
763 | 839 | ||
840 | /** | ||
841 | * p9_create_twrite - allocates and creates a T_WRITE request from the kernel | ||
842 | * @fid: handle of the file we are trying to write | ||
843 | * @offset: offset to start writing at | ||
844 | * @count: how many bytes to write | ||
845 | * @data: data to write | ||
846 | * | ||
847 | * This function will create a requst with data buffers from the kernel | ||
848 | * such as the page cache. | ||
849 | */ | ||
850 | |||
764 | struct p9_fcall *p9_create_twrite(u32 fid, u64 offset, u32 count, | 851 | struct p9_fcall *p9_create_twrite(u32 fid, u64 offset, u32 count, |
765 | const char *data) | 852 | const char *data) |
766 | { | 853 | { |
@@ -794,6 +881,16 @@ error: | |||
794 | } | 881 | } |
795 | EXPORT_SYMBOL(p9_create_twrite); | 882 | EXPORT_SYMBOL(p9_create_twrite); |
796 | 883 | ||
884 | /** | ||
885 | * p9_create_twrite_u - allocates and creates a T_WRITE request from userspace | ||
886 | * @fid: handle of the file we are trying to write | ||
887 | * @offset: offset to start writing at | ||
888 | * @count: how many bytes to write | ||
889 | * @data: data to write | ||
890 | * | ||
891 | * This function will create a request with data buffers from userspace | ||
892 | */ | ||
893 | |||
797 | struct p9_fcall *p9_create_twrite_u(u32 fid, u64 offset, u32 count, | 894 | struct p9_fcall *p9_create_twrite_u(u32 fid, u64 offset, u32 count, |
798 | const char __user *data) | 895 | const char __user *data) |
799 | { | 896 | { |
@@ -827,6 +924,14 @@ error: | |||
827 | } | 924 | } |
828 | EXPORT_SYMBOL(p9_create_twrite_u); | 925 | EXPORT_SYMBOL(p9_create_twrite_u); |
829 | 926 | ||
927 | /** | ||
928 | * p9_create_tclunk - allocate a request to forget about a file handle | ||
929 | * @fid: handle of the file we closing or forgetting about | ||
930 | * | ||
931 | * clunk is used both to close open files and to discard transient handles | ||
932 | * which may be created during meta-data operations and hierarchy traversal. | ||
933 | */ | ||
934 | |||
830 | struct p9_fcall *p9_create_tclunk(u32 fid) | 935 | struct p9_fcall *p9_create_tclunk(u32 fid) |
831 | { | 936 | { |
832 | int size; | 937 | int size; |
@@ -850,6 +955,12 @@ error: | |||
850 | } | 955 | } |
851 | EXPORT_SYMBOL(p9_create_tclunk); | 956 | EXPORT_SYMBOL(p9_create_tclunk); |
852 | 957 | ||
958 | /** | ||
959 | * p9_create_tremove - allocate and create a request to remove a file | ||
960 | * @fid: handle of the file or directory we are removing | ||
961 | * | ||
962 | */ | ||
963 | |||
853 | struct p9_fcall *p9_create_tremove(u32 fid) | 964 | struct p9_fcall *p9_create_tremove(u32 fid) |
854 | { | 965 | { |
855 | int size; | 966 | int size; |
@@ -873,6 +984,12 @@ error: | |||
873 | } | 984 | } |
874 | EXPORT_SYMBOL(p9_create_tremove); | 985 | EXPORT_SYMBOL(p9_create_tremove); |
875 | 986 | ||
987 | /** | ||
988 | * p9_create_tstat - allocate and populate a request for attributes | ||
989 | * @fid: handle of the file or directory we are trying to get the attributes of | ||
990 | * | ||
991 | */ | ||
992 | |||
876 | struct p9_fcall *p9_create_tstat(u32 fid) | 993 | struct p9_fcall *p9_create_tstat(u32 fid) |
877 | { | 994 | { |
878 | int size; | 995 | int size; |
@@ -896,6 +1013,14 @@ error: | |||
896 | } | 1013 | } |
897 | EXPORT_SYMBOL(p9_create_tstat); | 1014 | EXPORT_SYMBOL(p9_create_tstat); |
898 | 1015 | ||
1016 | /** | ||
1017 | * p9_create_tstat - allocate and populate a request to change attributes | ||
1018 | * @fid: handle of the file or directory we are trying to change | ||
1019 | * @wstat: &p9_stat structure with attributes we wish to set | ||
1020 | * @dotu: 9p2000.u enabled flag | ||
1021 | * | ||
1022 | */ | ||
1023 | |||
899 | struct p9_fcall *p9_create_twstat(u32 fid, struct p9_wstat *wstat, | 1024 | struct p9_fcall *p9_create_twstat(u32 fid, struct p9_wstat *wstat, |
900 | int dotu) | 1025 | int dotu) |
901 | { | 1026 | { |
@@ -922,3 +1047,4 @@ error: | |||
922 | return fc; | 1047 | return fc; |
923 | } | 1048 | } |
924 | EXPORT_SYMBOL(p9_create_twstat); | 1049 | EXPORT_SYMBOL(p9_create_twstat); |
1050 | |||
diff --git a/net/9p/error.c b/net/9p/error.c index 64104b9cb422..388770c3631e 100644 --- a/net/9p/error.c +++ b/net/9p/error.c | |||
@@ -33,6 +33,13 @@ | |||
33 | #include <linux/errno.h> | 33 | #include <linux/errno.h> |
34 | #include <net/9p/9p.h> | 34 | #include <net/9p/9p.h> |
35 | 35 | ||
36 | /** | ||
37 | * struct errormap - map string errors from Plan 9 to Linux numeric ids | ||
38 | * @name: string sent over 9P | ||
39 | * @val: numeric id most closely representing @name | ||
40 | * @namelen: length of string | ||
41 | * @list: hash-table list for string lookup | ||
42 | */ | ||
36 | struct errormap { | 43 | struct errormap { |
37 | char *name; | 44 | char *name; |
38 | int val; | 45 | int val; |
@@ -177,8 +184,7 @@ static struct errormap errmap[] = { | |||
177 | }; | 184 | }; |
178 | 185 | ||
179 | /** | 186 | /** |
180 | * p9_error_init - preload | 187 | * p9_error_init - preload mappings into hash list |
181 | * @errstr: error string | ||
182 | * | 188 | * |
183 | */ | 189 | */ |
184 | 190 | ||
@@ -206,6 +212,7 @@ EXPORT_SYMBOL(p9_error_init); | |||
206 | /** | 212 | /** |
207 | * errstr2errno - convert error string to error number | 213 | * errstr2errno - convert error string to error number |
208 | * @errstr: error string | 214 | * @errstr: error string |
215 | * @len: length of error string | ||
209 | * | 216 | * |
210 | */ | 217 | */ |
211 | 218 | ||
diff --git a/net/9p/fcprint.c b/net/9p/fcprint.c index 40244fbd9b0d..53dd8e28dd8a 100644 --- a/net/9p/fcprint.c +++ b/net/9p/fcprint.c | |||
@@ -142,6 +142,14 @@ p9_printdata(char *buf, int buflen, u8 *data, int datalen) | |||
142 | return p9_dumpdata(buf, buflen, data, datalen < 16?datalen:16); | 142 | return p9_dumpdata(buf, buflen, data, datalen < 16?datalen:16); |
143 | } | 143 | } |
144 | 144 | ||
145 | /** | ||
146 | * p9_printfcall - decode and print a protocol structure into a buffer | ||
147 | * @buf: buffer to deposit decoded structure into | ||
148 | * @buflen: available space in buffer | ||
149 | * @fc: protocol rpc structure of type &p9_fcall | ||
150 | * @extended: whether or not session is operating with extended protocol | ||
151 | */ | ||
152 | |||
145 | int | 153 | int |
146 | p9_printfcall(char *buf, int buflen, struct p9_fcall *fc, int extended) | 154 | p9_printfcall(char *buf, int buflen, struct p9_fcall *fc, int extended) |
147 | { | 155 | { |
diff --git a/net/9p/mod.c b/net/9p/mod.c index c285aab2af04..c6d9695949e0 100644 --- a/net/9p/mod.c +++ b/net/9p/mod.c | |||
@@ -39,9 +39,6 @@ module_param_named(debug, p9_debug_level, uint, 0); | |||
39 | MODULE_PARM_DESC(debug, "9P debugging level"); | 39 | MODULE_PARM_DESC(debug, "9P debugging level"); |
40 | #endif | 40 | #endif |
41 | 41 | ||
42 | extern int p9_mux_global_init(void); | ||
43 | extern void p9_mux_global_exit(void); | ||
44 | |||
45 | /* | 42 | /* |
46 | * Dynamic Transport Registration Routines | 43 | * Dynamic Transport Registration Routines |
47 | * | 44 | * |
@@ -52,7 +49,7 @@ static struct p9_trans_module *v9fs_default_transport; | |||
52 | 49 | ||
53 | /** | 50 | /** |
54 | * v9fs_register_trans - register a new transport with 9p | 51 | * v9fs_register_trans - register a new transport with 9p |
55 | * @m - structure describing the transport module and entry points | 52 | * @m: structure describing the transport module and entry points |
56 | * | 53 | * |
57 | */ | 54 | */ |
58 | void v9fs_register_trans(struct p9_trans_module *m) | 55 | void v9fs_register_trans(struct p9_trans_module *m) |
@@ -65,7 +62,7 @@ EXPORT_SYMBOL(v9fs_register_trans); | |||
65 | 62 | ||
66 | /** | 63 | /** |
67 | * v9fs_match_trans - match transport versus registered transports | 64 | * v9fs_match_trans - match transport versus registered transports |
68 | * @arg: string identifying transport | 65 | * @name: string identifying transport |
69 | * | 66 | * |
70 | */ | 67 | */ |
71 | struct p9_trans_module *v9fs_match_trans(const substring_t *name) | 68 | struct p9_trans_module *v9fs_match_trans(const substring_t *name) |
diff --git a/net/9p/trans_fd.c b/net/9p/trans_fd.c index f624dff76852..c6eda999fa7d 100644 --- a/net/9p/trans_fd.c +++ b/net/9p/trans_fd.c | |||
@@ -47,12 +47,29 @@ | |||
47 | #define SCHED_TIMEOUT 10 | 47 | #define SCHED_TIMEOUT 10 |
48 | #define MAXPOLLWADDR 2 | 48 | #define MAXPOLLWADDR 2 |
49 | 49 | ||
50 | /** | ||
51 | * struct p9_fd_opts - per-transport options | ||
52 | * @rfd: file descriptor for reading (trans=fd) | ||
53 | * @wfd: file descriptor for writing (trans=fd) | ||
54 | * @port: port to connect to (trans=tcp) | ||
55 | * | ||
56 | */ | ||
57 | |||
50 | struct p9_fd_opts { | 58 | struct p9_fd_opts { |
51 | int rfd; | 59 | int rfd; |
52 | int wfd; | 60 | int wfd; |
53 | u16 port; | 61 | u16 port; |
54 | }; | 62 | }; |
55 | 63 | ||
64 | |||
65 | /** | ||
66 | * struct p9_trans_fd - transport state | ||
67 | * @rd: reference to file to read from | ||
68 | * @wr: reference of file to write to | ||
69 | * @conn: connection state reference | ||
70 | * | ||
71 | */ | ||
72 | |||
56 | struct p9_trans_fd { | 73 | struct p9_trans_fd { |
57 | struct file *rd; | 74 | struct file *rd; |
58 | struct file *wr; | 75 | struct file *wr; |
@@ -90,10 +107,24 @@ enum { | |||
90 | }; | 107 | }; |
91 | 108 | ||
92 | struct p9_req; | 109 | struct p9_req; |
93 | |||
94 | typedef void (*p9_conn_req_callback)(struct p9_req *req, void *a); | 110 | typedef void (*p9_conn_req_callback)(struct p9_req *req, void *a); |
111 | |||
112 | /** | ||
113 | * struct p9_req - fd mux encoding of an rpc transaction | ||
114 | * @lock: protects req_list | ||
115 | * @tag: numeric tag for rpc transaction | ||
116 | * @tcall: request &p9_fcall structure | ||
117 | * @rcall: response &p9_fcall structure | ||
118 | * @err: error state | ||
119 | * @cb: callback for when response is received | ||
120 | * @cba: argument to pass to callback | ||
121 | * @flush: flag to indicate RPC has been flushed | ||
122 | * @req_list: list link for higher level objects to chain requests | ||
123 | * | ||
124 | */ | ||
125 | |||
95 | struct p9_req { | 126 | struct p9_req { |
96 | spinlock_t lock; /* protect request structure */ | 127 | spinlock_t lock; |
97 | int tag; | 128 | int tag; |
98 | struct p9_fcall *tcall; | 129 | struct p9_fcall *tcall; |
99 | struct p9_fcall *rcall; | 130 | struct p9_fcall *rcall; |
@@ -104,7 +135,39 @@ struct p9_req { | |||
104 | struct list_head req_list; | 135 | struct list_head req_list; |
105 | }; | 136 | }; |
106 | 137 | ||
107 | struct p9_mux_poll_task; | 138 | struct p9_mux_poll_task { |
139 | struct task_struct *task; | ||
140 | struct list_head mux_list; | ||
141 | int muxnum; | ||
142 | }; | ||
143 | |||
144 | /** | ||
145 | * struct p9_conn - fd mux connection state information | ||
146 | * @lock: protects mux_list (?) | ||
147 | * @mux_list: list link for mux to manage multiple connections (?) | ||
148 | * @poll_task: task polling on this connection | ||
149 | * @msize: maximum size for connection (dup) | ||
150 | * @extended: 9p2000.u flag (dup) | ||
151 | * @trans: reference to transport instance for this connection | ||
152 | * @tagpool: id accounting for transactions | ||
153 | * @err: error state | ||
154 | * @equeue: event wait_q (?) | ||
155 | * @req_list: accounting for requests which have been sent | ||
156 | * @unsent_req_list: accounting for requests that haven't been sent | ||
157 | * @rcall: current response &p9_fcall structure | ||
158 | * @rpos: read position in current frame | ||
159 | * @rbuf: current read buffer | ||
160 | * @wpos: write position for current frame | ||
161 | * @wsize: amount of data to write for current frame | ||
162 | * @wbuf: current write buffer | ||
163 | * @poll_wait: array of wait_q's for various worker threads | ||
164 | * @poll_waddr: ???? | ||
165 | * @pt: poll state | ||
166 | * @rq: current read work | ||
167 | * @wq: current write work | ||
168 | * @wsched: ???? | ||
169 | * | ||
170 | */ | ||
108 | 171 | ||
109 | struct p9_conn { | 172 | struct p9_conn { |
110 | spinlock_t lock; /* protect lock structure */ | 173 | spinlock_t lock; /* protect lock structure */ |
@@ -132,11 +195,16 @@ struct p9_conn { | |||
132 | unsigned long wsched; | 195 | unsigned long wsched; |
133 | }; | 196 | }; |
134 | 197 | ||
135 | struct p9_mux_poll_task { | 198 | /** |
136 | struct task_struct *task; | 199 | * struct p9_mux_rpc - fd mux rpc accounting structure |
137 | struct list_head mux_list; | 200 | * @m: connection this request was issued on |
138 | int muxnum; | 201 | * @err: error state |
139 | }; | 202 | * @tcall: request &p9_fcall |
203 | * @rcall: response &p9_fcall | ||
204 | * @wqueue: wait queue that client is blocked on for this rpc | ||
205 | * | ||
206 | * Bug: isn't this information duplicated elsewhere like &p9_req | ||
207 | */ | ||
140 | 208 | ||
141 | struct p9_mux_rpc { | 209 | struct p9_mux_rpc { |
142 | struct p9_conn *m; | 210 | struct p9_conn *m; |
@@ -207,10 +275,12 @@ static void p9_mux_put_tag(struct p9_conn *m, u16 tag) | |||
207 | 275 | ||
208 | /** | 276 | /** |
209 | * p9_mux_calc_poll_procs - calculates the number of polling procs | 277 | * p9_mux_calc_poll_procs - calculates the number of polling procs |
210 | * based on the number of mounted v9fs filesystems. | 278 | * @muxnum: number of mounts |
211 | * | 279 | * |
280 | * Calculation is based on the number of mounted v9fs filesystems. | ||
212 | * The current implementation returns sqrt of the number of mounts. | 281 | * The current implementation returns sqrt of the number of mounts. |
213 | */ | 282 | */ |
283 | |||
214 | static int p9_mux_calc_poll_procs(int muxnum) | 284 | static int p9_mux_calc_poll_procs(int muxnum) |
215 | { | 285 | { |
216 | int n; | 286 | int n; |
@@ -331,12 +401,11 @@ static void p9_mux_poll_stop(struct p9_conn *m) | |||
331 | 401 | ||
332 | /** | 402 | /** |
333 | * p9_conn_create - allocate and initialize the per-session mux data | 403 | * p9_conn_create - allocate and initialize the per-session mux data |
334 | * Creates the polling task if this is the first session. | 404 | * @trans: transport structure |
335 | * | 405 | * |
336 | * @trans - transport structure | 406 | * Note: Creates the polling task if this is the first session. |
337 | * @msize - maximum message size | ||
338 | * @extended - extended flag | ||
339 | */ | 407 | */ |
408 | |||
340 | static struct p9_conn *p9_conn_create(struct p9_trans *trans) | 409 | static struct p9_conn *p9_conn_create(struct p9_trans *trans) |
341 | { | 410 | { |
342 | int i, n; | 411 | int i, n; |
@@ -406,7 +475,10 @@ static struct p9_conn *p9_conn_create(struct p9_trans *trans) | |||
406 | 475 | ||
407 | /** | 476 | /** |
408 | * p9_mux_destroy - cancels all pending requests and frees mux resources | 477 | * p9_mux_destroy - cancels all pending requests and frees mux resources |
478 | * @m: mux to destroy | ||
479 | * | ||
409 | */ | 480 | */ |
481 | |||
410 | static void p9_conn_destroy(struct p9_conn *m) | 482 | static void p9_conn_destroy(struct p9_conn *m) |
411 | { | 483 | { |
412 | P9_DPRINTK(P9_DEBUG_MUX, "mux %p prev %p next %p\n", m, | 484 | P9_DPRINTK(P9_DEBUG_MUX, "mux %p prev %p next %p\n", m, |
@@ -429,9 +501,14 @@ static void p9_conn_destroy(struct p9_conn *m) | |||
429 | } | 501 | } |
430 | 502 | ||
431 | /** | 503 | /** |
432 | * p9_pollwait - called by files poll operation to add v9fs-poll task | 504 | * p9_pollwait - add poll task to the wait queue |
433 | * to files wait queue | 505 | * @filp: file pointer being polled |
506 | * @wait_address: wait_q to block on | ||
507 | * @p: poll state | ||
508 | * | ||
509 | * called by files poll operation to add v9fs-poll task to files wait queue | ||
434 | */ | 510 | */ |
511 | |||
435 | static void | 512 | static void |
436 | p9_pollwait(struct file *filp, wait_queue_head_t *wait_address, poll_table *p) | 513 | p9_pollwait(struct file *filp, wait_queue_head_t *wait_address, poll_table *p) |
437 | { | 514 | { |
@@ -462,7 +539,10 @@ p9_pollwait(struct file *filp, wait_queue_head_t *wait_address, poll_table *p) | |||
462 | 539 | ||
463 | /** | 540 | /** |
464 | * p9_poll_mux - polls a mux and schedules read or write works if necessary | 541 | * p9_poll_mux - polls a mux and schedules read or write works if necessary |
542 | * @m: connection to poll | ||
543 | * | ||
465 | */ | 544 | */ |
545 | |||
466 | static void p9_poll_mux(struct p9_conn *m) | 546 | static void p9_poll_mux(struct p9_conn *m) |
467 | { | 547 | { |
468 | int n; | 548 | int n; |
@@ -499,9 +579,14 @@ static void p9_poll_mux(struct p9_conn *m) | |||
499 | } | 579 | } |
500 | 580 | ||
501 | /** | 581 | /** |
502 | * p9_poll_proc - polls all v9fs transports for new events and queues | 582 | * p9_poll_proc - poll worker thread |
503 | * the appropriate work to the work queue | 583 | * @a: thread state and arguments |
584 | * | ||
585 | * polls all v9fs transports for new events and queues the appropriate | ||
586 | * work to the work queue | ||
587 | * | ||
504 | */ | 588 | */ |
589 | |||
505 | static int p9_poll_proc(void *a) | 590 | static int p9_poll_proc(void *a) |
506 | { | 591 | { |
507 | struct p9_conn *m, *mtmp; | 592 | struct p9_conn *m, *mtmp; |
@@ -527,7 +612,10 @@ static int p9_poll_proc(void *a) | |||
527 | 612 | ||
528 | /** | 613 | /** |
529 | * p9_write_work - called when a transport can send some data | 614 | * p9_write_work - called when a transport can send some data |
615 | * @work: container for work to be done | ||
616 | * | ||
530 | */ | 617 | */ |
618 | |||
531 | static void p9_write_work(struct work_struct *work) | 619 | static void p9_write_work(struct work_struct *work) |
532 | { | 620 | { |
533 | int n, err; | 621 | int n, err; |
@@ -638,7 +726,10 @@ static void process_request(struct p9_conn *m, struct p9_req *req) | |||
638 | 726 | ||
639 | /** | 727 | /** |
640 | * p9_read_work - called when there is some data to be read from a transport | 728 | * p9_read_work - called when there is some data to be read from a transport |
729 | * @work: container of work to be done | ||
730 | * | ||
641 | */ | 731 | */ |
732 | |||
642 | static void p9_read_work(struct work_struct *work) | 733 | static void p9_read_work(struct work_struct *work) |
643 | { | 734 | { |
644 | int n, err; | 735 | int n, err; |
@@ -793,7 +884,9 @@ error: | |||
793 | * @tc: request to be sent | 884 | * @tc: request to be sent |
794 | * @cb: callback function to call when response is received | 885 | * @cb: callback function to call when response is received |
795 | * @cba: parameter to pass to the callback function | 886 | * @cba: parameter to pass to the callback function |
887 | * | ||
796 | */ | 888 | */ |
889 | |||
797 | static struct p9_req *p9_send_request(struct p9_conn *m, | 890 | static struct p9_req *p9_send_request(struct p9_conn *m, |
798 | struct p9_fcall *tc, | 891 | struct p9_fcall *tc, |
799 | p9_conn_req_callback cb, void *cba) | 892 | p9_conn_req_callback cb, void *cba) |
@@ -961,10 +1054,12 @@ p9_conn_rpc_cb(struct p9_req *req, void *a) | |||
961 | /** | 1054 | /** |
962 | * p9_fd_rpc- sends 9P request and waits until a response is available. | 1055 | * p9_fd_rpc- sends 9P request and waits until a response is available. |
963 | * The function can be interrupted. | 1056 | * The function can be interrupted. |
964 | * @m: mux data | 1057 | * @t: transport data |
965 | * @tc: request to be sent | 1058 | * @tc: request to be sent |
966 | * @rc: pointer where a pointer to the response is stored | 1059 | * @rc: pointer where a pointer to the response is stored |
1060 | * | ||
967 | */ | 1061 | */ |
1062 | |||
968 | int | 1063 | int |
969 | p9_fd_rpc(struct p9_trans *t, struct p9_fcall *tc, struct p9_fcall **rc) | 1064 | p9_fd_rpc(struct p9_trans *t, struct p9_fcall *tc, struct p9_fcall **rc) |
970 | { | 1065 | { |
@@ -1041,8 +1136,10 @@ p9_fd_rpc(struct p9_trans *t, struct p9_fcall *tc, struct p9_fcall **rc) | |||
1041 | * @m: mux data | 1136 | * @m: mux data |
1042 | * @tc: request to be sent | 1137 | * @tc: request to be sent |
1043 | * @cb: callback function to be called when response arrives | 1138 | * @cb: callback function to be called when response arrives |
1044 | * @cba: value to pass to the callback function | 1139 | * @a: value to pass to the callback function |
1140 | * | ||
1045 | */ | 1141 | */ |
1142 | |||
1046 | int p9_conn_rpcnb(struct p9_conn *m, struct p9_fcall *tc, | 1143 | int p9_conn_rpcnb(struct p9_conn *m, struct p9_fcall *tc, |
1047 | p9_conn_req_callback cb, void *a) | 1144 | p9_conn_req_callback cb, void *a) |
1048 | { | 1145 | { |
@@ -1065,7 +1162,9 @@ int p9_conn_rpcnb(struct p9_conn *m, struct p9_fcall *tc, | |||
1065 | * p9_conn_cancel - cancel all pending requests with error | 1162 | * p9_conn_cancel - cancel all pending requests with error |
1066 | * @m: mux data | 1163 | * @m: mux data |
1067 | * @err: error code | 1164 | * @err: error code |
1165 | * | ||
1068 | */ | 1166 | */ |
1167 | |||
1069 | void p9_conn_cancel(struct p9_conn *m, int err) | 1168 | void p9_conn_cancel(struct p9_conn *m, int err) |
1070 | { | 1169 | { |
1071 | struct p9_req *req, *rtmp; | 1170 | struct p9_req *req, *rtmp; |
@@ -1099,7 +1198,7 @@ void p9_conn_cancel(struct p9_conn *m, int err) | |||
1099 | /** | 1198 | /** |
1100 | * v9fs_parse_options - parse mount options into session structure | 1199 | * v9fs_parse_options - parse mount options into session structure |
1101 | * @options: options string passed from mount | 1200 | * @options: options string passed from mount |
1102 | * @v9ses: existing v9fs session information | 1201 | * @opts: transport-specific structure to parse options into |
1103 | * | 1202 | * |
1104 | */ | 1203 | */ |
1105 | 1204 | ||
@@ -1193,11 +1292,12 @@ static int p9_socket_open(struct p9_trans *trans, struct socket *csocket) | |||
1193 | 1292 | ||
1194 | /** | 1293 | /** |
1195 | * p9_fd_read- read from a fd | 1294 | * p9_fd_read- read from a fd |
1196 | * @v9ses: session information | 1295 | * @trans: transport instance state |
1197 | * @v: buffer to receive data into | 1296 | * @v: buffer to receive data into |
1198 | * @len: size of receive buffer | 1297 | * @len: size of receive buffer |
1199 | * | 1298 | * |
1200 | */ | 1299 | */ |
1300 | |||
1201 | static int p9_fd_read(struct p9_trans *trans, void *v, int len) | 1301 | static int p9_fd_read(struct p9_trans *trans, void *v, int len) |
1202 | { | 1302 | { |
1203 | int ret; | 1303 | int ret; |
@@ -1220,11 +1320,12 @@ static int p9_fd_read(struct p9_trans *trans, void *v, int len) | |||
1220 | 1320 | ||
1221 | /** | 1321 | /** |
1222 | * p9_fd_write - write to a socket | 1322 | * p9_fd_write - write to a socket |
1223 | * @v9ses: session information | 1323 | * @trans: transport instance state |
1224 | * @v: buffer to send data from | 1324 | * @v: buffer to send data from |
1225 | * @len: size of send buffer | 1325 | * @len: size of send buffer |
1226 | * | 1326 | * |
1227 | */ | 1327 | */ |
1328 | |||
1228 | static int p9_fd_write(struct p9_trans *trans, void *v, int len) | 1329 | static int p9_fd_write(struct p9_trans *trans, void *v, int len) |
1229 | { | 1330 | { |
1230 | int ret; | 1331 | int ret; |
@@ -1296,6 +1397,7 @@ end: | |||
1296 | * @trans: private socket structure | 1397 | * @trans: private socket structure |
1297 | * | 1398 | * |
1298 | */ | 1399 | */ |
1400 | |||
1299 | static void p9_fd_close(struct p9_trans *trans) | 1401 | static void p9_fd_close(struct p9_trans *trans) |
1300 | { | 1402 | { |
1301 | struct p9_trans_fd *ts; | 1403 | struct p9_trans_fd *ts; |
diff --git a/net/9p/trans_virtio.c b/net/9p/trans_virtio.c index de7a9f532edc..0bab1f23590e 100644 --- a/net/9p/trans_virtio.c +++ b/net/9p/trans_virtio.c | |||
@@ -55,23 +55,69 @@ static int chan_index; | |||
55 | 55 | ||
56 | #define P9_INIT_MAXTAG 16 | 56 | #define P9_INIT_MAXTAG 16 |
57 | 57 | ||
58 | #define REQ_STATUS_IDLE 0 | 58 | |
59 | #define REQ_STATUS_SENT 1 | 59 | /** |
60 | #define REQ_STATUS_RCVD 2 | 60 | * enum p9_req_status_t - virtio request status |
61 | #define REQ_STATUS_FLSH 3 | 61 | * @REQ_STATUS_IDLE: request slot unused |
62 | * @REQ_STATUS_SENT: request sent to server | ||
63 | * @REQ_STATUS_RCVD: response received from server | ||
64 | * @REQ_STATUS_FLSH: request has been flushed | ||
65 | * | ||
66 | * The @REQ_STATUS_IDLE state is used to mark a request slot as unused | ||
67 | * but use is actually tracked by the idpool structure which handles tag | ||
68 | * id allocation. | ||
69 | * | ||
70 | */ | ||
71 | |||
72 | enum p9_req_status_t { | ||
73 | REQ_STATUS_IDLE, | ||
74 | REQ_STATUS_SENT, | ||
75 | REQ_STATUS_RCVD, | ||
76 | REQ_STATUS_FLSH, | ||
77 | }; | ||
78 | |||
79 | /** | ||
80 | * struct p9_req_t - virtio request slots | ||
81 | * @status: status of this request slot | ||
82 | * @wq: wait_queue for the client to block on for this request | ||
83 | * | ||
84 | * The virtio transport uses an array to track outstanding requests | ||
85 | * instead of a list. While this may incurr overhead during initial | ||
86 | * allocation or expansion, it makes request lookup much easier as the | ||
87 | * tag id is a index into an array. (We use tag+1 so that we can accomodate | ||
88 | * the -1 tag for the T_VERSION request). | ||
89 | * This also has the nice effect of only having to allocate wait_queues | ||
90 | * once, instead of constantly allocating and freeing them. Its possible | ||
91 | * other resources could benefit from this scheme as well. | ||
92 | * | ||
93 | */ | ||
62 | 94 | ||
63 | struct p9_req_t { | 95 | struct p9_req_t { |
64 | int status; | 96 | int status; |
65 | wait_queue_head_t *wq; | 97 | wait_queue_head_t *wq; |
66 | }; | 98 | }; |
67 | 99 | ||
68 | /* We keep all per-channel information in a structure. | 100 | /** |
101 | * struct virtio_chan - per-instance transport information | ||
102 | * @initialized: whether the channel is initialized | ||
103 | * @inuse: whether the channel is in use | ||
104 | * @lock: protects multiple elements within this structure | ||
105 | * @vdev: virtio dev associated with this channel | ||
106 | * @vq: virtio queue associated with this channel | ||
107 | * @tagpool: accounting for tag ids (and request slots) | ||
108 | * @reqs: array of request slots | ||
109 | * @max_tag: current number of request_slots allocated | ||
110 | * @sg: scatter gather list which is used to pack a request (protected?) | ||
111 | * | ||
112 | * We keep all per-channel information in a structure. | ||
69 | * This structure is allocated within the devices dev->mem space. | 113 | * This structure is allocated within the devices dev->mem space. |
70 | * A pointer to the structure will get put in the transport private. | 114 | * A pointer to the structure will get put in the transport private. |
115 | * | ||
71 | */ | 116 | */ |
117 | |||
72 | static struct virtio_chan { | 118 | static struct virtio_chan { |
73 | bool initialized; /* channel is initialized */ | 119 | bool initialized; |
74 | bool inuse; /* channel is in use */ | 120 | bool inuse; |
75 | 121 | ||
76 | spinlock_t lock; | 122 | spinlock_t lock; |
77 | 123 | ||
@@ -86,7 +132,19 @@ static struct virtio_chan { | |||
86 | struct scatterlist sg[VIRTQUEUE_NUM]; | 132 | struct scatterlist sg[VIRTQUEUE_NUM]; |
87 | } channels[MAX_9P_CHAN]; | 133 | } channels[MAX_9P_CHAN]; |
88 | 134 | ||
89 | /* Lookup requests by tag */ | 135 | /** |
136 | * p9_lookup_tag - Lookup requests by tag | ||
137 | * @c: virtio channel to lookup tag within | ||
138 | * @tag: numeric id for transaction | ||
139 | * | ||
140 | * this is a simple array lookup, but will grow the | ||
141 | * request_slots as necessary to accomodate transaction | ||
142 | * ids which did not previously have a slot. | ||
143 | * | ||
144 | * Bugs: there is currently no upper limit on request slots set | ||
145 | * here, but that should be constrained by the id accounting. | ||
146 | */ | ||
147 | |||
90 | static struct p9_req_t *p9_lookup_tag(struct virtio_chan *c, u16 tag) | 148 | static struct p9_req_t *p9_lookup_tag(struct virtio_chan *c, u16 tag) |
91 | { | 149 | { |
92 | /* This looks up the original request by tag so we know which | 150 | /* This looks up the original request by tag so we know which |
@@ -130,6 +188,15 @@ static unsigned int rest_of_page(void *data) | |||
130 | return PAGE_SIZE - ((unsigned long)data % PAGE_SIZE); | 188 | return PAGE_SIZE - ((unsigned long)data % PAGE_SIZE); |
131 | } | 189 | } |
132 | 190 | ||
191 | /** | ||
192 | * p9_virtio_close - reclaim resources of a channel | ||
193 | * @trans: transport state | ||
194 | * | ||
195 | * This reclaims a channel by freeing its resources and | ||
196 | * reseting its inuse flag. | ||
197 | * | ||
198 | */ | ||
199 | |||
133 | static void p9_virtio_close(struct p9_trans *trans) | 200 | static void p9_virtio_close(struct p9_trans *trans) |
134 | { | 201 | { |
135 | struct virtio_chan *chan = trans->priv; | 202 | struct virtio_chan *chan = trans->priv; |
@@ -151,6 +218,19 @@ static void p9_virtio_close(struct p9_trans *trans) | |||
151 | kfree(trans); | 218 | kfree(trans); |
152 | } | 219 | } |
153 | 220 | ||
221 | /** | ||
222 | * req_done - callback which signals activity from the server | ||
223 | * @vq: virtio queue activity was received on | ||
224 | * | ||
225 | * This notifies us that the server has triggered some activity | ||
226 | * on the virtio channel - most likely a response to request we | ||
227 | * sent. Figure out which requests now have responses and wake up | ||
228 | * those threads. | ||
229 | * | ||
230 | * Bugs: could do with some additional sanity checking, but appears to work. | ||
231 | * | ||
232 | */ | ||
233 | |||
154 | static void req_done(struct virtqueue *vq) | 234 | static void req_done(struct virtqueue *vq) |
155 | { | 235 | { |
156 | struct virtio_chan *chan = vq->vdev->priv; | 236 | struct virtio_chan *chan = vq->vdev->priv; |
@@ -169,6 +249,20 @@ static void req_done(struct virtqueue *vq) | |||
169 | spin_unlock_irqrestore(&chan->lock, flags); | 249 | spin_unlock_irqrestore(&chan->lock, flags); |
170 | } | 250 | } |
171 | 251 | ||
252 | /** | ||
253 | * pack_sg_list - pack a scatter gather list from a linear buffer | ||
254 | * @sg: scatter/gather list to pack into | ||
255 | * @start: which segment of the sg_list to start at | ||
256 | * @limit: maximum segment to pack data to | ||
257 | * @data: data to pack into scatter/gather list | ||
258 | * @count: amount of data to pack into the scatter/gather list | ||
259 | * | ||
260 | * sg_lists have multiple segments of various sizes. This will pack | ||
261 | * arbitrary data into an existing scatter gather list, segmenting the | ||
262 | * data as necessary within constraints. | ||
263 | * | ||
264 | */ | ||
265 | |||
172 | static int | 266 | static int |
173 | pack_sg_list(struct scatterlist *sg, int start, int limit, char *data, | 267 | pack_sg_list(struct scatterlist *sg, int start, int limit, char *data, |
174 | int count) | 268 | int count) |
@@ -189,6 +283,14 @@ pack_sg_list(struct scatterlist *sg, int start, int limit, char *data, | |||
189 | return index-start; | 283 | return index-start; |
190 | } | 284 | } |
191 | 285 | ||
286 | /** | ||
287 | * p9_virtio_rpc - issue a request and wait for a response | ||
288 | * @t: transport state | ||
289 | * @tc: &p9_fcall request to transmit | ||
290 | * @rc: &p9_fcall to put reponse into | ||
291 | * | ||
292 | */ | ||
293 | |||
192 | static int | 294 | static int |
193 | p9_virtio_rpc(struct p9_trans *t, struct p9_fcall *tc, struct p9_fcall **rc) | 295 | p9_virtio_rpc(struct p9_trans *t, struct p9_fcall *tc, struct p9_fcall **rc) |
194 | { | 296 | { |
@@ -263,6 +365,16 @@ p9_virtio_rpc(struct p9_trans *t, struct p9_fcall *tc, struct p9_fcall **rc) | |||
263 | return 0; | 365 | return 0; |
264 | } | 366 | } |
265 | 367 | ||
368 | /** | ||
369 | * p9_virtio_probe - probe for existence of 9P virtio channels | ||
370 | * @vdev: virtio device to probe | ||
371 | * | ||
372 | * This probes for existing virtio channels. At present only | ||
373 | * a single channel is in use, so in the future more work may need | ||
374 | * to be done here. | ||
375 | * | ||
376 | */ | ||
377 | |||
266 | static int p9_virtio_probe(struct virtio_device *vdev) | 378 | static int p9_virtio_probe(struct virtio_device *vdev) |
267 | { | 379 | { |
268 | int err; | 380 | int err; |
@@ -307,11 +419,28 @@ fail: | |||
307 | return err; | 419 | return err; |
308 | } | 420 | } |
309 | 421 | ||
310 | /* This sets up a transport channel for 9p communication. Right now | 422 | |
423 | /** | ||
424 | * p9_virtio_create - allocate a new virtio channel | ||
425 | * @devname: string identifying the channel to connect to (unused) | ||
426 | * @args: args passed from sys_mount() for per-transport options (unused) | ||
427 | * @msize: requested maximum packet size | ||
428 | * @extended: 9p2000.u enabled flag | ||
429 | * | ||
430 | * This sets up a transport channel for 9p communication. Right now | ||
311 | * we only match the first available channel, but eventually we couldlook up | 431 | * we only match the first available channel, but eventually we couldlook up |
312 | * alternate channels by matching devname versus a virtio_config entry. | 432 | * alternate channels by matching devname versus a virtio_config entry. |
313 | * We use a simple reference count mechanism to ensure that only a single | 433 | * We use a simple reference count mechanism to ensure that only a single |
314 | * mount has a channel open at a time. */ | 434 | * mount has a channel open at a time. |
435 | * | ||
436 | * Bugs: doesn't allow identification of a specific channel | ||
437 | * to allocate, channels are allocated sequentially. This was | ||
438 | * a pragmatic decision to get things rolling, but ideally some | ||
439 | * way of identifying the channel to attach to would be nice | ||
440 | * if we are going to support multiple channels. | ||
441 | * | ||
442 | */ | ||
443 | |||
315 | static struct p9_trans * | 444 | static struct p9_trans * |
316 | p9_virtio_create(const char *devname, char *args, int msize, | 445 | p9_virtio_create(const char *devname, char *args, int msize, |
317 | unsigned char extended) | 446 | unsigned char extended) |
@@ -360,6 +489,12 @@ p9_virtio_create(const char *devname, char *args, int msize, | |||
360 | return trans; | 489 | return trans; |
361 | } | 490 | } |
362 | 491 | ||
492 | /** | ||
493 | * p9_virtio_remove - clean up resources associated with a virtio device | ||
494 | * @vdev: virtio device to remove | ||
495 | * | ||
496 | */ | ||
497 | |||
363 | static void p9_virtio_remove(struct virtio_device *vdev) | 498 | static void p9_virtio_remove(struct virtio_device *vdev) |
364 | { | 499 | { |
365 | struct virtio_chan *chan = vdev->priv; | 500 | struct virtio_chan *chan = vdev->priv; |
diff --git a/net/9p/util.c b/net/9p/util.c index ef7215565d88..4d5646045330 100644 --- a/net/9p/util.c +++ b/net/9p/util.c | |||
@@ -32,11 +32,23 @@ | |||
32 | #include <linux/idr.h> | 32 | #include <linux/idr.h> |
33 | #include <net/9p/9p.h> | 33 | #include <net/9p/9p.h> |
34 | 34 | ||
35 | /** | ||
36 | * struct p9_idpool - per-connection accounting for tag idpool | ||
37 | * @lock: protects the pool | ||
38 | * @pool: idr to allocate tag id from | ||
39 | * | ||
40 | */ | ||
41 | |||
35 | struct p9_idpool { | 42 | struct p9_idpool { |
36 | spinlock_t lock; | 43 | spinlock_t lock; |
37 | struct idr pool; | 44 | struct idr pool; |
38 | }; | 45 | }; |
39 | 46 | ||
47 | /** | ||
48 | * p9_idpool_create - create a new per-connection id pool | ||
49 | * | ||
50 | */ | ||
51 | |||
40 | struct p9_idpool *p9_idpool_create(void) | 52 | struct p9_idpool *p9_idpool_create(void) |
41 | { | 53 | { |
42 | struct p9_idpool *p; | 54 | struct p9_idpool *p; |
@@ -52,6 +64,11 @@ struct p9_idpool *p9_idpool_create(void) | |||
52 | } | 64 | } |
53 | EXPORT_SYMBOL(p9_idpool_create); | 65 | EXPORT_SYMBOL(p9_idpool_create); |
54 | 66 | ||
67 | /** | ||
68 | * p9_idpool_destroy - create a new per-connection id pool | ||
69 | * @p: idpool to destory | ||
70 | */ | ||
71 | |||
55 | void p9_idpool_destroy(struct p9_idpool *p) | 72 | void p9_idpool_destroy(struct p9_idpool *p) |
56 | { | 73 | { |
57 | idr_destroy(&p->pool); | 74 | idr_destroy(&p->pool); |
@@ -61,9 +78,9 @@ EXPORT_SYMBOL(p9_idpool_destroy); | |||
61 | 78 | ||
62 | /** | 79 | /** |
63 | * p9_idpool_get - allocate numeric id from pool | 80 | * p9_idpool_get - allocate numeric id from pool |
64 | * @p - pool to allocate from | 81 | * @p: pool to allocate from |
65 | * | 82 | * |
66 | * XXX - This seems to be an awful generic function, should it be in idr.c with | 83 | * Bugs: This seems to be an awful generic function, should it be in idr.c with |
67 | * the lock included in struct idr? | 84 | * the lock included in struct idr? |
68 | */ | 85 | */ |
69 | 86 | ||
@@ -94,9 +111,10 @@ EXPORT_SYMBOL(p9_idpool_get); | |||
94 | 111 | ||
95 | /** | 112 | /** |
96 | * p9_idpool_put - release numeric id from pool | 113 | * p9_idpool_put - release numeric id from pool |
97 | * @p - pool to allocate from | 114 | * @id: numeric id which is being released |
115 | * @p: pool to release id into | ||
98 | * | 116 | * |
99 | * XXX - This seems to be an awful generic function, should it be in idr.c with | 117 | * Bugs: This seems to be an awful generic function, should it be in idr.c with |
100 | * the lock included in struct idr? | 118 | * the lock included in struct idr? |
101 | */ | 119 | */ |
102 | 120 | ||
@@ -111,11 +129,13 @@ EXPORT_SYMBOL(p9_idpool_put); | |||
111 | 129 | ||
112 | /** | 130 | /** |
113 | * p9_idpool_check - check if the specified id is available | 131 | * p9_idpool_check - check if the specified id is available |
114 | * @id - id to check | 132 | * @id: id to check |
115 | * @p - pool | 133 | * @p: pool to check |
116 | */ | 134 | */ |
135 | |||
117 | int p9_idpool_check(int id, struct p9_idpool *p) | 136 | int p9_idpool_check(int id, struct p9_idpool *p) |
118 | { | 137 | { |
119 | return idr_find(&p->pool, id) != NULL; | 138 | return idr_find(&p->pool, id) != NULL; |
120 | } | 139 | } |
121 | EXPORT_SYMBOL(p9_idpool_check); | 140 | EXPORT_SYMBOL(p9_idpool_check); |
141 | |||