/dports/www/ulfius/ulfius-2.7.3/example_programs/websocket_example/ |
H A D | websocket_server.c | 236 const struct _websocket_message * last_message, in websocket_incoming_message_callback() argument 241 … opcode: 0x%02x, mask: %d, len: %zu", last_message->rsv, last_message->opcode, last_message->has_m… in websocket_incoming_message_callback() 242 if (last_message->opcode == U_WEBSOCKET_OPCODE_TEXT) { in websocket_incoming_message_callback() 243 …y_log_message(Y_LOG_LEVEL_DEBUG, "text payload '%.*s'", last_message->data_len, last_message->data… in websocket_incoming_message_callback() 244 } else if (last_message->opcode == U_WEBSOCKET_OPCODE_BINARY) { in websocket_incoming_message_callback() 251 const struct _websocket_message * last_message, in websocket_echo_message_callback() argument 253 …load '%.*s'", last_message->rsv, last_message->opcode, last_message->has_mask, last_message->data_… in websocket_echo_message_callback() 254 …fius_websocket_send_message(websocket_manager, last_message->opcode, last_message->data_len, last_… in websocket_echo_message_callback() 261 const struct _websocket_message * last_message, in websocket_incoming_file_callback() argument 263 …: 0x%02x, mask: %d, len: %zu", last_message, last_message->rsv, last_message->opcode, last_message… in websocket_incoming_file_callback()
|
H A D | websocket_client.c | 92 const struct _websocket_message * last_message, in websocket_incoming_message_callback() argument 97 … message, opcode: 0x%02x, mask: %d, len: %zu", last_message->opcode, last_message->has_mask, last_… in websocket_incoming_message_callback() 98 if (last_message->opcode == U_WEBSOCKET_OPCODE_TEXT) { in websocket_incoming_message_callback() 99 …y_log_message(Y_LOG_LEVEL_DEBUG, "text payload '%.*s'", last_message->data_len, last_message->data… in websocket_incoming_message_callback() 100 } else if (last_message->opcode == U_WEBSOCKET_OPCODE_BINARY) { in websocket_incoming_message_callback()
|
/dports/net-p2p/qtum/qtum-mainnet-fastlane-v0.20.3/test/functional/ |
H A D | p2p_compactblocks.py | 43 for x in self.last_message["headers"].headers: 48 for x in self.last_message["inv"].inv: 60 self.last_message.pop("inv", None) 61 self.last_message.pop("headers", None) 62 self.last_message.pop("cmpctblock", None) 178 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 185 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 234 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 632 test_node.last_message.pop("block", None) 659 test_node.last_message.pop("block", None) [all …]
|
H A D | p2p_sendheaders.py | 151 …test_function = lambda: "getdata" in self.last_message and [x.hash for x in self.last_message["get… 174 self.last_message.pop("inv", None) 175 self.last_message.pop("headers", None) 187 self.last_message.pop("headers", None) 199 if "inv" in self.last_message: 203 self.last_message.pop("inv", None) 461 test_node.last_message.pop("getdata", None) 500 test_node.last_message.pop("getdata", None) 519 test_node.last_message.pop("getdata", None) 535 test_node.last_message.pop("getdata", None) [all …]
|
/dports/net-p2p/namecoin-utils/namecoin-core-nc0.21.0.1/test/functional/ |
H A D | p2p_compactblocks.py | 41 for x in self.last_message["headers"].headers: 46 for x in self.last_message["inv"].inv: 58 self.last_message.pop("inv", None) 59 self.last_message.pop("headers", None) 60 self.last_message.pop("cmpctblock", None) 173 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 180 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 218 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 599 test_node.last_message.pop("block", None) 600 test_node.last_message.pop("blocktxn", None) [all …]
|
H A D | p2p_ping.py | 56 assert no_pong_node.last_message.pop('ping').nonce != 0 72 assert 'ping' not in no_pong_node.last_message 76 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 88 assert 'ping' not in no_pong_node.last_message 91 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 94 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 95 no_pong_node.send_and_ping(msg_pong(no_pong_node.last_message.pop('ping').nonce)) 101 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 104 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 109 assert 'ping' not in no_pong_node.last_message [all …]
|
/dports/net-p2p/namecoin-daemon/namecoin-core-nc0.21.0.1/test/functional/ |
H A D | p2p_compactblocks.py | 41 for x in self.last_message["headers"].headers: 46 for x in self.last_message["inv"].inv: 58 self.last_message.pop("inv", None) 59 self.last_message.pop("headers", None) 60 self.last_message.pop("cmpctblock", None) 173 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 180 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 218 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 599 test_node.last_message.pop("block", None) 600 test_node.last_message.pop("blocktxn", None) [all …]
|
H A D | p2p_ping.py | 56 assert no_pong_node.last_message.pop('ping').nonce != 0 72 assert 'ping' not in no_pong_node.last_message 76 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 88 assert 'ping' not in no_pong_node.last_message 91 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 94 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 95 no_pong_node.send_and_ping(msg_pong(no_pong_node.last_message.pop('ping').nonce)) 101 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 104 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 109 assert 'ping' not in no_pong_node.last_message [all …]
|
/dports/net-p2p/namecoin/namecoin-core-nc0.21.0.1/test/functional/ |
H A D | p2p_compactblocks.py | 41 for x in self.last_message["headers"].headers: 46 for x in self.last_message["inv"].inv: 58 self.last_message.pop("inv", None) 59 self.last_message.pop("headers", None) 60 self.last_message.pop("cmpctblock", None) 173 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 180 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 218 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 599 test_node.last_message.pop("block", None) 600 test_node.last_message.pop("blocktxn", None) [all …]
|
H A D | p2p_ping.py | 56 assert no_pong_node.last_message.pop('ping').nonce != 0 72 assert 'ping' not in no_pong_node.last_message 76 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 88 assert 'ping' not in no_pong_node.last_message 91 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 94 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 95 no_pong_node.send_and_ping(msg_pong(no_pong_node.last_message.pop('ping').nonce)) 101 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 104 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 109 assert 'ping' not in no_pong_node.last_message [all …]
|
/dports/net-p2p/bitcoin/bitcoin-22.0/test/functional/ |
H A D | p2p_ping.py | 56 assert no_pong_node.last_message.pop('ping').nonce != 0 72 assert 'ping' not in no_pong_node.last_message 76 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 88 assert 'ping' not in no_pong_node.last_message 91 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 94 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 95 no_pong_node.send_and_ping(msg_pong(no_pong_node.last_message.pop('ping').nonce)) 101 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 104 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 109 assert 'ping' not in no_pong_node.last_message [all …]
|
H A D | p2p_compactblocks.py | 91 for x in self.last_message["headers"].headers: 96 for x in self.last_message["inv"].inv: 108 self.last_message.pop("inv", None) 109 self.last_message.pop("headers", None) 110 self.last_message.pop("cmpctblock", None) 222 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 229 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 267 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 648 test_node.last_message.pop("block", None) 649 test_node.last_message.pop("blocktxn", None) [all …]
|
/dports/net-p2p/bitcoin-utils/bitcoin-22.0/test/functional/ |
H A D | p2p_ping.py | 56 assert no_pong_node.last_message.pop('ping').nonce != 0 72 assert 'ping' not in no_pong_node.last_message 76 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 88 assert 'ping' not in no_pong_node.last_message 91 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 94 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 95 no_pong_node.send_and_ping(msg_pong(no_pong_node.last_message.pop('ping').nonce)) 101 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 104 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 109 assert 'ping' not in no_pong_node.last_message [all …]
|
H A D | p2p_compactblocks.py | 91 for x in self.last_message["headers"].headers: 96 for x in self.last_message["inv"].inv: 108 self.last_message.pop("inv", None) 109 self.last_message.pop("headers", None) 110 self.last_message.pop("cmpctblock", None) 222 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 229 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 267 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 648 test_node.last_message.pop("block", None) 649 test_node.last_message.pop("blocktxn", None) [all …]
|
/dports/net-p2p/bitcoin-daemon/bitcoin-22.0/test/functional/ |
H A D | p2p_ping.py | 56 assert no_pong_node.last_message.pop('ping').nonce != 0 72 assert 'ping' not in no_pong_node.last_message 76 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 88 assert 'ping' not in no_pong_node.last_message 91 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 94 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 95 no_pong_node.send_and_ping(msg_pong(no_pong_node.last_message.pop('ping').nonce)) 101 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 104 no_pong_node.wait_until(lambda: 'ping' in no_pong_node.last_message) 109 assert 'ping' not in no_pong_node.last_message [all …]
|
H A D | p2p_compactblocks.py | 91 for x in self.last_message["headers"].headers: 96 for x in self.last_message["inv"].inv: 108 self.last_message.pop("inv", None) 109 self.last_message.pop("headers", None) 110 self.last_message.pop("cmpctblock", None) 222 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 229 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 267 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 648 test_node.last_message.pop("block", None) 649 test_node.last_message.pop("blocktxn", None) [all …]
|
/dports/net-p2p/litecoin-daemon/litecoin-0.18.1/test/functional/ |
H A D | p2p_compactblocks.py | 43 for x in self.last_message["headers"].headers: 48 for x in self.last_message["inv"].inv: 60 self.last_message.pop("inv", None) 61 self.last_message.pop("headers", None) 62 self.last_message.pop("cmpctblock", None) 177 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 184 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 233 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 623 test_node.last_message.pop("block", None) 649 test_node.last_message.pop("block", None) [all …]
|
H A D | p2p_sendheaders.py | 152 …test_function = lambda: "getdata" in self.last_message and [x.hash for x in self.last_message["get… 175 self.last_message.pop("inv", None) 176 self.last_message.pop("headers", None) 188 self.last_message.pop("headers", None) 200 if "inv" in self.last_message: 204 self.last_message.pop("inv", None) 471 test_node.last_message.pop("getdata", None) 512 test_node.last_message.pop("getdata", None) 531 test_node.last_message.pop("getdata", None) 547 test_node.last_message.pop("getdata", None) [all …]
|
/dports/net-p2p/litecoin/litecoin-0.18.1/test/functional/ |
H A D | p2p_compactblocks.py | 43 for x in self.last_message["headers"].headers: 48 for x in self.last_message["inv"].inv: 60 self.last_message.pop("inv", None) 61 self.last_message.pop("headers", None) 62 self.last_message.pop("cmpctblock", None) 177 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 184 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 233 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 623 test_node.last_message.pop("block", None) 649 test_node.last_message.pop("block", None) [all …]
|
H A D | p2p_sendheaders.py | 152 …test_function = lambda: "getdata" in self.last_message and [x.hash for x in self.last_message["get… 175 self.last_message.pop("inv", None) 176 self.last_message.pop("headers", None) 188 self.last_message.pop("headers", None) 200 if "inv" in self.last_message: 204 self.last_message.pop("inv", None) 471 test_node.last_message.pop("getdata", None) 512 test_node.last_message.pop("getdata", None) 531 test_node.last_message.pop("getdata", None) 547 test_node.last_message.pop("getdata", None) [all …]
|
/dports/net-p2p/litecoin-utils/litecoin-0.18.1/test/functional/ |
H A D | p2p_compactblocks.py | 43 for x in self.last_message["headers"].headers: 48 for x in self.last_message["inv"].inv: 60 self.last_message.pop("inv", None) 61 self.last_message.pop("headers", None) 62 self.last_message.pop("cmpctblock", None) 177 … block_hash, peer.last_message.get("cmpctblock", None), peer.last_message.get("inv", None))) 184 …ew_block(node, test_node, lambda p: "cmpctblock" not in p.last_message and "inv" in p.last_message) 233 …lock(node, test_node, lambda p: "cmpctblock" not in p.last_message and "headers" in p.last_message) 623 test_node.last_message.pop("block", None) 649 test_node.last_message.pop("block", None) [all …]
|
H A D | p2p_sendheaders.py | 152 …test_function = lambda: "getdata" in self.last_message and [x.hash for x in self.last_message["get… 175 self.last_message.pop("inv", None) 176 self.last_message.pop("headers", None) 188 self.last_message.pop("headers", None) 200 if "inv" in self.last_message: 204 self.last_message.pop("inv", None) 471 test_node.last_message.pop("getdata", None) 512 test_node.last_message.pop("getdata", None) 531 test_node.last_message.pop("getdata", None) 547 test_node.last_message.pop("getdata", None) [all …]
|
/dports/irc/irssi-scripts/irssi-scripts/scripts/ |
H A D | norepeat.pl | 26 our %last_message = (); 32 if ( $norepeat_enabled and my $ref = $last_message{$server->{tag}}{$target}{$nick} ) { 36 $last_message{$server->{tag}}{$target}{$nick} = [ $md5, $time ]; 41 if ( my $ref = delete $last_message{$server->{tag}}{$target}{$nick} ) { 49 foreach my $nick ( keys %{$last_message{$chanrec->{server}->{tag}}{$target}} ) { 52 %{$last_message{$chanrec->{server}->{tag}}{$target}} = (); 71 $last_message{$chanrec->{server}->{tag}}{lc $chanrec->{name}}{lc $nickrec->{nick}} = 72 delete $last_message{$chanrec->{server}->{tag}}{lc $chanrec->{name}}{lc $oldnick};
|
/dports/editors/the/THE-3.3RC4/ |
H A D | error.c | 298 if (last_message == NULL) 302 if (last_message == NULL) 313 … last_message = (CHARTYPE *)(*the_realloc)(last_message,last_message_length*sizeof(CHARTYPE)); 314 if (last_message == NULL) 322 strcpy((DEFCHAR *)last_message,(DEFCHAR *)mess); 359 Operator("%s%s",hdr,last_message); 376 fprintf(stderr,"%s\n",last_message); 386 fprintf(stderr,"%s\n",last_message); 403 strcpy((DEFCHAR *)last_error->line,(DEFCHAR *)last_message); 404 last_error->length = strlen((DEFCHAR *)last_message); [all …]
|
/dports/www/ulfius/ulfius-2.7.3/test/ |
H A D | websocket.c | 118 ck_assert_ptr_ne(NULL, o_strnstr(last_message->data, MESSAGE, last_message->data_len)); in websocket_incoming_extension_callback() 121 ck_assert_ptr_ne(NULL, o_strnstr(last_message->data, MESSAGE_EXT1, last_message->data_len)); in websocket_incoming_extension_callback() 125 ck_assert_ptr_ne(NULL, o_strnstr(last_message->data, MESSAGE_EXT2, last_message->data_len)); in websocket_incoming_extension_callback() 138 ck_assert_int_eq(0, o_strncmp(last_message->data, MESSAGE_SERVER, last_message->data_len)); in websocket_incoming_extension_deflate_client_callback() 148 ck_assert_int_eq(0, o_strncmp(last_message->data, MESSAGE_SERVER, last_message->data_len)); in websocket_incoming_extension_deflate_client_callback_disabled() 156 ck_assert_int_eq(0, o_strncmp(last_message->data, MESSAGE_CLIENT, last_message->data_len)); in websocket_incoming_extension_deflate_server_callback() 166 ck_assert_int_eq(0, o_strncmp(last_message->data, MESSAGE_CLIENT, last_message->data_len)); in websocket_incoming_extension_deflate_server_callback_disabled() 183 if (0 == o_strncmp(MESSAGE_EXT1, last_message->data, last_message->data_len)) { in websocket_incoming_keep_messages() 185 } else if (0 == o_strncmp(MESSAGE_EXT2, last_message->data, last_message->data_len)) { in websocket_incoming_keep_messages() 187 } else if (0 == o_strncmp(MESSAGE_EXT3, last_message->data, last_message->data_len)) { in websocket_incoming_keep_messages() [all …]
|