| /dports/science/jstrack/jstrack/extlib/tcllib1.19/amazon-s3/ |
| H A D | S3.tcl | 349 dict set thunk blocking 0
522 fconfigure $s3 -blocking [dict get $thunk blocking]
696 if {![dict exists $myargs -blocking] || [dict get $myargs -blocking]} {
719 if {![dict exists $myargs -blocking] || [dict get $myargs -blocking]} {
1232 -blocking [dict get $myargs -blocking] \
1247 -blocking [dict get $myargs -blocking] \
1643 -result-type names -blocking $blocking]
1727 S3::Put -bucket $bucket -blocking $blocking \
1761 S3::Delete -bucket $bucket -blocking $blocking \
1838 S3::Get -bucket $bucket -blocking $blocking \
[all …]
|
| /dports/devel/tcllib/tcllib-1.20/modules/amazon-s3/ |
| H A D | S3.tcl | 349 dict set thunk blocking 0
522 fconfigure $s3 -blocking [dict get $thunk blocking]
696 if {![dict exists $myargs -blocking] || [dict get $myargs -blocking]} {
719 if {![dict exists $myargs -blocking] || [dict get $myargs -blocking]} {
1232 -blocking [dict get $myargs -blocking] \
1247 -blocking [dict get $myargs -blocking] \
1643 -result-type names -blocking $blocking]
1727 S3::Put -bucket $bucket -blocking $blocking \
1761 S3::Delete -bucket $bucket -blocking $blocking \
1838 S3::Get -bucket $bucket -blocking $blocking \
[all …]
|
| /dports/devel/tcllibc/tcllib-1.20/modules/amazon-s3/ |
| H A D | S3.tcl | 349 dict set thunk blocking 0
522 fconfigure $s3 -blocking [dict get $thunk blocking]
696 if {![dict exists $myargs -blocking] || [dict get $myargs -blocking]} {
719 if {![dict exists $myargs -blocking] || [dict get $myargs -blocking]} {
1232 -blocking [dict get $myargs -blocking] \
1247 -blocking [dict get $myargs -blocking] \
1643 -result-type names -blocking $blocking]
1727 S3::Put -bucket $bucket -blocking $blocking \
1761 S3::Delete -bucket $bucket -blocking $blocking \
1838 S3::Get -bucket $bucket -blocking $blocking \
[all …]
|
| /dports/databases/pymongo/pymongo-3.12.0/pymongo/ |
| H A D | thread_util.py | 38 def acquire(self, blocking=True, timeout=None): argument
39 if not blocking and timeout is not None:
45 if not blocking:
92 def acquire(self, blocking=True, timeout=None): argument
104 def acquire(self, blocking=True, timeout=None): argument
108 return self.semaphore.acquire(blocking, timeout)
|
| /dports/net-mgmt/observium/observium/libs/Fabiang/Xmpp/EventListener/Stream/ |
| H A D | Authentication.php | 59 protected $blocking = false; variable in Fabiang\\Xmpp\\EventListener\\Stream\\Authentication
91 $this->blocking = true;
107 $this->blocking = true;
162 $this->blocking = false;
175 $this->blocking = false;
190 return $this->blocking;
|
| /dports/misc/mxnet/incubator-mxnet-1.9.0/3rdparty/mkldnn/src/gpu/nvidia/ |
| H A D | cudnn_reorder.hpp | 49 && src_md()->format_desc.blocking.inner_nblks > 0) in valid_data_n_mem_format()
52 && dst_md()->format_desc.blocking.inner_nblks > 0) in valid_data_n_mem_format()
56 if (dst_md()->format_desc.blocking.inner_nblks > 1 in valid_data_n_mem_format()
57 || src_md()->format_desc.blocking.inner_nblks > 1) in valid_data_n_mem_format()
60 && src_md()->format_desc.blocking.inner_nblks == 1) { in valid_data_n_mem_format()
63 int blks = dst_md()->format_desc.blocking.inner_nblks; in valid_data_n_mem_format()
|
| /dports/math/onednn/oneDNN-2.5.1/src/gpu/nvidia/ |
| H A D | cudnn_reorder.hpp | 49 && src_md()->format_desc.blocking.inner_nblks > 0) in valid_data_n_mem_format()
52 && dst_md()->format_desc.blocking.inner_nblks > 0) in valid_data_n_mem_format()
56 if (dst_md()->format_desc.blocking.inner_nblks > 1 in valid_data_n_mem_format()
57 || src_md()->format_desc.blocking.inner_nblks > 1) in valid_data_n_mem_format()
60 && src_md()->format_desc.blocking.inner_nblks == 1) { in valid_data_n_mem_format()
63 int blks = dst_md()->format_desc.blocking.inner_nblks; in valid_data_n_mem_format()
|
| /dports/security/p5-Crypt-SSLeay/Crypt-SSLeay-0.72/t/ |
| H A D | 01-connect.t | 64 # RT #90803: Don't whether $sock->blocking returns 1 or 0.
66 ok( $sock->blocking, 'socket is blocking' );
67 $sock->blocking(0);
68 ok( !$sock->blocking, 'socket is now non-blocking' );
|
| /dports/www/tikiwiki/tiki-21.2/vendor_bundled/vendor/montefuscolo/xmpp/src/EventListener/Stream/ |
| H A D | Authentication.php | 59 protected $blocking = false; variable in Fabiang\\Xmpp\\EventListener\\Stream\\Authentication
91 $this->blocking = true;
107 $this->blocking = true;
162 $this->blocking = false;
175 $this->blocking = false;
190 return $this->blocking;
|
| /dports/misc/visp/visp-3.4.0/modules/core/src/display/ |
| H A D | vpDisplay_rgba.cpp | 805 …vpDisplay::getClick(const vpImage<vpRGBa> &I, bool blocking) { return vp_display_get_click(I, bloc… in getClick() argument
827 return vp_display_get_click(I, ip, blocking); in getClick()
851 bool blocking) in getClick() argument
853 return vp_display_get_click(I, ip, button, blocking); in getClick()
875 return vpDisplay::getClick(I, ip, button, blocking); in getClick()
899 bool blocking) in getClickUp() argument
901 return vp_display_get_click_up(I, ip, button, blocking); in getClickUp()
923 return vpDisplay::getClickUp(I, ip, button, blocking); in getClickUp()
1010 return vp_display_get_keyboard_event(I, blocking); in getKeyboardEvent()
1101 return vp_display_get_keyboard_event(I, key, blocking); in getKeyboardEvent()
[all …]
|
| /dports/audio/gogglesmm/gogglesmm-1.2.2/cfox/lib/ |
| H A D | FXReactor.cpp | 419 FXbool FXReactor::dispatch(FXTime blocking,FXuint flags){ in dispatch() argument
477 if(blocking<=0) return false; in dispatch()
483 interval=Math::imin(delay,blocking); in dispatch()
495 blocking-=interval; in dispatch()
518 FXbool FXReactor::dispatch(FXTime blocking,FXuint flags){ in dispatch() argument
577 if(blocking<=0) return false; in dispatch()
583 interval=Math::imin(delay,blocking); in dispatch()
595 blocking-=interval; in dispatch()
764 if(blocking<=0) return false; in dispatch()
772 interval=Math::imin(delay,blocking); in dispatch()
[all …]
|
| /dports/accessibility/wl-gammarelay-rs/wl-gammarelay-rs-0.2.1/cargo-crates/tokio-1.16.1/src/runtime/ |
| H A D | handle.rs | 1 use crate::runtime::blocking::{BlockingTask, NoopSchedule};
3 use crate::runtime::{blocking, context, driver, Spawner};
47 pub(super) blocking_spawner: blocking::Spawner,
194 self.spawn_blocking_inner(Box::new(func), blocking::Mandatory::NonMandatory, None) in spawn_blocking()
196 self.spawn_blocking_inner(func, blocking::Mandatory::NonMandatory, None) in spawn_blocking()
216 blocking::Mandatory::Mandatory,
222 blocking::Mandatory::Mandatory,
239 is_mandatory: blocking::Mandatory, in spawn_blocking_inner()
269 .spawn(blocking::Task::new(task, is_mandatory), self); in spawn_blocking_inner()
|
| /dports/security/cryptopp/cryptopp-8.6.0/ |
| H A D | channels.cpp | 150 …elPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking) in ChannelPut2() argument
163 if (m_it.Destination().ChannelPut2(m_it.Channel(), begin, length, messageEnd, blocking)) in ChannelPut2()
183 …witch::ChannelFlush(const std::string &channel, bool completeFlush, int propagation, bool blocking) in ChannelFlush() argument
196 if (m_it.Destination().ChannelFlush(m_it.Channel(), completeFlush, propagation, blocking)) in ChannelFlush()
208 … ChannelSwitch::ChannelMessageSeriesEnd(const std::string &channel, int propagation, bool blocking) in ChannelMessageSeriesEnd() argument
210 CRYPTOPP_UNUSED(blocking); in ChannelMessageSeriesEnd()
249 …difiable2(const std::string &channel, byte *inString, size_t length, int messageEnd, bool blocking) in ChannelPutModifiable2() argument
260 return target.ChannelPutModifiable2(targetChannel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
263 return ChannelPut2(channel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
|
| /dports/net-p2p/qtum/qtum-mainnet-fastlane-v0.20.3/src/cryptopp/ |
| H A D | channels.cpp | 146 …elPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking) in ChannelPut2() argument
159 if (m_it.Destination().ChannelPut2(m_it.Channel(), begin, length, messageEnd, blocking)) in ChannelPut2()
179 …witch::ChannelFlush(const std::string &channel, bool completeFlush, int propagation, bool blocking) in ChannelFlush() argument
192 if (m_it.Destination().ChannelFlush(m_it.Channel(), completeFlush, propagation, blocking)) in ChannelFlush()
204 … ChannelSwitch::ChannelMessageSeriesEnd(const std::string &channel, int propagation, bool blocking) in ChannelMessageSeriesEnd() argument
206 CRYPTOPP_UNUSED(blocking); in ChannelMessageSeriesEnd()
245 …difiable2(const std::string &channel, byte *inString, size_t length, int messageEnd, bool blocking) in ChannelPutModifiable2() argument
256 return target.ChannelPutModifiable2(targetChannel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
259 return ChannelPut2(channel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
|
| /dports/emulators/citra/citra-ac98458e0/externals/cryptopp/cryptopp/ |
| H A D | channels.cpp | 150 …elPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking) in ChannelPut2() argument
163 if (m_it.Destination().ChannelPut2(m_it.Channel(), begin, length, messageEnd, blocking)) in ChannelPut2()
183 …witch::ChannelFlush(const std::string &channel, bool completeFlush, int propagation, bool blocking) in ChannelFlush() argument
196 if (m_it.Destination().ChannelFlush(m_it.Channel(), completeFlush, propagation, blocking)) in ChannelFlush()
208 … ChannelSwitch::ChannelMessageSeriesEnd(const std::string &channel, int propagation, bool blocking) in ChannelMessageSeriesEnd() argument
210 CRYPTOPP_UNUSED(blocking); in ChannelMessageSeriesEnd()
249 …difiable2(const std::string &channel, byte *inString, size_t length, int messageEnd, bool blocking) in ChannelPutModifiable2() argument
260 return target.ChannelPutModifiable2(targetChannel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
263 return ChannelPut2(channel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
|
| /dports/net/p5-IO-Socket-Socks/IO-Socket-Socks-0.74/ |
| H A D | Changes | 20 - Fix non-blocking connections when IO::Socket::INET used as base class
25 - Add support for non-blocking multi-homed connect to proxy
74 - Return socket to non-blocking state after new_from_fd if socket was non-blocking before
78 - Added support for non-blocking clients accept on the server side
83 - Non-blocking connect on BSD systems could break connection with ENOTCONN error
88 - Added support for non-blocking connect/bind operations on the client side
107 …- blocking reading and writing replaced by non-blocking equivalents, so `Timeout' option now docum…
|
| /dports/emulators/citra-qt5/citra-ac98458e0/externals/cryptopp/cryptopp/ |
| H A D | channels.cpp | 150 …elPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking) in ChannelPut2() argument
163 if (m_it.Destination().ChannelPut2(m_it.Channel(), begin, length, messageEnd, blocking)) in ChannelPut2()
183 …witch::ChannelFlush(const std::string &channel, bool completeFlush, int propagation, bool blocking) in ChannelFlush() argument
196 if (m_it.Destination().ChannelFlush(m_it.Channel(), completeFlush, propagation, blocking)) in ChannelFlush()
208 … ChannelSwitch::ChannelMessageSeriesEnd(const std::string &channel, int propagation, bool blocking) in ChannelMessageSeriesEnd() argument
210 CRYPTOPP_UNUSED(blocking); in ChannelMessageSeriesEnd()
249 …difiable2(const std::string &channel, byte *inString, size_t length, int messageEnd, bool blocking) in ChannelPutModifiable2() argument
260 return target.ChannelPutModifiable2(targetChannel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
263 return ChannelPut2(channel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/js/src/jit/ |
| H A D | MoveResolver.cpp | 154 PendingMove* blocking = findBlockingMove(stack.peekBack()); in resolve() local
156 if (blocking) { in resolve()
158 PendingMove* cycled = findCycledMove(&stackiter, stack.end(), blocking); in resolve()
168 cycled = findCycledMove(&stackiter, stack.end(), blocking); in resolve()
171 blocking->setCycleBegin(pm->type(), curCycles_); in resolve()
173 pending_.remove(blocking); in resolve()
174 stack.pushBack(blocking); in resolve()
178 pending_.remove(blocking); in resolve()
179 stack.pushBack(blocking); in resolve()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/dbus-0.9.5/src/blocking/ |
| H A D | generated_org_freedesktop_standard_interfaces.rs | 5 use crate::blocking;
13 impl<'a, T: blocking::BlockingSender, C: ::std::ops::Deref<Target=T>> Properties for blocking::Prox…
64 impl<'a, T: blocking::BlockingSender, C: ::std::ops::Deref<Target=T>> Introspectable for blocking::…
77 impl<'a, T: blocking::BlockingSender, C: ::std::ops::Deref<Target=T>> Peer for blocking::Proxy<'a, …
93 impl<'a, T: blocking::BlockingSender, C: ::std::ops::Deref<Target=T>> ObjectManager for blocking::P…
|
| /dports/sysutils/fusefs-securefs/securefs-0.12.0/external/cryptopp/ |
| H A D | channels.cpp | 150 …elPut2(const std::string &channel, const byte *begin, size_t length, int messageEnd, bool blocking) in ChannelPut2() argument
163 if (m_it.Destination().ChannelPut2(m_it.Channel(), begin, length, messageEnd, blocking)) in ChannelPut2()
183 …witch::ChannelFlush(const std::string &channel, bool completeFlush, int propagation, bool blocking) in ChannelFlush() argument
196 if (m_it.Destination().ChannelFlush(m_it.Channel(), completeFlush, propagation, blocking)) in ChannelFlush()
208 … ChannelSwitch::ChannelMessageSeriesEnd(const std::string &channel, int propagation, bool blocking) in ChannelMessageSeriesEnd() argument
210 CRYPTOPP_UNUSED(blocking); in ChannelMessageSeriesEnd()
249 …difiable2(const std::string &channel, byte *inString, size_t length, int messageEnd, bool blocking) in ChannelPutModifiable2() argument
260 return target.ChannelPutModifiable2(targetChannel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
263 return ChannelPut2(channel, inString, length, messageEnd, blocking); in ChannelPutModifiable2()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/mozjs-45/extract/js/src/jit/ |
| H A D | MoveResolver.cpp | 152 PendingMove* blocking = findBlockingMove(stack.peekBack()); in resolve() local
154 if (blocking) { in resolve()
156 PendingMove* cycled = findCycledMove(&stackiter, stack.end(), blocking); in resolve()
166 cycled = findCycledMove(&stackiter, stack.end(), blocking); in resolve()
169 blocking->setCycleBegin(pm->type(), curCycles_); in resolve()
171 pending_.remove(blocking); in resolve()
172 stack.pushBack(blocking); in resolve()
176 pending_.remove(blocking); in resolve()
177 stack.pushBack(blocking); in resolve()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/apr/file_io/os2/ |
| H A D | pipe.c | 87 (*in)->blocking = BLK_ON; in apr_file_pipe_create()
99 (*out)->blocking = BLK_ON; in apr_file_pipe_create()
121 if (thepipe->blocking != BLK_OFF) { in apr_file_pipe_timeout_set()
122 thepipe->blocking = BLK_OFF; in apr_file_pipe_timeout_set()
127 if (thepipe->blocking != BLK_ON) { in apr_file_pipe_timeout_set()
128 thepipe->blocking = BLK_ON; in apr_file_pipe_timeout_set()
158 (*file)->blocking = BLK_UNKNOWN; /* app needs to make a timeout call */ in apr_os_pipe_put_ex()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/apr/file_io/netware/ |
| H A D | pipe.c | 45 thepipe->blocking = BLK_ON; in pipeblock()
69 thepipe->blocking = BLK_OFF; in pipenonblock()
78 if (thepipe->blocking != BLK_OFF) { /* blocking or unknown state */ in apr_file_pipe_timeout_set()
83 if (thepipe->blocking != BLK_ON) { /* non-blocking or unknown state */ in apr_file_pipe_timeout_set()
112 (*file)->blocking = BLK_UNKNOWN; /* app needs to make a timeout call */ in apr_os_pipe_put_ex()
162 (*in)->blocking = in apr_file_pipe_create()
163 (*out)->blocking = BLK_ON; in apr_file_pipe_create()
|
| /dports/science/jstrack/jstrack/extlib/tcllib1.19/ident/ |
| H A D | ident.tcl | 69 set blocking [string equal $command ""]
73 if {$blocking} {
80 fconfigure $sock -encoding binary -buffering line -blocking $blocking
82 if {$blocking} {
|
| /dports/sysutils/consul_exporter/consul_exporter-0.3.0/vendor/github.com/hashicorp/raft/ |
| H A D | observer.go | 32 blocking bool member
53 func NewObserver(channel chan Observation, blocking bool, filter FilterFn) *Observer {
56 blocking: blocking,
103 if or.blocking {
|