| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | v1_decoder.cpp | 46 int rc = _in_progress.init (); in v1_decoder_t()
55 const int rc = _in_progress.close (); in ~v1_decoder_t()
79 int rc = _in_progress.close (); in one_byte_size_ready()
81 rc = _in_progress.init_size (*_tmpbuf - 1); in one_byte_size_ready()
84 rc = _in_progress.init (); in one_byte_size_ready()
124 int rc = _in_progress.close (); in eight_byte_size_ready()
126 rc = _in_progress.init_size (msg_size); in eight_byte_size_ready()
129 rc = _in_progress.init (); in eight_byte_size_ready()
142 _in_progress.set_flags (_tmpbuf[0] & msg_t::more); in flags_ready()
144 next_step (_in_progress.data (), _in_progress.size (), in flags_ready()
|
| H A D | v2_decoder.cpp | 49 int rc = _in_progress.init (); in v2_decoder_t()
58 const int rc = _in_progress.close (); in ~v2_decoder_t()
110 int rc = _in_progress.close (); in size_ready()
122 rc = _in_progress.init_size (static_cast<size_t> (msg_size_)); in size_ready()
128 _in_progress.init (const_cast<unsigned char *> (read_pos_), in size_ready()
134 if (_in_progress.is_zcmsg ()) { in size_ready()
142 rc = _in_progress.init (); in size_ready()
148 _in_progress.set_flags (_msg_flags); in size_ready()
155 next_step (_in_progress.data (), _in_progress.size (), in size_ready()
|
| H A D | ws_decoder.cpp | 53 int rc = _in_progress.init (); in ws_decoder_t()
62 const int rc = _in_progress.close (); in ~ws_decoder_t()
208 int rc = _in_progress.close (); in size_ready()
223 rc = _in_progress.init_size (static_cast<size_t> (_size)); in size_ready()
228 rc = _in_progress.init ( in size_ready()
234 if (_in_progress.is_zcmsg ()) { in size_ready()
242 rc = _in_progress.init (); in size_ready()
248 _in_progress.set_flags (_msg_flags); in size_ready()
255 next_step (_in_progress.data (), _in_progress.size (), in size_ready()
267 static_cast<unsigned char *> (_in_progress.data ()); in message_ready()
|
| H A D | encoder.hpp | 64 _in_progress (NULL) in encoder_base_t()
89 int rc = _in_progress->close (); in encode()
91 rc = _in_progress->init (); in encode()
93 _in_progress = NULL; in encode()
132 _in_progress = msg_; in load_msg()
153 msg_t *in_progress () { return _in_progress; } in in_progress()
172 msg_t *_in_progress; member in zmq::encoder_base_t
|
| H A D | raw_decoder.cpp | 39 const int rc = _in_progress.init (); in raw_decoder_t()
45 const int rc = _in_progress.close (); in ~raw_decoder_t()
60 _in_progress.init (const_cast<unsigned char *> (data_), size_, in decode()
66 if (_in_progress.is_zcmsg ()) { in decode()
|
| H A D | v1_decoder.hpp | 45 msg_t *msg () { return &_in_progress; } in msg()
54 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| H A D | raw_decoder.hpp | 54 msg_t *msg () { return &_in_progress; } in msg()
59 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| H A D | v2_decoder.hpp | 49 msg_t *msg () { return &_in_progress; } in msg()
61 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| H A D | ws_decoder.hpp | 53 msg_t *msg () { return &_in_progress; } in msg()
68 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/ |
| H A D | v1_decoder.cpp | 46 int rc = _in_progress.init (); in v1_decoder_t()
55 const int rc = _in_progress.close (); in ~v1_decoder_t()
79 int rc = _in_progress.close (); in one_byte_size_ready()
81 rc = _in_progress.init_size (*_tmpbuf - 1); in one_byte_size_ready()
84 rc = _in_progress.init (); in one_byte_size_ready()
124 int rc = _in_progress.close (); in eight_byte_size_ready()
126 rc = _in_progress.init_size (msg_size); in eight_byte_size_ready()
129 rc = _in_progress.init (); in eight_byte_size_ready()
142 _in_progress.set_flags (_tmpbuf[0] & msg_t::more); in flags_ready()
144 next_step (_in_progress.data (), _in_progress.size (), in flags_ready()
|
| H A D | v2_decoder.cpp | 49 int rc = _in_progress.init (); in v2_decoder_t()
58 const int rc = _in_progress.close (); in ~v2_decoder_t()
110 int rc = _in_progress.close (); in size_ready()
122 rc = _in_progress.init_size (static_cast<size_t> (msg_size_)); in size_ready()
128 _in_progress.init (const_cast<unsigned char *> (read_pos_), in size_ready()
134 if (_in_progress.is_zcmsg ()) { in size_ready()
142 rc = _in_progress.init (); in size_ready()
148 _in_progress.set_flags (_msg_flags); in size_ready()
155 next_step (_in_progress.data (), _in_progress.size (), in size_ready()
|
| H A D | ws_decoder.cpp | 53 int rc = _in_progress.init (); in ws_decoder_t()
62 const int rc = _in_progress.close (); in ~ws_decoder_t()
208 int rc = _in_progress.close (); in size_ready()
223 rc = _in_progress.init_size (static_cast<size_t> (_size)); in size_ready()
228 rc = _in_progress.init ( in size_ready()
234 if (_in_progress.is_zcmsg ()) { in size_ready()
242 rc = _in_progress.init (); in size_ready()
248 _in_progress.set_flags (_msg_flags); in size_ready()
255 next_step (_in_progress.data (), _in_progress.size (), in size_ready()
267 static_cast<unsigned char *> (_in_progress.data ()); in message_ready()
|
| H A D | encoder.hpp | 64 _in_progress (NULL) in encoder_base_t()
89 int rc = _in_progress->close (); in encode()
91 rc = _in_progress->init (); in encode()
93 _in_progress = NULL; in encode()
132 _in_progress = msg_; in load_msg()
153 msg_t *in_progress () { return _in_progress; } in in_progress()
172 msg_t *_in_progress; member in zmq::encoder_base_t
|
| H A D | raw_decoder.cpp | 39 const int rc = _in_progress.init (); in raw_decoder_t()
45 const int rc = _in_progress.close (); in ~raw_decoder_t()
60 _in_progress.init (const_cast<unsigned char *> (data_), size_, in decode()
66 if (_in_progress.is_zcmsg ()) { in decode()
|
| H A D | v1_decoder.hpp | 45 msg_t *msg () { return &_in_progress; } in msg()
54 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| H A D | raw_decoder.hpp | 54 msg_t *msg () { return &_in_progress; } in msg()
59 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| H A D | v2_decoder.hpp | 49 msg_t *msg () { return &_in_progress; } in msg()
61 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| H A D | ws_decoder.hpp | 53 msg_t *msg () { return &_in_progress; } in msg()
68 msg_t _in_progress; member in zmq::ZMQ_FINAL
|
| /dports/databases/p5-MR-Tarantool/MR-Tarantool-0.0.24/lib/MR/IProto/Connection/ |
| H A D | Async.pm | 32 has _in_progress => (
77 if( $self->_in_progress < $self->max_parallel ) {
78 $self->_in_progress( $self->_in_progress + 1 );
159 while( $self->_in_progress < $self->max_parallel && (my $task = shift @{ $self->_queue }) ) {
160 $self->_in_progress( $self->_in_progress + 1 );
172 $self->_in_progress( $self->_in_progress - 1 );
203 $self->_in_progress( $self->_in_progress - 1 );
235 $self->_in_progress( $self->_in_progress - 1 );
|
| /dports/www/Stikked/Stikked-0.13.0/htdocs/system/core/ |
| H A D | Hooks.php | 81 protected $_in_progress = FALSE; variable in CI_Hooks
187 if ($this->_in_progress === TRUE)
219 $this->_in_progress = TRUE;
233 return $this->_in_progress = FALSE;
242 return $this->_in_progress = FALSE;
256 return $this->_in_progress = FALSE;
262 $this->_in_progress = FALSE;
|
| /dports/www/codeigniter/CodeIgniter-3.1.11/system/core/ |
| H A D | Hooks.php | 81 protected $_in_progress = FALSE; variable in CI_Hooks
187 if ($this->_in_progress === TRUE)
219 $this->_in_progress = TRUE;
233 return $this->_in_progress = FALSE;
242 return $this->_in_progress = FALSE;
256 return $this->_in_progress = FALSE;
262 $this->_in_progress = FALSE;
|
| /dports/www/qutebrowser/qutebrowser-2.4.0/qutebrowser/components/utils/ |
| H A D | blockutils.py | 70 self._in_progress: List[downloads.TempDownload] = []
91 if not self._in_progress and not self._finished:
116 self._in_progress.append(download)
135 self._in_progress.append(download)
144 self._in_progress.remove(download)
154 if not self._in_progress and self._finished_registering_downloads:
|
| /dports/www/qutebrowser/qutebrowser-2.4.0/tests/unit/components/ |
| H A D | test_braveadblock.py | 224 while downloads._in_progress:
225 current_download = downloads._in_progress[0]
254 while downloads._in_progress:
255 current_download = downloads._in_progress[0]
295 while downloads._in_progress:
296 current_download = downloads._in_progress[0]
312 while downloads._in_progress:
313 current_download = downloads._in_progress[0]
|
| H A D | test_hostblock.py | 264 while downloads._in_progress:
265 current_download = downloads._in_progress[0]
316 while downloads._in_progress:
317 current_download = downloads._in_progress[0]
387 while downloads._in_progress:
388 current_download = downloads._in_progress[0]
424 current_download = downloads._in_progress[0]
|
| /dports/databases/p5-MR-Tarantool/MR-Tarantool-0.0.24/lib/MR/ |
| H A D | IProto.pm | 194 has _in_progress => (
506 if( $self->_in_progress < $self->max_parallel ) {
507 $self->_in_progress( $self->_in_progress + 1 );
524 $self->_in_progress( $self->_in_progress - 1 );
|