| /dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/pubsub/internal/ |
| H A D | subscription_flow_control_test.cc | 117 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
123 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
129 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
199 EXPECT_CALL(*mock, Pull).WillOnce([&](std::int32_t max_messages) { in TEST_F()
239 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
245 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
298 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
302 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
306 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
310 .WillOnce([&](std::int32_t max_messages) { in TEST_F()
|
| /dports/audio/jack/jack2-eaedec353489f26617221d66f80fd2503953c663/common/ |
| H A D | JackMidiAsyncQueue.cpp | 26 JackMidiAsyncQueue::JackMidiAsyncQueue(size_t max_bytes, size_t max_messages) in JackMidiAsyncQueue()
|
| H A D | JackMidiAsyncWaitQueue.cpp | 29 size_t max_messages): in JackMidiAsyncWaitQueue()
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/pubsub/subscriptions/ |
| H A D | pull.py | 41 def _Run(args, max_messages, return_immediately=True): argument
|
| /dports/games/wesnoth/wesnoth-1.14.17/src/server/ |
| H A D | player.cpp | 19 … bool registered, const std::string& version, const std::string& source, const size_t max_messages, in player()
|
| /dports/audio/jack/jack2-eaedec353489f26617221d66f80fd2503953c663/linux/alsarawmidi/ |
| H A D | JackALSARawMidiInputPort.cpp | 33 size_t max_messages): in JackALSARawMidiInputPort()
|
| H A D | JackALSARawMidiOutputPort.cpp | 33 size_t max_messages): in JackALSARawMidiOutputPort()
|
| /dports/games/flare-engine/flare-engine-1.12/src/ |
| H A D | WidgetLog.h | 39 unsigned max_messages; variable
|
| /dports/devel/obby/obby-0.4.8/inc/ |
| H A D | chat.hpp | 209 chat::chat(const Buffer& buffer, unsigned int max_messages): in chat()
|
| /dports/devel/hpx/hpx-1.2.1/hpx/plugins/parcel/ |
| H A D | message_buffer.hpp | 38 message_buffer(std::size_t max_messages) in message_buffer()
|
| /dports/audio/jack/jack2-eaedec353489f26617221d66f80fd2503953c663/windows/winmme/ |
| H A D | JackWinMMEInputPort.cpp | 51 size_t max_bytes, size_t max_messages) in JackWinMMEInputPort()
|
| H A D | JackWinMMEOutputPort.cpp | 52 size_t max_messages) in JackWinMMEOutputPort()
|
| /dports/security/snort3/snort3-3.1.19.0/src/side_channel/ |
| H A D | side_channel.cc | 189 bool SideChannel::process(int max_messages) in process()
|
| /dports/www/kannel/gateway-1.4.4/gw/ |
| H A D | sms.c | 305 int max_messages, int max_octets) in sms_split()
|
| /dports/mail/isync/isync-1.4.4/src/ |
| H A D | sync.h | 56 int max_messages; // For near side only. member
|
| /dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/queue/v2018_03_28/aio/ |
| H A D | _queue_client_async.py | 627 async def peek_messages(self, max_messages=None, **kwargs): argument
|
| /dports/www/nginx-full/nchan-1.2.12/src/store/memory/ |
| H A D | store-private.h | 68 ngx_uint_t max_messages; member
108 ngx_uint_t max_messages; member
|
| /dports/www/nginx-full/nchan-1.2.12/src/subscribers/ |
| H A D | memstore_redis.c | 192 intptr_t max_messages; in sub_notify_handler() local
|
| /dports/devel/py-azure-multiapi-storage/azure-multiapi-storage-0.6.2/azure/multiapi/storagev2/queue/v2018_03_28/ |
| H A D | _queue_client.py | 712 def peek_messages(self, max_messages=None, **kwargs): argument
|
| /dports/deskutils/xmdiary/xmdiary-3.0.3/xtools/ |
| H A D | xitMsgWin.c | 133 int max_messages, in xitCreateMsgWindow()
|
| /dports/audio/zynaddsubfx/zynaddsubfx-3.0.6-rc5/rtosc/src/cpp/ |
| H A D | thread-link.cpp | 88 ThreadLink::ThreadLink(size_t max_message_length, size_t max_messages) in ThreadLink()
|
| /dports/math/pspp/pspp-1.4.1/src/data/ |
| H A D | settings.h | 63 int settings_get_viewlength (void);
|
| /dports/games/unnethack/unnethack-5.1.0-20131208/win/curses/ |
| H A D | cursmesg.c | 29 static int max_messages; variable
|
| /dports/games/vultures-eye/vulture-2.3.67/unnethack/win/curses/ |
| H A D | cursmesg.c | 29 static int max_messages; variable
|
| /dports/net-p2p/c-lightning/lightning-0.10.2/devtools/ |
| H A D | gossipwith.c | 56 static unsigned long max_messages = -1UL; variable
|