source4/torture/raw/composite.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3
   4    libcli composite function testing
   5
   6    Copyright (C) Andrew Tridgell 2005
   7
   8    This program is free software; you can redistribute it and/or modify
   9    it under the terms of the GNU General Public License as published by
  10    the Free Software Foundation; either version 2 of the License, or
  11    (at your option) any later version.
  12
  13    This program is distributed in the hope that it will be useful,
  14    but WITHOUT ANY WARRANTY; without even the implied warranty of
  15    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16    GNU General Public License for more details.
  17
  18    You should have received a copy of the GNU General Public License
  19    along with this program; if not, write to the Free Software
  20    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  21 */
  22
  23 #include "includes.h"
  24 #include "libcli/raw/libcliraw.h"
  25 #include "libcli/composite/composite.h"
  26
  27 #define BASEDIR "\\composite"
  28
  29 static void loadfile_complete(struct smbcli_composite *c)
  30 {
  31         int *count = talloc_get_type(c->async.private, int);
  32         (*count)++;
  33 }
  34
  35 /*
  36   test a simple savefile/loadfile combination
  37 */
  38 static BOOL test_loadfile(struct smbcli_state *cli, TALLOC_CTX *mem_ctx)
  39 {
  40         const char *fname = BASEDIR "\\test.txt";
  41         NTSTATUS status;
  42         struct smb_composite_savefile io1;
  43         struct smb_composite_loadfile io2;
  44         struct smbcli_composite **c;
  45         char *data;
  46         size_t len = random() % 100000;
  47         const int num_ops = 50;
  48         int i;
  49         int *count = talloc_zero(mem_ctx, int);
  50
  51         data = talloc_array(mem_ctx, uint8_t, len);
  52
  53         generate_random_buffer(data, len);
  54
  55         io1.in.fname = fname;
  56         io1.in.data  = data;
  57         io1.in.size  = len;
  58
  59         printf("testing savefile\n");
  60
  61         status = smb_composite_savefile(cli->tree, &io1);
  62         if (!NT_STATUS_IS_OK(status)) {
  63                 printf("savefile failed: %s\n", nt_errstr(status));
  64                 return False;
  65         }
  66
  67         io2.in.fname = fname;
  68
  69         printf("testing parallel loadfile with %d ops\n", num_ops);
  70
  71         c = talloc_array(mem_ctx, struct smbcli_composite *, num_ops);
  72
  73         for (i=0;i<num_ops;i++) {
  74                 c[i] = smb_composite_loadfile_send(cli->tree, &io2);
  75                 c[i]->async.fn = loadfile_complete;
  76                 c[i]->async.private = count;
  77         }
  78
  79         printf("waiting for completion\n");
  80         while (*count != num_ops) {
  81                 event_loop_once(cli->transport->socket->event.ctx);
  82                 printf("count=%d\r", *count);
  83                 fflush(stdout);
  84         }
  85         printf("count=%d\n", *count);
  86
  87         for (i=0;i<num_ops;i++) {
  88                 status = smb_composite_loadfile_recv(c[i], mem_ctx);
  89                 if (!NT_STATUS_IS_OK(status)) {
  90                         printf("loadfile[%d] failed - %s\n", i, nt_errstr(status));
  91                         return False;
  92                 }
  93
  94                 if (io2.out.size != len) {
  95                         printf("wrong length in returned data - %d should be %d\n",
  96                                io2.out.size, len);
  97                         return False;
  98                 }
  99
 100                 if (memcmp(io2.out.data, data, len) != 0) {
 101                         printf("wrong data in loadfile!\n");
 102                         return False;
 103                 }
 104         }
 105
 106         talloc_free(data);
 107
 108         return True;
 109 }
 110
 111 /*
 112    basic testing of libcli composite calls
 113 */
 114 BOOL torture_raw_composite(void)
 115 {
 116         struct smbcli_state *cli;
 117         BOOL ret = True;
 118         TALLOC_CTX *mem_ctx;
 119
 120         if (!torture_open_connection(&cli)) {
 121                 return False;
 122         }
 123
 124         mem_ctx = talloc_init("torture_raw_composite");
 125
 126         if (!torture_setup_dir(cli, BASEDIR)) {
 127                 return False;
 128         }
 129
 130         ret &= test_loadfile(cli, mem_ctx);
 131
 132         smb_raw_exit(cli->session);
 133         smbcli_deltree(cli->tree, BASEDIR);
 134
 135         torture_close_connection(cli);
 136         talloc_destroy(mem_ctx);
 137         return ret;
 138 }