diff options
Diffstat (limited to 'net/sunrpc/pmap_clnt.c')
| -rw-r--r-- | net/sunrpc/pmap_clnt.c | 41 |
1 files changed, 29 insertions, 12 deletions
diff --git a/net/sunrpc/pmap_clnt.c b/net/sunrpc/pmap_clnt.c index 8139ce68e915..d25b054ec921 100644 --- a/net/sunrpc/pmap_clnt.c +++ b/net/sunrpc/pmap_clnt.c | |||
| @@ -82,6 +82,7 @@ rpc_getport(struct rpc_task *task, struct rpc_clnt *clnt) | |||
| 82 | rpc_call_setup(child, &msg, 0); | 82 | rpc_call_setup(child, &msg, 0); |
| 83 | 83 | ||
| 84 | /* ... and run the child task */ | 84 | /* ... and run the child task */ |
| 85 | task->tk_xprt->stat.bind_count++; | ||
| 85 | rpc_run_child(task, child, pmap_getport_done); | 86 | rpc_run_child(task, child, pmap_getport_done); |
| 86 | return; | 87 | return; |
| 87 | 88 | ||
| @@ -103,6 +104,11 @@ rpc_getport_external(struct sockaddr_in *sin, __u32 prog, __u32 vers, int prot) | |||
| 103 | .pm_prot = prot, | 104 | .pm_prot = prot, |
| 104 | .pm_port = 0 | 105 | .pm_port = 0 |
| 105 | }; | 106 | }; |
| 107 | struct rpc_message msg = { | ||
| 108 | .rpc_proc = &pmap_procedures[PMAP_GETPORT], | ||
| 109 | .rpc_argp = &map, | ||
| 110 | .rpc_resp = &map.pm_port, | ||
| 111 | }; | ||
| 106 | struct rpc_clnt *pmap_clnt; | 112 | struct rpc_clnt *pmap_clnt; |
| 107 | char hostname[32]; | 113 | char hostname[32]; |
| 108 | int status; | 114 | int status; |
| @@ -116,7 +122,7 @@ rpc_getport_external(struct sockaddr_in *sin, __u32 prog, __u32 vers, int prot) | |||
| 116 | return PTR_ERR(pmap_clnt); | 122 | return PTR_ERR(pmap_clnt); |
| 117 | 123 | ||
| 118 | /* Setup the call info struct */ | 124 | /* Setup the call info struct */ |
| 119 | status = rpc_call(pmap_clnt, PMAP_GETPORT, &map, &map.pm_port, 0); | 125 | status = rpc_call_sync(pmap_clnt, &msg, 0); |
| 120 | 126 | ||
| 121 | if (status >= 0) { | 127 | if (status >= 0) { |
| 122 | if (map.pm_port != 0) | 128 | if (map.pm_port != 0) |
| @@ -161,16 +167,27 @@ pmap_getport_done(struct rpc_task *task) | |||
| 161 | int | 167 | int |
| 162 | rpc_register(u32 prog, u32 vers, int prot, unsigned short port, int *okay) | 168 | rpc_register(u32 prog, u32 vers, int prot, unsigned short port, int *okay) |
| 163 | { | 169 | { |
| 164 | struct sockaddr_in sin; | 170 | struct sockaddr_in sin = { |
| 165 | struct rpc_portmap map; | 171 | .sin_family = AF_INET, |
| 172 | .sin_addr.s_addr = htonl(INADDR_LOOPBACK), | ||
| 173 | }; | ||
| 174 | struct rpc_portmap map = { | ||
| 175 | .pm_prog = prog, | ||
| 176 | .pm_vers = vers, | ||
| 177 | .pm_prot = prot, | ||
| 178 | .pm_port = port, | ||
| 179 | }; | ||
| 180 | struct rpc_message msg = { | ||
| 181 | .rpc_proc = &pmap_procedures[port ? PMAP_SET : PMAP_UNSET], | ||
| 182 | .rpc_argp = &map, | ||
| 183 | .rpc_resp = okay, | ||
| 184 | }; | ||
| 166 | struct rpc_clnt *pmap_clnt; | 185 | struct rpc_clnt *pmap_clnt; |
| 167 | int error = 0; | 186 | int error = 0; |
| 168 | 187 | ||
| 169 | dprintk("RPC: registering (%d, %d, %d, %d) with portmapper.\n", | 188 | dprintk("RPC: registering (%d, %d, %d, %d) with portmapper.\n", |
| 170 | prog, vers, prot, port); | 189 | prog, vers, prot, port); |
| 171 | 190 | ||
| 172 | sin.sin_family = AF_INET; | ||
| 173 | sin.sin_addr.s_addr = htonl(INADDR_LOOPBACK); | ||
| 174 | pmap_clnt = pmap_create("localhost", &sin, IPPROTO_UDP, 1); | 191 | pmap_clnt = pmap_create("localhost", &sin, IPPROTO_UDP, 1); |
| 175 | if (IS_ERR(pmap_clnt)) { | 192 | if (IS_ERR(pmap_clnt)) { |
| 176 | error = PTR_ERR(pmap_clnt); | 193 | error = PTR_ERR(pmap_clnt); |
| @@ -178,13 +195,7 @@ rpc_register(u32 prog, u32 vers, int prot, unsigned short port, int *okay) | |||
| 178 | return error; | 195 | return error; |
| 179 | } | 196 | } |
| 180 | 197 | ||
| 181 | map.pm_prog = prog; | 198 | error = rpc_call_sync(pmap_clnt, &msg, 0); |
| 182 | map.pm_vers = vers; | ||
| 183 | map.pm_prot = prot; | ||
| 184 | map.pm_port = port; | ||
| 185 | |||
| 186 | error = rpc_call(pmap_clnt, port? PMAP_SET : PMAP_UNSET, | ||
| 187 | &map, okay, 0); | ||
| 188 | 199 | ||
| 189 | if (error < 0) { | 200 | if (error < 0) { |
| 190 | printk(KERN_WARNING | 201 | printk(KERN_WARNING |
| @@ -260,6 +271,8 @@ static struct rpc_procinfo pmap_procedures[] = { | |||
| 260 | .p_decode = (kxdrproc_t) xdr_decode_bool, | 271 | .p_decode = (kxdrproc_t) xdr_decode_bool, |
| 261 | .p_bufsiz = 4, | 272 | .p_bufsiz = 4, |
| 262 | .p_count = 1, | 273 | .p_count = 1, |
| 274 | .p_statidx = PMAP_SET, | ||
| 275 | .p_name = "SET", | ||
| 263 | }, | 276 | }, |
| 264 | [PMAP_UNSET] = { | 277 | [PMAP_UNSET] = { |
| 265 | .p_proc = PMAP_UNSET, | 278 | .p_proc = PMAP_UNSET, |
| @@ -267,6 +280,8 @@ static struct rpc_procinfo pmap_procedures[] = { | |||
| 267 | .p_decode = (kxdrproc_t) xdr_decode_bool, | 280 | .p_decode = (kxdrproc_t) xdr_decode_bool, |
| 268 | .p_bufsiz = 4, | 281 | .p_bufsiz = 4, |
| 269 | .p_count = 1, | 282 | .p_count = 1, |
| 283 | .p_statidx = PMAP_UNSET, | ||
| 284 | .p_name = "UNSET", | ||
| 270 | }, | 285 | }, |
| 271 | [PMAP_GETPORT] = { | 286 | [PMAP_GETPORT] = { |
| 272 | .p_proc = PMAP_GETPORT, | 287 | .p_proc = PMAP_GETPORT, |
| @@ -274,6 +289,8 @@ static struct rpc_procinfo pmap_procedures[] = { | |||
| 274 | .p_decode = (kxdrproc_t) xdr_decode_port, | 289 | .p_decode = (kxdrproc_t) xdr_decode_port, |
| 275 | .p_bufsiz = 4, | 290 | .p_bufsiz = 4, |
| 276 | .p_count = 1, | 291 | .p_count = 1, |
| 292 | .p_statidx = PMAP_GETPORT, | ||
| 293 | .p_name = "GETPORT", | ||
| 277 | }, | 294 | }, |
| 278 | }; | 295 | }; |
| 279 | 296 | ||
