| /dports/audio/cyanrip/cyanrip-0.7.0/src/ |
| H A D | fifo_template.c | 6 int max_queued; member
51 ctx->max_queued = max_queued; in RENAME()
64 if (!ctx->max_queued) in RENAME()
66 else if (ctx->max_queued > 0) in RENAME()
67 ret = ctx->num_queued > (ctx->max_queued + 1); in RENAME()
91 int ret = ctx->max_queued == -1 ? INT_MAX : ctx->max_queued; in RENAME()
100 ctx->max_queued = max_queued; in RENAME()
123 if (ctx->max_queued == 0) in RENAME()
127 if (in && (ctx->max_queued != -1) && in RENAME()
128 (ctx->num_queued > (ctx->max_queued + 1))) { in RENAME()
[all …]
|
| H A D | fifo_template.h | 2 AVBufferRef *RENAME(fifo_create)(int max_queued, FNAME block_flags); /* -1 = INF, 0 = none */
3 AVBufferRef *RENAME(fifo_ref)(AVBufferRef *src, int max_queued, FNAME block_flags);
11 void RENAME(fifo_set_max_queued)(AVBufferRef *dst, int max_queued);
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/zbus-2.1.1/src/ |
| H A D | connection_builder.rs | 46 max_queued: Option<usize>, field
161 pub fn max_queued(mut self, max: usize) -> Self { in max_queued() method
162 self.max_queued = Some(max); in max_queued()
298 conn.set_max_queued(self.max_queued.unwrap_or(DEFAULT_MAX_QUEUED)); in build()
327 max_queued: None, in new()
|
| H A D | connection.rs | 603 pub fn max_queued(&self) -> usize { in max_queued() method
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/zbus-1.9.1/src/ |
| H A D | connection.rs | 41 max_queued: RwLock<usize>, field
192 pub fn max_queued(&self) -> usize { in max_queued() method
193 *self.0.max_queued.read().expect(LOCK_FAIL_MSG) in max_queued()
214 *self.0.max_queued.write().expect(LOCK_FAIL_MSG) = max; in set_max_queued()
279 } else if queue.len() < *self.0.max_queued.read().expect(LOCK_FAIL_MSG) { in receive_specific()
555 max_queued: RwLock::new(DEFAULT_MAX_QUEUED), in new_authenticated_unix_()
|
| /dports/security/openvpn/openvpn-2.5.6/src/openvpn/ |
| H A D | mbuf.h | 63 unsigned int max_queued; member
96 return (int) ms->max_queued; in mbuf_maximum_queued()
|
| H A D | mbuf.c | 107 if (++ms->len > ms->max_queued) in mbuf_add_item()
109 ms->max_queued = ms->len; in mbuf_add_item()
|
| /dports/security/openvpn-devel/openvpn-0033811e0215af76f469d78912c95a2f59813454/src/openvpn/ |
| H A D | mbuf.h | 61 unsigned int max_queued; member
94 return (int) ms->max_queued; in mbuf_maximum_queued()
|
| H A D | mbuf.c | 105 if (++ms->len > ms->max_queued) in mbuf_add_item()
107 ms->max_queued = ms->len; in mbuf_add_item()
|
| /dports/security/openvpn-mbedtls/openvpn-2.5.6/src/openvpn/ |
| H A D | mbuf.h | 63 unsigned int max_queued; member
96 return (int) ms->max_queued; in mbuf_maximum_queued()
|
| H A D | mbuf.c | 107 if (++ms->len > ms->max_queued) in mbuf_add_item()
109 ms->max_queued = ms->len; in mbuf_add_item()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/zbus-1.9.1/src/azync/ |
| H A D | connection.rs | 146 max_queued: usize, field
254 if self.incoming_queue.len() + tmp_queue.len() < self.max_queued() { in call_method()
370 pub fn max_queued(&self) -> usize { in max_queued() function
371 self.max_queued in max_queued()
394 self.max_queued = max; in set_max_queued()
422 max_queued: DEFAULT_MAX_QUEUED, in new_authenticated()
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/zbus-2.1.1/src/blocking/ |
| H A D | connection_builder.rs | 107 pub fn max_queued(self, max: usize) -> Self { in max_queued() method
108 Self(self.0.max_queued(max)) in max_queued()
|
| H A D | connection.rs | 35 pub fn max_queued(&self) -> usize { in max_queued() method
36 self.inner.max_queued() in max_queued()
|
| /dports/textproc/wiggle/wiggle-1.3/tests/linux/raid1-A/ |
| H A D | patch | 25 + if (conf->pending_count >= max_queued) {
28 + conf->pending_count < max_queued);
|
| H A D | merge | 527 static int max_queued = INT_MAX;
815 if (conf->pending_count >= max_queued) {
818 conf->pending_count < max_queued);
1037 conf->pending_count >= max_queued)
2329 module_param(max_queued, int, S_IRUGO|S_IWUSR);
|
| H A D | orig | 527 static int max_queued = INT_MAX;
992 conf->pending_count >= max_queued)
2273 module_param(max_queued, int, S_IRUGO|S_IWUSR);
|
| /dports/www/domoticz/domoticz-2020.2/extern/mosquitto/src/ |
| H A D | database.c | 31 static int max_queued = 100; variable
78 if(max_queued == 0 && max_queued_bytes == 0){ in db__ready_for_queue()
98 bool valid_count = source_count - adjust_count < max_queued; in db__ready_for_queue()
103 if(max_queued == 0){ in db__ready_for_queue()
1151 max_queued = queued; in db__limits_set()
|
| /dports/devel/libvirt/libvirt-7.10.0/src/qemu/ |
| H A D | test_libvirtd_qemu.aug.in | 88 { "max_queued" = "0" }
|
| H A D | libvirtd_qemu.aug | 119 let rpc_entry = int_entry "max_queued"
|
| /dports/net/pacemaker1/pacemaker-Pacemaker-1.1.24/doc/Clusters_from_Scratch/ro-RO/ |
| H A D | Ap-Cman.po | 175 " max_queued: 10\n"
212 " max_queued: 10\n"
|
| /dports/net/pacemaker1/pacemaker-Pacemaker-1.1.24/extra/ |
| H A D | cluster-init | 671 max_queued: 10
|
| /dports/deskutils/egroupware/egroupware/api/js/etemplate/ |
| H A D | et2_extension_nextmatch.ts | 1025 const max_queued = 50; constant
1041 if(this._queued_refreshes.length >= max_queued || _type == et2_nextmatch.EDIT || !_type)
|
| /dports/devel/libvirt/libvirt-7.10.0/po/ |
| H A D | hi.po | 21425 "cannot acquire state change lock (held by agent=%s) due to max_queued limit"
21426 msgstr "स्थिति परिवर्तन लॉक पा नहीं सकता है max_queued सीमा के कारण"
21430 msgstr "स्थिति परिवर्तन लॉक पा नहीं सकता है max_queued सीमा के कारण"
21435 "max_queued limit"
21436 msgstr "स्थिति परिवर्तन लॉक पा नहीं सकता है max_queued सीमा के कारण"
21444 "cannot acquire state change lock (held by monitor=%s) due to max_queued limit"
21445 msgstr "स्थिति परिवर्तन लॉक पा नहीं सकता है max_queued सीमा के कारण"
21447 msgid "cannot acquire state change lock due to max_queued limit"
21448 msgstr "स्थिति परिवर्तन लॉक पा नहीं सकता है max_queued सीमा के कारण"
|
| H A D | kn.po | 21627 "cannot acquire state change lock (held by agent=%s) due to max_queued limit"
21628 msgstr "max_queued ಮಿತಿಯ ಕಾರಣದಿಂದಾಗಿ ಸ್ಥಿತಿ ಬದಲಾವಣೆ ಲಾಕ್ ಅನ್ನು ಪಡೆಯಲು ಸಾಧ್ಯವಾಗಿಲ್ಲ"
21632 msgstr "max_queued ಮಿತಿಯ ಕಾರಣದಿಂದಾಗಿ ಸ್ಥಿತಿ ಬದಲಾವಣೆ ಲಾಕ್ ಅನ್ನು ಪಡೆಯಲು ಸಾಧ್ಯವಾಗಿಲ್ಲ"
21637 "max_queued limit"
21638 msgstr "max_queued ಮಿತಿಯ ಕಾರಣದಿಂದಾಗಿ ಸ್ಥಿತಿ ಬದಲಾವಣೆ ಲಾಕ್ ಅನ್ನು ಪಡೆಯಲು ಸಾಧ್ಯವಾಗಿಲ್ಲ"
21646 "cannot acquire state change lock (held by monitor=%s) due to max_queued limit"
21647 msgstr "max_queued ಮಿತಿಯ ಕಾರಣದಿಂದಾಗಿ ಸ್ಥಿತಿ ಬದಲಾವಣೆ ಲಾಕ್ ಅನ್ನು ಪಡೆಯಲು ಸಾಧ್ಯವಾಗಿಲ್ಲ"
21649 msgid "cannot acquire state change lock due to max_queued limit"
21650 msgstr "max_queued ಮಿತಿಯ ಕಾರಣದಿಂದಾಗಿ ಸ್ಥಿತಿ ಬದಲಾವಣೆ ಲಾಕ್ ಅನ್ನು ಪಡೆಯಲು ಸಾಧ್ಯವಾಗಿಲ್ಲ"
|