-/*
+/*
Unix SMB/CIFS implementation.
generic testing tool - version with both SMB and SMB2 support
Copyright (C) Andrew Tridgell 2003-2008
-
+
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 3 of the License, or
(at your option) any later version.
-
+
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
-
+
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
return false;
}
-/*****************************************************
+/*****************************************************
connect to the servers
*******************************************************/
static bool connect_servers_fast(void)
-/*****************************************************
+/*****************************************************
connect to the servers
*******************************************************/
static bool connect_servers(struct tevent_context *ev,
lpcfg_smbcli_session_options(lp_ctx, &smb_session_options);
printf("Connecting to \\\\%s\\%s as %s - instance %d\n",
- servers[i].server_name, servers[i].share_name,
+ servers[i].server_name, servers[i].share_name,
cli_credentials_get_username(servers[i].credentials),
j);
- cli_credentials_set_workstation(servers[i].credentials,
+ cli_credentials_set_workstation(servers[i].credentials,
"gentest", CRED_SPECIFIED);
if (options.smb2) {
- status = smb2_connect(NULL, servers[i].server_name,
+ status = smb2_connect(NULL, servers[i].server_name,
lpcfg_smb_ports(lp_ctx),
servers[i].share_name,
lpcfg_resolve_context(lp_ctx),
);
} else {
status = smbcli_tree_full_connection(NULL,
- &servers[i].smb_tree[j],
- servers[i].server_name,
+ &servers[i].smb_tree[j],
+ servers[i].server_name,
lpcfg_smb_ports(lp_ctx),
servers[i].share_name, "A:",
lpcfg_socket_options(lp_ctx),
if (options.smb2) {
servers[i].smb2_tree[j]->session->transport->oplock.handler = oplock_handler_smb2;
servers[i].smb2_tree[j]->session->transport->oplock.private_data = (void *)(uintptr_t)((i<<8)|j);
- smb2_transport_idle_handler(servers[i].smb2_tree[j]->session->transport,
+ smb2_transport_idle_handler(servers[i].smb2_tree[j]->session->transport,
idle_func_smb2, 50000, NULL);
} else {
- smbcli_oplock_handler(servers[i].smb_tree[j]->session->transport, oplock_handler_smb,
+ smbcli_oplock_handler(servers[i].smb_tree[j]->session->transport, oplock_handler_smb,
(void *)(uintptr_t)((i<<8)|j));
- smbcli_transport_idle_handler(servers[i].smb_tree[j]->session->transport, idle_func_smb,
+ smbcli_transport_idle_handler(servers[i].smb_tree[j]->session->transport, idle_func_smb,
50000, (void *)(uintptr_t)((i<<8)|j));
}
}
return i;
}
}
- printf("Invalid server handle in fnum_to_handle on server %d instance %d\n",
+ printf("Invalid server handle in fnum_to_handle on server %d instance %d\n",
server, instance);
return BAD_HANDLE;
}
return i;
}
}
- printf("Invalid server handle in fnum_to_handle on server %d instance %d\n",
+ printf("Invalid server handle in fnum_to_handle on server %d instance %d\n",
server, instance);
return BAD_HANDLE;
}
h = random() % options.max_open_handles;
for (i=0;i<NSERVERS;i++) {
NTSTATUS status;
- status = smb2_util_close(servers[i].smb2_tree[open_handles[h].instance],
+ status = smb2_util_close(servers[i].smb2_tree[open_handles[h].instance],
open_handles[h].smb2_handle[i]);
if (NT_STATUS_IS_ERR(status)) {
printf("INTERNAL ERROR: Close failed when recovering handle! - %s\n",
}
num_open_handles++;
- printf("OPEN num_open_handles=%d h=%d (%s)\n",
+ printf("OPEN num_open_handles=%d h=%d (%s)\n",
num_open_handles, h, name);
}
h = random() % options.max_open_handles;
for (i=0;i<NSERVERS;i++) {
NTSTATUS status;
- status = smbcli_close(servers[i].smb_tree[open_handles[h].instance],
+ status = smbcli_close(servers[i].smb_tree[open_handles[h].instance],
open_handles[h].smb_handle[i]);
if (NT_STATUS_IS_ERR(status)) {
printf("INTERNAL ERROR: Close failed when recovering handle! - %s\n",
}
num_open_handles++;
- printf("OPEN num_open_handles=%d h=%d (%s)\n",
+ printf("OPEN num_open_handles=%d h=%d (%s)\n",
num_open_handles, h, name);
}
for (h=0;h<options.max_open_handles;h++) {
if (instance == open_handles[h].instance &&
smb2_handle_equal(&open_handles[h].smb2_handle[0], &handles[0])) {
- open_handles[h].active = false;
+ open_handles[h].active = false;
num_open_handles--;
- printf("CLOSE num_open_handles=%d h=%d (%s)\n",
- num_open_handles, h,
+ printf("CLOSE num_open_handles=%d h=%d (%s)\n",
+ num_open_handles, h,
open_handles[h].name);
return;
}
for (h=0;h<options.max_open_handles;h++) {
if (instance == open_handles[h].instance &&
open_handles[h].smb_handle[0] == handles[0]) {
- open_handles[h].active = false;
+ open_handles[h].active = false;
num_open_handles--;
- printf("CLOSE num_open_handles=%d h=%d (%s)\n",
- num_open_handles, h,
+ printf("CLOSE num_open_handles=%d h=%d (%s)\n",
+ num_open_handles, h,
open_handles[h].name);
return;
}
while (num_open_handles > 0 && count++ < 10*options.max_open_handles) {
h = random() % options.max_open_handles;
- if (open_handles[h].active &&
+ if (open_handles[h].active &&
open_handles[h].instance == instance) {
return h;
}
*/
static const char *gen_fname(void)
{
- const char *names[] = {"gentest\\gentest.dat",
- "gentest\\foo",
- "gentest\\foo2.sym",
- "gentest\\foo3.dll",
- "gentest\\foo4",
- "gentest\\foo4:teststream1",
- "gentest\\foo4:teststream2",
- "gentest\\foo5.exe",
- "gentest\\foo5.exe:teststream3",
- "gentest\\foo5.exe:teststream4",
- "gentest\\foo6.com",
- "gentest\\blah",
- "gentest\\blah\\blergh.txt",
- "gentest\\blah\\blergh2",
- "gentest\\blah\\blergh3.txt",
- "gentest\\blah\\blergh4",
- "gentest\\blah\\blergh5.txt",
- "gentest\\blah\\blergh5",
- "gentest\\blah\\.",
- "gentest\\blah\\..",
- "gentest\\a_very_long_name.bin",
- "gentest\\x.y",
+ const char *names[] = {"gentest\\gentest.dat",
+ "gentest\\foo",
+ "gentest\\foo2.sym",
+ "gentest\\foo3.dll",
+ "gentest\\foo4",
+ "gentest\\foo4:teststream1",
+ "gentest\\foo4:teststream2",
+ "gentest\\foo5.exe",
+ "gentest\\foo5.exe:teststream3",
+ "gentest\\foo5.exe:teststream4",
+ "gentest\\foo6.com",
+ "gentest\\blah",
+ "gentest\\blah\\blergh.txt",
+ "gentest\\blah\\blergh2",
+ "gentest\\blah\\blergh3.txt",
+ "gentest\\blah\\blergh4",
+ "gentest\\blah\\blergh5.txt",
+ "gentest\\blah\\blergh5",
+ "gentest\\blah\\.",
+ "gentest\\blah\\..",
+ "gentest\\a_very_long_name.bin",
+ "gentest\\x.y",
"gentest\\blah"};
int i;
}
/*
- generate a filename with a higher chance of choosing an already
+ generate a filename with a higher chance of choosing an already
open file
*/
static const char *gen_fname_open(int instance)
static const char *gen_pattern(void)
{
int i;
- const char *names[] = {"gentest\\*.dat",
- "gentest\\*",
- "gentest\\*.*",
- "gentest\\blah\\*.*",
- "gentest\\blah\\*",
+ const char *names[] = {"gentest\\*.dat",
+ "gentest\\*",
+ "gentest\\*.*",
+ "gentest\\blah\\*.*",
+ "gentest\\blah\\*",
"gentest\\?"};
if (gen_chance(50)) return gen_fname();
}
/*
- generate a pid
+ generate a pid
*/
static uint16_t gen_pid(void)
{
if (!options.valid && gen_chance(5)) return gen_bits_mask(0xFFFF);
if (gen_chance(20)) return gen_bits_mask(0x1F);
if (gen_chance(50)) return SMB2_LOCK_FLAG_UNLOCK;
- return gen_bits_mask(SMB2_LOCK_FLAG_SHARED |
- SMB2_LOCK_FLAG_EXCLUSIVE |
+ return gen_bits_mask(SMB2_LOCK_FLAG_SHARED |
+ SMB2_LOCK_FLAG_EXCLUSIVE |
SMB2_LOCK_FLAG_FAIL_IMMEDIATELY);
}
static struct ea_struct gen_ea_struct(void)
{
struct ea_struct ea;
- const char *names[] = {"EAONE",
- "",
- "FOO!",
- " WITH SPACES ",
- ".",
+ const char *names[] = {"EAONE",
+ "",
+ "FOO!",
+ " WITH SPACES ",
+ ".",
"AVERYLONGATTRIBUTENAME"};
- const char *values[] = {"VALUE1",
- "",
- "NOT MUCH FOO",
- " LEADING SPACES ",
- ":",
+ const char *values[] = {"VALUE1",
+ "",
+ "NOT MUCH FOO",
+ " LEADING SPACES ",
+ ":",
"ASOMEWHATLONGERATTRIBUTEVALUE"};
int i;
}
}
-static bool send_oplock_ack_smb2(struct smb2_tree *tree, struct smb2_handle handle,
+static bool send_oplock_ack_smb2(struct smb2_tree *tree, struct smb2_handle handle,
uint8_t level)
{
struct smb2_break br;
/*
the oplock handler will either ack the break or close the file
*/
-static bool oplock_handler_smb2(struct smb2_transport *transport, const struct smb2_handle *handle,
+static bool oplock_handler_smb2(struct smb2_transport *transport, const struct smb2_handle *handle,
uint8_t level, void *private_data)
{
struct smb2_close io;
/* also support ignore patterns of the form NT_STATUS_XX:NT_STATUS_YY
meaning that the first server returns NT_STATUS_XX and the 2nd
returns NT_STATUS_YY */
- s = talloc_asprintf(current_op.mem_ctx, "%s:%s",
- nt_errstr(status1),
+ s = talloc_asprintf(current_op.mem_ctx, "%s:%s",
+ nt_errstr(status1),
nt_errstr(status2));
if (ignore_pattern(s)) {
return true;
for (i=0;i<NSERVERS;i++) {
// smb2_transport_process(servers[i].smb2_tree[j]->session->transport);
}
- }
+ }
}
/*
oplocks[0][j].level != oplocks[i][j].level) {
if (tries++ < 10) goto again;
printf("oplock break inconsistent - %d/%d/%d vs %d/%d/%d\n",
- oplocks[0][j].got_break,
- oplocks[0][j].handle,
- oplocks[0][j].level,
- oplocks[i][j].got_break,
- oplocks[i][j].handle,
+ oplocks[0][j].got_break,
+ oplocks[0][j].handle,
+ oplocks[0][j].level,
+ oplocks[i][j].got_break,
+ oplocks[i][j].handle,
oplocks[i][j].level);
current_op.mismatch = "oplock break";
return false;
gen_remove_handle_smb(j, fnums);
break;
}
- }
+ }
return true;
}
not2 = notifies[i][j].notify;
for (n=0;n<not1.nttrans.out.num_changes;n++) {
- if (not1.nttrans.out.changes[n].action !=
+ if (not1.nttrans.out.changes[n].action !=
not2.nttrans.out.changes[n].action) {
printf("Notify action %d inconsistent %d %d\n", n,
not1.nttrans.out.changes[n].action,
/*
compare returned fileinfo structures
*/
-static bool cmp_fileinfo(int instance,
+static bool cmp_fileinfo(int instance,
union smb_fileinfo parm[NSERVERS],
NTSTATUS status[NSERVERS])
{
case RAW_FILEINFO_IS_NAME_VALID:
break;
-
+
case RAW_FILEINFO_BASIC_INFO:
case RAW_FILEINFO_BASIC_INFORMATION:
CHECK_NTTIMES_EQUAL(basic_info.out.create_time);
parm[0].openx.in.flags &= ~(OPENX_FLAGS_REQUEST_OPLOCK|
OPENX_FLAGS_REQUEST_BATCH_OPLOCK);
}
-
+
GEN_COPY_PARM;
GEN_CALL_SMB(smb_raw_open(tree, current_op.mem_ctx, &parm[i]));
parm[0].openold.in.open_mode &= ~(OPENX_FLAGS_REQUEST_OPLOCK|
OPENX_FLAGS_REQUEST_BATCH_OPLOCK);
}
-
+
GEN_COPY_PARM;
GEN_CALL_SMB(smb_raw_open(tree, current_op.mem_ctx, &parm[i]));
parm[0].ntcreatex.in.flags &= ~(NTCREATEX_FLAGS_REQUEST_OPLOCK|
NTCREATEX_FLAGS_REQUEST_BATCH_OPLOCK);
}
-
+
GEN_COPY_PARM;
if (parm[0].ntcreatex.in.root_fid.fnum != 0) {
GEN_SET_FNUM_SMB(ntcreatex.in.root_fid.fnum);
} levels[] = {
#if 0
/* disabled until win2003 can handle them ... */
- LVL(EA_SET), LVL(BASIC_INFO), LVL(DISPOSITION_INFO),
- LVL(STANDARD), LVL(ALLOCATION_INFO), LVL(END_OF_FILE_INFO),
+ LVL(EA_SET), LVL(BASIC_INFO), LVL(DISPOSITION_INFO),
+ LVL(STANDARD), LVL(ALLOCATION_INFO), LVL(END_OF_FILE_INFO),
#endif
LVL(SETATTR), LVL(SETATTRE), LVL(BASIC_INFORMATION),
- LVL(RENAME_INFORMATION), LVL(DISPOSITION_INFORMATION),
+ LVL(RENAME_INFORMATION), LVL(DISPOSITION_INFORMATION),
LVL(POSITION_INFORMATION), LVL(MODE_INFORMATION),
- LVL(ALLOCATION_INFORMATION), LVL(END_OF_FILE_INFORMATION),
+ LVL(ALLOCATION_INFORMATION), LVL(END_OF_FILE_INFORMATION),
LVL(1023), LVL(1025), LVL(1029), LVL(1032), LVL(1039), LVL(1040)
};
do {
const char *name;
};
struct levels smb_levels[] = {
- LVL(EA_SET), LVL(BASIC_INFO), LVL(DISPOSITION_INFO),
- LVL(STANDARD), LVL(ALLOCATION_INFO), LVL(END_OF_FILE_INFO),
+ LVL(EA_SET), LVL(BASIC_INFO), LVL(DISPOSITION_INFO),
+ LVL(STANDARD), LVL(ALLOCATION_INFO), LVL(END_OF_FILE_INFO),
LVL(SETATTR), LVL(SETATTRE), LVL(BASIC_INFORMATION),
- LVL(RENAME_INFORMATION), LVL(DISPOSITION_INFORMATION),
+ LVL(RENAME_INFORMATION), LVL(DISPOSITION_INFORMATION),
LVL(POSITION_INFORMATION), LVL(FULL_EA_INFORMATION), LVL(MODE_INFORMATION),
- LVL(ALLOCATION_INFORMATION), LVL(END_OF_FILE_INFORMATION),
- LVL(PIPE_INFORMATION), LVL(VALID_DATA_INFORMATION), LVL(SHORT_NAME_INFORMATION),
+ LVL(ALLOCATION_INFORMATION), LVL(END_OF_FILE_INFORMATION),
+ LVL(PIPE_INFORMATION), LVL(VALID_DATA_INFORMATION), LVL(SHORT_NAME_INFORMATION),
LVL(1025), LVL(1027), LVL(1029), LVL(1030), LVL(1031), LVL(1032), LVL(1036),
LVL(1041), LVL(1042), LVL(1043), LVL(1044),
};
struct levels smb2_levels[] = {
LVL(BASIC_INFORMATION),
- LVL(RENAME_INFORMATION), LVL(DISPOSITION_INFORMATION),
+ LVL(RENAME_INFORMATION), LVL(DISPOSITION_INFORMATION),
LVL(POSITION_INFORMATION), LVL(FULL_EA_INFORMATION), LVL(MODE_INFORMATION),
- LVL(ALLOCATION_INFORMATION), LVL(END_OF_FILE_INFORMATION),
- LVL(PIPE_INFORMATION), LVL(VALID_DATA_INFORMATION), LVL(SHORT_NAME_INFORMATION),
+ LVL(ALLOCATION_INFORMATION), LVL(END_OF_FILE_INFORMATION),
+ LVL(PIPE_INFORMATION), LVL(VALID_DATA_INFORMATION), LVL(SHORT_NAME_INFORMATION),
LVL(1025), LVL(1027), LVL(1029), LVL(1030), LVL(1031), LVL(1032), LVL(1036),
LVL(1041), LVL(1042), LVL(1043), LVL(1044),
};
notify.nttrans.level = RAW_NOTIFY_NTTRANS;
status = smb_raw_changenotify_recv(req, current_op.mem_ctx, ¬ify);
if (NT_STATUS_IS_OK(status) && notify.nttrans.out.num_changes > 0) {
- printf("notify tid=%d num_changes=%d action=%d name=%s\n",
- tid,
+ printf("notify tid=%d num_changes=%d action=%d name=%s\n",
+ tid,
notify.nttrans.out.num_changes,
notify.nttrans.out.changes[0].action,
notify.nttrans.out.changes[0].name.s);
parm[0].in.file.handle.data[0] = gen_fnum(instance);
parm[0].in.lock_count = gen_lock_count();
parm[0].in.lock_sequence = gen_reserved32();
-
+
parm[0].in.locks = talloc_array(current_op.mem_ctx,
struct smb2_lock_element,
parm[0].in.lock_count);
parm[0].in.locks[n].offset = gen_offset();
parm[0].in.locks[n].length = gen_io_count();
/* don't yet cope with async replies */
- parm[0].in.locks[n].flags = gen_lock_flags_smb2() |
+ parm[0].in.locks[n].flags = gen_lock_flags_smb2() |
SMB2_LOCK_FLAG_FAIL_IMMEDIATELY;
parm[0].in.locks[n].reserved = gen_bits_mask2(0x0, 0xFFFFFFFF);
}
gen_ops[which_op].count++;
if (NT_STATUS_IS_OK(current_op.status)) {
- gen_ops[which_op].success_count++;
+ gen_ops[which_op].success_count++;
}
if (!ret) {
}
for (i=0;i<ARRAY_SIZE(gen_ops);i++) {
- printf("Op %-10s got %d/%d success\n",
+ printf("Op %-10s got %d/%d success\n",
gen_ops[i].name,
gen_ops[i].success_count,
gen_ops[i].count);
return op;
}
-/*
+/*
perform a backtracking analysis of the minimal set of operations
to generate an error
*/
do {
int base;
- for (base=0;
+ for (base=0;
chunk > 0 && base+chunk < options.numops && options.numops > 1; ) {
int i, max;
for (i=base;i<max; i++) {
op_parms[i].disabled = true;
}
- printf("Testing %d ops with %d-%d disabled\n",
+ printf("Testing %d ops with %d-%d disabled\n",
options.numops, base, max-1);
ret = run_test(ev, lp_ctx);
printf("Completed %d of %d ops\n", ret, options.numops);
base = 0;
} else {
/* it failed - this chunk isn't needed for a failure */
- memmove(&op_parms[base], &op_parms[max],
+ memmove(&op_parms[base], &op_parms[max],
sizeof(op_parms[0]) * (options.numops - max));
options.numops = (ret+1) - (max - base);
}
}
}
-/*
+/*
start the main gentest process
*/
static bool start_gentest(struct tevent_context *ev,
*p = 0;
(*share) = p+1;
-
+
return true;
}
projects / thirdparty / samba.git / commitdiff
