65
65
io1.in.data = data;
68
printf("testing savefile\n");
68
printf("Testing savefile\n");
70
70
status = smb_composite_savefile(cli->tree, &io1);
71
71
if (!NT_STATUS_IS_OK(status)) {
76
76
io2.in.fname = fname;
78
printf("testing parallel loadfile with %d ops\n", num_ops);
78
printf("Testing parallel loadfile with %d ops\n", num_ops);
80
80
c = talloc_array(tctx, struct composite_context *, num_ops);
145
145
io1.in.data = data;
146
146
io1.in.size = len;
148
printf("testing savefile\n");
148
printf("Testing savefile\n");
150
150
status = smb_composite_savefile(cli->tree, &io1);
151
151
if (!NT_STATUS_IS_OK(status)) {
156
156
io2.in.dest_host = torture_setting_string(tctx, "host", NULL);
157
io2.in.ports = lp_smb_ports(tctx->lp_ctx);
157
io2.in.ports = lpcfg_smb_ports(tctx->lp_ctx);
158
158
io2.in.called_name = torture_setting_string(tctx, "host", NULL);
159
159
io2.in.service = torture_setting_string(tctx, "share", NULL);
160
160
io2.in.service_type = "A:";
162
162
io2.in.credentials = cmdline_credentials;
163
io2.in.workgroup = lp_workgroup(tctx->lp_ctx);
163
io2.in.workgroup = lpcfg_workgroup(tctx->lp_ctx);
164
164
io2.in.filename = fname;
165
io2.in.resolve_ctx = lp_resolve_context(tctx->lp_ctx);
166
io2.in.iconv_convenience = lp_iconv_convenience(tctx->lp_ctx);
167
io2.in.gensec_settings = lp_gensec_settings(tctx, tctx->lp_ctx);
168
lp_smbcli_options(tctx->lp_ctx, &io2.in.options);
169
lp_smbcli_session_options(tctx->lp_ctx, &io2.in.session_options);
165
io2.in.resolve_ctx = lpcfg_resolve_context(tctx->lp_ctx);
166
io2.in.gensec_settings = lpcfg_gensec_settings(tctx, tctx->lp_ctx);
167
lpcfg_smbcli_options(tctx->lp_ctx, &io2.in.options);
168
lpcfg_smbcli_session_options(tctx->lp_ctx, &io2.in.session_options);
171
printf("testing parallel fetchfile with %d ops\n", torture_numops);
170
printf("Testing parallel fetchfile with %d ops\n", torture_numops);
173
172
event_ctx = cli->transport->socket->event.ctx;
174
173
c = talloc_array(tctx, struct composite_context *, torture_numops);
285
284
/* set parameters for appendacl async call */
287
printf("testing parallel appendacl with %d ops\n", num_ops);
286
printf("Testing parallel appendacl with %d ops\n", num_ops);
289
288
c = talloc_array(tctx, struct composite_context *, num_ops);
290
289
io = talloc_array(tctx, struct smb_composite_appendacl *, num_ops);
349
348
io1.in.dest_host = torture_setting_string(tctx, "host", NULL);
350
io1.in.dest_ports = lp_smb_ports(tctx->lp_ctx);
351
io1.in.socket_options = lp_socket_options(tctx->lp_ctx);
349
io1.in.dest_ports = lpcfg_smb_ports(tctx->lp_ctx);
350
io1.in.socket_options = lpcfg_socket_options(tctx->lp_ctx);
352
351
io1.in.called_name = torture_setting_string(tctx, "host", NULL);
353
352
io1.in.service = torture_setting_string(tctx, "share", NULL);
354
353
io1.in.service_type = "A:";
355
354
io1.in.credentials = cmdline_credentials;
356
io1.in.workgroup = lp_workgroup(tctx->lp_ctx);
355
io1.in.workgroup = lpcfg_workgroup(tctx->lp_ctx);
357
356
io1.in.level = RAW_QFS_OBJECTID_INFORMATION;
358
io1.in.iconv_convenience = lp_iconv_convenience(tctx->lp_ctx);
359
io1.in.gensec_settings = lp_gensec_settings(tctx, tctx->lp_ctx);
357
io1.in.gensec_settings = lpcfg_gensec_settings(tctx, tctx->lp_ctx);
361
printf("testing parallel queryfsinfo [Object ID] with %d ops\n", torture_numops);
359
printf("Testing parallel queryfsinfo [Object ID] with %d ops\n",
363
362
event_ctx = tctx->ev;
364
363
c = talloc_array(tctx, struct composite_context *, torture_numops);
366
365
for (i=0; i<torture_numops; i++) {
367
c[i] = smb_composite_fsinfo_send(cli->tree, &io1, lp_resolve_context(tctx->lp_ctx));
366
c[i] = smb_composite_fsinfo_send(cli->tree, &io1, lpcfg_resolve_context(tctx->lp_ctx));
368
367
c[i]->async.fn = loadfile_complete;
369
368
c[i]->async.private_data = count;