Home
last modified time | relevance | path

Searched refs:current_message (Results 1 – 25 of 146) sorted by relevance

123456

/dports/net/libarcus/libArcus-4.8.0/src/
H A DSocket_p.h392 if(!current_message) in receiveNextMessage()
422 current_message.reset(); in receiveNextMessage()
430 current_message.reset(); in receiveNextMessage()
438 current_message.reset(); in receiveNextMessage()
458 current_message.reset(); in receiveNextMessage()
464 current_message->size = size; in receiveNextMessage()
491 current_message.reset(); in receiveNextMessage()
503 …result = platform_socket.readBytes(current_message->getRemainingSize(), &current_message->data[cur… in receiveNextMessage()
508 current_message.reset(); in receiveNextMessage()
513 current_message->received_size = current_message->received_size + result; in receiveNextMessage()
[all …]
/dports/mail/libesmtp/libesmtp-1.0.6/
H A Dsmtp-bdat.c62 session->current_message->cb, in cmd_bdat()
63 session->current_message->cb_arg); in cmd_bdat()
72 reset_header_table (session->current_message); in cmd_bdat()
120 session->current_message, len); in cmd_bdat()
160 session->current_message, len); in cmd_bdat()
209 session->current_message, len); in cmd_bdat2()
243 message = session->current_message; in rsp_bdat2()
255 for (recipient = session->current_message->recipients; in rsp_bdat2()
267 session->current_message); in rsp_bdat2()
287 for (recipient = session->current_message->recipients; in rsp_bdat2()
[all …]
H A Dprotocol.c78 if (session->current_message == NULL) in set_first_recipient()
108 while ((session->current_message = session->current_message->next) != NULL) in next_message()
120 session->current_message != NULL; in set_first_message()
121 session->current_message = session->current_message->next) in set_first_message()
976 message = session->current_message; in cmd_mail()
1058 message = session->current_message; in rsp_mail()
1222 message = session->current_message; in rsp_data()
1283 session->current_message->cb, in cmd_data2()
1338 session->current_message, len); in cmd_data2()
1393 session->current_message, len); in cmd_data2()
[all …]
/dports/mail/p5-Mail-Folder/MailFolder-0.07/t/emaul/
H A D04_curr.t10 okay_if(3, $folder->current_message == 1);
12 okay_if(5, $folder->next_message($folder->current_message) == 3);
13 okay_if(6, $folder->current_message($folder->next_message));
14 okay_if(7, $folder->current_message == 3);
24 okay_if(16, $folder->current_message == 1);
25 okay_if(17, $folder->current_message($folder->next_message));
30 okay_if(21, $folder->current_message == 3);
H A D11_pack.t14 okay_if(6, $folder->current_message($folder->next_message));
23 okay_if(15, $folder->current_message == 2);
/dports/net/arataga/restinio-v.0.6.13/dev/test/websocket/parser/
H A Dmain.cpp108 auto ws_message_details = parser.current_message();
113 REQUIRE( parser.current_message().payload_len() == 0 );
126 auto ws_message_details = parser.current_message();
145 REQUIRE( parser.current_message().payload_len() == 127 );
153 REQUIRE( parser.current_message().payload_len() == 128 );
160 REQUIRE( parser.current_message().payload_len() == 1000 );
179 REQUIRE( parser.current_message().payload_len() == 0x7F );
187 REQUIRE( parser.current_message().payload_len() == 0x80 );
216 REQUIRE(parser.current_message().m_mask_flag);
232 auto ws_message_details = parser.current_message();
[all …]
/dports/net/libmdf/libmdf-1.0.21/src/
H A Dencode.c39 message->current_message = -1; in mdf_message_create()
49 if (message->current_message != -1) { in mdf_message_add()
57 message->current_message++; in mdf_message_add()
79 if (message->current_message == -1) in mdf_message_del()
87 message->current_message--; in mdf_message_del()
89 if (message->current_message == -1) in mdf_message_del()
97 message->current_message = -1; in mdf_message_reset()
163 int current_message; in mdf_message_deserialize() local
182 message->current_message = current_message; in mdf_message_deserialize()
296 message_dst->current_message++; in mdf_message_move()
[all …]
/dports/games/battletanks/btanks-0.9.8083/data/maps/
H A Darena.lua4 current_message = nil
130 if current_message == nil then
137 current_message = 'ready'
139 display_message('messages', current_message, message_timer, true)
140 elseif current_message == 'ready' then
141 current_message = 'go'
143 display_message('messages', current_message, message_timer, true)
145 current_message = nil;
/dports/mail/p5-Mail-Folder/MailFolder-0.07/t/mbox/
H A D04_curr.t10 okay_if(3, $folder->current_message == 1);
12 okay_if(5, $folder->next_message($folder->current_message) == 2);
13 okay_if(6, $folder->current_message($folder->next_message));
14 okay_if(7, $folder->current_message == 2);
16 okay_if(9, $folder->prev_message($folder->current_message) == 1);
H A D07_del.t19 okay_if(9, $folder->current_message(2));
21 okay_if(11, $folder->current_message == 1);
H A D11_pack.t13 okay_if(6, $folder->current_message(3));
24 okay_if(17, $folder->current_message == 2);
/dports/accessibility/speech-dispatcher/speech-dispatcher-0.10.2/src/server/
H A Dspeaking.c174 current_message = NULL; in speak()
301 if (current_message != NULL) { in speak()
320 current_message-> in speak()
323 (current_message-> in speak()
330 current_message = message; in speak()
591 if (current_message == NULL) { in speaking_pause()
717 if (current_message == NULL) { in REPORT_STATE()
749 report_end(current_message); in REPORT_STATE()
755 report_pause(current_message); in REPORT_STATE()
758 current_message = NULL; in REPORT_STATE()
[all …]
/dports/accessibility/py-speech-dispatcher/speech-dispatcher-0.10.2/src/server/
H A Dspeaking.c174 current_message = NULL; in speak()
301 if (current_message != NULL) { in speak()
320 current_message-> in speak()
323 (current_message-> in speak()
330 current_message = message; in speak()
591 if (current_message == NULL) { in speaking_pause()
717 if (current_message == NULL) { in REPORT_STATE()
749 report_end(current_message); in REPORT_STATE()
755 report_pause(current_message); in REPORT_STATE()
758 current_message = NULL; in REPORT_STATE()
[all …]
/dports/mail/p5-Mail-Folder/MailFolder-0.07/t/maildir/
H A D04_curr.t10 okay_if(3, $folder->current_message == 1);
12 okay_if(5, $folder->next_message($folder->current_message) == 2);
13 okay_if(6, $folder->current_message($folder->next_message));
14 okay_if(7, $folder->current_message == 2);
16 okay_if(9, $folder->prev_message($folder->current_message) == 1);
H A D11_pack.t14 okay_if(7, $folder->current_message($folder->next_message));
19 okay_if(12, $folder->current_message == 2);
H A D07_del.t19 okay_if(9, $folder->current_message(2));
21 okay_if(11, $folder->current_message == 1);
/dports/mail/p5-Mail-Folder/MailFolder-0.07/Mail/Folder/
H A DEmaul.pm113 $self->current_message(_load_current_msg($foldername));
154 my $current_message = $self->current_message;
171 my $msg = $self->current_message;
176 $self->current_message($msg);
186 _store_current_msg($foldername, $current_message);
221 my $current_message = $self->current_message;
233 $self->current_message($newmsg) if ($msg == $current_message);
H A DMaildir.pm112 $self->current_message(1);
162 my $msg = $self->current_message;
167 $self->current_message($msg);
195 my $current_message = $self->current_message;
202 $self->current_message($newmsg) if ($msg == $current_message);
/dports/math/py-Pyomo/Pyomo-6.1.2/pyomo/neos/plugins/
H A Dkestrel_plugin.py30 def _neos_error(msg, results, current_message):
34 logger.error("%s NEOS log:\n%s" % ( msg, current_message, ),
207 (current_offset, current_message) = self._neos_log[jobNumber]
209 OUTPUT.write(current_message)
218 results, current_message )
235 results, current_message )
249 (current_offset, current_message) = self._neos_log[jobNumber]
265 current_message + (
/dports/mail/p5-Mail-Folder/MailFolder-0.07/examples/
H A Dxmailfolder.pl503 $fref->current_message($nextmsg);
601 $fref->current_message($currmsg);
603 $currmsg = $fref->current_message;
665 my $msgnum = $self->{'folder'}->current_message;
678 $self->{'folder'}->current_message($msgnum);
727 my $msgnum = $self->{'folder'}->current_message;
737 $self->{'folder'}->current_message($msgnum);
759 my $msgnum = $self->{'folder'}->current_message;
781 my $msgnum = $self->{'folder'}->current_message;
800 my $msgnum = $self->{'folder'}->current_message;
[all …]
/dports/www/nginx-full/nchan-1.2.12/src/store/redis/redis-lua-scripts/
H A Drsck.lua152 if not ch.current_message or not ch.time then
156 elseif (ch.current_message or ch.prev_message) and msgs_list_type ~= "list" then
169 check_msg(id, ch.prev_message, false, ch.current_message, "channel prev_message")
171 if ch.current_message then
172 if redis.call('LINDEX', key.msgs, 0) ~= ch.current_message then
175 check_msg(id, ch.current_message, ch.prev_message, false, "channel current_message")
/dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/ssl_session_reuse/src/
H A Dpublish.cc259 Message current_message(m_messageQueue.front()); in runWorker() local
260 if (!current_message.cleanup) { in runWorker()
267 if (current_message.cleanup) { in runWorker()
274 current_reply = send_publish(my_context, my_endpoint, current_message); in runWorker()
277 current_message.hosts_tried.insert(my_endpoint); in runWorker()
278 if (current_message.hosts_tried.size() < m_redisEndpoints.size()) { in runWorker()
283 m_messageQueue.push_front(current_message); in runWorker()
/dports/sysutils/vector/tower-c87fdd9c1e4c0728fdaa87d3fafe3e48da9b498a/tower/src/buffer/
H A Dworker.rs30 current_message: Option<Message<Request, T::Future>>, field
58 current_message: None, in new()
83 if let Some(mut msg) = self.current_message.take() { in poll_next_msg()
185 self.current_message = Some(msg); in poll()
/dports/devel/sccache/sccache-0.2.15/cargo-crates/tower-buffer-0.1.2/src/
H A Dworker.rs23 current_message: Option<Message<Request, T::Future>>, field
70 current_message: None, in spawn()
95 if let Some(mut msg) = self.current_message.take() { in poll_next_msg()
197 self.current_message = Some(msg); in poll()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/tower-buffer-0.1.2/src/
H A Dworker.rs23 current_message: Option<Message<Request, T::Future>>, field
70 current_message: None, in spawn()
95 if let Some(mut msg) = self.current_message.take() { in poll_next_msg()
197 self.current_message = Some(msg); in poll()

123456