Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commitfefe8b1

Browse files
committed
[refer #PGPRO-1745] Make remote mkdir operation synchronous
1 parent3ff6a37 commitfefe8b1

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

‎src/utils/file.c‎

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -697,7 +697,10 @@ int fio_mkdir(char const* path, int mode, fio_location location)
697697
IO_CHECK(fio_write_all(fio_stdout,&hdr,sizeof(hdr)),sizeof(hdr));
698698
IO_CHECK(fio_write_all(fio_stdout,path,path_len),path_len);
699699

700-
return0;
700+
IO_CHECK(fio_read_all(fio_stdin,&hdr,sizeof(hdr)),sizeof(hdr));
701+
Assert(hdr.cop==FIO_MKDIR);
702+
703+
returnhdr.arg;
701704
}
702705
else
703706
{
@@ -1297,7 +1300,9 @@ void fio_communicate(int in, int out)
12971300
SYS_CHECK(remove(buf));
12981301
break;
12991302
caseFIO_MKDIR:/* Create direcory */
1300-
SYS_CHECK(dir_create_dir(buf,hdr.arg));
1303+
hdr.size=0;
1304+
hdr.arg=dir_create_dir(buf,hdr.arg);
1305+
IO_CHECK(fio_write_all(out,&hdr,sizeof(hdr)),sizeof(hdr));
13011306
break;
13021307
caseFIO_CHMOD:/* Change file mode */
13031308
SYS_CHECK(chmod(buf,hdr.arg));

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp