/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/ |
H A D | benchmark_test.go | 58 n, delay := s.profile(s.inMiddleThird(), maxMessages) 78 …defaultReceiveProfile := func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, … 97 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 100 * tim… 101 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 1 * time.… 113 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 114 return maxMessages, 1 * time.Second 120 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 129 n := maxMessages 145 return maxMessages, d 240 sub.preReceiveBatchHook = func(maxMessages int) { [all …]
|
H A D | pubsub_test.go | 71 func (s *driverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) { 75 ms := s.grabQueue(maxMessages) 86 func (s *driverSub) grabQueue(maxMessages int) []*driver.Message { 89 if len(s.q) <= maxMessages { 94 ms := s.q[:maxMessages] 95 s.q = s.q[maxMessages:] 243 func (b blockingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, e… 355 sub.preReceiveBatchHook = func(maxMessages int) { 358 lastMaxMessages = maxMessages 451 func (t *failSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) {
|
H A D | acks_test.go | 38 func (s *ackingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, er… 39 if len(s.q) <= maxMessages { 44 ms := s.q[:maxMessages] 45 s.q = s.q[maxMessages:] 358 func (s *callbackDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, …
|
/dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/ |
H A D | benchmark_test.go | 54 n, delay := s.profile(s.inMiddleThird(), maxMessages) 74 …defaultReceiveProfile := func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, … 98 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 100 * tim… 102 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 1 * time.… 114 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 115 return maxMessages, 1 * time.Second 121 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 130 n := maxMessages 146 return maxMessages, d 241 sub.preReceiveBatchHook = func(maxMessages int) { [all …]
|
H A D | pubsub_test.go | 73 func (s *driverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) { 77 ms := s.grabQueue(maxMessages) 88 func (s *driverSub) grabQueue(maxMessages int) []*driver.Message { 91 if len(s.q) <= maxMessages { 96 ms := s.q[:maxMessages] 97 s.q = s.q[maxMessages:] 241 func (b blockingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, e… 386 func (t *failSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) {
|
H A D | acks_test.go | 38 func (s *ackingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, er… 39 if len(s.q) <= maxMessages { 44 ms := s.q[:maxMessages] 45 s.q = s.q[maxMessages:] 358 func (s *callbackDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, …
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/ |
H A D | benchmark_test.go | 58 n, delay := s.profile(s.inMiddleThird(), maxMessages) 78 …defaultReceiveProfile := func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, … 97 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 100 * tim… 101 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 1 * time.… 113 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 114 return maxMessages, 1 * time.Second 120 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 129 n := maxMessages 145 return maxMessages, d 240 sub.preReceiveBatchHook = func(maxMessages int) { [all …]
|
H A D | pubsub_test.go | 71 func (s *driverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) { 75 ms := s.grabQueue(maxMessages) 86 func (s *driverSub) grabQueue(maxMessages int) []*driver.Message { 89 if len(s.q) <= maxMessages { 94 ms := s.q[:maxMessages] 95 s.q = s.q[maxMessages:] 239 func (b blockingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, e… 351 sub.preReceiveBatchHook = func(maxMessages int) { 354 lastMaxMessages = maxMessages 447 func (t *failSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) {
|
H A D | acks_test.go | 38 func (s *ackingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, er… 39 if len(s.q) <= maxMessages { 44 ms := s.q[:maxMessages] 45 s.q = s.q[maxMessages:] 358 func (s *callbackDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, …
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/ |
H A D | benchmark_test.go | 58 n, delay := s.profile(s.inMiddleThird(), maxMessages) 78 …defaultReceiveProfile := func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, … 97 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 100 * tim… 101 …receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { return maxMessages, 1 * time.… 113 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 114 return maxMessages, 1 * time.Second 120 receiveProfile: func(_ bool, maxMessages int) (int, time.Duration) { 129 n := maxMessages 145 return maxMessages, d 240 sub.preReceiveBatchHook = func(maxMessages int) { [all …]
|
H A D | pubsub_test.go | 71 func (s *driverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) { 75 ms := s.grabQueue(maxMessages) 86 func (s *driverSub) grabQueue(maxMessages int) []*driver.Message { 89 if len(s.q) <= maxMessages { 94 ms := s.q[:maxMessages] 95 s.q = s.q[maxMessages:] 239 func (b blockingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, e… 351 sub.preReceiveBatchHook = func(maxMessages int) { 354 lastMaxMessages = maxMessages 447 func (t *failSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, error) {
|
H A D | acks_test.go | 38 func (s *ackingDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, er… 39 if len(s.q) <= maxMessages { 44 ms := s.q[:maxMessages] 45 s.q = s.q[maxMessages:] 358 func (s *callbackDriverSub) ReceiveBatch(ctx context.Context, maxMessages int) ([]*driver.Message, …
|
/dports/www/owncloud/owncloud/apps/files_external/3rdparty/google/apiclient-services/src/Google/Service/Pubsub/ |
H A D | PullRequest.php | 20 public $maxMessages; variable in Google_Service_Pubsub_PullRequest 23 public function setMaxMessages($maxMessages) argument 25 $this->maxMessages = $maxMessages; 29 return $this->maxMessages;
|
/dports/www/orangehrm/orangehrm-4.9/symfony/lib/vendor/google/apiclient-services/src/Google/Service/Pubsub/ |
H A D | PullRequest.php | 20 public $maxMessages; variable in Google_Service_Pubsub_PullRequest 23 public function setMaxMessages($maxMessages) argument 25 $this->maxMessages = $maxMessages; 29 return $this->maxMessages;
|
/dports/security/keybase/client-v5.7.1/go/chat/search/ |
H A D | regexp_searcher.go | 51 maxMessages := opts.MaxMessages 66 if maxMessages > MaxAllowedSearchMessages || maxMessages <= 0 { 67 maxMessages = MaxAllowedSearchMessages 147 for !pagination.Last && numHits < maxHits && numMessages < maxMessages { 197 if numHits >= maxHits || numMessages >= maxMessages {
|
/dports/games/critterding/critterding-beta12/src/scenes/gui/ |
H A D | textverbosemessage.cpp | 22 maxMessages = 5; in Textverbosemessage() 54 births.size() > maxMessages in deleteExpiredMsg() 65 deaths.size() > maxMessages in deleteExpiredMsg()
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
H A D | functional_consumer_group_test.go | 230 maxMessages int32 member 238 func runTestFuncConsumerGroupMember(t *testing.T, groupID, clientID string, maxMessages int32, sink… 262 maxMessages: maxMessages, 263 isCapped: maxMessages != 0, 350 if n := atomic.AddInt32(&m.maxMessages, -1); m.isCapped && n < 0 { 416 if n := atomic.LoadInt32(&m.maxMessages); m.isCapped && n < 0 {
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
H A D | functional_consumer_group_test.go | 230 maxMessages int32 member 238 func runTestFuncConsumerGroupMember(t *testing.T, groupID, clientID string, maxMessages int32, sink… 262 maxMessages: maxMessages, 263 isCapped: maxMessages != 0, 348 if n := atomic.AddInt32(&m.maxMessages, -1); m.isCapped && n < 0 { 414 if n := atomic.LoadInt32(&m.maxMessages); m.isCapped && n < 0 {
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
H A D | functional_consumer_group_test.go | 230 maxMessages int32 member 238 func runTestFuncConsumerGroupMember(t *testing.T, groupID, clientID string, maxMessages int32, sink… 262 maxMessages: maxMessages, 263 isCapped: maxMessages != 0, 348 if n := atomic.AddInt32(&m.maxMessages, -1); m.isCapped && n < 0 { 414 if n := atomic.LoadInt32(&m.maxMessages); m.isCapped && n < 0 {
|
/dports/games/xpilot-ng-server/xpilot-ng-4.7.3/src/client/ |
H A D | messages.c | 37 int maxMessages; /* Max. number of messages to display */ variable 740 for (i = 0; i < maxMessages && TalkMsg[i]->len > 0; i++) in Bms_clear() 839 while (last_msg_index < maxMessages in Add_message() 856 msg = msg_set[maxMessages - 1]; in Add_message() 857 for (i = maxMessages - 1; i > 0; i--) in Add_message() 877 || (selection.draw.y1 == maxMessages - 1)) { in Add_message() 892 if (selection.draw.y2 == maxMessages - 1) in Add_message() 929 for (i = 0; i < maxMessages; i++) { in Delete_pending_messages() 953 for (i = maxMessages-1; i >= 0; i--) { in Add_pending_messages() 1053 for (i = 0; i < maxMessages; i++) { in Print_messages_to_stdout() [all …]
|
/dports/games/xpilot/xpilot-4.5.5/src/client/ |
H A D | painthud.c | 770 while (last_msg_index < maxMessages in Paint_messages() 780 if (i < maxMessages) { in Paint_messages() 783 msg = GameMsg[i - maxMessages]; in Paint_messages() 817 if (i < maxMessages) { in Paint_messages() 843 && i < maxMessages in Paint_messages() 1011 while (last_msg_index < maxMessages in Add_message() 1043 tmp = msg_set[maxMessages - 1]; in Add_message() 1044 for (i = maxMessages - 1; i > 0; i--) { in Add_message() 1077 if (selection.draw.y2 == maxMessages - 1) { in Add_message() 1131 for (i = 0; i < maxMessages; i++) { in Delete_pending_messages() [all …]
|
/dports/games/critterding/critterding-beta12/src/utils/ |
H A D | logbuffer.cpp | 11 maxMessages = 5; in Logbuffer() 33 messages.size() > maxMessages in deleteExpiredMsg()
|
/dports/devel/staf/src/staf/stafproc/ |
H A D | STAFHandleQueue.h | 56 STAFHandleQueue(unsigned int maxMessages = 100) 57 : fMaxMessages(maxMessages), fNotify(new STAFEventSem(), in fMaxMessages() argument
|
/dports/games/kfourinline/kfourinline-21.12.3/src/ |
H A D | kchatdialog.cpp | 132 …QLabel* maxMessages = new QLabel(i18n("Maximum number of messages (-1 = unlimited):"), d->mTextPag… in init() local 133 layout->addWidget(maxMessages, 6, 0); in init() 222 widget->setMaxItems(maxMessages()); in configureChatWidget() 263 int KChatDialog::maxMessages() const in maxMessages() function in KChatDialog
|
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/profiler/google-cloud-go-0.1.0/pubsub/ |
H A D | iterator_test.go | 78 func (s *blockingFetch) fetchMessages(ctx context.Context, subName string, maxMessages int64) ([]*M… 89 func (s *justInTimeFetch) fetchMessages(ctx context.Context, subName string, maxMessages int64) ([]… 94 for i := 0; i < int(maxMessages); i++ {
|