Home
last modified time | relevance | path

Searched refs:inputQueues (Results 1 – 8 of 8) sorted by relevance

/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/pkg/cri/server/
H A Devents_test.go33 inputQueues := map[string]*backOffQueue{
71 for k, queue := range inputQueues {
79 for k, queue := range inputQueues {
100 assert.Equal(t, len(inputQueues), len(actKeyList))
101 for k := range inputQueues {
107 for k := range inputQueues {
114 for k := range inputQueues {
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/pkg/cri/server/
H A Devents_test.go33 inputQueues := map[string]*backOffQueue{
71 for k, queue := range inputQueues {
79 for k, queue := range inputQueues {
100 assert.Equal(t, len(inputQueues), len(actKeyList))
101 for k := range inputQueues {
107 for k := range inputQueues {
114 for k := range inputQueues {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/pkg/cri/server/
H A Devents_test.go33 inputQueues := map[string]*backOffQueue{
71 for k, queue := range inputQueues {
79 for k, queue := range inputQueues {
100 assert.Equal(t, len(inputQueues), len(actKeyList))
101 for k := range inputQueues {
107 for k := range inputQueues {
114 for k := range inputQueues {
/dports/security/cryptopp/cryptopp-8.6.0/
H A Dida.cpp209 std::vector<MessageQueue> inputQueues; in ProcessInputQueues() local
212 inputQueues.swap(m_inputQueues); in ProcessInputQueues()
219 inputQueues[i].GetNextMessage(); in ProcessInputQueues()
220 inputQueues[i].TransferAllTo(*AttachedTransformation(), WordToString(inputChannelIds[i])); in ProcessInputQueues()
/dports/net-p2p/qtum/qtum-mainnet-fastlane-v0.20.3/src/cryptopp/
H A Dida.cpp214 std::vector<MessageQueue> inputQueues; in ProcessInputQueues() local
217 inputQueues.swap(m_inputQueues); in ProcessInputQueues()
224 inputQueues[i].GetNextMessage(); in ProcessInputQueues()
225 inputQueues[i].TransferAllTo(*AttachedTransformation(), WordToString(inputChannelIds[i])); in ProcessInputQueues()
/dports/emulators/citra-qt5/citra-ac98458e0/externals/cryptopp/cryptopp/
H A Dida.cpp209 std::vector<MessageQueue> inputQueues; in ProcessInputQueues() local
212 inputQueues.swap(m_inputQueues); in ProcessInputQueues()
219 inputQueues[i].GetNextMessage(); in ProcessInputQueues()
220 inputQueues[i].TransferAllTo(*AttachedTransformation(), WordToString(inputChannelIds[i])); in ProcessInputQueues()
/dports/emulators/citra/citra-ac98458e0/externals/cryptopp/cryptopp/
H A Dida.cpp209 std::vector<MessageQueue> inputQueues; in ProcessInputQueues() local
212 inputQueues.swap(m_inputQueues); in ProcessInputQueues()
219 inputQueues[i].GetNextMessage(); in ProcessInputQueues()
220 inputQueues[i].TransferAllTo(*AttachedTransformation(), WordToString(inputChannelIds[i])); in ProcessInputQueues()
/dports/sysutils/fusefs-securefs/securefs-0.12.0/external/cryptopp/
H A Dida.cpp209 std::vector<MessageQueue> inputQueues; in ProcessInputQueues() local
212 inputQueues.swap(m_inputQueues); in ProcessInputQueues()
219 inputQueues[i].GetNextMessage(); in ProcessInputQueues()
220 inputQueues[i].TransferAllTo(*AttachedTransformation(), WordToString(inputChannelIds[i])); in ProcessInputQueues()