the next step in the dcerpc server code. Added the link between the
[gd/samba-autobuild/.git] / source4 / libcli / raw / rawtrans.c
1 /* 
2    Unix SMB/CIFS implementation.
3    raw trans/trans2/nttrans operations
4
5    Copyright (C) James Myers 2003 <myersjj@samba.org>
6    
7    This program is free software; you can redistribute it and/or modify
8    it under the terms of the GNU General Public License as published by
9    the Free Software Foundation; either version 2 of the License, or
10    (at your option) any later version.
11    
12    This program is distributed in the hope that it will be useful,
13    but WITHOUT ANY WARRANTY; without even the implied warranty of
14    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15    GNU General Public License for more details.
16    
17    You should have received a copy of the GNU General Public License
18    along with this program; if not, write to the Free Software
19    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20 */
21
22 #include "includes.h"
23
24
25 /*
26   check out of bounds for incoming data
27 */
28 static BOOL raw_trans_oob(struct cli_request *req,
29                           uint_t offset, uint_t count)
30 {
31         char *ptr;
32
33         if (count == 0) {
34                 return False;
35         }
36
37         ptr = req->in.hdr + offset;
38         
39         /* be careful with wraparound! */
40         if (ptr < req->in.data ||
41             ptr >= req->in.data + req->in.data_size ||
42             count > req->in.data_size ||
43             ptr + count > req->in.data + req->in.data_size) {
44                 return True;
45         }
46         return False;   
47 }
48
49 /****************************************************************************
50   receive a SMB trans or trans2 response allocating the necessary memory
51   ****************************************************************************/
52 NTSTATUS smb_raw_trans2_recv(struct cli_request *req,
53                              TALLOC_CTX *mem_ctx,
54                              struct smb_trans2 *parms)
55 {
56         int total_data=0;
57         int total_param=0;
58         char *tdata;
59         char *tparam;
60
61         parms->out.data.length = 0;
62         parms->out.data.data = NULL;
63         parms->out.params.length = 0;
64         parms->out.params.data = NULL;
65
66         if (!cli_request_receive(req)) {
67                 req->status = NT_STATUS_UNSUCCESSFUL;
68                 return cli_request_destroy(req);
69         }
70         
71         /*
72          * An NT RPC pipe call can return ERRDOS, ERRmoredata
73          * to a trans call. This is not an error and should not
74          * be treated as such.
75          */
76         if (NT_STATUS_IS_ERR(req->status)) {
77                 return cli_request_destroy(req);
78         }
79
80         CLI_CHECK_MIN_WCT(req, 10);
81
82         /* parse out the lengths */
83         total_data = SVAL(req->in.vwv, VWV(1));
84         total_param = SVAL(req->in.vwv, VWV(0));
85
86         /* allocate it */
87         if (total_data != 0) {
88                 tdata = talloc_realloc(mem_ctx, parms->out.data.data,total_data);
89                 if (!tdata) {
90                         DEBUG(0,("smb_raw_receive_trans: failed to enlarge data buffer to %d bytes\n", total_data));
91                         req->status = NT_STATUS_NO_MEMORY;
92                         return cli_request_destroy(req);
93                 }
94                 parms->out.data.data = tdata;
95         }
96
97         if (total_param != 0) {
98                 tparam = talloc_realloc(mem_ctx, parms->out.params.data,total_param);
99                 if (!tparam) {
100                         DEBUG(0,("smb_raw_receive_trans: failed to enlarge param buffer to %d bytes\n", total_param));
101                         req->status = NT_STATUS_NO_MEMORY;
102                         return cli_request_destroy(req);
103                 }
104                 parms->out.params.data = tparam;
105         }
106
107         parms->out.setup_count = SVAL(req->in.vwv, VWV(9));
108         CLI_CHECK_WCT(req, 10 + parms->out.setup_count);
109
110         if (parms->out.setup_count > 0) {
111                 int i;
112                 parms->out.setup = talloc(mem_ctx, 2 * parms->out.setup_count);
113                 if (!parms->out.setup) {
114                         req->status = NT_STATUS_NO_MEMORY;
115                         return cli_request_destroy(req);
116                 }
117                 for (i=0;i<parms->out.setup_count;i++) {
118                         parms->out.setup[i] = SVAL(req->in.vwv, VWV(10+i));
119                 }
120         }
121
122         while (1)  {
123                 uint16 param_count, param_ofs, param_disp;
124                 uint16 data_count, data_ofs, data_disp;
125                 uint16 total_data2, total_param2;
126
127                 /* parse out the total lengths again - they can shrink! */
128                 total_data2 = SVAL(req->in.vwv, VWV(1));
129                 total_param2 = SVAL(req->in.vwv, VWV(0));
130
131                 if (total_data2 > total_data ||
132                     total_param2 > total_param) {
133                         /* they must *only* shrink */
134                         DEBUG(1,("smb_raw_receive_trans: data/params expanded!\n"));
135                         req->status = NT_STATUS_BUFFER_TOO_SMALL;
136                         return cli_request_destroy(req);
137                 }
138
139                 total_data = total_data2;
140                 total_param = total_param2;             
141
142                 /* parse params for this lump */
143                 param_count = SVAL(req->in.vwv, VWV(3));
144                 param_ofs   = SVAL(req->in.vwv, VWV(4));
145                 param_disp  = SVAL(req->in.vwv, VWV(5));
146
147                 data_count = SVAL(req->in.vwv, VWV(6));
148                 data_ofs   = SVAL(req->in.vwv, VWV(7));
149                 data_disp  = SVAL(req->in.vwv, VWV(8));
150
151                 if (data_count + data_disp > total_data ||
152                     param_count + param_disp > total_param) {
153                         DEBUG(1,("smb_raw_receive_trans: Buffer overflow\n"));
154                         req->status = NT_STATUS_BUFFER_TOO_SMALL;
155                         return cli_request_destroy(req);
156                 }
157                 
158                 /* check the server isn't being nasty */
159                 if (raw_trans_oob(req, param_ofs, param_count) ||
160                     raw_trans_oob(req, data_ofs, data_count)) {
161                         DEBUG(1,("smb_raw_receive_trans: out of bounds parameters!\n"));
162                         req->status = NT_STATUS_BUFFER_TOO_SMALL;
163                         return cli_request_destroy(req);
164                 }
165
166                 if (data_count) {
167                         memcpy(parms->out.data.data + data_disp,
168                                req->in.hdr + data_ofs, 
169                                data_count);
170                 }
171
172                 if (param_count) {
173                         memcpy(parms->out.params.data + param_disp,
174                                req->in.hdr + param_ofs, 
175                                param_count);
176                 }
177
178                 parms->out.data.length += data_count;
179                 parms->out.params.length += param_count;
180
181                 if (total_data <= parms->out.data.length && total_param <= parms->out.params.length)
182                         break;
183         
184                 /* to receive more requests we need to mark this request as not received */
185                 req->in.buffer = NULL;
186         
187                 if (!cli_request_receive(req)) {
188                         req->status = NT_STATUS_UNSUCCESSFUL;
189                         return cli_request_destroy(req);
190                 }
191         }
192
193 failed:
194         return cli_request_destroy(req);
195 }
196
197 NTSTATUS smb_raw_trans_recv(struct cli_request *req,
198                              TALLOC_CTX *mem_ctx,
199                              struct smb_trans2 *parms)
200 {
201         return smb_raw_trans2_recv(req, mem_ctx, parms);
202 }
203
204 /****************************************************************************
205  trans/trans2 raw async interface - only BLOBs used in this interface.
206  note that this doesn't yet support multi-part requests
207 ****************************************************************************/
208 struct cli_request *smb_raw_trans_send_backend(struct cli_tree *tree,
209                                                struct smb_trans2 *parms,
210                                                uint8 command)
211 {
212         int wct = 14 + parms->in.setup_count;
213         struct cli_request *req; 
214         char *outdata,*outparam;
215         int i;
216         int padding;
217         size_t namelen = 0;
218
219         if (command == SMBtrans)
220                 padding = 1;
221         else
222                 padding = 3;
223         
224         req = cli_request_setup(tree, command, wct, padding);
225         if (!req) {
226                 return NULL;
227         }
228         
229         /* fill in SMB parameters */
230         outparam = req->out.data + padding;
231         outdata = outparam + parms->in.params.length;
232
233         /* make sure we don't leak data via the padding */
234         memset(req->out.data, 0, padding);
235
236         if (command == SMBtrans && parms->in.trans_name) {
237                 namelen = cli_req_append_string(req, parms->in.trans_name, 
238                                                 STR_TERMINATE);
239         }
240
241         /* primary request */
242         SSVAL(req->out.vwv,VWV(0),parms->in.params.length);
243         SSVAL(req->out.vwv,VWV(1),parms->in.data.length);
244         SSVAL(req->out.vwv,VWV(2),parms->in.max_param);
245         SSVAL(req->out.vwv,VWV(3),parms->in.max_data);
246         SSVAL(req->out.vwv,VWV(4),parms->in.max_setup);
247         SSVAL(req->out.vwv,VWV(5),parms->in.flags);
248         SIVAL(req->out.vwv,VWV(6),parms->in.timeout);
249         SSVAL(req->out.vwv,VWV(8),0); /* reserved */
250         SSVAL(req->out.vwv,VWV(9),parms->in.params.length);
251         SSVAL(req->out.vwv,VWV(10),PTR_DIFF(outparam,req->out.hdr)+namelen);
252         SSVAL(req->out.vwv,VWV(11),parms->in.data.length);
253         SSVAL(req->out.vwv,VWV(12),PTR_DIFF(outdata,req->out.hdr)+namelen);
254         SSVAL(req->out.vwv,VWV(13),parms->in.setup_count);
255         for (i=0;i<parms->in.setup_count;i++)   {
256                 SSVAL(req->out.vwv,VWV(14)+i*2,parms->in.setup[i]);
257         }
258         if (parms->in.params.data)      {
259                 cli_req_append_blob(req, &parms->in.params);
260         }
261         if (parms->in.data.data) {
262                 cli_req_append_blob(req, &parms->in.data);
263         }
264
265         if (!cli_request_send(req)) {
266                 cli_request_destroy(req);
267                 return NULL;
268         }
269         
270         return req;
271 }
272
273 /****************************************************************************
274  trans/trans2 raw async interface - only BLOBs used in this interface.
275 note that this doesn't yet support multi-part requests
276 ****************************************************************************/
277
278 struct cli_request *smb_raw_trans_send(struct cli_tree *tree,
279                                        struct smb_trans2 *parms)
280 {
281         return smb_raw_trans_send_backend(tree, parms, SMBtrans);
282 }
283
284 struct cli_request *smb_raw_trans2_send(struct cli_tree *tree,
285                                        struct smb_trans2 *parms)
286 {
287         return smb_raw_trans_send_backend(tree, parms, SMBtrans2);
288 }
289
290 /*
291   trans2 synchronous blob interface
292 */
293 NTSTATUS smb_raw_trans2(struct cli_tree *tree,
294                         TALLOC_CTX *mem_ctx,
295                         struct smb_trans2 *parms)
296 {
297         struct cli_request *req;
298         req = smb_raw_trans2_send(tree, parms);
299         if (!req) return NT_STATUS_UNSUCCESSFUL;
300         return smb_raw_trans2_recv(req, mem_ctx, parms);
301 }
302
303
304 /*
305   trans synchronous blob interface
306 */
307 NTSTATUS smb_raw_trans(struct cli_tree *tree,
308                        TALLOC_CTX *mem_ctx,
309                        struct smb_trans2 *parms)
310 {
311         struct cli_request *req;
312         req = smb_raw_trans_send(tree, parms);
313         if (!req) return NT_STATUS_UNSUCCESSFUL;
314         return smb_raw_trans_recv(req, mem_ctx, parms);
315 }
316
317 /****************************************************************************
318   receive a SMB nttrans response allocating the necessary memory
319   ****************************************************************************/
320 NTSTATUS smb_raw_nttrans_recv(struct cli_request *req,
321                               TALLOC_CTX *mem_ctx,
322                               struct smb_nttrans *parms)
323 {
324         uint32 total_data, recvd_data=0;
325         uint32 total_param, recvd_param=0;
326
327         if (!cli_request_receive(req) ||
328             cli_request_is_error(req)) {
329                 return cli_request_destroy(req);
330         }
331
332         /* sanity check */
333         if (CVAL(req->in.hdr, HDR_COM) != SMBnttrans) {
334                 DEBUG(0,("smb_raw_receive_nttrans: Expected %s response, got command 0x%02x\n",
335                          "SMBnttrans", 
336                          CVAL(req->in.hdr,HDR_COM)));
337                 req->status = NT_STATUS_UNSUCCESSFUL;
338                 return cli_request_destroy(req);
339         }
340
341         CLI_CHECK_MIN_WCT(req, 18);
342
343         /* parse out the lengths */
344         total_param = IVAL(req->in.vwv, 3);
345         total_data  = IVAL(req->in.vwv, 7);
346
347         parms->out.data = data_blob_talloc(mem_ctx, NULL, total_data);
348         parms->out.params = data_blob_talloc(mem_ctx, NULL, total_param);
349
350         if (parms->out.data.length != total_data ||
351             parms->out.params.length != total_param) {
352                 req->status = NT_STATUS_NO_MEMORY;
353                 return cli_request_destroy(req);
354         }
355
356         parms->out.setup_count = CVAL(req->in.vwv, 35);
357         CLI_CHECK_WCT(req, 18 + parms->out.setup_count);
358
359         if (parms->out.setup_count > 0) {
360                 int i;
361                 parms->out.setup = talloc(mem_ctx, 2 * parms->out.setup_count);
362                 if (!parms->out.setup) {
363                         req->status = NT_STATUS_NO_MEMORY;
364                         return cli_request_destroy(req);
365                 }
366                 for (i=0;i<parms->out.setup_count;i++) {
367                         parms->out.setup[i] = SVAL(req->in.vwv, VWV(18+i));
368                 }
369         }
370         
371         while (recvd_data < total_data || 
372                recvd_param < total_param)  {
373                 uint32 param_count, param_ofs, param_disp;
374                 uint32 data_count, data_ofs, data_disp;
375                 uint32 total_data2, total_param2;
376
377                 /* parse out the total lengths again - they can shrink! */
378                 total_param2 = IVAL(req->in.vwv, 3);
379                 total_data2  = IVAL(req->in.vwv, 7);
380
381                 if (total_data2 > total_data ||
382                     total_param2 > total_param) {
383                         /* they must *only* shrink */
384                         DEBUG(1,("smb_raw_receive_nttrans: data/params expanded!\n"));
385                         req->status = NT_STATUS_BUFFER_TOO_SMALL;
386                         return cli_request_destroy(req);
387                 }
388
389                 total_data = total_data2;
390                 total_param = total_param2;
391                 parms->out.data.length = total_data;
392                 parms->out.params.length = total_param;
393
394                 /* parse params for this lump */
395                 param_count = IVAL(req->in.vwv, 11);
396                 param_ofs   = IVAL(req->in.vwv, 15);
397                 param_disp  = IVAL(req->in.vwv, 19);
398
399                 data_count = IVAL(req->in.vwv, 23);
400                 data_ofs   = IVAL(req->in.vwv, 27);
401                 data_disp  = IVAL(req->in.vwv, 31);
402
403                 if (data_count + data_disp > total_data ||
404                     param_count + param_disp > total_param) {
405                         DEBUG(1,("smb_raw_receive_nttrans: Buffer overflow\n"));
406                         req->status = NT_STATUS_BUFFER_TOO_SMALL;
407                         return cli_request_destroy(req);
408                 }
409                 
410                 /* check the server isn't being nasty */
411                 if (raw_trans_oob(req, param_ofs, param_count) ||
412                     raw_trans_oob(req, data_ofs, data_count)) {
413                         DEBUG(1,("smb_raw_receive_nttrans: out of bounds parameters!\n"));
414                         req->status = NT_STATUS_BUFFER_TOO_SMALL;
415                         return cli_request_destroy(req);
416                 }
417
418                 if (data_count) {
419                         memcpy(parms->out.data.data + data_disp,
420                                req->in.hdr + data_ofs, 
421                                data_count);
422                 }
423
424                 if (param_count) {
425                         memcpy(parms->out.params.data + param_disp,
426                                req->in.hdr + param_ofs, 
427                                param_count);
428                 }
429
430                 recvd_param += param_count;
431                 recvd_data += data_count;
432
433                 if (recvd_data >= total_data &&
434                     recvd_param >= total_param) {
435                         break;
436                 }
437                 
438                 if (!cli_request_receive(req) ||
439                     cli_request_is_error(req)) {
440                         return cli_request_destroy(req);
441                 }
442                 
443                 /* sanity check */
444                 if (CVAL(req->in.hdr, HDR_COM) != SMBnttrans) {
445                         DEBUG(0,("smb_raw_receive_nttrans: Expected nttranss, got command 0x%02x\n",
446                                  CVAL(req->in.hdr, HDR_COM)));
447                         req->status = NT_STATUS_UNSUCCESSFUL;
448                         return cli_request_destroy(req);
449                 }
450         }
451
452 failed:
453         return cli_request_destroy(req);
454 }
455
456
457 /****************************************************************************
458  nttrans raw - only BLOBs used in this interface.
459  at the moment we only handle a single primary request 
460 ****************************************************************************/
461 struct cli_request *smb_raw_nttrans_send(struct cli_tree *tree,
462                                          struct smb_nttrans *parms)
463 {
464         struct cli_request *req; 
465         char *outdata, *outparam;
466         int i;
467         int align = 0;
468
469         /* only align if there are parameters or data */
470         if (parms->in.params.length || parms->in.data.length) {
471                 align = 3;
472         }
473         
474         req = cli_request_setup(tree, SMBnttrans, 
475                                 19 + parms->in.setup_count, 
476                                 align +
477                                 parms->in.params.length +
478                                 parms->in.data.length);
479         if (!req) {
480                 return NULL;
481         }
482         
483         /* fill in SMB parameters */
484         outparam = req->out.data + align;
485         outdata = outparam + parms->in.params.length;
486
487         SCVAL(req->out.vwv,  0, parms->in.max_setup);
488         SSVAL(req->out.vwv,  1, 0); /* reserved */
489         SIVAL(req->out.vwv,  3, parms->in.params.length);
490         SIVAL(req->out.vwv,  7, parms->in.data.length);
491         SIVAL(req->out.vwv, 11, parms->in.max_param);
492         SIVAL(req->out.vwv, 15, parms->in.max_data);
493         SIVAL(req->out.vwv, 19, parms->in.params.length);
494         SIVAL(req->out.vwv, 23, PTR_DIFF(outparam,req->out.hdr));
495         SIVAL(req->out.vwv, 27, parms->in.data.length);
496         SIVAL(req->out.vwv, 31, PTR_DIFF(outdata,req->out.hdr));
497         SCVAL(req->out.vwv, 35, parms->in.setup_count);
498         SSVAL(req->out.vwv, 36, parms->in.function);
499         for (i=0;i<parms->in.setup_count;i++) {
500                 SSVAL(req->out.vwv,VWV(19+i),parms->in.setup[i]);
501         }
502         if (parms->in.params.length) {
503                 memcpy(outparam, parms->in.params.data, parms->in.params.length);
504         }
505         if (parms->in.data.length) {
506                 memcpy(outparam, parms->in.data.data, parms->in.data.length);
507         }
508
509         if (!cli_request_send(req)) {
510                 cli_request_destroy(req);
511                 return NULL;
512         }
513
514         return req;
515 }
516
517
518 /****************************************************************************
519   receive a SMB nttrans response allocating the necessary memory
520   ****************************************************************************/
521 NTSTATUS smb_raw_nttrans(struct cli_tree *tree,
522                          TALLOC_CTX *mem_ctx,
523                          struct smb_nttrans *parms)
524 {
525         struct cli_request *req;
526
527         req = smb_raw_nttrans_send(tree, parms);
528         if (!req) {
529                 return NT_STATUS_UNSUCCESSFUL;
530         }
531
532         return smb_raw_nttrans_recv(req, mem_ctx, parms);
533 }