Home
last modified time | relevance | path

Searched refs:topic (Results 1 – 25 of 9729) sorted by relevance

12345678910>>...390

/dports/deskutils/calcurse/calcurse-4.7.1/src/
H A Dhelp.c98 if (!topic) in display_help()
99 topic = "intro"; in display_help()
122 topic = "intro"; in display_help()
124 topic = "intro"; in display_help()
128 topic = "save"; in display_help()
136 topic = "tab"; in display_help()
142 topic = "goto"; in display_help()
190 topic = "add"; in display_help()
194 topic = "edit"; in display_help()
196 topic = "view"; in display_help()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/invalidation/impl/
H A Dfcm_invalidation_listener_unittest.cc56 auto it = invalidations_.find(topic); in GetInvalidationCount()
65 auto it = invalidations_.find(topic); in GetVersion()
75 auto it = invalidations_.find(topic); in GetPayload()
85 auto it = invalidations_.find(topic); in IsUnknownVersion()
107 List& list = invalidations_[topic]; in AcknowledgeNthInvalidation()
113 List& list = invalidations_[topic]; in AcknowledgeAll()
120 List& list = invalidations_[topic]; in DropNthInvalidation()
138 for (const auto& topic : topics) { in OnInvalidate() local
251 fcm_sync_network_channel_->DeliverIncomingMessage(payload, topic, topic, in FireInvalidate()
296 EXPECT_EQ("", GetPayload(topic)); in TEST_F()
[all …]
/dports/games/pvpgn/pvpgn-1.8.5/src/bnetd/
H A Dtopic.c72 t_topic * topic; in get_topic() local
91 t_topic * topic; in channel_get_topic() local
96 return topic->topic; in channel_get_topic()
102 t_topic * topic; in topiclist_save() local
122 fprintf(fp,"\"%s\",\"%s\"\n",topic->channel_name,topic->topic); in topiclist_save()
133 t_topic * topic; in topiclist_add_topic() local
137 topic->topic = xstrdup(topic_text); in topiclist_add_topic()
145 t_topic * topic; in channel_set_topic() local
161 xfree((void *)topic->topic); in channel_set_topic()
162 topic->topic = xstrdup(topic_text); in channel_set_topic()
[all …]
/dports/www/beehive/beehive-0.4.0/vendor/github.com/asaskevich/EventBus/
H A Devent_bus.go11 Subscribe(topic string, fn interface{}) error
25 HasCallback(topic string) bool
68 bus.handlers[topic] = append(bus.handlers[topic], handler)
111 _, ok := bus.handlers[topic]
113 return len(bus.handlers[topic]) > 0
123 if _, ok := bus.handlers[topic]; ok && len(bus.handlers[topic]) > 0 {
124 bus.removeHandler(topic, bus.findHandlerIdx(topic, reflect.ValueOf(handler)))
141 bus.removeHandler(topic, i)
173 l := len(bus.handlers[topic])
179 copy(bus.handlers[topic][idx:], bus.handlers[topic][idx+1:])
[all …]
/dports/www/aquatone/aquatone-1.7.0/vendor/github.com/asaskevich/EventBus/
H A Devent_bus.go11 Subscribe(topic string, fn interface{}) error
25 HasCallback(topic string) bool
68 bus.handlers[topic] = append(bus.handlers[topic], handler)
111 _, ok := bus.handlers[topic]
113 return len(bus.handlers[topic]) > 0
123 if _, ok := bus.handlers[topic]; ok && len(bus.handlers[topic]) > 0 {
124 bus.removeHandler(topic, bus.findHandlerIdx(topic, reflect.ValueOf(handler)))
141 bus.removeHandler(topic, i)
173 l := len(bus.handlers[topic])
179 copy(bus.handlers[topic][idx:], bus.handlers[topic][idx+1:])
[all …]
/dports/mail/sympa/sympa-6.2.62/src/lib/Sympa/
H A DRobot.pm244 $topic = {};
289 $topic->{'current_title'} = $topic->{'title'}{$l};
297 $topic->{'current_title'} = $topic->{'title'}{'default'}
328 my $topic = shift;
350 my $topic = {};
358 return $topic;
367 my $topic = $_;
369 ( $topic,
370 map { $topic . '/' . $_ } sort keys %{$topics{$topic}->{sub}}
373 ($topic);
[all …]
/dports/dns/blocky/blocky-0.17/vendor/github.com/asaskevich/EventBus/
H A Devent_bus.go11 Subscribe(topic string, fn interface{}) error
25 HasCallback(topic string) bool
68 bus.handlers[topic] = append(bus.handlers[topic], handler)
111 _, ok := bus.handlers[topic]
113 return len(bus.handlers[topic]) > 0
123 if _, ok := bus.handlers[topic]; ok && len(bus.handlers[topic]) > 0 {
124 bus.removeHandler(topic, bus.findHandlerIdx(topic, reflect.ValueOf(handler)))
141 bus.removeHandler(topic, i)
175 l := len(bus.handlers[topic])
181 copy(bus.handlers[topic][idx:], bus.handlers[topic][idx+1:])
[all …]
/dports/www/elixir-phoenix/phoenix-1.3.3/test/phoenix/
H A Dpresence_test.exs46 assert MyPresence.list(%Phoenix.Socket{topic: config.topic}) == %{}
51 MyPresence.list(%Phoenix.Socket{topic: config.topic})
61 %{topic: topic} = config do
68 assert_receive %Broadcast{topic: ^topic, event: "presence_diff", payload: %{
76 assert_receive %Broadcast{topic: ^topic, event: "presence_diff", payload: %{
84 %{topic: topic} = config do
90 assert_receive %Broadcast{topic: ^topic, event: "presence_diff", payload: %{
105 test "untrack with pid", %{topic: topic} = config do
117 test "track and untrack with %Socket{}", %{topic: topic} = config do
119 socket = %Phoenix.Socket{topic: topic, channel_pid: self()}
[all …]
/dports/audio/ampache/ampache-php74-5.0.0/vendor/cboden/ratchet/tests/unit/Wamp/
H A DTopicTest.php10 $topic = new Topic($id);
16 $topic = new Topic('merp');
30 $topic->add($tracked);
55 $topic->add($first);
56 $topic->add($second);
81 $topic->add($first);
82 $topic->add($second);
83 $topic->add($third);
108 $topic->add($first);
110 $topic->add($third);
[all …]
/dports/textproc/yelp-xsl/yelp-xsl-40.2/doc/yelp-xsl/ducks/
H A Ddb2xhtml.duck6 @link[topic >l10n group=imports]
7 @link[topic >color group=imports]
8 @link[topic >icons group=imports]
9 @link[topic >html group=imports]
10 @link[topic >tmpl group=imports]
11 @link[topic >utils group=imports]
12 @link[topic >db-chunk group=imports]
13 @link[topic >db-common group=imports]
14 @link[topic >db-profile group=imports]
15 @link[topic >db-title group=imports]
[all …]
H A Ddb2html.duck6 @link[topic >l10n group=imports]
7 @link[topic >color group=imports]
8 @link[topic >icons group=imports]
9 @link[topic >html group=imports]
10 @link[topic >tmpl group=imports]
11 @link[topic >utils group=imports]
12 @link[topic >db-chunk group=imports]
13 @link[topic >db-common group=imports]
14 @link[topic >db-profile group=imports]
15 @link[topic >db-title group=imports]
[all …]
/dports/irc/epic4/help/1_General/
H A Dtopic3 topic (to query topic in current channel)
4 topic <channel> (to query topic in stated channel)
5 topic - (to unset topic in current channel)
6 topic -<channel> (to unset topic in stated channel)
7 topic <new topic> (to set topic in current channel)
8 topic <channel> <new topic> (to set topic in stated channel)
20 The channel "has no topic" after the topic is unset.
42 /topic #blah
44 /topic
47 /topic -#blah
[all …]
/dports/www/elixir-phoenix_pubsub/phoenix_pubsub-1.0.2/test/phoenix/tracker/
H A Dintegration_test.exs26 %{tracker: tracker, topic: topic} do
47 %{tracker: tracker, topic: topic} do
92 %{tracker: tracker, tracker_pid: tracker_pid, topic: topic} do
124 %{tracker: tracker, topic: topic} do
187 %{tracker: tracker, topic: topic} do
232 %{tracker: tracker, topic: topic} do
259 %{tracker: tracker, topic: topic} do
264 %{tracker: tracker, topic: topic} do
280 %{tracker: tracker, topic: topic} do
294 %{tracker: tracker, topic: topic} do
[all …]
/dports/net/boinc-client/boinc-client_release-7.8-7.8.6/drupal/sites/default/boinc/themes/boinc/templates/
H A Dforum-topic-list.tpl.php40 $topic = current($topics); variable
67 <?php foreach ($topics as $topic): ?>
69 node_load($topic->id);
70 $author = user_load($topic->uid);
76 if ($topic->sticky) {
86 if ($topic->new) {
92 <?php if ($topic->sticky): ?>
98 <?php if (($topic->new) AND ($topic->new_replies)): ?>
100 <?php elseif ($topic->new): ?>
105 <?php print $topic->title; ?>
[all …]
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/
H A Dkafka_topic.c32 struct flb_kafka_topic *topic; in flb_kafka_topic_create() local
42 if (!topic) { in flb_kafka_topic_create()
49 topic->tp = tp; in flb_kafka_topic_create()
52 return topic; in flb_kafka_topic_create()
58 mk_list_del(&topic->_head); in flb_kafka_topic_destroy()
60 flb_free(topic->name); in flb_kafka_topic_destroy()
61 flb_free(topic); in flb_kafka_topic_destroy()
71 struct flb_kafka_topic *topic; in flb_kafka_topic_destroy_all() local
93 return topic; in flb_kafka_topic_default()
113 if (strncmp(name, topic->name, topic->name_len) == 0) { in flb_kafka_topic_lookup()
[all …]
/dports/devel/spark/spark-2.1.1/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/
H A DKafkaSourceSuite.scala193 val referenceOffset = KafkaSourceOffset((topic, 0, 0L), (topic, 1, 0L), (topic, 2, 0L))
213 val offset = KafkaSourceOffset((topic, 0, 0L), (topic, 1, 0L), (topic, 2, 0L))
347 topic,
356 topic,
365 topic,
374 topic,
383 topic,
398 topic,
408 topic,
418 topic,
[all …]
/dports/editors/nedit/nedit-5.7/source/
H A Dhelp.c546 HelpWindows[topic] = createHelpPanel(topic); in Help()
557 topic++; in setHelpWinTitle()
837 topic--; in prevTopicCB()
839 changeTopicOrRaise(topic+1, topic); in prevTopicCB()
848 topic++; in nextTopicCB()
850 changeTopicOrRaise(topic-1, topic); in nextTopicCB()
938 for (*topic=0; HelpTitles[*topic] != NULL; (*topic)++) in is_known_link()
954 *topic = hypertext->topic; in is_known_link()
1034 for (topic = 0; topic < NUM_TOPICS; topic++) in helpButtonActionAP()
1122 for (topic = 0; topic < NUM_TOPICS; topic++) in helpHyperlinkAP()
[all …]
/dports/devel/py-pyro/Pyro4-4.77/examples/messagebus/messagebus/
H A Dmessagebus.py122 def create_topic(self, topic): argument
123 if topic in self.messages:
125 self.messages[topic] = []
128 def remove_topic(self, topic): argument
131 del self.messages[topic]
142 del self.subscribers[topic]
169 return {topic: list(msgs) for topic, msgs in self.messages.items()}
172 return topic in self.messages and any(self.messages[topic])
175 return topic in self.subscribers and any(self.subscribers[topic])
415 def add_topic(self, topic): argument
[all …]
/dports/net/mosquitto/mosquitto-2.0.13/lib/
H A Dutil_topic.c208 if(!sub || !topic || sub[0] == 0 || topic[0] == 0){ in mosquitto_topic_matches_sub2()
221 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
236 while(topic[0] != 0 && topic[0] != '/'){ in mosquitto_topic_matches_sub2()
237 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
240 topic++; in mosquitto_topic_matches_sub2()
256 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
259 topic++; in mosquitto_topic_matches_sub2()
266 if(topic[0] == 0 in mosquitto_topic_matches_sub2()
301 topic++; in mosquitto_topic_matches_sub2()
320 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
[all …]
/dports/www/domoticz/domoticz-2020.2/extern/mosquitto/lib/
H A Dutil_topic.c193 if(!sub || !topic || sub[0] == 0 || topic[0] == 0){ in mosquitto_topic_matches_sub2()
206 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
221 while(topic[0] != 0 && topic[0] != '/'){ in mosquitto_topic_matches_sub2()
222 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
225 topic++; in mosquitto_topic_matches_sub2()
241 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
244 topic++; in mosquitto_topic_matches_sub2()
251 if(topic[0] == 0 in mosquitto_topic_matches_sub2()
286 topic++; in mosquitto_topic_matches_sub2()
305 if(topic[0] == '+' || topic[0] == '#'){ in mosquitto_topic_matches_sub2()
[all …]
/dports/www/grafana8/google-cloud-go-storage-v1.14.0/pubsublite/internal/wire/
H A Dpublisher_test.go93 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
116 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
152 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
194 verifiers.AddPublishStream(topic.Path, topic.Partition, stream1)
201 verifiers.AddPublishStream(topic.Path, topic.Partition, stream2)
233 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
271 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
314 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
349 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
385 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher_test.go93 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
116 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
152 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
194 verifiers.AddPublishStream(topic.Path, topic.Partition, stream1)
201 verifiers.AddPublishStream(topic.Path, topic.Partition, stream2)
233 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
271 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
314 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
349 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
385 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
[all …]
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher_test.go93 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
116 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
152 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
194 verifiers.AddPublishStream(topic.Path, topic.Partition, stream1)
201 verifiers.AddPublishStream(topic.Path, topic.Partition, stream2)
233 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
271 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
314 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
349 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
385 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
[all …]
/dports/databases/litestream/litestream-0.3.6/vendor/cloud.google.com/go/pubsublite/internal/wire/
H A Dpublisher_test.go93 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
116 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
152 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
194 verifiers.AddPublishStream(topic.Path, topic.Partition, stream1)
201 verifiers.AddPublishStream(topic.Path, topic.Partition, stream2)
233 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
271 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
314 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
349 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
385 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
[all …]
/dports/databases/litestream/google-cloud-go-storage-v1.15.0/pubsublite/internal/wire/
H A Dpublisher_test.go93 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
116 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
152 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
194 verifiers.AddPublishStream(topic.Path, topic.Partition, stream1)
201 verifiers.AddPublishStream(topic.Path, topic.Partition, stream2)
233 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
271 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
314 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
349 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
385 verifiers.AddPublishStream(topic.Path, topic.Partition, stream)
[all …]

12345678910>>...390