1

たとえば、非同期関数00000....を使用したいなど、ファイルに同じ番号を入力する必要があります。aio_writeしかし、ここで私が得るもの

^@ w▒(▒▒▒▒▒l▒@^@Y▒^@^@^@^@▒▒▒▒u▒l▒@*`▒^@ w▒h▒▒▒ ......

これが私のコードです

int main(int argc, char *argv[] ){
    int sk;
    int d;
    struct aiocb aior;
    if(argc == 3){
            sk = atoi(argv[2]);
            char buffer[MB * MB * sk];
            memset(&aior, 0, sizeof( struct aiocb ));
            d = da_open(argv[1]);
            da_aio_write( d, &aior, buffer, sizeof(buffer) );
            da_test_wait( &aior );
            da_close( d );
    }
    return 0;
}

そして、これが私の非同期書き込み関数です（この関数は悪いと思います）

int da_aio_write(const int d, struct aiocb *aiorp, void *buf, const int count){
   int rv = 0;
   memset( (void *)aiorp, 0, sizeof( struct aiocb ) );
   aiorp->aio_fildes = d;
   aiorp->aio_buf = buf;
   aiorp->aio_nbytes = count;
   aiorp->aio_offset = 0;

   rv = aio_write( aiorp );

   if( rv == -1) {
       perror("Error da_aio_write\n");
       exit(1);
       return rv;
   }
   return rv;
}

また、ここでは asyncronius 関数が終了するのを待ちます

int da_test_wait( struct aiocb *aiorp ){
   const struct aiocb *aioptr[1];
   int rv;
   aioptr[0] = aiorp;
   rv = aio_suspend( aioptr, 1, NULL );
   if( rv != 0 ){
      perror( "aio_suspend failed" );
      abort();
   }
   rv = aio_return( aiorp );
   printf( "AIO complete, %d bytes write.\n", rv );
   return 1;
}

また、ここに私の完全なプログラムがあります

#include <stdio.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/time.h>
#include <string.h>
#include <aio.h>
 #include <errno.h>

#define MB 1024

int da_open(const char *name);
int da_aio_write(const int d, struct aiocb *aiorp, void *buf, const int count);
int da_test_wait( struct aiocb *aiorp );
int da_close(int fd);

int da_open(const char *name){
   int dskr;
   int dskr2;
   dskr = open( name, O_RDWR );
   if( dskr == -1 ){
       printf("File created\n");
       dskr2 = open( name, O_WRONLY | O_CREAT, 0644);
   }else{
       printf("End job!\n");
       exit(1);
   }
   printf( "dskr1 = %d\n", dskr2 );
   return dskr2;
}

int da_aio_write(const int d, struct aiocb *aiorp, void *buf, const int count){
   int rv = 0;
   memset( (void *)aiorp, 0, sizeof( struct aiocb ) );
   aiorp->aio_fildes = d;
   aiorp->aio_buf = buf;
   aiorp->aio_nbytes = count;
   aiorp->aio_offset = 0;

   rv = aio_write( aiorp );

   if( rv == -1) {
       perror("Error da_aio_write\n");
       exit(1);
       return rv;
   }
   return rv;
}

int da_test_wait( struct aiocb *aiorp ){
   const struct aiocb *aioptr[1];
   int rv;
   aioptr[0] = aiorp;
   rv = aio_suspend( aioptr, 1, NULL );
   if( rv != 0 ){
      perror( "aio_suspend failed" );
      abort();
   }
   rv = aio_return( aiorp );
   printf( "AIO complete, %d bytes write.\n", rv );
   return 1;
}

int da_close(int fd){
   int rv;
   rv = close( fd );
   if( rv != 0 ) perror ( "close() failed" );
   else puts( "closed" );
   return rv;
}

int main(int argc, char *argv[] ){
        int sk;
        int d;
        struct aiocb aior;
        if(argc == 3){
                sk = atoi(argv[2]);
                char buffer[MB * MB * sk];
                memset(&aior, 0, sizeof( struct aiocb ));
                d = da_open(argv[1]);
                da_aio_write( d, &aior, buffer, sizeof(buffer) );
                da_test_wait( &aior );
                da_close( d );
        }
        return 0;
}
4

1 に答える 1

1 
#include <stdio.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/time.h>
#include <string.h>
#include <aio.h>

int da_open(const char *name);
int da_aio_read(const int d, struct aiocb *aiorp, void *buf, const int count);

int da_open(const char *name){
   int dskr;
   int dskr2;
   dskr = open( name, O_RDWR );
   if( dskr == -1 ){
       dskr2 = open( name, O_WRONLY | O_CREAT, 0644);
   }else{
       exit(1);
   }
   return dskr2;
}

ここで何が起こっているのですか？これは、ファイルが既に存在する場合にファイルに書き込まないようにするための難読化された方法ですか? 2 回目のオープンの前にファイルが表示された可能性があるため、これは明らかに正しくありません。代わりに O_EXCL を使用できます。

exit を先に処理しないことで、コードはさらに難読化されます。

int da_aio_read(const int d, struct aiocb *aiorp, void *buf, const int count){
    int rv = 0;
    memset( (void *)aiorp, 0, sizeof( struct aiocb ) );
    //memset(buf, 0, sizeof( buf) );
    aiorp->aio_fildes = d;
    aiorp->aio_buf = buf;
    aiorp->aio_nbytes = count;
    aiorp->aio_offset = 0;
    rv = aio_write( aiorp );
    return rv;
}

まず、fsckは何ですか。なぜ書き込み関数 something_readを呼び出しているのですか?

rvの用途は何ですか？

aio に関するドキュメントを読むと、イベントの完了を明示的に待つ必要があることがわかります。

int main(int argc, char *argv[] ){
    int sk;
    int d;
    struct aiocb aior;
    char buffer[100];
    memset(buffer, 0, sizeof buffer);
    if(argc == 3){
        sk = atoi(argv[2]);
        d = da_open(argv[1]);
        da_aio_read( d, &aior, buffer, sizeof(buffer) );
    }
    return 0;
}
于 2015-05-04T18:47:16.747 に答える