Lines Matching refs:res_len

661                   char **res, unsigned int *res_len, int *flags)  in command_recv_http()  argument
688 *res_len = e - *res; in command_recv_http()
690 fprintf(stderr, "body: <%.*s>\n", *res_len, *res); in command_recv_http()
697 *res_len = 0; in command_recv_http()
708 char **res, unsigned int *res_len, int *flags) in command_recv_ctx() argument
710 grn_ctx_recv(ctx, res, res_len, flags); in command_recv_ctx()
719 char **res, unsigned int *res_len, int *flags) in command_recv() argument
722 command_recv_http(ctx, type, task_id, res, res_len, flags); in command_recv()
724 command_recv_ctx(ctx, type, task_id, res, res_len, flags); in command_recv()
733 unsigned int res_len; in shutdown_server() local
747 &res, &res_len, &flags); in shutdown_server()
757 unsigned int res_len; in do_load_command() local
771 command_recv(ctx, type, task_id, &res, &res_len, &flags); in do_load_command()
772 if (res_len) { in do_load_command()
789 if (res_len < BUF_LEN) { in do_load_command()
790 strncpy(tmpbuf, res, res_len); in do_load_command()
791 tmpbuf[res_len] = '\0'; in do_load_command()
799 fwrite(res, 1, res_len, grntest_job[grntest_task[task_id].job_id].outputlog); in do_load_command()
819 res, res_len)) { in do_load_command()
822 fwrite(res, 1, res_len, output); in do_load_command()
848 unsigned int res_len; in do_command() local
857 command_recv(ctx, type, task_id, &res, &res_len, &flags); in do_command()
858 if (res_len) { in do_command()
875 if (res_len < BUF_LEN) { in do_command()
876 strncpy(tmpbuf, res, res_len); in do_command()
877 tmpbuf[res_len] = '\0'; in do_command()
885 fwrite(res, 1, res_len, grntest_job[grntest_task[task_id].job_id].outputlog); in do_command()
905 res, res_len)) { in do_command()
908 fwrite(res, 1, res_len, output); in do_command()