| /dports/mail/geary/geary-40.0/src/engine/imap-engine/replay-ops/ |
| H A D | imap-engine-user-close.vala | 19 public Trillian is_closing = Trillian.UNKNOWN;
37 this.is_closing = Trillian.from_boolean(closing);
42 return "is_closing: %s".printf(this.is_closing.to_string());
|
| /dports/emulators/qemu/qemu-6.2.0/python/qemu/aqmp/ |
| H A D | util.py | 105 def is_closing(writer: asyncio.StreamWriter) -> bool: function
113 return writer.is_closing()
118 return transport.is_closing()
135 while not transport.is_closing():
|
| /dports/www/mitmproxy/mitmproxy-7.0.4/mitmproxy/contentviews/ |
| H A D | xml_html.py | 65 def is_closing(self): member in Tag
75 return not self.is_closing and not self.is_self_closing
129 if a.is_opening and "\n" not in b.data and c.is_closing and a.tag == c.tag:
140 if isinstance(next1, Tag) and t.is_opening and next1.is_closing and t.tag == next1.tag:
142 if isinstance(prev1, Tag) and prev1.is_opening and t.is_closing and prev1.tag == t.tag:
191 elif token.is_closing:
|
| /dports/devel/py-aiorpcX/aiorpcX-0.22.1/aiorpcx/ |
| H A D | rawsocket.py | 100 if not self.is_closing():
113 if not self.is_closing():
132 def is_closing(self): member in RSTransport
134 return self._closed_event.is_set() or self._asyncio_transport.is_closing()
|
| /dports/finance/electrum/Electrum-4.1.5/packages/aiorpcx/ |
| H A D | rawsocket.py | 103 if not self.is_closing():
116 if not self.is_closing():
135 def is_closing(self): member in RSTransport
137 return self._closed_event.is_set() or self._asyncio_transport.is_closing()
|
| /dports/devel/py-aiorpcX-legacy/aiorpcX-0.18.7/aiorpcx/ |
| H A D | rawsocket.py | 103 if not self.is_closing():
116 if not self.is_closing():
135 def is_closing(self): member in RSTransport
137 return self._closed_event.is_set() or self._asyncio_transport.is_closing()
|
| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/src/ |
| H A D | connection_pool.cpp | 31 if (a->is_closing()) { // "a" is closed so it can't be the least busy. in least_busy_comp()
33 } else if (b->is_closing()) { // "a" is not close, but "b" is closed so "a" is less busy. in least_busy_comp()
83 if (!connection->is_closing()) { in ConnectionPool()
101 if (it == connections_.end() || (*it)->is_closing()) { in find_least_busy()
|
| H A D | connection.cpp | 239 while (remaining != 0 && !socket_->is_closing()) { in on_read()
317 if (!is_closing() && heartbeat_interval_secs_ > 0) { in restart_heartbeat_timer()
324 if (!heartbeat_outstanding_ && !socket_->is_closing()) { in on_heartbeat()
344 if (!is_closing() && heartbeat_interval_secs_ > 0 && idle_timeout_secs_ > 0) { in restart_terminate_timer()
|
| /dports/sysutils/vector/tracing-65547d8809fcc726b8187db85b23c42e32ef5dce/tracing-subscriber/src/registry/ |
| H A D | sharded.rs | 117 is_closing: bool, field
142 is_closing: false, in start_close()
301 pub(crate) fn is_closing(&mut self) { in is_closing() method
302 self.is_closing = true; in is_closing()
316 if c == 1 && self.is_closing { in drop()
|
| /dports/mail/cone/cone-1.1/libs/gpglib/ |
| H A D | gpg.c | 128 int is_closing; in find_boundary() local
164 if (is_closing) in find_boundary()
170 if (is_closing) in find_boundary()
212 int is_closing; in read_headers() local
218 b=is_boundary(*stack, buf, &is_closing); in read_headers()
244 if (is_closing) in read_headers()
250 if (is_closing) in read_headers()
1591 int is_closing; in close_mime() local
1605 if (!is_closing) in close_mime()
1879 int is_closing; in dodecrypt() local
[all …]
|
| /dports/mail/sqwebmail/sqwebmail-6.0.6/libs/gpglib/ |
| H A D | gpg.c | 128 int is_closing; in find_boundary() local
164 if (is_closing) in find_boundary()
170 if (is_closing) in find_boundary()
212 int is_closing; in read_headers() local
218 b=is_boundary(*stack, buf, &is_closing); in read_headers()
244 if (is_closing) in read_headers()
250 if (is_closing) in read_headers()
1591 int is_closing; in close_mime() local
1605 if (!is_closing) in close_mime()
1879 int is_closing; in dodecrypt() local
[all …]
|
| /dports/mail/courier/courier-0.65.3/gpglib/ |
| H A D | gpg.c | 129 int is_closing; in find_boundary() local
165 if (is_closing) in find_boundary()
171 if (is_closing) in find_boundary()
213 int is_closing; in read_headers() local
219 b=is_boundary(*stack, buf, &is_closing); in read_headers()
245 if (is_closing) in read_headers()
251 if (is_closing) in read_headers()
1578 int is_closing; in close_mime() local
1592 if (!is_closing) in close_mime()
1866 int is_closing; in dodecrypt() local
[all …]
|
| /dports/games/freeciv/freeciv-2.6.6/server/ |
| H A D | sernet.c | 290 if (pconn->used && pconn->server.is_closing) { in really_close_connections()
319 pconn->server.is_closing = TRUE; in server_conn_close_callback()
328 if (!pconn->server.is_closing in cut_lagging_connection()
377 && !pconn->server.is_closing in flush_packets()
396 if (pconn->used && !pconn->server.is_closing) { in flush_packets()
629 if ((!pconn->server.is_closing
657 && !pconn->server.is_closing
795 && !pconn->server.is_closing
866 || pconn->server.is_closing
887 && !pconn->server.is_closing
[all …]
|
| /dports/games/freeciv-nox11/freeciv-2.6.6/server/ |
| H A D | sernet.c | 290 if (pconn->used && pconn->server.is_closing) { in really_close_connections()
319 pconn->server.is_closing = TRUE; in server_conn_close_callback()
328 if (!pconn->server.is_closing in cut_lagging_connection()
377 && !pconn->server.is_closing in flush_packets()
396 if (pconn->used && !pconn->server.is_closing) { in flush_packets()
629 if ((!pconn->server.is_closing
657 && !pconn->server.is_closing
795 && !pconn->server.is_closing
866 || pconn->server.is_closing
887 && !pconn->server.is_closing
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/ |
| H A D | process_manager.cc | 184 bool is_closing = false; member
486 return (host && background_page_data_[extension_id].is_closing); in IsBackgroundHostClosing()
569 background_page_data_[extension_id].is_closing = true; in OnSuspendAck()
619 bool& is_closing = background_page_data_[extension->id()].is_closing; in CancelSuspend() local
621 if (host && is_closing) { in CancelSuspend()
622 is_closing = false; in CancelSuspend()
838 if (!background_page_data_[extension_id].is_closing) { in DecrementLazyKeepaliveCount()
883 if (host && !background_page_data_[extension_id].is_closing && in OnLazyBackgroundPageIdle()
898 if (!background_page_data_[extension_id].is_closing) { in OnLazyBackgroundPageActive()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/browser/ |
| H A D | process_manager.cc | 158 bool is_closing = false; member
461 return (host && background_page_data_[extension_id].is_closing); in IsBackgroundHostClosing()
544 background_page_data_[extension_id].is_closing = true; in OnSuspendAck()
594 bool& is_closing = background_page_data_[extension->id()].is_closing; in CancelSuspend() local
596 if (host && is_closing) { in CancelSuspend()
597 is_closing = false; in CancelSuspend()
813 if (!background_page_data_[extension_id].is_closing) { in DecrementLazyKeepaliveCount()
858 if (host && !background_page_data_[extension_id].is_closing && in OnLazyBackgroundPageIdle()
873 if (!background_page_data_[extension_id].is_closing) { in OnLazyBackgroundPageActive()
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/hyper-0.11.27/src/proto/h1/ |
| H A D | dispatch.rs | 16 is_closing: bool, field
57 is_closing: false, in new()
126 if self.is_closing { in poll_read()
227 if self.is_closing { in poll_write()
279 self.is_closing = true; in close()
285 if self.is_closing { in is_done()
|
| /dports/audio/spotifyd/spotifyd-0.3.0/cargo-crates/hyper-0.11.27/src/proto/h1/ |
| H A D | dispatch.rs | 16 is_closing: bool,
57 is_closing: false, in locktree_release_lock()
126 if self.is_closing {
227 if self.is_closing {
279 self.is_closing = true;
285 if self.is_closing {
|
| /dports/www/h2o-devel/h2o-dcc7134/deps/quicly/lib/ |
| H A D | loss.c | 25 int is_closing) in quicly_loss_init_sentmap_iter() argument
37 if (!is_closing && loss->sentmap.num_packets < 32) in quicly_loss_init_sentmap_iter()
|
| /dports/lang/rust/rustc-1.58.1-src/src/librustdoc/passes/ |
| H A D | html_tags.rs | 81 let mut is_closing = false; in extract_html_tag() localVariable
94 is_closing = true; in extract_html_tag()
105 if is_closing { in extract_html_tag()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/hyper-0.12.35/src/proto/h1/ |
| H A D | dispatch.rs | 20 is_closing: bool, field
64 is_closing: false, in new()
160 if self.is_closing { in poll_read()
260 if self.is_closing { in poll_write()
338 self.is_closing = true; in close()
344 if self.is_closing { in is_done()
|
| /dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/hyper-0.12.35/src/proto/h1/ |
| H A D | dispatch.rs | 20 is_closing: bool, field
64 is_closing: false, in new()
160 if self.is_closing { in poll_read()
260 if self.is_closing { in poll_write()
338 self.is_closing = true; in close()
344 if self.is_closing { in is_done()
|
| /dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/hyper-0.12.19/src/proto/h1/ |
| H A D | dispatch.rs | 18 is_closing: bool, field
58 is_closing: false, in new()
133 if self.is_closing { in poll_read()
234 if self.is_closing { in poll_write()
312 self.is_closing = true; in close()
318 if self.is_closing { in is_done()
|
| /dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/hyper-0.12.35/src/proto/h1/ |
| H A D | dispatch.rs | 20 is_closing: bool, field
64 is_closing: false, in new()
160 if self.is_closing { in poll_read()
260 if self.is_closing { in poll_write()
338 self.is_closing = true; in close()
344 if self.is_closing { in is_done()
|
| /dports/sysutils/rsfetch/rsfetch-2.0.0/cargo-crates/hyper-0.12.35/src/proto/h1/ |
| H A D | dispatch.rs | 20 is_closing: bool, field
64 is_closing: false, in new()
160 if self.is_closing { in poll_read()
260 if self.is_closing { in poll_write()
338 self.is_closing = true; in close()
344 if self.is_closing { in is_done()
|