Home
last modified time | relevance | path

Searched refs:maxMessages (Results 1 – 25 of 194) sorted by relevance

12345678

/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/
H A Dbenchmark_test.go58 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 Dpubsub_test.go71 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 Dacks_test.go38 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 Dbenchmark_test.go54 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 Dpubsub_test.go73 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 Dacks_test.go38 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 Dbenchmark_test.go58 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 Dpubsub_test.go71 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 Dacks_test.go38 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 Dbenchmark_test.go58 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 Dpubsub_test.go71 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 Dacks_test.go38 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 DPullRequest.php20 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 DPullRequest.php20 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 Dregexp_searcher.go51 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 Dtextverbosemessage.cpp22 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 Dfunctional_consumer_group_test.go230 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 Dfunctional_consumer_group_test.go230 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 Dfunctional_consumer_group_test.go230 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 Dmessages.c37 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 Dpainthud.c770 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 Dlogbuffer.cpp11 maxMessages = 5; in Logbuffer()
33 messages.size() > maxMessages in deleteExpiredMsg()
/dports/devel/staf/src/staf/stafproc/
H A DSTAFHandleQueue.h56 STAFHandleQueue(unsigned int maxMessages = 100)
57 : fMaxMessages(maxMessages), fNotify(new STAFEventSem(), in fMaxMessages() argument
/dports/games/kfourinline/kfourinline-21.12.3/src/
H A Dkchatdialog.cpp132 …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 Diterator_test.go78 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++ {

12345678