| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-proto/src/ |
| H A D | channel.rs | 121 .map_err(|_| Error::ChannelClosed) in poll_ready()
127 return Err(Error::ChannelClosed); in start_send()
145 .map_err(|_| Error::ChannelClosed) in start_send()
152 .map_err(|_| Error::ChannelClosed) in poll_flush()
159 .map_err(|_| Error::ChannelClosed) in poll_close()
342 return Err(Error::ChannelClosed); in new_circ()
356 .map_err(|_| Error::ChannelClosed)?; in new_circ()
357 let (id, circ_unique_id) = rx.await.map_err(|_| Error::ChannelClosed)??; in new_circ()
387 .map_err(|_| Error::ChannelClosed)?; in close_circuit()
|
| /dports/devel/py-pika/pika-1.1.0/tests/unit/ |
| H A D | exceptions_test.py | 41 exc = exceptions.ChannelClosed(9, 'args abcd')
46 exc = exceptions.ChannelClosed(reply_code=9, reply_text='kwargs abcd')
51 exc = exceptions.ChannelClosed(200, 'all is swell')
|
| /dports/devel/llvm90/llvm-9.0.1.src/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 118 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
119 InQueue->setReadError(ChannelClosed); in close()
120 InQueue->setWriteError(ChannelClosed); in close()
121 OutQueue->setReadError(ChannelClosed); in close()
122 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/llvm80/llvm-8.0.1.src/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 119 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
120 InQueue->setReadError(ChannelClosed); in close()
121 InQueue->setWriteError(ChannelClosed); in close()
122 OutQueue->setReadError(ChannelClosed); in close()
123 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/llvm70/llvm-7.0.1.src/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 119 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
120 InQueue->setReadError(ChannelClosed); in close()
121 InQueue->setWriteError(ChannelClosed); in close()
122 OutQueue->setReadError(ChannelClosed); in close()
123 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/llvm11/llvm-11.0.1.src/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/llvm12/llvm-project-12.0.1.src/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/llvm10/llvm-10.0.1.src/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/lang/rust/rustc-1.58.1-src/src/llvm-project/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/wasi-compiler-rt12/llvm-project-12.0.1.src/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/wasi-compiler-rt13/llvm-project-13.0.1.src/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/llvm/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/tinygo/tinygo-0.14.1/llvm-project/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/wasi-libcxx/llvm-project-13.0.1.src/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/graphics/llvm-mesa/llvm-13.0.1.src/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/llvm13/llvm-project-13.0.1.src/llvm/unittests/ExecutionEngine/Orc/ |
| H A D | QueueChannel.h | 146 auto ChannelClosed = []() { return make_error<QueueChannelClosedError>(); }; in close()
147 InQueue->setReadError(ChannelClosed); in close()
148 InQueue->setWriteError(ChannelClosed); in close()
149 OutQueue->setReadError(ChannelClosed); in close()
150 OutQueue->setWriteError(ChannelClosed); in close()
|
| /dports/devel/py-pika/pika-1.1.0/pika/ |
| H A D | exceptions.py | 148 class ChannelClosed(AMQPChannelError): class
165 super(ChannelClosed, self).__init__(int(reply_code), str(reply_text))
188 class ChannelClosedByBroker(ChannelClosed):
197 class ChannelClosedByClient(ChannelClosed):
|
| /dports/www/firefox-esr/firefox-91.8.0/netwerk/protocol/http/ |
| H A D | BackgroundDataBridgeChild.cpp | 30 if (mBgChild->ChannelClosed()) { in RecvOnTransportAndData()
47 if (mBgChild->ChannelClosed()) { in RecvOnStopRequest()
|
| /dports/www/firefox/firefox-99.0/netwerk/protocol/http/ |
| H A D | BackgroundDataBridgeChild.cpp | 30 if (mBgChild->ChannelClosed()) { in RecvOnTransportAndData()
47 if (mBgChild->ChannelClosed()) { in RecvOnStopRequest()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/netwerk/protocol/http/ |
| H A D | BackgroundDataBridgeChild.cpp | 30 if (mBgChild->ChannelClosed()) { in RecvOnTransportAndData()
47 if (mBgChild->ChannelClosed()) { in RecvOnStopRequest()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/ipc/glue/ |
| H A D | MessageLink.cpp | 128 while (mChan->mChannelState == ChannelClosed) { in Open()
223 mChan->mChannelState = ChannelClosed; in SendClose()
235 return mChan->mChannelState == ChannelClosed; in Unsound_IsClosed()
362 mChan->mChannelState = ChannelClosed; in OnCloseChannel()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/ipc/glue/ |
| H A D | MessageLink.cpp | 129 while (mChan->mChannelState == ChannelClosed) { in Open()
228 mChan->mChannelState = ChannelClosed; in SendClose()
240 return mChan->mChannelState == ChannelClosed; in Unsound_IsClosed()
371 mChan->mChannelState = ChannelClosed; in OnCloseChannel()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/ipc/glue/ |
| H A D | MessageLink.cpp | 222 mChan->mChannelState = ChannelClosed; in SendClose()
237 return mChan->mChannelState == ChannelClosed; in Unsound_IsClosed()
370 mChan->mChannelState = ChannelClosed; in OnCloseChannel()
|
| /dports/net/py-txamqp/txAMQP-0.8.2/src/txamqp/test/ |
| H A D | test_exchange.py | 30 from txamqp.client import ChannelClosed, ConnectionClosed
241 except ChannelClosed as e:
362 except ChannelClosed as e:
|