Home
last modified time | relevance | path

Searched refs:d_itemsize (Results 1 – 25 of 64) sorted by relevance

123

/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-blocks/lib/
H A Dfile_descriptor_source_impl.cc58 d_itemsize(itemsize), in file_descriptor_source_impl()
75 assert(d_residue_len < d_itemsize); in read_items()
85 int r = read(d_fd, buf + nbytes_read, nitems * d_itemsize - nbytes_read); in read_items()
102 int nitems_read = nbytes_read / d_itemsize; in handle_residue()
103 d_residue_len = nbytes_read % d_itemsize; in handle_residue()
140 o += r * d_itemsize; in work()
H A Dkeep_m_in_n_impl.cc45 d_itemsize(itemsize) in keep_m_in_n_impl()
108 int excess = (d_offset + d_m - d_n) * d_itemsize; in general_work()
112 const uint8_t* iptr = &in[(i * d_n + d_offset) * d_itemsize]; in general_work()
113 uint8_t* optr = &out[i * d_m * d_itemsize]; in general_work()
116 memcpy(optr, iptr, d_m * d_itemsize); in general_work()
118 memcpy(optr, &in[i * d_n * d_itemsize], excess); in general_work()
119 memcpy(optr + excess, iptr, d_m * d_itemsize - excess); in general_work()
H A Dfile_source_impl.cc72 d_itemsize(itemsize), in file_source_impl()
123 return GR_FSEEK((FILE*)d_fp, seek_point * d_itemsize, SEEK_SET) == 0; in seek()
169 if ((file_size / d_itemsize) < (start_offset_items + 1)) { in open()
182 uint64_t items_available = (file_size / d_itemsize - start_offset_items); in open()
187 if (file_size % d_itemsize) { in open()
201 GR_FSEEK(d_new_fp, start_offset_items * d_itemsize, SEEK_SET); in open()
272 size_t nitems_read = fread(o, d_itemsize, nitems_to_read, (FILE*)d_fp); in work()
286 o += nitems_read * d_itemsize; in work()
293 GR_FSEEK(d_fp, d_start_offset_items * d_itemsize, SEEK_SET); in work()
H A Ddelay_impl.cc43 d_itemsize(itemsize) in delay_impl()
93 std::memcpy(optr, iptr, noutput_items * d_itemsize); in general_work()
108 std::memcpy(optr, iptr + delta * d_itemsize, n_to_copy * d_itemsize); in general_work()
124 std::memset(optr, 0, n_padding * d_itemsize); in general_work()
125 std::memcpy(optr, iptr, n_from_input * d_itemsize); in general_work()
H A Drepeat_impl.cc43 d_itemsize(itemsize), in repeat_impl()
75 memcpy(out, in, d_itemsize); in work()
76 out += d_itemsize; in work()
79 in += d_itemsize; in work()
H A Dinterleave_impl.cc42 d_itemsize(itemsize), in interleave_impl()
86 memcpy(out, in[n], d_itemsize * d_blocksize); in general_work()
87 out += d_itemsize * d_blocksize; in general_work()
88 in[n] += d_itemsize * d_blocksize; in general_work()
H A Dpatterned_interleaver_impl.cc47 d_itemsize(itemsize) in patterned_interleaver_impl()
71 memcpy(oo, ii[d_pattern[j]], d_itemsize); in general_work()
72 oo += d_itemsize; in general_work()
73 ii[d_pattern[j]] += d_itemsize; in general_work()
H A Dstream_mux_impl.cc44 d_itemsize(itemsize), in stream_mux_impl()
89 in = (const char*)input_items[d_stream] + input_index[d_stream] * d_itemsize; in general_work()
90 memcpy(&out[out_index * d_itemsize], in, items_to_copy * d_itemsize); in general_work()
H A Dfile_sink_impl.cc43 d_itemsize(itemsize) in file_sink_impl()
62 int count = fwrite(inbuf, d_itemsize, noutput_items - nwritten, d_fp); in work()
73 inbuf += count * d_itemsize; in work()
H A Dtagged_file_sink_impl.cc65 d_itemsize(itemsize), in tagged_file_sink_impl()
198 &inbuf[d_itemsize * idx], d_itemsize, idx_stop - idx, d_handle); in work()
215 &inbuf[d_itemsize * idx], d_itemsize, noutput_items - idx, d_handle); in work()
H A Dfile_meta_sink_impl.cc91 d_itemsize(itemsize), in file_meta_sink_impl()
129 d_header = pmt::dict_add(d_header, pmt::mp("size"), pmt::from_long(d_itemsize)); in file_meta_sink_impl()
310 size_t seg_size = d_itemsize * d_total_seg_size; in update_last_header_inline()
328 size_t seg_size = d_itemsize * d_total_seg_size; in update_last_header_detached()
408 int count = fwrite(inbuf, d_itemsize, towrite, d_fp); in work()
412 inbuf += count * d_itemsize; in work()
441 int count = fwrite(inbuf, d_itemsize, towrite, d_fp); in work()
445 inbuf += count * d_itemsize; in work()
H A Dtagged_stream_mux_impl.cc48 d_itemsize(itemsize), in tagged_stream_mux_impl()
89 memcpy((void*)out, (const void*)in, ninput_items[i] * d_itemsize); in work()
90 out += ninput_items[i] * d_itemsize; in work()
H A Dpdu_to_tagged_stream_impl.cc46 d_itemsize(pdu::itemsize(type)), in pdu_to_tagged_stream_impl()
66 d_curr_len = pmt::blob_length(d_curr_vect) / d_itemsize; in calculate_output_stream_length()
91 memcpy(out, ptr, d_curr_len * d_itemsize); in work()
H A Dtcp_server_sink_impl.cc55 d_itemsize(itemsize), in tcp_server_sink_impl()
145 size_t data_len = std::min(size_t(BUF_SIZE), noutput_items * d_itemsize); in work()
146 data_len -= data_len % d_itemsize; in work()
161 return data_len / d_itemsize; in work()
H A Dfile_meta_source_impl.cc73 d_itemsize(0), in file_meta_source_impl()
102 set_output_signature(io_signature::make(1, 1, d_itemsize)); in file_meta_source_impl()
216 d_itemsize = in parse_header()
228 d_seg_size /= d_itemsize; in parse_header()
391 i = fread(out, d_itemsize, size, d_fp); in work()
395 out += i * d_itemsize; in work()
H A Dfile_descriptor_sink_impl.cc53 d_itemsize(itemsize), in file_descriptor_sink_impl()
65 unsigned long byte_size = noutput_items * d_itemsize; in work()
H A Ddeinterleave_impl.cc42 d_itemsize(itemsize), in deinterleave_impl()
46 d_size_bytes = d_itemsize * d_blocksize; in deinterleave_impl()
H A Dtagged_stream_align_impl.cc45 d_itemsize(itemsize), in tagged_stream_align_impl()
69 memcpy(output_items[0], input_items[0], ncp * d_itemsize); in general_work()
H A Dudp_source_impl.cc53 d_itemsize(itemsize), in udp_source_impl()
197 int bytes_to_send = std::min<int>(d_itemsize * noutput_items, bytes_left_in_buffer); in work()
201 int nitems = bytes_to_send / d_itemsize; in work()
H A Dstream_to_tagged_stream_impl.cc51 d_itemsize(itemsize * vlen), in stream_to_tagged_stream_impl()
79 memcpy(out, in, noutput_items * d_itemsize); in work()
H A Dtags_strobe_impl.cc57 d_itemsize(sizeof_stream_item) in tags_strobe_impl()
81 memset(optr, 0, noutput_items * d_itemsize); in work()
H A Dcopy_impl.cc43 d_itemsize(itemsize), in copy_impl()
81 memcpy(out[i], in[i], noutput_items * d_itemsize); in general_work()
H A Dburst_tagger_impl.cc43 d_itemsize(itemsize), in burst_tagger_impl()
88 memcpy(out, signal, noutput_items * d_itemsize); in work()
/dports/comms/gnuradio/gnuradio-3.8.4.0/gnuradio-runtime/lib/pmt/
H A Dpmt_pool.cc41 : d_itemsize(ROUNDUP(itemsize, alignment)), in pmt_pool()
81 size_t n = (end - start) / d_itemsize; in malloc()
88 p = (item*)((char*)p + d_itemsize); in malloc()
/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-digital/lib/
H A Dheader_payload_demux_impl.cc119 d_itemsize(itemsize), in header_payload_demux_impl()
136 if (d_items_per_symbol < 1 || d_gi < 0 || d_itemsize < 1) { in header_payload_demux_impl()
244 in += (items_to_consume)*d_itemsize; in general_work()
488 (void*)(in + d_gi * d_itemsize), in copy_n_symbols()
489 d_items_per_symbol * d_itemsize); in copy_n_symbols()
490 in += d_itemsize * (d_items_per_symbol + d_gi); in copy_n_symbols()
491 out += d_itemsize * d_items_per_symbol; in copy_n_symbols()
496 (n_symbols * d_items_per_symbol + n_padding_items) * d_itemsize); in copy_n_symbols()

123