diff options
| author | gkostka <kostka.grzegorz@gmail.com> | 2014-04-06 15:58:29 +0000 |
|---|---|---|
| committer | gkostka <kostka.grzegorz@gmail.com> | 2014-04-06 15:58:29 +0000 |
| commit | 52a1caf80302fcaa86466785cd036bdfab2d2298 (patch) | |
| tree | 93a904dcc002e95a0d54c1f2a1548d4254b1266d /fs_test/lwext4_server.c | |
| parent | 28eaf612482f3b681e9d17e7370052d73649ffd1 (diff) | |
Client server basic test suite + minor code improvment.
Diffstat (limited to 'fs_test/lwext4_server.c')
| -rw-r--r-- | fs_test/lwext4_server.c | 1071 |
1 files changed, 1071 insertions, 0 deletions
diff --git a/fs_test/lwext4_server.c b/fs_test/lwext4_server.c new file mode 100644 index 0000000..deb9bd6 --- /dev/null +++ b/fs_test/lwext4_server.c @@ -0,0 +1,1071 @@ +
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <errno.h>
+#include <string.h>
+#include <stdint.h>
+#include <stdbool.h>
+#include <getopt.h>
+#include <time.h>
+
+#ifdef WIN32
+#include <windows.h>
+#include <winsock2.h>
+#else
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <sys/types.h>
+#endif
+
+#include <ext4.h>
+#include <ext4_filedev.h>
+#include <io_raw.h>
+
+static int winsock_init(void);
+static void winsock_fini(void);
+static char* entry_to_str(uint8_t type);
+
+#define MAX_FILES 64
+#define MAX_DIRS 64
+
+#define MAX_RW_BUFFER (1024 * 1024)
+#define RW_BUFFER_PATERN ('x')
+
+
+/**@brief Default connection port*/
+static int connection_port = 8888;
+
+/**@brief Default filesystem filename.*/
+static char *ext4_fname = "ext2";
+
+/**@brief Verbose mode*/
+static int verbose = 0;
+
+static char read_buffer[MAX_RW_BUFFER];
+static char write_buffer[MAX_RW_BUFFER];
+
+
+static const char *usage = " \n\
+Welcome in lwext4_server. \n\
+Copyright (c) 2013 Grzegorz Kostka (kostka.grzegorz@gmail.com) \n\
+Usage: \n\
+ --image (-i) - ext2/3/4 image file \n\
+ --port (-p) - server port \n\
+ --verbose (-v) - verbose mode \n\
+\n";
+
+
+
+/**@brief Open file instance descriptor.*/
+struct lwext4_files {
+ char name[255];
+ ext4_file fd;
+};
+
+/**@brief Open directory instance descriptor.*/
+struct lwext4_dirs {
+ char name[255];
+ ext4_dir fd;
+};
+
+/**@brief Library call opcode.*/
+struct lwext4_op_codes {
+ char *func;
+};
+
+/**@brief Library call wraper.*/
+struct lwext4_call {
+ int (*lwext4_call)(char *p);
+};
+
+/**@brief */
+static struct lwext4_files file_tab[MAX_FILES];
+
+/**@brief */
+static struct lwext4_dirs dir_tab[MAX_DIRS];
+
+/**@brief */
+static struct lwext4_op_codes op_codes[] = {
+ "device_register",
+ "mount",
+ "umount",
+ "mount_point_stats",
+ "cache_write_back",
+ "fremove",
+ "fopen",
+ "fclose",
+ "fread",
+ "fwrite",
+ "fseek",
+ "ftell",
+ "fsize",
+ "dir_rm",
+ "dir_mk",
+ "dir_open",
+ "dir_close",
+ "dir_entry_get",
+
+ "multi_fcreate",
+ "multi_fwrite",
+ "multi_fread",
+ "multi_fremove",
+ "multi_dcreate",
+ "multi_dremove",
+ "stats_save",
+ "stats_check",
+};
+
+int _device_register(char *p);
+int _mount(char *p);
+int _umount(char *p);
+int _mount_point_stats(char *p);
+int _cache_write_back(char *p);
+int _fremove(char *p);
+int _fopen(char *p);
+int _fclose(char *p);
+int _fread(char *p);
+int _fwrite(char *p);
+int _fseek(char *p);
+int _ftell(char *p);
+int _fsize(char *p);
+int _dir_rm(char *p);
+int _dir_mk(char *p);
+int _dir_open(char *p);
+int _dir_close(char *p);
+int _dir_close(char *p);
+int _dir_entry_get(char *p);
+
+int _multi_fcreate(char *p);
+int _multi_fwrite(char *p);
+int _multi_fread(char *p);
+int _multi_fremove(char *p);
+int _multi_dcreate(char *p);
+int _multi_dremove(char *p);
+int _stats_save(char *p);
+int _stats_check(char *p);
+
+/**@brief */
+static struct lwext4_call op_call[] = {
+ _device_register, /*PARAMS(3): 0 cache_mode dev_name */
+ _mount, /*PARAMS(2): dev_name mount_point */
+ _umount, /*PARAMS(1): mount_point */
+ _mount_point_stats,/*PARAMS(2): mount_point, 0 */
+ _cache_write_back, /*PARAMS(2): mount_point, en */
+ _fremove, /*PARAMS(1): path */
+ _fopen, /*PARAMS(2): fid path flags */
+ _fclose, /*PARAMS(1): fid */
+ _fread, /*PARAMS(4): fid 0 len 0 */
+ _fwrite, /*PARAMS(4): fid 0 len 0 */
+ _fseek, /*PARAMS(2): fid off origin */
+ _ftell, /*PARAMS(2): fid exp */
+ _fsize, /*PARAMS(2): fid exp */
+ _dir_rm, /*PARAMS(1): path */
+ _dir_mk, /*PARAMS(1): path */
+ _dir_open, /*PARAMS(2): did, path */
+ _dir_close, /*PARAMS(1): did */
+ _dir_entry_get, /*PARAMS(2): did, exp */
+
+ _multi_fcreate, /*PARAMS(3): path prefix cnt */
+ _multi_fwrite, /*PARAMS(4): path prefix cnt size */
+ _multi_fread, /*PARAMS(4): path prefix cnt size */
+ _multi_fremove, /*PARAMS(2): path prefix cnt */
+ _multi_dcreate, /*PARAMS(3): path prefix cnt */
+ _multi_dremove, /*PARAMS(2): path prefix */
+ _stats_save, /*PARAMS(1): path */
+ _stats_check, /*PARAMS(1): path */
+};
+
+static clock_t get_ms(void)
+{
+ struct timeval t;
+ gettimeofday(&t, NULL);
+ return (t.tv_sec * 1000) + (t.tv_usec / 1000);
+}
+
+/**@brief */
+static int exec_op_code(char *opcode)
+{
+ int i;
+ int r = -1;
+
+ for (i = 0; i < sizeof(op_codes) / sizeof(op_codes[0]); ++i) {
+
+ if(strncmp(op_codes[i].func, opcode, strlen(op_codes[i].func)))
+ continue;
+
+ if(opcode[strlen(op_codes[i].func)] != ' ')
+ continue;
+
+ printf("%s\n", opcode);
+ opcode += strlen(op_codes[i].func);
+ /*Call*/
+
+ clock_t t = get_ms();
+ r = op_call[i].lwext4_call(opcode);
+
+ printf("rc: %d, time: %ums\n", r, get_ms() - t);
+
+ break;
+ }
+
+ return r;
+}
+
+
+static int server_open(void)
+{
+ int fd = 0;
+ struct sockaddr_in serv_addr;
+
+ memset(&serv_addr, 0, sizeof(serv_addr));
+
+ if(winsock_init() < 0) {
+ printf("winsock_init() error\n");
+ exit(-1);
+ }
+
+ fd = socket(AF_INET, SOCK_STREAM, 0);
+ if(fd < 0) {
+ printf("socket() error: %s\n", strerror(errno));
+ exit(-1);
+ }
+
+ serv_addr.sin_family = AF_INET;
+ serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
+ serv_addr.sin_port = htons(connection_port);
+
+ if(bind(fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr))){
+ printf("bind() error: %s\n", strerror(errno));
+ exit(-1);
+ }
+
+ if(listen(fd, 1)){
+ printf("listen() error: %s\n", strerror(errno));
+ exit(-1);
+ }
+
+ return fd;
+}
+
+static bool parse_opt(int argc, char **argv)
+{
+ int option_index = 0;
+ int c;
+
+ static struct option long_options[] = {
+ {"image", required_argument, 0, 'i'},
+ {"port", required_argument, 0, 'p'},
+ {"verbose", required_argument, 0, 'v'},
+ {0, 0, 0, 0}
+ };
+
+ while(-1 != (c = getopt_long (argc, argv, "i:p:v:", long_options, &option_index))) {
+
+ switch(c){
+ case 'i':
+ ext4_fname = optarg;
+ break;
+ case 'p':
+ connection_port = atoi(optarg);
+ break;
+ case 'v':
+ verbose = atoi(optarg);
+ break;
+ default:
+ printf("%s", usage);
+ return false;
+
+ }
+ }
+ return true;
+}
+
+int main(int argc, char *argv[])
+{
+ int n;
+ int listenfd;
+ int connfd;
+ char op_code[128];
+
+ if(!parse_opt(argc, argv))
+ return -1;
+
+ ext4_filedev_filename(ext4_fname);
+ listenfd = server_open();
+
+ printf("lwext4_server: listening on port: %d\n", connection_port);
+
+ memset(write_buffer, RW_BUFFER_PATERN, MAX_RW_BUFFER);
+ while(1)
+ {
+ connfd = accept(listenfd, (struct sockaddr*)NULL, NULL);
+
+ n = recv(connfd, op_code, sizeof(op_code), 0);
+
+ if(n < 0) {
+ printf("recv() error: %s fd = %d\n", strerror(errno), connfd);
+ break;
+ }
+
+ op_code[n] = 0;
+
+ int r = exec_op_code(op_code);
+
+ n = send(connfd, (void *)&r, sizeof(r), 0);
+ if(n < 0) {
+ printf("send() error: %s fd = %d\n", strerror(errno), connfd);
+ break;
+ }
+
+ close(connfd);
+ }
+
+ closesocket(listenfd);
+ winsock_fini();
+ return 0;
+}
+
+
+int _device_register(char *p)
+{
+ int bd;
+ int cache_mode;
+ char dev_name[32];
+
+ if(sscanf(p, "%d %d %s", &bd, &cache_mode, dev_name) != 3){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_device_register(ext4_filedev_get(), 0, dev_name);
+}
+
+int _mount(char *p)
+{
+ char dev_name[32];
+ char mount_point[32];
+ int rc;
+
+ if(sscanf(p, "%s %s", dev_name, mount_point) != 2){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_mount(dev_name, mount_point);
+}
+
+int _umount(char *p)
+{
+ char mount_point[32];
+
+ if(sscanf(p, "%s", mount_point) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_umount(mount_point);
+}
+
+int _mount_point_stats(char *p)
+{
+ char mount_point[32];
+ int d;
+ int rc;
+ struct ext4_mount_stats stats;
+
+ if(sscanf(p, "%s %d", mount_point, &d) != 2){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ rc = ext4_mount_point_stats(mount_point, &stats);
+
+ if(rc != EOK)
+ return;
+
+ if(verbose){
+ printf("\tinodes_count = %d\n", stats.inodes_count);
+ printf("\tfree_inodes_count = %d\n", stats.free_inodes_count);
+ printf("\tblocks_count = %llu\n", stats.blocks_count);
+ printf("\tfree_blocks_count = %llu\n", stats.free_blocks_count);
+
+ printf("\tblock_size = %d\n", stats.block_size);
+ printf("\tblock_group_count = %d\n", stats.block_group_count);
+ printf("\tblocks_per_group = %d\n", stats.blocks_per_group);
+ printf("\tinodes_per_group = %d\n", stats.inodes_per_group);
+
+ printf("\tvolume_name = %s\n", stats.volume_name);
+ }
+
+ return rc;
+}
+
+int _cache_write_back(char *p)
+{
+ char mount_point[32];
+ int en;
+
+ if(sscanf(p, "%s %d", mount_point, &en) != 2){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_cache_write_back(mount_point, en);
+}
+
+
+int _fremove(char *p)
+{
+ char path[255];
+
+ if(sscanf(p, "%s", path) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_fremove(path);
+}
+
+int _fopen(char *p)
+{
+ int fid = MAX_FILES;
+ char path[256];
+ char flags[8];
+ int rc;
+
+ if(sscanf(p, "%d %s %s", &fid, path, flags) != 3){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(fid < MAX_FILES)){
+ printf("File id too big\n");
+ return -1;
+ }
+
+ rc = ext4_fopen(&file_tab[fid].fd, path, flags);
+
+ if(rc == EOK)
+ strcpy(file_tab[fid].name, path);
+
+ return rc;
+}
+
+int _fclose(char *p)
+{
+ int fid = MAX_FILES;
+ int rc;
+
+ if(sscanf(p, "%d", &fid) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(fid < MAX_FILES)){
+ printf("File id too big\n");
+ return -1;
+ }
+
+ if(file_tab[fid].name[0] == 0){
+ printf("File id empty\n");
+ return -1;
+ }
+
+ rc = ext4_fclose(&file_tab[fid].fd);
+
+ if(rc == EOK)
+ file_tab[fid].name[0] = 0;
+
+ return rc;
+}
+
+int _fread(char *p)
+{
+ int fid = MAX_FILES;
+ int len;
+ int d;
+ int rc;
+ int rb;
+
+ if(sscanf(p, "%d %d %d %d", &fid, &d, &len, &d) != 4){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(fid < MAX_FILES)){
+ printf("File id too big\n");
+ return -1;
+ }
+
+ if(file_tab[fid].name[0] == 0){
+ printf("File id empty\n");
+ return -1;
+ }
+
+ while(len){
+ d = len > MAX_RW_BUFFER ? MAX_RW_BUFFER : len;
+
+ memset(read_buffer, 0, MAX_RW_BUFFER);
+ rc = ext4_fread(&file_tab[fid].fd, read_buffer, d, &rb);
+
+ if(rc != EOK)
+ break;
+
+ if(rb != d){
+ printf("Read count error\n");
+ return -1;
+ }
+
+ if(memcmp(read_buffer, write_buffer, d)){
+ printf("Read compare error\n");
+ return -1;
+ }
+
+ len -= d;
+ }
+
+ return rc;
+}
+
+int _fwrite(char *p)
+{
+ int fid = MAX_FILES;
+ int len;
+ int d;
+ int rc;
+ int wb;
+
+ if(sscanf(p, "%d %d %d %d", &fid, &d, &len, &d) != 4){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(fid < MAX_FILES)){
+ printf("File id too big\n");
+ return -1;
+ }
+
+ if(file_tab[fid].name[0] == 0){
+ printf("File id empty\n");
+ return -1;
+ }
+
+ while(len){
+ d = len > MAX_RW_BUFFER ? MAX_RW_BUFFER : len;
+ rc = ext4_fwrite(&file_tab[fid].fd, write_buffer, d, &wb);
+
+ if(rc != EOK)
+ break;
+
+ if(wb != d){
+ printf("Write count error\n");
+ return -1;
+ }
+
+ len -= d;
+ }
+
+ return rc;
+}
+
+int _fseek(char *p)
+{
+ int fid = MAX_FILES;
+ int off;
+ int origin;
+
+ if(sscanf(p, "%d %d %d", &fid, &off, &origin) != 3){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(fid < MAX_FILES)){
+ printf("File id too big\n");
+ return -1;
+ }
+
+ if(file_tab[fid].name[0] == 0){
+ printf("File id empty\n");
+ return -1;
+ }
+
+ return ext4_fseek(&file_tab[fid].fd, off, origin);
+}
+
+int _ftell(char *p)
+{
+ int fid = MAX_FILES;
+ uint32_t exp_pos;
+
+ if(sscanf(p, "%d %u", &fid, &exp_pos) != 2){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(fid < MAX_FILES)){
+ printf("File id too big\n");
+ return -1;
+ }
+
+ if(file_tab[fid].name[0] == 0){
+ printf("File id empty\n");
+ return -1;
+ }
+
+
+ if(exp_pos != ext4_ftell(&file_tab[fid].fd)){
+ printf("Expected filepos error\n");
+ return -1;
+ }
+
+ return EOK;
+}
+
+int _fsize(char *p)
+{
+ int fid = MAX_FILES;
+ uint32_t exp_size;
+
+ if(sscanf(p, "%d %u", &fid, &exp_size) != 2){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(fid < MAX_FILES)){
+ printf("File id too big\n");
+ return -1;
+ }
+
+ if(file_tab[fid].name[0] == 0){
+ printf("File id empty\n");
+ return -1;
+ }
+
+ if(exp_size != ext4_fsize(&file_tab[fid].fd)){
+ printf("Expected filesize error\n");
+ return -1;
+ }
+
+ return EOK;
+}
+
+int _dir_rm(char *p)
+{
+ char path[255];
+
+ if(sscanf(p, "%s", path) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_dir_rm(path);
+}
+
+int _dir_mk(char *p)
+{
+ char path[255];
+
+ if(sscanf(p, "%s", path) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_dir_mk(path);
+}
+
+int _dir_open(char *p)
+{
+ int did = MAX_DIRS;
+ char path[255];
+ int rc;
+
+ if(sscanf(p, "%d %s", &did, path) != 2){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(did < MAX_DIRS)){
+ printf("Dir id too big\n");
+ return -1;
+ }
+
+ rc = ext4_dir_open(&dir_tab[did].fd, path);
+
+ if(rc == EOK)
+ strcpy(dir_tab[did].name, path);
+
+ return rc;
+}
+
+int _dir_close(char *p)
+{
+ int did = MAX_DIRS;
+ int rc;
+
+ if(sscanf(p, "%d", &did) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(did < MAX_DIRS)){
+ printf("Dir id too big\n");
+ return -1;
+ }
+
+ if(dir_tab[did].name[0] == 0){
+ printf("Dir id empty\n");
+ return -1;
+ }
+
+ rc = ext4_dir_close(&dir_tab[did].fd);
+
+ if(rc == EOK)
+ dir_tab[did].name[0] = 0;
+
+ return rc;
+}
+
+int _dir_entry_get(char *p)
+{
+ int did = MAX_DIRS;
+ int exp;
+ char name[256];
+
+ if(sscanf(p, "%d %d", &did, &exp) != 2){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ if(!(did < MAX_DIRS)){
+ printf("Dir id too big\n");
+ return -1;
+ }
+
+ if(dir_tab[did].name[0] == 0){
+ printf("Dir id empty\n");
+ return -1;
+ }
+
+
+ int idx = 0;
+ ext4_direntry *d;
+
+ while(d = ext4_dir_entry_get(&dir_tab[did].fd, idx++)){
+
+ memcpy(name, d->name, d->name_length);
+ name[d->name_length] = 0;
+ if(verbose){
+ printf("\t%s %s\n", entry_to_str(d->inode_type), name);
+ }
+ }
+
+ idx--;
+
+ if(idx < 2){
+ printf("Minumum dir entry error\n");
+ return -1;
+ }
+
+ if((idx - 2) != exp){
+ printf("Expected dir entry error\n");
+ return -1;
+ }
+
+ return EOK;
+}
+
+int _multi_fcreate(char *p)
+{
+ char path[256];
+ char path1[256];
+ char prefix[32];
+ int cnt;
+ int rc;
+ int i;
+ ext4_file fd;
+
+ if(sscanf(p, "%s %s %d", &path, prefix, &cnt) != 3){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ for (i = 0; i < cnt; ++i) {
+ sprintf(path1, "%s%s%d", path, prefix, i);
+ rc = ext4_fopen(&fd, path1, "wb+");
+
+ if(rc != EOK)
+ break;
+ }
+
+ return rc;
+}
+
+int _multi_fwrite(char *p)
+{
+ char path[256];
+ char path1[256];
+ char prefix[32];
+ int cnt;
+ int len, ll;
+ int rc;
+ int i, d, wb;
+ ext4_file fd;
+
+ if(sscanf(p, "%s %s %d %d", &path, prefix, &cnt, &ll) != 4){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ for (i = 0; i < cnt; ++i) {
+ sprintf(path1, "%s%s%d", path, prefix, i);
+ rc = ext4_fopen(&fd, path1, "rb+");
+
+ if(rc != EOK)
+ break;
+
+ len = ll;
+ while(len){
+ d = len > MAX_RW_BUFFER ? MAX_RW_BUFFER : len;
+ rc = ext4_fwrite(&fd, write_buffer, d, &wb);
+
+ if(rc != EOK)
+ break;
+
+ if(wb != d){
+ printf("Write count error\n");
+ return -1;
+ }
+
+ len -= d;
+ }
+ }
+
+ return rc;
+}
+
+int _multi_fread(char *p)
+{
+ char path[256];
+ char path1[256];
+ char prefix[32];
+ int cnt;
+ int len, ll;
+ int rc;
+ int i, d, rb;
+ ext4_file fd;
+
+ if(sscanf(p, "%s %s %d %d", &path, prefix, &cnt, &ll) != 4){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ for (i = 0; i < cnt; ++i) {
+ sprintf(path1, "%s%s%d", path, prefix, i);
+ rc = ext4_fopen(&fd, path1, "rb+");
+
+ if(rc != EOK)
+ break;
+
+ len = ll;
+ while(len){
+ d = len > MAX_RW_BUFFER ? MAX_RW_BUFFER : len;
+
+ memset(read_buffer, 0, MAX_RW_BUFFER);
+ rc = ext4_fread(&fd, read_buffer, d, &rb);
+
+ if(rc != EOK)
+ break;
+
+ if(rb != d){
+ printf("Read count error\n");
+ return -1;
+ }
+
+ if(memcmp(read_buffer, write_buffer, d)){
+ printf("Read compare error\n");
+ return -1;
+ }
+
+ len -= d;
+ }
+ }
+
+ return rc;
+}
+
+int _multi_fremove(char *p)
+{
+ char path[256];
+ char path1[256];
+ char prefix[32];
+ int cnt, i, rc;
+
+ if(sscanf(p, "%s %s %d", &path, prefix, &cnt) != 3){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ for (i = 0; i < cnt; ++i) {
+ sprintf(path1, "%s%s%d", path, prefix, i);
+ rc = ext4_fremove(path1);
+ if(rc != EOK)
+ break;
+ }
+
+ return rc;
+}
+
+int _multi_dcreate(char *p)
+{
+ char path[256];
+ char path1[256];
+ char prefix[32];
+ int cnt, i, rc;
+
+ if(sscanf(p, "%s %s %d", &path, prefix, &cnt) != 3){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ for (i = 0; i < cnt; ++i) {
+ sprintf(path1, "%s%s%d", path, prefix, i);
+ rc = ext4_dir_mk(path1);
+ if(rc != EOK)
+ break;
+ }
+
+ return rc;
+}
+
+int _multi_dremove(char *p)
+{
+ char path[256];
+ char path1[256];
+ char prefix[32];
+ int cnt, i, rc;
+
+ if(sscanf(p, "%s %s %d", &path, prefix, &cnt) != 3){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ for (i = 0; i < cnt; ++i) {
+ sprintf(path1, "%s%s%d", path, prefix, i);
+ rc = ext4_dir_rm(path1);
+ if(rc != EOK)
+ break;
+ }
+
+ return rc;
+}
+
+struct ext4_mount_stats saved_stats;
+
+int _stats_save(char *p)
+{
+ char path[256];
+
+ if(sscanf(p, "%s", &path) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ return ext4_mount_point_stats(path, &saved_stats);
+}
+
+int _stats_check(char *p)
+{
+ char path[256];
+ int rc;
+
+ struct ext4_mount_stats actual_stats;
+
+ if(sscanf(p, "%s", &path) != 1){
+ printf("Param list error\n");
+ return -1;
+ }
+
+ rc = ext4_mount_point_stats(path, &actual_stats);
+
+ if(rc != EOK)
+ return rc;
+
+ if(memcmp(&saved_stats, &actual_stats, sizeof(struct ext4_mount_stats))){
+ if(verbose){
+ printf("\tMount point stats error:\n");
+ printf("\tsaved_stats:\n");
+ printf("\tinodes_count = %d\n", saved_stats.inodes_count);
+ printf("\tfree_inodes_count = %d\n", saved_stats.free_inodes_count);
+ printf("\tblocks_count = %llu\n", saved_stats.blocks_count);
+ printf("\tfree_blocks_count = %llu\n", saved_stats.free_blocks_count);
+ printf("\tblock_size = %d\n", saved_stats.block_size);
+ printf("\tblock_group_count = %d\n", saved_stats.block_group_count);
+ printf("\tblocks_per_group = %d\n", saved_stats.blocks_per_group);
+ printf("\tinodes_per_group = %d\n", saved_stats.inodes_per_group);
+ printf("\tvolume_name = %s\n", saved_stats.volume_name);
+ printf("\tactual_stats:\n");
+ printf("\tinodes_count = %d\n", actual_stats.inodes_count);
+ printf("\tfree_inodes_count = %d\n", actual_stats.free_inodes_count);
+ printf("\tblocks_count = %llu\n", actual_stats.blocks_count);
+ printf("\tfree_blocks_count = %llu\n", actual_stats.free_blocks_count);
+ printf("\tblock_size = %d\n", actual_stats.block_size);
+ printf("\tblock_group_count = %d\n", actual_stats.block_group_count);
+ printf("\tblocks_per_group = %d\n", actual_stats.blocks_per_group);
+ printf("\tinodes_per_group = %d\n", actual_stats.inodes_per_group);
+ printf("\tvolume_name = %s\n", actual_stats.volume_name);
+ }
+ return -1;
+ }
+
+
+ return rc;
+}
+
+
+static char* entry_to_str(uint8_t type)
+{
+ switch(type){
+ case EXT4_DIRENTRY_UNKNOWN:
+ return "[UNK] ";
+ case EXT4_DIRENTRY_REG_FILE:
+ return "[FIL] ";
+ case EXT4_DIRENTRY_DIR:
+ return "[DIR] ";
+ case EXT4_DIRENTRY_CHRDEV:
+ return "[CHA] ";
+ case EXT4_DIRENTRY_BLKDEV:
+ return "[BLK] ";
+ case EXT4_DIRENTRY_FIFO:
+ return "[FIF] ";
+ case EXT4_DIRENTRY_SOCK:
+ return "[SOC] ";
+ case EXT4_DIRENTRY_SYMLINK:
+ return "[SYM] ";
+ default:
+ break;
+ }
+ return "[???]";
+}
+
+static int winsock_init(void)
+{
+#if WIN32
+ int rc;
+ static WSADATA wsaData;
+ rc = WSAStartup(MAKEWORD(2,2), &wsaData);
+ if (rc != 0) {
+ return -1;
+ }
+#endif
+ return 0;
+}
+
+static void winsock_fini(void)
+{
+#if WIN32
+ WSACleanup();
+#endif
+}
+
|