Changeset 988 for vendor/current/source4/ntvfs/nbench
- Timestamp:
- Nov 24, 2016, 1:14:11 PM (9 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
vendor/current/source4/ntvfs/nbench/vfs_nbench.c
r740 r988 28 28 #include "system/filesys.h" 29 29 30 NTSTATUS ntvfs_nbench_init(void); 31 30 32 /* this is stored in ntvfs_private */ 31 33 struct nbench_private { … … 125 127 126 128 logname = talloc_asprintf(req, "/tmp/nbenchlog%d.%u", ntvfs->depth, 127 getpid());129 (unsigned int)getpid()); 128 130 NT_STATUS_HAVE_NO_MEMORY(logname); 129 131 nprivates->log_fd = open(logname, O_WRONLY|O_CREAT|O_APPEND, 0644); … … 164 166 { 165 167 union smb_unlink *unl = req->async_states->private_data; 166 167 168 nbench_log(req, "Unlink \"%s\" 0x%x %s\n", 168 169 unl->unlink.in.pattern, unl->unlink.in.attrib, 169 get_nt_error_c_code(req ->async_states->status));170 get_nt_error_c_code(req, req->async_states->status)); 170 171 171 172 PASS_THRU_REP_POST(req); … … 212 213 nbench_log(req, "Chkpath \"%s\" %s\n", 213 214 cp->chkpath.in.path, 214 get_nt_error_c_code(req ->async_states->status));215 get_nt_error_c_code(req, req->async_states->status)); 215 216 216 217 PASS_THRU_REP_POST(req); … … 238 239 info->generic.in.file.path, 239 240 info->generic.level, 240 get_nt_error_c_code(req ->async_states->status));241 get_nt_error_c_code(req, req->async_states->status)); 241 242 242 243 PASS_THRU_REP_POST(req); … … 263 264 nbench_ntvfs_handle_string(req, info->generic.in.file.ntvfs), 264 265 info->generic.level, 265 get_nt_error_c_code(req ->async_states->status));266 get_nt_error_c_code(req, req->async_states->status)); 266 267 267 268 PASS_THRU_REP_POST(req); … … 288 289 st->generic.in.file.path, 289 290 st->generic.level, 290 get_nt_error_c_code(req ->async_states->status));291 get_nt_error_c_code(req, req->async_states->status)); 291 292 292 293 PASS_THRU_REP_POST(req); … … 320 321 io->ntcreatex.in.open_disposition, 321 322 nbench_ntvfs_handle_string(req, io->ntcreatex.out.file.ntvfs), 322 get_nt_error_c_code(req ->async_states->status));323 get_nt_error_c_code(req, req->async_states->status)); 323 324 break; 324 325 … … 372 373 nbench_log(req, "Rmdir \"%s\" %s\n", 373 374 rd->in.path, 374 get_nt_error_c_code(req ->async_states->status));375 get_nt_error_c_code(req, req->async_states->status)); 375 376 376 377 PASS_THRU_REP_POST(req); … … 399 400 ren->rename.in.pattern1, 400 401 ren->rename.in.pattern2, 401 get_nt_error_c_code(req ->async_states->status));402 get_nt_error_c_code(req, req->async_states->status)); 402 403 break; 403 404 … … 458 459 rd->readx.in.maxcnt, 459 460 rd->readx.out.nread, 460 get_nt_error_c_code(req ->async_states->status));461 get_nt_error_c_code(req, req->async_states->status)); 461 462 break; 462 463 default: … … 496 497 wr->writex.in.count, 497 498 wr->writex.out.nwritten, 498 get_nt_error_c_code(req ->async_states->status));499 get_nt_error_c_code(req, req->async_states->status)); 499 500 break; 500 501 … … 508 509 wr->write.in.count, 509 510 wr->write.out.nwritten, 510 get_nt_error_c_code(req ->async_states->status));511 get_nt_error_c_code(req, req->async_states->status)); 511 512 break; 512 513 … … 562 563 nbench_log(req, "Flush %s %s\n", 563 564 nbench_ntvfs_handle_string(req, io->flush.in.file.ntvfs), 564 get_nt_error_c_code(req ->async_states->status));565 get_nt_error_c_code(req, req->async_states->status)); 565 566 break; 566 567 case RAW_FLUSH_ALL: 567 568 nbench_log(req, "Flush %d %s\n", 568 569 0xFFFF, 569 get_nt_error_c_code(req ->async_states->status));570 get_nt_error_c_code(req, req->async_states->status)); 570 571 break; 571 572 default: … … 600 601 nbench_log(req, "Close %s %s\n", 601 602 nbench_ntvfs_handle_string(req, io->close.in.file.ntvfs), 602 get_nt_error_c_code(req ->async_states->status));603 get_nt_error_c_code(req, req->async_states->status)); 603 604 break; 604 605 … … 717 718 (int)lck->lockx.in.locks[0].offset, 718 719 (int)lck->lockx.in.locks[0].count, 719 get_nt_error_c_code(req ->async_states->status));720 get_nt_error_c_code(req, req->async_states->status)); 720 721 } else if (lck->generic.level == RAW_LOCK_LOCKX && 721 722 lck->lockx.in.ulock_cnt == 1) { … … 724 725 (int)lck->lockx.in.locks[0].offset, 725 726 (int)lck->lockx.in.locks[0].count, 726 get_nt_error_c_code(req ->async_states->status));727 get_nt_error_c_code(req, req->async_states->status)); 727 728 } else { 728 729 nbench_log(req, "Lock-%d - NOT HANDLED\n", lck->generic.level); … … 752 753 nbench_ntvfs_handle_string(req, info->generic.in.file.ntvfs), 753 754 info->generic.level, 754 get_nt_error_c_code(req ->async_states->status));755 get_nt_error_c_code(req, req->async_states->status)); 755 756 756 757 PASS_THRU_REP_POST(req); … … 777 778 nbench_log(req, "QUERY_FS_INFORMATION %d %s\n", 778 779 fs->generic.level, 779 get_nt_error_c_code(req ->async_states->status));780 get_nt_error_c_code(req, req->async_states->status)); 780 781 781 782 PASS_THRU_REP_POST(req); … … 831 832 io->t2ffirst.in.max_count, 832 833 io->t2ffirst.out.count, 833 get_nt_error_c_code(req ->async_states->status));834 get_nt_error_c_code(req, req->async_states->status)); 834 835 break; 835 836 … … 930 931 931 932 /* fill in all the operations */ 932 ops.connect = nbench_connect;933 ops.disconnect = nbench_disconnect;934 ops.unlink = nbench_unlink;935 ops.chkpath = nbench_chkpath;936 ops.qpathinfo = nbench_qpathinfo;937 ops.setpathinfo = nbench_setpathinfo;938 ops.open = nbench_open;939 ops.mkdir = nbench_mkdir;940 ops.rmdir = nbench_rmdir;941 ops.rename = nbench_rename;942 ops.copy = nbench_copy;943 ops.ioctl = nbench_ioctl;944 ops.read = nbench_read;945 ops.write = nbench_write;946 ops.seek = nbench_seek;947 ops.flush = nbench_flush;948 ops.close = nbench_close;949 ops.exit = nbench_exit;950 ops.lock = nbench_lock;951 ops.setfileinfo = nbench_setfileinfo;952 ops.qfileinfo = nbench_qfileinfo;953 ops.fsinfo = nbench_fsinfo;954 ops.lpq = nbench_lpq;955 ops.search_first = nbench_search_first;956 ops.search_next = nbench_search_next;957 ops.search_close = nbench_search_close;958 ops.trans = nbench_trans;959 ops.logoff = nbench_logoff;960 ops.async_setup = nbench_async_setup;961 ops.cancel = nbench_cancel;933 ops.connect_fn = nbench_connect; 934 ops.disconnect_fn = nbench_disconnect; 935 ops.unlink_fn = nbench_unlink; 936 ops.chkpath_fn = nbench_chkpath; 937 ops.qpathinfo_fn = nbench_qpathinfo; 938 ops.setpathinfo_fn = nbench_setpathinfo; 939 ops.open_fn = nbench_open; 940 ops.mkdir_fn = nbench_mkdir; 941 ops.rmdir_fn = nbench_rmdir; 942 ops.rename_fn = nbench_rename; 943 ops.copy_fn = nbench_copy; 944 ops.ioctl_fn = nbench_ioctl; 945 ops.read_fn = nbench_read; 946 ops.write_fn = nbench_write; 947 ops.seek_fn = nbench_seek; 948 ops.flush_fn = nbench_flush; 949 ops.close_fn = nbench_close; 950 ops.exit_fn = nbench_exit; 951 ops.lock_fn = nbench_lock; 952 ops.setfileinfo_fn = nbench_setfileinfo; 953 ops.qfileinfo_fn = nbench_qfileinfo; 954 ops.fsinfo_fn = nbench_fsinfo; 955 ops.lpq_fn = nbench_lpq; 956 ops.search_first_fn = nbench_search_first; 957 ops.search_next_fn = nbench_search_next; 958 ops.search_close_fn = nbench_search_close; 959 ops.trans_fn = nbench_trans; 960 ops.logoff_fn = nbench_logoff; 961 ops.async_setup_fn = nbench_async_setup; 962 ops.cancel_fn = nbench_cancel; 962 963 963 964 /* we don't register a trans2 handler as we want to be able to 964 965 log individual trans2 requests */ 965 ops.trans2 = NULL;966 ops.trans2_fn = NULL; 966 967 967 968 /* register ourselves with the NTVFS subsystem. */
Note:
See TracChangeset
for help on using the changeset viewer.