4
Unix SMB/CIFS implementation.
6
Copyright (C) Andrew Tridgell 1997-1998
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.
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.
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.
25
#define MAX_FILES 1000
27
static char buf[70000];
28
extern int line_count;
37
static struct children {
38
double bytes_in, bytes_out;
43
double nbio_total(void)
47
for (i=0;i<nprocs;i++) {
48
total += children[i].bytes_out + children[i].bytes_in;
53
void nb_alarm(int ignore)
56
int lines=0, num_clients=0;
57
if (nbio_id != -1) return;
59
for (i=0;i<nprocs;i++) {
60
lines += children[i].line;
61
if (!children[i].done) num_clients++;
64
printf("%4d %8d %.2f MB/sec\r", num_clients, lines/nprocs, 1.0e-6 * nbio_total() / end_timer());
66
signal(SIGALRM, nb_alarm);
70
void nbio_shmem(int n)
73
children = (struct children *)shm_setup(sizeof(*children) * nprocs);
75
printf("Failed to setup shared memory!\n");
81
static int ne_find_handle(int handle)
84
children[nbio_id].line = line_count;
85
for (i=0;i<MAX_FILES;i++) {
86
if (ftable[i].handle == handle) return i;
92
static int find_handle(int handle)
95
children[nbio_id].line = line_count;
96
for (i=0;i<MAX_FILES;i++) {
97
if (ftable[i].handle == handle) return i;
99
printf("(%d) ERROR: handle %d was not found\n",
103
return -1; /* Not reached */
107
static struct cli_state *c;
109
static void sigsegv(int sig)
112
printf("segv at line %d\n", line_count);
113
slprintf(line, sizeof(line), "/usr/X11R6/bin/xterm -e gdb /proc/%d/exe %d",
114
(int)getpid(), (int)getpid());
119
void nb_setup(struct cli_state *cli)
121
signal(SIGSEGV, sigsegv);
124
children[nbio_id].done = 0;
128
void nb_unlink(const char *fname)
130
if (!cli_unlink(c, fname)) {
132
printf("(%d) unlink %s failed (%s)\n",
133
line_count, fname, cli_errstr(c));
139
void nb_createx(const char *fname,
140
unsigned create_options, unsigned create_disposition, int handle)
143
uint32 desired_access;
145
if (create_options & FILE_DIRECTORY_FILE) {
146
desired_access = FILE_READ_DATA;
148
desired_access = FILE_READ_DATA | FILE_WRITE_DATA;
151
fd = cli_nt_create_full(c, fname, 0,
154
FILE_SHARE_READ|FILE_SHARE_WRITE,
157
if (fd == -1 && handle != -1) {
158
printf("ERROR: cli_nt_create_full failed for %s - %s\n",
159
fname, cli_errstr(c));
162
if (fd != -1 && handle == -1) {
163
printf("ERROR: cli_nt_create_full succeeded for %s\n", fname);
166
if (fd == -1) return;
168
for (i=0;i<MAX_FILES;i++) {
169
if (ftable[i].handle == 0) break;
171
if (i == MAX_FILES) {
172
printf("(%d) file table full for %s\n", line_count,
176
ftable[i].handle = handle;
180
void nb_writex(int handle, int offset, int size, int ret_size)
184
if (buf[0] == 0) memset(buf, 1, sizeof(buf));
186
i = find_handle(handle);
187
if (cli_write(c, ftable[i].fd, 0, buf, offset, size) != ret_size) {
188
printf("(%d) ERROR: write failed on handle %d, fd %d \
189
errno %d (%s)\n", line_count, handle, ftable[i].fd, errno, strerror(errno));
193
children[nbio_id].bytes_out += ret_size;
196
void nb_readx(int handle, int offset, int size, int ret_size)
200
i = find_handle(handle);
201
if ((ret=cli_read(c, ftable[i].fd, buf, offset, size)) != ret_size) {
202
printf("(%d) ERROR: read failed on handle %d ofs=%d size=%d res=%d fd %d errno %d (%s)\n",
203
line_count, handle, offset, size, ret, ftable[i].fd, errno, strerror(errno));
206
children[nbio_id].bytes_in += ret_size;
209
void nb_close(int handle)
212
i = find_handle(handle);
213
if (!cli_close(c, ftable[i].fd)) {
214
printf("(%d) close failed on handle %d\n", line_count, handle);
217
ftable[i].handle = 0;
220
void nb_rmdir(const char *fname)
222
if (!cli_rmdir(c, fname)) {
223
printf("ERROR: rmdir %s failed (%s)\n",
224
fname, cli_errstr(c));
229
void nb_rename(const char *oldname, const char *newname)
231
if (!cli_rename(c, oldname, newname)) {
232
printf("ERROR: rename %s %s failed (%s)\n",
233
oldname, newname, cli_errstr(c));
239
void nb_qpathinfo(const char *fname)
241
cli_qpathinfo(c, fname, NULL, NULL, NULL, NULL, NULL);
244
void nb_qfileinfo(int fnum)
247
i = find_handle(fnum);
248
cli_qfileinfo(c, ftable[i].fd, NULL, NULL, NULL, NULL, NULL, NULL, NULL);
251
void nb_qfsinfo(int level)
253
int bsize, total, avail;
254
/* this is not the right call - we need cli_qfsinfo() */
255
cli_dskattr(c, &bsize, &total, &avail);
258
static void find_fn(const char *mnt, file_info *finfo, const char *name, void *state)
263
void nb_findfirst(const char *mask)
265
cli_list(c, mask, 0, find_fn, NULL);
268
void nb_flush(int fnum)
271
i = find_handle(fnum);
272
/* hmmm, we don't have cli_flush() yet */
275
static int total_deleted;
277
static void delete_fn(const char *mnt, file_info *finfo, const char *name, void *state)
280
if (finfo->name[0] == '.') return;
282
n = SMB_STRDUP(name);
284
asprintf(&s, "%s%s", n, finfo->name);
285
if (finfo->mode & aDIR) {
287
asprintf(&s2, "%s\\*", s);
288
cli_list(c, s2, aDIR, delete_fn, NULL);
298
void nb_deltree(const char *dname)
301
asprintf(&mask, "%s\\*", dname);
304
cli_list(c, mask, aDIR, delete_fn, NULL);
308
if (total_deleted) printf("WARNING: Cleaned up %d files\n", total_deleted);
312
void nb_cleanup(void)
314
cli_rmdir(c, "clients");
315
children[nbio_id].done = 1;