| /dports/security/putty-nogtk/putty-0.76/windows/ |
| H A D | winhandl.c | 273 bufchain queued_data; /* data still waiting to be written */ member
350 if (!ctx->busy && bufchain_size(&ctx->queued_data)) { in handle_try_output()
351 ptrlen data = bufchain_prefix(&ctx->queued_data); in handle_try_output()
356 } else if (!ctx->busy && bufchain_size(&ctx->queued_data) == 0 && in handle_try_output()
478 bufchain_init(&h->u.o.queued_data); in handle_output_new()
523 bufchain_add(&h->u.o.queued_data, data, len); in handle_write()
525 return bufchain_size(&h->u.o.queued_data); in handle_write()
573 bufchain_clear(&h->u.o.queued_data); in handle_destroy()
690 bufchain_consume(&h->u.o.queued_data, h->u.o.lenwritten); in handle_got_event()
692 h->u.o.sentdata(h, bufchain_size(&h->u.o.queued_data), 0); in handle_got_event()
[all …]
|
| /dports/security/putty/putty-0.76/windows/ |
| H A D | winhandl.c | 273 bufchain queued_data; /* data still waiting to be written */ member
350 if (!ctx->busy && bufchain_size(&ctx->queued_data)) { in handle_try_output()
351 ptrlen data = bufchain_prefix(&ctx->queued_data); in handle_try_output()
356 } else if (!ctx->busy && bufchain_size(&ctx->queued_data) == 0 && in handle_try_output()
478 bufchain_init(&h->u.o.queued_data); in handle_output_new()
523 bufchain_add(&h->u.o.queued_data, data, len); in handle_write()
525 return bufchain_size(&h->u.o.queued_data); in handle_write()
573 bufchain_clear(&h->u.o.queued_data); in handle_destroy()
690 bufchain_consume(&h->u.o.queued_data, h->u.o.lenwritten); in handle_got_event()
692 h->u.o.sentdata(h, bufchain_size(&h->u.o.queued_data), 0); in handle_got_event()
[all …]
|
| /dports/ftp/filezilla/filezilla-3.55.1/src/putty/windows/ |
| H A D | winhandl.c | 273 bufchain queued_data; /* data still waiting to be written */ member
350 if (!ctx->busy && bufchain_size(&ctx->queued_data)) { in handle_try_output()
351 ptrlen data = bufchain_prefix(&ctx->queued_data); in handle_try_output()
356 } else if (!ctx->busy && bufchain_size(&ctx->queued_data) == 0 && in handle_try_output()
476 bufchain_init(&h->u.o.queued_data); in handle_output_new()
519 bufchain_add(&h->u.o.queued_data, data, len); in handle_write()
521 return bufchain_size(&h->u.o.queued_data); in handle_write()
569 bufchain_clear(&h->u.o.queued_data); in handle_destroy()
686 bufchain_consume(&h->u.o.queued_data, h->u.o.lenwritten); in handle_got_event()
688 h->u.o.sentdata(h, bufchain_size(&h->u.o.queued_data), 0); in handle_got_event()
[all …]
|
| /dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/erts/emulator/nifs/common/ |
| H A D | prim_buffer_nif.c | 192 SysIOVec *queued_data; in copy_from_queue() local
195 queued_data = enif_ioq_peek(queue, &queue_length); in copy_from_queue()
198 copy_from_iovec(queued_data, queue_length, queue_skip, byte_skip, size, data); in copy_from_queue()
416 SysIOVec *queued_data; in find_nif() local
435 queued_data = enif_ioq_peek(buffer->queue, &queue_length); in find_nif()
462 block_start = queued_data[queue_index].iov_base; in find_nif()
463 block_size = queued_data[queue_index].iov_len; in find_nif()
|
| /dports/lang/erlang-runtime24/otp-OTP-24.1.7/erts/emulator/nifs/common/ |
| H A D | prim_buffer_nif.c | 192 SysIOVec *queued_data; in copy_from_queue() local
195 queued_data = enif_ioq_peek(queue, &queue_length); in copy_from_queue()
198 copy_from_iovec(queued_data, queue_length, queue_skip, byte_skip, size, data); in copy_from_queue()
416 SysIOVec *queued_data; in find_nif() local
435 queued_data = enif_ioq_peek(buffer->queue, &queue_length); in find_nif()
462 block_start = queued_data[queue_index].iov_base; in find_nif()
463 block_size = queued_data[queue_index].iov_len; in find_nif()
|
| /dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/erts/emulator/nifs/common/ |
| H A D | prim_buffer_nif.c | 192 SysIOVec *queued_data; in copy_from_queue() local
195 queued_data = enif_ioq_peek(queue, &queue_length); in copy_from_queue()
198 copy_from_iovec(queued_data, queue_length, queue_skip, byte_skip, size, data); in copy_from_queue()
416 SysIOVec *queued_data; in find_nif() local
435 queued_data = enif_ioq_peek(buffer->queue, &queue_length); in find_nif()
462 block_start = queued_data[queue_index].iov_base; in find_nif()
463 block_size = queued_data[queue_index].iov_len; in find_nif()
|
| /dports/lang/erlang-wx/otp-OTP-24.1.7/erts/emulator/nifs/common/ |
| H A D | prim_buffer_nif.c | 192 SysIOVec *queued_data; in copy_from_queue() local
195 queued_data = enif_ioq_peek(queue, &queue_length); in copy_from_queue()
198 copy_from_iovec(queued_data, queue_length, queue_skip, byte_skip, size, data); in copy_from_queue()
416 SysIOVec *queued_data; in find_nif() local
435 queued_data = enif_ioq_peek(buffer->queue, &queue_length); in find_nif()
462 block_start = queued_data[queue_index].iov_base; in find_nif()
463 block_size = queued_data[queue_index].iov_len; in find_nif()
|
| /dports/lang/erlang/otp-OTP-24.1.7/erts/emulator/nifs/common/ |
| H A D | prim_buffer_nif.c | 192 SysIOVec *queued_data; in copy_from_queue() local
195 queued_data = enif_ioq_peek(queue, &queue_length); in copy_from_queue()
198 copy_from_iovec(queued_data, queue_length, queue_skip, byte_skip, size, data); in copy_from_queue()
416 SysIOVec *queued_data; in find_nif() local
435 queued_data = enif_ioq_peek(buffer->queue, &queue_length); in find_nif()
462 block_start = queued_data[queue_index].iov_base; in find_nif()
463 block_size = queued_data[queue_index].iov_len; in find_nif()
|
| /dports/lang/erlang-java/otp-OTP-24.1.7/erts/emulator/nifs/common/ |
| H A D | prim_buffer_nif.c | 192 SysIOVec *queued_data; in copy_from_queue() local
195 queued_data = enif_ioq_peek(queue, &queue_length); in copy_from_queue()
198 copy_from_iovec(queued_data, queue_length, queue_skip, byte_skip, size, data); in copy_from_queue()
416 SysIOVec *queued_data; in find_nif() local
435 queued_data = enif_ioq_peek(buffer->queue, &queue_length); in find_nif()
462 block_start = queued_data[queue_index].iov_base; in find_nif()
463 block_size = queued_data[queue_index].iov_len; in find_nif()
|
| /dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/erts/emulator/nifs/common/ |
| H A D | prim_buffer_nif.c | 192 SysIOVec *queued_data; in copy_from_queue() local
195 queued_data = enif_ioq_peek(queue, &queue_length); in copy_from_queue()
198 copy_from_iovec(queued_data, queue_length, queue_skip, byte_skip, size, data); in copy_from_queue()
416 SysIOVec *queued_data; in find_nif() local
435 queued_data = enif_ioq_peek(buffer->queue, &queue_length); in find_nif()
462 block_start = queued_data[queue_index].iov_base; in find_nif()
463 block_size = queued_data[queue_index].iov_len; in find_nif()
|
| /dports/misc/adios2/ADIOS2-2.7.1/thirdparty/EVPath/EVPath/ |
| H A D | cm.c | 2741 conn->queued_data.rem_attr_len); in CMWriteQueuedData()
2758 conn->queued_data.rem_header_len); in CMWriteQueuedData()
2780 conn, conn->queued_data.rem_attr_len); in CMWriteQueuedData()
2784 if (conn->queued_data.vector_data) { in CMWriteQueuedData()
2940 conn->queued_data.rem_header_len = 0; in queue_remaining_write()
2948 conn->queued_data.rem_attr_len = 0; in queue_remaining_write()
2957 conn->queued_data.vector_data = NULL; in queue_remaining_write()
2963 …int data_length = remaining_bytes - conn->queued_data.rem_attr_len - conn->queued_data.rem_header_… in queue_remaining_write()
2972 conn->queued_data.buffer_to_free = buf; in queue_remaining_write()
2973 conn->queued_data.vector_data = vec; in queue_remaining_write()
[all …]
|
| H A D | cmenet.c | 104 } *queued_data; typedef
118 queued_data pending_data;
276 queued_data entry = ecd->pending_data; in enet_service_network()
|
| H A D | cm_internal.h | 271 struct queued_data_rec queued_data; member
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/modules/webmidi/ |
| H A D | midi_output.cc | 313 HeapVector<std::pair<Member<DOMUint8Array>, base::TimeTicks>> queued_data; in DidOpen() local
314 queued_data.swap(pending_data_); in DidOpen()
315 for (auto& data : queued_data) { in DidOpen()
321 queued_data.clear(); in DidOpen()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/modules/webmidi/ |
| H A D | midi_output.cc | 313 HeapVector<std::pair<Member<DOMUint8Array>, base::TimeTicks>> queued_data; in DidOpen() local
314 queued_data.swap(pending_data_); in DidOpen()
315 for (auto& data : queued_data) { in DidOpen()
320 queued_data.clear(); in DidOpen()
|
| /dports/devel/libspice-server/spice-0.15.0/server/ |
| H A D | spicevmc.cpp | 92 uint32_t queued_data; member
233 if (!channel->rcc || channel->queued_data >= QUEUED_DATA_LIMIT) { in read_one_msg_from_device()
475 channel->queued_data += item->buf_used; in spicevmc_red_channel_queue_data()
501 uint32_t old_queued_data = channel->queued_data; in spicevmc_red_channel_send_data()
502 channel->queued_data -= i->buf_used; in spicevmc_red_channel_send_data()
504 old_queued_data >= QUEUED_DATA_LIMIT && channel->queued_data < QUEUED_DATA_LIMIT) { in spicevmc_red_channel_send_data()
598 vmc_channel->queued_data = 0; in on_connect()
|
| /dports/security/suricata/suricata-6.0.4/rust/src/smb/ |
| H A D | files.rs | 201 let queued_data = tdf.file_tracker.get_queued_size(); in filetracker_update() localVariable
202 if queued_data > 2000000 { // TODO should probably be configurable in filetracker_update()
203 … SCLogDebug!("QUEUED size {} while we've seen GAPs. Truncating file.", queued_data); in filetracker_update()
|
| /dports/games/minetest_game/minetest_game-5.4.1/mods/tnt/ |
| H A D | init.lua | 384 for _, queued_data in pairs(on_blast_queue) do
385 local dist = math.max(1, vector.distance(queued_data.pos, pos))
387 local node_drops = queued_data.on_blast(queued_data.pos, intensity)
395 for _, queued_data in pairs(on_construct_queue) do
396 queued_data.fn(queued_data.pos)
|
| /dports/sysutils/duplicity/duplicity-0.8.20/duplicity/ |
| H A D | diffdir.py | 498 self.queued_data = None # data to return in next next() call
534 if self.queued_data is not None:
535 result = self.queued_data
536 self.queued_data = None
572 self.queued_data = data
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chromecast/media/cma/backend/mixer/ |
| H A D | mixer_input_connection.cc | 643 bool queued_data = false; in InitializeAudioPlayback() local
662 queued_data = true; in InitializeAudioPlayback()
666 if (queued_data) { in InitializeAudioPlayback()
|
| /dports/security/suricata/suricata-6.0.4/rust/src/nfs/ |
| H A D | nfs.rs | 848 let queued_data = tdf.file_tracker.get_queued_size(); in filetracker_update() localVariable
849 if queued_data > 2000000 { // TODO should probably be configurable in filetracker_update()
850 … SCLogDebug!("QUEUED size {} while we've seen GAPs. Truncating file.", queued_data); in filetracker_update()
|