| /dports/devel/libaravis/aravis-ARAVIS_0_5_12/src/ |
| H A D | arvgvdevice.c | 143 success = g_socket_receive (io_data->socket, io_data->buffer, in _flush_socket_buffer()
198 count = g_socket_receive (io_data->socket, io_data->buffer, in _read_memory()
318 count = g_socket_receive (io_data->socket, io_data->buffer, in _write_memory()
632 ArvGvDeviceIOData *io_data = thread_data->io_data; in arv_gv_device_heartbeat_thread() local
773 ArvGvDeviceIOData *io_data = gv_device->priv->io_data; in arv_gv_device_auto_packet_size() local
1221 ArvGvDeviceIOData *io_data = gv_device->priv->io_data; in arv_gv_device_create_stream() local
1392 gv_device->priv->io_data = io_data; in arv_gv_device_new()
1406 heartbeat_data->io_data = io_data; in arv_gv_device_new()
1462 io_data = gv_device->priv->io_data; in arv_gv_device_finalize()
1494 ArvGvDeviceIOData *io_data = device->priv->io_data; in arv_gv_device_get_interface_address() local
[all …]
|
| /dports/multimedia/aravis/aravis-ARAVIS_0_5_12/src/ |
| H A D | arvgvdevice.c | 136 success = g_socket_receive (io_data->socket, io_data->buffer, in _flush_socket_buffer()
191 count = g_socket_receive (io_data->socket, io_data->buffer, in _read_memory()
311 count = g_socket_receive (io_data->socket, io_data->buffer, in _write_memory()
625 ArvGvDeviceIOData *io_data = thread_data->io_data; in arv_gv_device_heartbeat_thread() local
766 ArvGvDeviceIOData *io_data = gv_device->priv->io_data; in arv_gv_device_auto_packet_size() local
1214 ArvGvDeviceIOData *io_data = gv_device->priv->io_data; in arv_gv_device_create_stream() local
1385 gv_device->priv->io_data = io_data; in arv_gv_device_new()
1399 heartbeat_data->io_data = io_data; in arv_gv_device_new()
1455 io_data = gv_device->priv->io_data; in arv_gv_device_finalize()
1487 ArvGvDeviceIOData *io_data = device->priv->io_data; in arv_gv_device_get_interface_address() local
[all …]
|
| /dports/science/minc2/minc-release-2.2.00/conversion/gcomserver/ |
| H A D | open_connection.c | 125 Io_data *io_data; in input_routine() local
130 io_data = (Io_data *) user_data; in input_routine()
133 nread = GCOM_READ(io_data->fd, buffer, (unsigned int) nbytes); in input_routine()
155 Io_data *io_data; in output_routine() local
160 io_data = (Io_data *) user_data; in output_routine()
163 nwritten = GCOM_WRITE(io_data->fd, buffer, (unsigned int) nbytes); in output_routine()
192 Io_data *io_data; in open_connection() local
220 io_data = MALLOC(sizeof(*io_data)); in open_connection()
221 io_data->fd = fileno(stdin); in open_connection()
226 io_data = MALLOC(sizeof(*io_data)); in open_connection()
[all …]
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/may-0.3.17/src/io/sys/unix/ |
| H A D | wait_io.rs | 12 io_data: &'a io_impl::IoData, field
16 fn new(io_data: &'a io_impl::IoData) -> Self { in new()
17 RawIoBlock { io_data } in new()
23 let io_data = (*self.io_data).clone(); in subscribe() localVariable
24 self.io_data.co.swap(co, Ordering::Release); in subscribe()
26 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
27 return io_data.schedule(); in subscribe()
42 let io_data = self.as_io_data(); in reset_io() localVariable
43 io_data.reset(); in reset_io()
47 let io_data = self.as_io_data(); in wait_io() localVariable
[all …]
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/may-0.3.17/src/io/sys/unix/net/ |
| H A D | socket_read.rs | 13 io_data: &'a IoData, field
21 io_data: s.as_io_data(), in new()
32 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
35 match read(self.io_data.fd, self.buf) { in done()
47 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
61 let io_data = (*self.io_data).clone(); in subscribe() localVariable
66 .add_io_timer(self.io_data, dur); in subscribe()
72 self.io_data.co.swap(co, Ordering::Release); in subscribe()
76 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
77 return io_data.schedule(); in subscribe()
[all …]
|
| H A D | socket_write.rs | 13 io_data: &'a IoData, field
21 io_data: s.as_io_data(), in new()
32 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
34 match write(self.io_data.fd, self.buf) { in done()
46 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
58 let io_data = (*self.io_data).clone(); in subscribe() localVariable
63 .add_io_timer(self.io_data, dur); in subscribe()
65 self.io_data.co.swap(co, Ordering::Release); in subscribe()
68 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
69 io_data.schedule(); in subscribe()
|
| H A D | udp_recv_from.rs | 14 io_data: &'a IoData, field
23 io_data: socket.as_io_data(), in new()
35 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
51 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
65 let io_data = (*self.io_data).clone(); in subscribe() localVariable
70 .add_io_timer(self.io_data, dur); in subscribe()
72 self.io_data.co.swap(co, Ordering::Release); in subscribe()
75 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
76 return io_data.schedule(); in subscribe()
80 cancel.set_io(io_data); in subscribe()
|
| H A D | unix_recv_from.rs | 14 io_data: &'a IoData, field
23 io_data: socket.0.as_io_data(), in new()
35 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
51 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
65 let io_data = (*self.io_data).clone(); in subscribe() localVariable
70 .add_io_timer(self.io_data, dur); in subscribe()
72 self.io_data.co.swap(co, Ordering::Release); in subscribe()
75 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
76 return io_data.schedule(); in subscribe()
80 cancel.set_io(io_data); in subscribe()
|
| H A D | tcp_listener_accpet.rs | 12 io_data: &'a IoData, field
19 io_data: socket.as_io_data(), in new()
29 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
48 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
62 let io_data = (*self.io_data).clone(); in subscribe() localVariable
64 self.io_data.co.swap(co, Ordering::Release); in subscribe()
67 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
68 return io_data.schedule(); in subscribe()
72 cancel.set_io(io_data); in subscribe()
|
| H A D | socket_write_vectored.rs | 12 io_data: &'a IoData, field
26 io_data: s.as_io_data(), in new()
40 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
55 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
67 let io_data = (*self.io_data).clone(); in subscribe() localVariable
72 .add_io_timer(self.io_data, dur); in subscribe()
74 self.io_data.co.swap(co, Ordering::Release); in subscribe()
77 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
78 io_data.schedule(); in subscribe()
|
| H A D | unix_listener_accpet.rs | 12 io_data: &'a IoData, field
19 io_data: socket.0.as_io_data(), in new()
29 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
48 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
62 let io_data = (*self.io_data).clone(); in subscribe() localVariable
65 self.io_data.co.swap(co, Ordering::Release); in subscribe()
68 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
69 return io_data.schedule(); in subscribe()
73 cancel.set_io(io_data); in subscribe()
|
| H A D | unix_stream_connect.rs | 16 io_data: OptionCell<IoData>, field
29 io_data: OptionCell::new(io), in new()
54 UnixStream::from_coio(CoIo::from_raw(stream, s.io_data.take())) in done()
66 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
78 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
92 let io_data = (*self.io_data).clone(); in subscribe() localVariable
96 .add_io_timer(&self.io_data, Duration::from_secs(2)); in subscribe()
97 io_data.co.swap(co, Ordering::Release); in subscribe()
100 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
101 return io_data.schedule(); in subscribe()
[all …]
|
| H A D | udp_send_to.rs | 14 io_data: &'a IoData, field
24 io_data: socket.as_io_data(), in new()
37 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
53 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
65 let io_data = (*self.io_data).clone(); in subscribe() localVariable
70 .add_io_timer(self.io_data, dur); in subscribe()
72 self.io_data.co.swap(co, Ordering::Release); in subscribe()
75 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
76 io_data.schedule(); in subscribe()
|
| H A D | unix_send_to.rs | 14 io_data: &'a IoData, field
24 io_data: socket.0.as_io_data(), in new()
37 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
53 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
65 let io_data = (*self.io_data).clone(); in subscribe() localVariable
70 .add_io_timer(self.io_data, dur); in subscribe()
72 self.io_data.co.swap(co, Ordering::Release); in subscribe()
75 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
76 io_data.schedule(); in subscribe()
|
| H A D | tcp_stream_connect.rs | 16 io_data: OptionCell<IoData>, field
43 io_data: OptionCell::new(io), in new()
70 TcpStream::from_stream(stream, s.io_data.take()) in done()
82 self.io_data.io_flag.store(false, Ordering::Relaxed); in done()
94 if self.io_data.io_flag.swap(false, Ordering::Relaxed) { in done()
108 let io_data = self.io_data.clone(); in subscribe() localVariable
113 .add_io_timer(&self.io_data, dur); in subscribe()
115 io_data.co.swap(co, Ordering::Release); in subscribe()
118 if io_data.io_flag.load(Ordering::Acquire) { in subscribe()
119 return io_data.schedule(); in subscribe()
[all …]
|
| /dports/games/libretro-uae/libretro-uae-8333daa/sources/src/ |
| H A D | scsiemul.c | 630 dev->changeint = io_data; in dev_do_io()
697 io_data += 6; in dev_do_io()
710 io_data += 6; in dev_do_io()
763 put_word (io_data + 14, 0); in dev_do_io()
764 put_word (io_data + 16, 0); in dev_do_io()
765 put_word (io_data + 18, 0); in dev_do_io()
770 put_word (io_data + 28, 0); in dev_do_io()
771 put_word (io_data + 30, 0); in dev_do_io()
772 put_word (io_data + 32, 0); in dev_do_io()
789 io_data += 8; in dev_do_io()
[all …]
|
| /dports/emulators/fs-uae/fs-uae-3.1.35/src/ |
| H A D | scsiemul.cpp | 732 dev->changeint = io_data; in dev_do_io_cd()
799 io_data += 6; in dev_do_io_cd()
812 io_data += 6; in dev_do_io_cd()
865 put_word (io_data + 14, 0); in dev_do_io_cd()
866 put_word (io_data + 16, 0); in dev_do_io_cd()
867 put_word (io_data + 18, 0); in dev_do_io_cd()
872 put_word (io_data + 28, 0); in dev_do_io_cd()
873 put_word (io_data + 30, 0); in dev_do_io_cd()
874 put_word (io_data + 32, 0); in dev_do_io_cd()
891 io_data += 8; in dev_do_io_cd()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/video/fbdev/via/ |
| H A D | vt1636.c | 53 *plvds_chip_info, struct IODATA io_data) in viafb_gpio_i2c_write_mask_lvds() argument
57 index = io_data.Index; in viafb_gpio_i2c_write_mask_lvds()
60 data = (data & (~io_data.Mask)) | io_data.Data; in viafb_gpio_i2c_write_mask_lvds()
160 struct IODATA io_data; in set_dpa_vt1636() local
162 io_data.Index = 0x09; in set_dpa_vt1636()
163 io_data.Mask = 0x1F; in set_dpa_vt1636()
164 io_data.Data = p_vt1636_dpa_setting->CLK_SEL_ST1; in set_dpa_vt1636()
166 plvds_chip_info, io_data); in set_dpa_vt1636()
168 io_data.Index = 0x08; in set_dpa_vt1636()
169 io_data.Mask = 0x0F; in set_dpa_vt1636()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/video/fbdev/via/ |
| H A D | vt1636.c | 53 *plvds_chip_info, struct IODATA io_data) in viafb_gpio_i2c_write_mask_lvds() argument
57 index = io_data.Index; in viafb_gpio_i2c_write_mask_lvds()
60 data = (data & (~io_data.Mask)) | io_data.Data; in viafb_gpio_i2c_write_mask_lvds()
160 struct IODATA io_data; in set_dpa_vt1636() local
162 io_data.Index = 0x09; in set_dpa_vt1636()
163 io_data.Mask = 0x1F; in set_dpa_vt1636()
164 io_data.Data = p_vt1636_dpa_setting->CLK_SEL_ST1; in set_dpa_vt1636()
166 plvds_chip_info, io_data); in set_dpa_vt1636()
168 io_data.Index = 0x08; in set_dpa_vt1636()
169 io_data.Mask = 0x0F; in set_dpa_vt1636()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/video/fbdev/via/ |
| H A D | vt1636.c | 53 *plvds_chip_info, struct IODATA io_data) in viafb_gpio_i2c_write_mask_lvds() argument
57 index = io_data.Index; in viafb_gpio_i2c_write_mask_lvds()
60 data = (data & (~io_data.Mask)) | io_data.Data; in viafb_gpio_i2c_write_mask_lvds()
160 struct IODATA io_data; in set_dpa_vt1636() local
162 io_data.Index = 0x09; in set_dpa_vt1636()
163 io_data.Mask = 0x1F; in set_dpa_vt1636()
164 io_data.Data = p_vt1636_dpa_setting->CLK_SEL_ST1; in set_dpa_vt1636()
166 plvds_chip_info, io_data); in set_dpa_vt1636()
168 io_data.Index = 0x08; in set_dpa_vt1636()
169 io_data.Mask = 0x0F; in set_dpa_vt1636()
[all …]
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/may-0.3.17/src/io/sys/windows/net/ |
| H A D | socket_read.rs | 14 io_data: EventData,
25 io_data: EventData::new(socket as HANDLE),
34 co_io_result(&self.io_data)
47 s.get_selector().add_io_timer(&mut self.io_data, dur);
51 self.io_data.co = Some(co);
54 co_try!(s, self.io_data.co.take().expect("can't get co"), unsafe {
56 let ret = socket.read_overlapped(self.buf, self.io_data.get_overlapped());
63 cancel.set_io(CancelIoData::new(&self.io_data));
|
| H A D | udp_recv_from.rs | 16 io_data: EventData, field
27 io_data: EventData::new(socket.as_raw_socket() as HANDLE), in new()
37 let size = co_io_result(&self.io_data)?; in done()
51 s.get_selector().add_io_timer(&mut self.io_data, dur); in subscribe()
54 self.io_data.co = Some(co); in subscribe()
56 co_try!(s, self.io_data.co.take().expect("can't get co"), unsafe { in subscribe()
60 self.io_data.get_overlapped(), in subscribe()
65 cancel.set_io(CancelIoData::new(&self.io_data)); in subscribe()
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/may-0.3.17/src/io/sys/windows/pipe/ |
| H A D | pipe_read.rs | 14 io_data: EventData, field
25 io_data: EventData::new(pipe), in new()
34 match co_io_result(&self.io_data) { in done()
51 s.get_selector().add_io_timer(&mut self.io_data, dur); in subscribe()
54 self.io_data.co = Some(co); in subscribe()
57 co_try!(s, self.io_data.co.take().expect("can't get co"), unsafe { in subscribe()
59 let ret = pipe.read_overlapped(self.buf, self.io_data.get_overlapped()); in subscribe()
66 cancel.set_io(CancelIoData::new(&self.io_data)); in subscribe()
|
| /dports/editors/libreoffice/libreoffice-7.2.6.2/svtools/source/table/ |
| H A D | cellvalueconversion.cxx | 292 bool lcl_ensureNumberFormatter( CellValueConversion_Data & io_data ) in lcl_ensureNumberFormatter() argument
294 if ( io_data.bAttemptedFormatterCreation ) in lcl_ensureNumberFormatter()
295 return io_data.xNumberFormatter.is(); in lcl_ensureNumberFormatter()
296 io_data.bAttemptedFormatterCreation = true; in lcl_ensureNumberFormatter()
319 io_data.xNumberFormatter = xFormatter; in lcl_ensureNumberFormatter()
326 return io_data.xNumberFormatter.is(); in lcl_ensureNumberFormatter()
330 bool lcl_getValueNormalizer( CellValueConversion_Data & io_data, Type const & i_valueType, in lcl_getValueNormalizer() argument
334 if ( pos == io_data.aNormalizers.end() ) in lcl_getValueNormalizer()
348 o_formatter = std::make_shared<DateNormalization>( io_data.xNumberFormatter ); in lcl_getValueNormalizer()
352 o_formatter = std::make_shared<TimeNormalization>( io_data.xNumberFormatter ); in lcl_getValueNormalizer()
[all …]
|
| /dports/editors/libreoffice6/libreoffice-6.4.7.2/svtools/source/table/ |
| H A D | cellvalueconversion.cxx | 291 bool lcl_ensureNumberFormatter( CellValueConversion_Data & io_data ) in lcl_ensureNumberFormatter() argument
293 if ( io_data.bAttemptedFormatterCreation ) in lcl_ensureNumberFormatter()
294 return io_data.xNumberFormatter.is(); in lcl_ensureNumberFormatter()
295 io_data.bAttemptedFormatterCreation = true; in lcl_ensureNumberFormatter()
318 io_data.xNumberFormatter = xFormatter; in lcl_ensureNumberFormatter()
325 return io_data.xNumberFormatter.is(); in lcl_ensureNumberFormatter()
333 if ( pos == io_data.aNormalizers.end() ) in lcl_getValueNormalizer()
347 o_formatter.reset( new DateNormalization( io_data.xNumberFormatter ) ); in lcl_getValueNormalizer()
351 o_formatter.reset( new TimeNormalization( io_data.xNumberFormatter ) ); in lcl_getValueNormalizer()
361 o_formatter.reset( new DoubleNormalization( io_data.xNumberFormatter ) ); in lcl_getValueNormalizer()
[all …]
|