numbytes 304 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_sendto(int fd, char *buffer, ssize_t numbytes, numbytes 309 opal/mca/btl/usnic/btl_usnic_cagent.c rc = sendto(fd, buffer, numbytes, 0, addr, sizeof(*addr)); numbytes 312 opal/mca/btl/usnic/btl_usnic_cagent.c if (rc == numbytes) { numbytes 346 opal/mca/btl/usnic/btl_usnic_cagent.c ssize_t numbytes, struct sockaddr *from) numbytes 352 opal/mca/btl/usnic/btl_usnic_cagent.c if (msg->size != numbytes) { numbytes 358 opal/mca/btl/usnic/btl_usnic_cagent.c (int) numbytes, str, (int) msg->size); numbytes 405 opal/mca/btl/usnic/btl_usnic_cagent.c numbytes, msg_ipv4_addr_str); numbytes 422 opal/mca/btl/usnic/btl_usnic_cagent.c ssize_t numbytes, struct sockaddr *from) numbytes 431 opal/mca/btl/usnic/btl_usnic_cagent.c if (numbytes != sizeof(*msg)) { numbytes 434 opal/mca/btl/usnic/btl_usnic_cagent.c (int) numbytes, str, (int) sizeof(*msg)); numbytes 467 opal/mca/btl/usnic/btl_usnic_cagent.c (int) numbytes, str); numbytes 480 opal/mca/btl/usnic/btl_usnic_cagent.c ssize_t numbytes; numbytes 486 opal/mca/btl/usnic/btl_usnic_cagent.c numbytes = recvfrom(listener->fd, listener->buffer, listener->max_msg_size, 0, numbytes 488 opal/mca/btl/usnic/btl_usnic_cagent.c if (numbytes > 0) { numbytes 490 opal/mca/btl/usnic/btl_usnic_cagent.c } else if (numbytes < 0) { numbytes 505 opal/mca/btl/usnic/btl_usnic_cagent.c agent_thread_handle_ping(listener, numbytes, &src_addr); numbytes 508 opal/mca/btl/usnic/btl_usnic_cagent.c agent_thread_handle_ack(listener, numbytes, &src_addr); numbytes 515 opal/mca/btl/usnic/btl_usnic_cagent.c (int) numbytes, str); numbytes 491 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c output->numbytes = bo->size; numbytes 557 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c output->numbytes = bo->size; numbytes 660 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c output->numbytes = k; numbytes 693 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 694 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (num_written < output->numbytes) { numbytes 721 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (0 == output->numbytes) { numbytes 726 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 746 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c } else if (num_written < output->numbytes) { numbytes 748 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c memmove(output->data, &output->data[num_written], output->numbytes - num_written); numbytes 750 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c output->numbytes -= num_written; numbytes 853 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c int32_t numbytes; numbytes 869 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c numbytes = read(fd, data, sizeof(data)); numbytes 871 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c if (numbytes < 0) { numbytes 887 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c numbytes = 0; numbytes 947 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c bo.size = numbytes; numbytes 90 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.h int numbytes; numbytes 73 orte/mca/filem/raw/filem_raw.h int numbytes; numbytes 756 orte/mca/filem/raw/filem_raw_module.c int32_t numbytes; numbytes 767 orte/mca/filem/raw/filem_raw_module.c numbytes = read(fd, data, sizeof(data)); numbytes 769 orte/mca/filem/raw/filem_raw_module.c if (numbytes < 0) { numbytes 787 orte/mca/filem/raw/filem_raw_module.c numbytes = 0; numbytes 801 orte/mca/filem/raw/filem_raw_module.c rev->nchunk, numbytes, rev->file)); numbytes 815 orte/mca/filem/raw/filem_raw_module.c if (OPAL_SUCCESS != (rc = opal_dss.pack(&chunk, data, numbytes, OPAL_BYTE))) { numbytes 846 orte/mca/filem/raw/filem_raw_module.c if (0 == numbytes) { numbytes 1089 orte/mca/filem/raw/filem_raw_module.c output->numbytes = nbytes; numbytes 1128 orte/mca/filem/raw/filem_raw_module.c if (0 == output->numbytes) { numbytes 1194 orte/mca/filem/raw/filem_raw_module.c num_written = write(sink->fd, output->data, output->numbytes); numbytes 1223 orte/mca/filem/raw/filem_raw_module.c } else if (num_written < output->numbytes) { numbytes 1225 orte/mca/filem/raw/filem_raw_module.c memmove(output->data, &output->data[num_written], output->numbytes - num_written); numbytes 1329 orte/mca/filem/raw/filem_raw_module.c ptr->numbytes = 0; numbytes 143 orte/mca/iof/base/base.h int numbytes; numbytes 279 orte/mca/iof/base/base.h const unsigned char *data, int numbytes, numbytes 50 orte/mca/iof/base/iof_base_output.c const unsigned char *data, int numbytes, numbytes 61 orte/mca/iof/base/iof_base_output.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes, numbytes 72 orte/mca/iof/base/iof_base_output.c if (0 < numbytes) { numbytes 77 orte/mca/iof/base/iof_base_output.c memcpy(output->data, data, numbytes); numbytes 79 orte/mca/iof/base/iof_base_output.c output->numbytes = numbytes; numbytes 142 orte/mca/iof/base/iof_base_output.c if (0 < numbytes) { numbytes 147 orte/mca/iof/base/iof_base_output.c memcpy(output->data, data, numbytes); numbytes 149 orte/mca/iof/base/iof_base_output.c output->numbytes = numbytes; numbytes 163 orte/mca/iof/base/iof_base_output.c for (i=0; i < numbytes && k < ORTE_IOF_BASE_TAGGED_OUT_MAX; i++) { numbytes 211 orte/mca/iof/base/iof_base_output.c if (i < numbytes-1 && (k+starttaglen) < ORTE_IOF_BASE_TAGGED_OUT_MAX) { numbytes 232 orte/mca/iof/base/iof_base_output.c if (i < numbytes-1) { numbytes 252 orte/mca/iof/base/iof_base_output.c output->numbytes = k; numbytes 287 orte/mca/iof/base/iof_base_output.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 288 orte/mca/iof/base/iof_base_output.c if (num_written < output->numbytes) { numbytes 316 orte/mca/iof/base/iof_base_output.c if (0 == output->numbytes) { numbytes 321 orte/mca/iof/base/iof_base_output.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 342 orte/mca/iof/base/iof_base_output.c } else if (num_written < output->numbytes) { numbytes 344 orte/mca/iof/base/iof_base_output.c memmove(output->data, &output->data[num_written], output->numbytes - num_written); numbytes 346 orte/mca/iof/base/iof_base_output.c output->numbytes -= num_written; numbytes 469 orte/mca/iof/hnp/iof_hnp.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 470 orte/mca/iof/hnp/iof_hnp.c if (num_written < output->numbytes) { numbytes 486 orte/mca/iof/hnp/iof_hnp.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 487 orte/mca/iof/hnp/iof_hnp.c if (num_written < output->numbytes) { numbytes 555 orte/mca/iof/hnp/iof_hnp.c if (0 == output->numbytes) { numbytes 564 orte/mca/iof/hnp/iof_hnp.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 586 orte/mca/iof/hnp/iof_hnp.c } else if (num_written < output->numbytes) { numbytes 591 orte/mca/iof/hnp/iof_hnp.c memmove(output->data, &output->data[num_written], output->numbytes - num_written); numbytes 84 orte/mca/iof/hnp/iof_hnp.h unsigned char *data, int numbytes); numbytes 105 orte/mca/iof/hnp/iof_hnp_read.c int32_t numbytes; numbytes 121 orte/mca/iof/hnp/iof_hnp_read.c numbytes = read(fd, data, sizeof(data)); numbytes 129 orte/mca/iof/hnp/iof_hnp_read.c if (numbytes < 0) { numbytes 146 orte/mca/iof/hnp/iof_hnp_read.c numbytes = 0; numbytes 170 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes, numbytes 177 orte/mca/iof/hnp/iof_hnp_read.c if (ORTE_IOF_MAX_INPUT_BUFFERS < orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, proct->stdinev->wev)) { numbytes 188 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes, numbytes 199 orte/mca/iof/hnp/iof_hnp_read.c if( ORTE_SUCCESS != (rc = orte_iof_hnp_send_data_to_endpoint(&proct->stdinev->daemon, &proct->stdinev->name, ORTE_IOF_STDIN, data, numbytes))) { numbytes 208 orte/mca/iof/hnp/iof_hnp_read.c if (0 == numbytes) { numbytes 254 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), (int)numbytes, numbytes 257 orte/mca/iof/hnp/iof_hnp_read.c if (0 < numbytes) { numbytes 258 orte/mca/iof/hnp/iof_hnp_read.c rc = opal_pmix.server_iof_push(&proct->name, rev->tag, data, numbytes); numbytes 268 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_hnp_send_data_to_endpoint(&sink->daemon, &proct->name, rev->tag, data, numbytes)); numbytes 279 orte/mca/iof/hnp/iof_hnp_read.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes, numbytes 283 orte/mca/iof/hnp/iof_hnp_read.c if (0 == numbytes) { numbytes 319 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stdout->wev); numbytes 321 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stderr->wev); numbytes 327 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stdout->wev); numbytes 329 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, orte_iof_base.iof_write_stderr->wev); numbytes 336 orte/mca/iof/hnp/iof_hnp_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); numbytes 62 orte/mca/iof/hnp/iof_hnp_receive.c int32_t count, numbytes; numbytes 212 orte/mca/iof/hnp/iof_hnp_receive.c numbytes=ORTE_IOF_BASE_MSG_MAX; numbytes 213 orte/mca/iof/hnp/iof_hnp_receive.c if (ORTE_SUCCESS != (rc = opal_dss.unpack(buffer, data, &numbytes, OPAL_BYTE))) { numbytes 221 orte/mca/iof/hnp/iof_hnp_receive.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes, numbytes 254 orte/mca/iof/hnp/iof_hnp_receive.c if (0 < numbytes) { numbytes 255 orte/mca/iof/hnp/iof_hnp_receive.c rc = opal_pmix.server_iof_push(&proct->name, stream, data, numbytes); numbytes 261 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_hnp_send_data_to_endpoint(&sink->daemon, &origin, stream, data, numbytes); numbytes 277 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stdout->wev); numbytes 279 orte/mca/iof/hnp/iof_hnp_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stderr->wev); numbytes 49 orte/mca/iof/hnp/iof_hnp_send.c unsigned char *data, int numbytes) numbytes 88 orte/mca/iof/hnp/iof_hnp_send.c if (ORTE_SUCCESS != (rc = opal_dss.pack(buf, data, numbytes, OPAL_BYTE))) { numbytes 403 orte/mca/iof/orted/iof_orted.c if (0 == output->numbytes) { numbytes 414 orte/mca/iof/orted/iof_orted.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 444 orte/mca/iof/orted/iof_orted.c } else if (num_written < output->numbytes) { numbytes 449 orte/mca/iof/orted/iof_orted.c memmove(output->data, &output->data[num_written], output->numbytes - num_written); numbytes 53 orte/mca/iof/orted/iof_orted_read.c int32_t numbytes; numbytes 65 orte/mca/iof/orted/iof_orted_read.c numbytes = read(fd, data, sizeof(data)); numbytes 71 orte/mca/iof/orted/iof_orted_read.c numbytes = (int)readed; numbytes 84 orte/mca/iof/orted/iof_orted_read.c numbytes, ORTE_NAME_PRINT(&proct->name), fd)); numbytes 86 orte/mca/iof/orted/iof_orted_read.c if (numbytes <= 0) { numbytes 87 orte/mca/iof/orted/iof_orted_read.c if (0 > numbytes) { numbytes 107 orte/mca/iof/orted/iof_orted_read.c orte_iof_base_write_output(&proct->name, rev->tag, data, numbytes, rev->sink->wev); numbytes 133 orte/mca/iof/orted/iof_orted_read.c if (ORTE_SUCCESS != (rc = opal_dss.pack(buf, &data, numbytes, OPAL_BYTE))) { numbytes 141 orte/mca/iof/orted/iof_orted_read.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes)); numbytes 95 orte/mca/iof/orted/iof_orted_receive.c int32_t count, numbytes; numbytes 121 orte/mca/iof/orted/iof_orted_receive.c numbytes=ORTE_IOF_BASE_MSG_MAX; numbytes 122 orte/mca/iof/orted/iof_orted_receive.c if (ORTE_SUCCESS != (rc = opal_dss.unpack(buffer, data, &numbytes, OPAL_BYTE))) { numbytes 130 orte/mca/iof/orted/iof_orted_receive.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes, numbytes 151 orte/mca/iof/orted/iof_orted_receive.c if (ORTE_IOF_MAX_INPUT_BUFFERS < orte_iof_base_write_output(&target, stream, data, numbytes, proct->stdinev->wev)) { numbytes 244 orte/mca/iof/tool/iof_tool.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 245 orte/mca/iof/tool/iof_tool.c if (num_written < output->numbytes) { numbytes 263 orte/mca/iof/tool/iof_tool.c num_written = write(wev->fd, output->data, output->numbytes); numbytes 264 orte/mca/iof/tool/iof_tool.c if (num_written < output->numbytes) { numbytes 53 orte/mca/iof/tool/iof_tool_receive.c int32_t count, numbytes; numbytes 84 orte/mca/iof/tool/iof_tool_receive.c numbytes=ORTE_IOF_BASE_MSG_MAX; numbytes 85 orte/mca/iof/tool/iof_tool_receive.c if (ORTE_SUCCESS != (rc = opal_dss.unpack(buffer, data, &numbytes, OPAL_BYTE))) { numbytes 93 orte/mca/iof/tool/iof_tool_receive.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), numbytes, numbytes 99 orte/mca/iof/tool/iof_tool_receive.c if (0 < numbytes) { numbytes 102 orte/mca/iof/tool/iof_tool_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stdout->wev); numbytes 104 orte/mca/iof/tool/iof_tool_receive.c orte_iof_base_write_output(&origin, stream, data, numbytes, orte_iof_base.iof_write_stderr->wev); numbytes 147 orte/mca/odls/base/odls_base_default_fns.c int32_t numbytes; numbytes 230 orte/mca/odls/base/odls_base_default_fns.c numbytes = (int32_t)opal_list_get_size(modex); numbytes 231 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = opal_dss.pack(wireup, &numbytes, 1, OPAL_INT32))) { numbytes 294 orte/mca/odls/base/odls_base_default_fns.c numbytes = (int32_t)opal_list_get_size(modex); numbytes 295 orte/mca/odls/base/odls_base_default_fns.c if (ORTE_SUCCESS != (rc = opal_dss.pack(wireup, &numbytes, 1, OPAL_INT32))) { numbytes 315 orte/mca/odls/base/odls_base_default_fns.c opal_dss.unload(wireup, (void**)&bo.bytes, &numbytes); numbytes 318 orte/mca/odls/base/odls_base_default_fns.c bo.size = numbytes;