[BACK]Return to test.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitsched / example

Diff for /libaitsched/example/test.c between versions 1.6.8.5 and 1.6.8.6

version 1.6.8.5, 2012/08/02 11:37:08 version 1.6.8.6, 2012/08/02 12:08:44
Line 11 Line 11
 #include <aitsched.h>  #include <aitsched.h>
   
 intptr_t Kill;  intptr_t Kill;
struct iovec iv[3];struct iovec iv[3], wiv[3], riv[3];
   
 void *event(sched_task_t *arg)  void *event(sched_task_t *arg)
 {  {
Line 90  void *aiobulkread(sched_task_t *arg) Line 90  void *aiobulkread(sched_task_t *arg)
   
         printf("aioBULKread::\n");          printf("aioBULKread::\n");
         for (i = 0; i < 3; i++) {          for (i = 0; i < 3; i++) {
                printf("%d) [%d]=%s\n---\n", i, iv[i].iov_len, (char*) iv[i].iov_base);                printf("%d) rlen[%d]=%s\n---\n", i, iv[i].iov_len, (char*) iv[i].iov_base);
                 free(iv[i].iov_base);                  free(iv[i].iov_base);
         }          }
   
Line 104  void *aiobulkwrite(sched_task_t *arg) Line 104  void *aiobulkwrite(sched_task_t *arg)
   
         printf("aioBULKwrite::\n");          printf("aioBULKwrite::\n");
         for (i = 0; i < 3; i++) {          for (i = 0; i < 3; i++) {
                printf("%d) %d\n", i, iv[i].iov_len);                printf("%d) wlen=%d\n", i, iv[i].iov_len);
                 free(iv[i].iov_base);                  free(iv[i].iov_base);
         }          }
   
Line 197  main(int argc, char **argv) Line 197  main(int argc, char **argv)
                 printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());                  printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());
   
   
         lseek(fd, 0, SEEK_SET);  
         iv[0].iov_len = 5;          iv[0].iov_len = 5;
         iv[1].iov_len = 2;          iv[1].iov_len = 2;
         iv[2].iov_len = 50;          iv[2].iov_len = 50;
         for (i = 0; i < 3; i++)          for (i = 0; i < 3; i++)
                 iv[i].iov_base = malloc(iv[i].iov_len);                  iv[i].iov_base = malloc(iv[i].iov_len);
        if (!schedLIORead(root, aiobulkread, NULL, fd, iv, 3))        if (!schedLIORead(root, aiobulkread, NULL, fd, iv, 3, 0))
                 printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());                  printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());
        fsync(fd);
         for (i = 0; i < 3; i++) {          for (i = 0; i < 3; i++) {
                iv[i].iov_len = 100;                wiv[i].iov_len = 100;
                iv[i].iov_base = malloc(iv[i].iov_len);                wiv[i].iov_base = malloc(iv[i].iov_len);
         }          }
        strlcpy(iv[0].iov_base, "aaa\n", iv[0].iov_len);        strlcpy(wiv[0].iov_base, "aaa0000000000000000000134234234242424\n", wiv[0].iov_len);
        strlcpy(iv[1].iov_base, "bbbbb\n", iv[1].iov_len);        wiv[0].iov_len = strlen(wiv[0].iov_base) + 1;
        strlcpy(iv[2].iov_base, "zzz\n", iv[2].iov_len);        strlcpy(wiv[1].iov_base, "bbbbbbbbbbbbbbbbbbbbb\n", wiv[1].iov_len);
        if (!schedLIOWrite(root, aiobulkwrite, NULL, fd, iv, 3))        wiv[1].iov_len = strlen(wiv[1].iov_base) + 1;
         strlcpy(wiv[2].iov_base, "zzz\n", wiv[2].iov_len);
         wiv[2].iov_len = strlen(wiv[2].iov_base) + 1;
         if (!schedLIOWrite(root, aiobulkwrite, NULL, fd, wiv, 3, 0))
                 printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());                  printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());
   
         lseek(fd, 0, SEEK_SET);  
         for (i = 0; i < 3; i++) {          for (i = 0; i < 3; i++) {
                iv[i].iov_len = 4;                riv[i].iov_len = 5;
                iv[i].iov_base = malloc(iv[i].iov_len);                riv[i].iov_base = malloc(riv[i].iov_len + 1);
                 memset(riv[i].iov_base, 0, riv[i].iov_len + 1);
         }          }
        if (!schedLIORead(root, aiobulkread, NULL, fd, iv, 3))        if (!schedLIORead(root, aiobulkread, NULL, fd, riv, 3, 0))
                 printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());                  printf("Warning:: #%d - %s\n", sched_GetErrno(), sched_GetError());
   
         schedCallOnce(root, once, "000000", 42, NULL, 0);          schedCallOnce(root, once, "000000", 42, NULL, 0);
Removed from v.1.6.8.5  
changed lines
  Added in v.1.6.8.6

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>