| /dports/games/megaglest/megaglest-source-3.13.0/source/shared_lib/sources/libircclient/build/source/libircclient/src/ |
| H A D | dcc.c | 177 if ( dcc->incoming_offset < sizeof(dcc->incoming_buf) - 1 ) in libirc_dcc_add_descriptors()
296 unsigned int amount = sizeof (dcc->incoming_buf) - dcc->incoming_offset; in libirc_dcc_process_descriptors()
298 length = socket_recv (&dcc->sock, dcc->incoming_buf + dcc->incoming_offset, amount); in libirc_dcc_process_descriptors()
321 offset = libirc_findcrorlf (dcc->incoming_buf, dcc->incoming_offset); in libirc_dcc_process_descriptors()
335 unsigned int received_size = ntohl (*((unsigned int*)dcc->incoming_buf)); in libirc_dcc_process_descriptors()
361 (*dcc->cb)(ircsession, dcc->id, err, dcc->ctx, dcc->incoming_buf, offset); in libirc_dcc_process_descriptors()
376 (*dcc->cb)(ircsession, dcc->id, err, dcc->ctx, dcc->incoming_buf, strlen(dcc->incoming_buf)); in libirc_dcc_process_descriptors()
381 memmove (dcc->incoming_buf, dcc->incoming_buf + offset, dcc->incoming_offset - offset); in libirc_dcc_process_descriptors()
|
| H A D | libircclient.c | 385 if ( session->incoming_offset < (sizeof (session->incoming_buf) - 1) ) in irc_add_select_descriptors()
413 memcpy (buf, session->incoming_buf, process_length); in libirc_process_incoming_data()
774 unsigned int amount = (sizeof (session->incoming_buf) - 1) - session->incoming_offset; in irc_process_select_descriptors()
775 length = socket_recv (&session->sock, session->incoming_buf + session->incoming_offset, amount); in irc_process_select_descriptors()
787 while ( (offset = libirc_findcrlf (session->incoming_buf, session->incoming_offset)) > 0 ) in irc_process_select_descriptors()
791 libirc_dump_data ("RECV", session->incoming_buf, offset); in irc_process_select_descriptors()
797 …memmove (session->incoming_buf, session->incoming_buf + offset, session->incoming_offset - offset); in irc_process_select_descriptors()
|
| /dports/games/megaglest/megaglest-source-3.13.0/source/shared_lib/sources/libircclient/src/ |
| H A D | dcc.c | 178 if ( dcc->incoming_offset < sizeof(dcc->incoming_buf) - 1 ) in libirc_dcc_add_descriptors()
297 unsigned int amount = sizeof (dcc->incoming_buf) - dcc->incoming_offset; in libirc_dcc_process_descriptors()
299 length = socket_recv (&dcc->sock, dcc->incoming_buf + dcc->incoming_offset, amount); in libirc_dcc_process_descriptors()
322 offset = libirc_findcrorlf (dcc->incoming_buf, dcc->incoming_offset); in libirc_dcc_process_descriptors()
336 unsigned int received_size = ntohl (*((unsigned int*)dcc->incoming_buf)); in libirc_dcc_process_descriptors()
362 (*dcc->cb)(ircsession, dcc->id, err, dcc->ctx, dcc->incoming_buf, offset); in libirc_dcc_process_descriptors()
377 (*dcc->cb)(ircsession, dcc->id, err, dcc->ctx, dcc->incoming_buf, strlen(dcc->incoming_buf)); in libirc_dcc_process_descriptors()
382 memmove (dcc->incoming_buf, dcc->incoming_buf + offset, dcc->incoming_offset - offset); in libirc_dcc_process_descriptors()
|
| H A D | libircclient.c | 385 if ( session->incoming_offset < (sizeof (session->incoming_buf) - 1) ) in irc_add_select_descriptors()
413 memcpy (buf, session->incoming_buf, process_length); in libirc_process_incoming_data()
774 unsigned int amount = (sizeof (session->incoming_buf) - 1) - session->incoming_offset; in irc_process_select_descriptors()
775 length = socket_recv (&session->sock, session->incoming_buf + session->incoming_offset, amount); in irc_process_select_descriptors()
787 while ( (offset = libirc_findcrlf (session->incoming_buf, session->incoming_offset)) > 0 ) in irc_process_select_descriptors()
791 libirc_dump_data ("RECV", session->incoming_buf, offset); in irc_process_select_descriptors()
797 …memmove (session->incoming_buf, session->incoming_buf + offset, session->incoming_offset - offset); in irc_process_select_descriptors()
|
| /dports/irc/libircclient/libircclient-1.10/src/ |
| H A D | ssl.c | 248 unsigned int amount = (sizeof (session->incoming_buf) - 1) - session->incoming_offset; in ssl_recv()
253 count = SSL_read( session->ssl, session->incoming_buf + session->incoming_offset, amount ); in ssl_recv()
354 session->incoming_buf + session->incoming_offset, in session_socket_read()
355 (sizeof (session->incoming_buf) - 1) - session->incoming_offset ); in session_socket_read()
|
| H A D | dcc.c | 177 if ( dcc->incoming_offset < sizeof(dcc->incoming_buf) - 1 ) in libirc_dcc_add_descriptors()
299 unsigned int amount = sizeof (dcc->incoming_buf) - dcc->incoming_offset; in libirc_dcc_process_descriptors()
301 length = socket_recv (&dcc->sock, dcc->incoming_buf + dcc->incoming_offset, amount); in libirc_dcc_process_descriptors()
324 offset = libirc_findcrorlf (dcc->incoming_buf, dcc->incoming_offset); in libirc_dcc_process_descriptors()
339 const unsigned char * bptr = (const unsigned char *) dcc->incoming_buf; in libirc_dcc_process_descriptors()
366 (*dcc->cb)(ircsession, dcc->id, err, dcc->ctx, dcc->incoming_buf, offset); in libirc_dcc_process_descriptors()
386 (*dcc->cb)(ircsession, dcc->id, err, dcc->ctx, dcc->incoming_buf, strlen(dcc->incoming_buf)); in libirc_dcc_process_descriptors()
391 memmove (dcc->incoming_buf, dcc->incoming_buf + offset, dcc->incoming_offset - offset); in libirc_dcc_process_descriptors()
|
| H A D | dcc.h | 43 char incoming_buf[LIBIRC_DCC_BUFFER_SIZE]; member
|
| H A D | libircclient.c | 505 if ( session->incoming_offset < (sizeof (session->incoming_buf) - 1) in irc_add_select_descriptors()
535 memcpy (buf, session->incoming_buf, process_length); in libirc_process_incoming_data()
915 while ( (offset = libirc_findcrlf (session->incoming_buf, session->incoming_offset)) > 0 ) in irc_process_select_descriptors()
919 libirc_dump_data ("RECV", session->incoming_buf, offset); in irc_process_select_descriptors()
924 offset = libirc_findcrlf_offset(session->incoming_buf, offset, session->incoming_offset); in irc_process_select_descriptors()
927 …memmove (session->incoming_buf, session->incoming_buf + offset, session->incoming_offset - offset); in irc_process_select_descriptors()
|
| H A D | session.h | 42 char incoming_buf[LIBIRC_BUFFER_SIZE]; member
|
| /dports/www/websocat/websocat-1.9.0/cargo-crates/tokio-stdin-stdout-0.1.5/src/ |
| H A D | lib.rs | 88 let mut handle_the_buffer = |incoming_buf: Box<[u8]>| { in read()
90 let dl = incoming_buf.len(); in read()
92 buf[0..dl].copy_from_slice(&incoming_buf); in read()
95 buf[0..l].copy_from_slice(&incoming_buf[0..l]); in read()
96 let newdebt = Some(incoming_buf[l..].to_vec().into_boxed_slice()); in read()
|
| /dports/www/p5-HTML5-DOM/HTML5-DOM-1.25/third_party/modest/source/myhtml/ |
| H A D | tokenizer.c | 35 tree->incoming_buf_first = tree->incoming_buf; in myhtml_tokenizer_set_first_settings()
51 …tree->incoming_buf = mycore_incoming_buffer_add(tree->incoming_buf, tree->mcobject_incoming_buf, h… in myhtml_tokenizer_chunk_process()
163 if(tree->incoming_buf) in myhtml_tokenizer_end()
165 tree->global_offset -= tree->incoming_buf->size; in myhtml_tokenizer_end()
168 …(tree, tree->current_token_node, tree->incoming_buf->data, tree->incoming_buf->size, tree->incomin… in myhtml_tokenizer_end()
901 tree->incoming_buf->length = html_offset; in myhtml_tokenizer_state_markup_declaration_open()
921 tree->incoming_buf->length = html_offset; in myhtml_tokenizer_state_markup_declaration_open()
931 html_offset = (token_node->raw_begin + 7) - tree->incoming_buf->offset; in myhtml_tokenizer_state_markup_declaration_open()
951 html_offset = (token_node->raw_begin + 7) - tree->incoming_buf->offset; in myhtml_tokenizer_state_markup_declaration_open()
|
| H A D | tokenizer_doctype.c | 186 html_offset = (token_node->str.length + 6) - tree->incoming_buf->offset; in myhtml_tokenizer_state_custom_after_doctype_name_a_z()
202 html_offset = (token_node->str.length + 6) - tree->incoming_buf->offset; in myhtml_tokenizer_state_custom_after_doctype_name_a_z()
|
| /dports/games/megaglest/megaglest-source-3.13.0/source/shared_lib/include/libircclient/include/ |
| H A D | libirc_dcc.h | 48 char incoming_buf[LIBIRC_DCC_BUFFER_SIZE]; member
|
| H A D | libirc_session.h | 38 char incoming_buf[LIBIRC_BUFFER_SIZE]; member
|
| /dports/games/megaglest/megaglest-source-3.13.0/source/shared_lib/sources/libircclient/build/source/libircclient/include/ |
| H A D | libirc_dcc.h | 47 char incoming_buf[LIBIRC_DCC_BUFFER_SIZE]; member
|
| H A D | libirc_session.h | 38 char incoming_buf[LIBIRC_BUFFER_SIZE]; member
|
| /dports/devel/libunit/unit-1.26.1/src/ |
| H A D | nxt_unit.c | 231 nxt_unit_mmap_buf_t *incoming_buf; member
250 nxt_unit_mmap_buf_t *incoming_buf; member
940 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1300 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1322 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1323 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1324 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1411 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1419 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1422 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
[all …]
|
| /dports/www/unit-java/unit-1.26.1/src/ |
| H A D | nxt_unit.c | 231 nxt_unit_mmap_buf_t *incoming_buf; member
250 nxt_unit_mmap_buf_t *incoming_buf; member
940 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1300 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1322 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1323 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1324 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1411 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1419 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1422 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
[all …]
|
| /dports/www/unit-perl/unit-1.26.1/src/ |
| H A D | nxt_unit.c | 231 nxt_unit_mmap_buf_t *incoming_buf; member
250 nxt_unit_mmap_buf_t *incoming_buf; member
940 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1300 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1322 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1323 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1324 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1411 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1419 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1422 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
[all …]
|
| /dports/www/unit-python/unit-1.26.1/src/ |
| H A D | nxt_unit.c | 231 nxt_unit_mmap_buf_t *incoming_buf; member
250 nxt_unit_mmap_buf_t *incoming_buf; member
940 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1300 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1322 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1323 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1324 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1411 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1419 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1422 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
[all …]
|
| /dports/www/unit-php/unit-1.26.1/src/ |
| H A D | nxt_unit.c | 231 nxt_unit_mmap_buf_t *incoming_buf; member
250 nxt_unit_mmap_buf_t *incoming_buf; member
940 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1300 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1322 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1323 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1324 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1411 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1419 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1422 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
[all …]
|
| /dports/www/unit/unit-1.26.1/src/ |
| H A D | nxt_unit.c | 231 nxt_unit_mmap_buf_t *incoming_buf; member
250 nxt_unit_mmap_buf_t *incoming_buf; member
940 recv_msg.incoming_buf = NULL; in nxt_unit_process_msg()
1300 b = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1322 req_impl->incoming_buf = recv_msg->incoming_buf; in nxt_unit_process_req_headers()
1323 req_impl->incoming_buf->prev = &req_impl->incoming_buf; in nxt_unit_process_req_headers()
1324 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_headers()
1411 if (recv_msg->incoming_buf != NULL) { in nxt_unit_process_req_body()
1419 b->next = recv_msg->incoming_buf; in nxt_unit_process_req_body()
1422 recv_msg->incoming_buf = NULL; in nxt_unit_process_req_body()
[all …]
|
| /dports/net/netpipes/netpipes-4.2/ |
| H A D | encapsulate.c | 1061 char incoming_buf[BUF_SIZE]; /* read from socket, will write to child */ local
1165 write_to_child(curr_writeable, incoming_buf, &incoming_len);
1187 incoming_buf, &incoming_len,
1188 sizeof(incoming_buf) );
1221 handle_control_message(incoming_buf, incoming_len);
|
| /dports/emulators/gxemul/gxemul-0.6.3/src/include/ |
| H A D | net.h | 94 unsigned char *incoming_buf; member
|
| /dports/emulators/gxemul/gxemul-0.6.3/src/net/ |
| H A D | net_ip.cc | 1405 if (net->tcp_connections[con_id].incoming_buf == NULL) in net_tcp_rx_avail()
1407 incoming_buf = (unsigned char *) malloc(TCP_INCOMING_BUF_LEN)); in net_tcp_rx_avail()
1479 incoming_buf, in net_tcp_rx_avail()
1516 memcpy(net->tcp_connections[con_id].incoming_buf, in net_tcp_rx_avail()
|