/dports/net/libarcus/libArcus-4.8.0/src/ |
H A D | Socket_p.h | 392 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(), ¤t_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 D | smtp-bdat.c | 62 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 D | protocol.c | 78 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 D | 04_curr.t | 10 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 D | 11_pack.t | 14 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 D | main.cpp | 108 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 D | encode.c | 39 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 D | arena.lua | 4 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 D | 04_curr.t | 10 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 D | 07_del.t | 19 okay_if(9, $folder->current_message(2)); 21 okay_if(11, $folder->current_message == 1);
|
H A D | 11_pack.t | 13 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 D | speaking.c | 174 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 D | speaking.c | 174 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 D | 04_curr.t | 10 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 D | 11_pack.t | 14 okay_if(7, $folder->current_message($folder->next_message)); 19 okay_if(12, $folder->current_message == 2);
|
H A D | 07_del.t | 19 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 D | Emaul.pm | 113 $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 D | Maildir.pm | 112 $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 D | kestrel_plugin.py | 30 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 D | xmailfolder.pl | 503 $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 D | rsck.lua | 152 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 D | publish.cc | 259 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 D | worker.rs | 30 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 D | worker.rs | 23 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 D | worker.rs | 23 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()
|