Lines Matching refs:ctx
3744 const struct thread_ctx* ctx; in thread_main() local
3748 ctx = (struct thread_ctx*)arg; in thread_main()
3749 size = ctx->size; in thread_main()
3750 data = ctx->data; in thread_main()
3755 nbytes = size < ctx->interval ? size : ctx->interval; in thread_main()
3756 if (ctx->doread) { in thread_main()
3757 result = write(ctx->fd, data, nbytes); in thread_main()
3761 result = read(ctx->fd, data, nbytes); in thread_main()
3768 pthread_kill(ctx->pid, SIGUSR1); in thread_main()
3793 struct thread_ctx ctx; in test_fs_partial() local
3807 ctx.pid = pthread_self(); in test_fs_partial()
3808 ctx.doread = doread; in test_fs_partial()
3809 ctx.interval = 1000; in test_fs_partial()
3810 ctx.size = sizeof(test_buf) * iovcount; in test_fs_partial()
3811 ctx.data = calloc(ctx.size, 1); in test_fs_partial()
3812 ASSERT_NOT_NULL(ctx.data); in test_fs_partial()
3813 buffer = calloc(ctx.size, 1); in test_fs_partial()
3826 ctx.fd = pipe_fds[doread]; in test_fs_partial()
3827 ASSERT_OK(uv_thread_create(&thread, thread_main, &ctx)); in test_fs_partial()
3834 while (nread < ctx.size) { in test_fs_partial()
3852 ASSERT_EQ(result, ctx.size); in test_fs_partial()
3858 ASSERT_MEM_EQ(buffer, ctx.data, ctx.size); in test_fs_partial()
3875 free(ctx.data); in test_fs_partial()