/dports/www/p5-AnyEvent-WebSocket-Client/AnyEvent-WebSocket-Client-0.44/t/ |
H A D | anyevent_websocket_connection__payload_size.t | 35 sub get_next_message 70 my $rmessage = get_next_message(); 81 my $rmessage = get_next_message();
|
/dports/net/libvncserver/libvncserver-LibVNCServer-0.9.13/examples/ |
H A D | 1instance.c | 48 int get_next_message(char* buffer,int len,single_instance_struct* str,int usecs) in get_next_message() function 83 if((num_fds=get_next_message(buffer,1024,str,usecs)) && buffer[0]) in dispatch_event()
|
/dports/databases/couchdb3/apache-couchdb-3.2.1/src/couch/test/eunit/ |
H A D | couch_server_tests.erl | 239 ?assertEqual({OpenRef, ok}, get_next_message()), 243 ?assertMatch({CrtRef, {ok, _}}, get_next_message()), 288 get_next_message() -> function
|
/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/pydev/pydev_tests_python/ |
H A D | debugger_unittest.py | 195 def get_next_message(self, context_message, timeout=None): member in ReaderThread 591 def get_next_message(self, context_message, timeout=None): member in AbstractWriterThread 592 return self.reader_thread.get_next_message(context_message, timeout=timeout) 638 last = self.get_next_message('wait_for_new_thread') 649 msg = self.get_next_message('wait_output') 729 last = self.get_next_message('wait_for_get_next_statement_targets') 745 …last = self.get_next_message('wait_for_custom_operation. Expected (encoded): %s' % (expected_encod… 773 last = self.get_next_message('wait_for_multiple_vars: %s' % (expected_vars,)) 1007 last = self.get_next_message('wait_for_message', timeout=timeout)
|
/dports/net-p2p/bazarr/bazarr-1.0.2/libs/engineio/async_drivers/ |
H A D | tornado.py | 45 async def get_next_message(self): member in get_tornado_handler.Handler 170 msg = await self.tornado_handler.get_next_message()
|
/dports/devel/py-python-engineio/python-engineio-3.14.2/engineio/async_drivers/ |
H A D | tornado.py | 47 async def get_next_message(self): member in get_tornado_handler.Handler 172 msg = await self.tornado_handler.get_next_message()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/router/src/routing/src/protocol/ |
H A D | x_protocol.cc | 113 static bool get_next_message(int sender, RoutingProtocolBuffer &buffer, in get_next_message() function 229 while (get_next_message(sender, buffer, bytes_read, message_offset, in copy_packets()
|
/dports/www/tikiwiki/tiki-21.2/ |
H A D | messu-read_sent.php | 49 $next = $messulib->get_next_message($user, $_REQUEST['msgId'], $_REQUEST['sort_mode'], $_REQUEST['f…
|
H A D | messu-read_archive.php | 50 $next = $messulib->get_next_message($user, $_REQUEST['msgId'], $_REQUEST['sort_mode'], $_REQUEST['f…
|
H A D | messu-read.php | 51 $next = $messulib->get_next_message($user, $_REQUEST['msgId'], $_REQUEST['sort_mode'], $_REQUEST['f…
|
/dports/databases/db5/db-5.3.28/examples/c/ex_rep/base/ |
H A D | rep_base.h | 106 int get_next_message __P((socket_t, DBT *, DBT *));
|
H A D | rep_msg.c | 82 if ((ret = get_next_message(fd, &rec, &control)) != 0) {
|
H A D | rep_net.c | 485 get_next_message(fd, rec, control) in get_next_message() function
|
/dports/databases/db18/db-18.1.40/examples/c/ex_rep/base/ |
H A D | rep_base.h | 109 int get_next_message __P((socket_t, DBT *, DBT *));
|
H A D | rep_msg.c | 83 if ((ret = get_next_message(fd, &rec, &control)) != 0) {
|
H A D | rep_net.c | 565 get_next_message(fd, rec, control) in get_next_message() function
|
/dports/textproc/c2man/c2man-2.0.42/tests/ |
H A D | sessipc.h | 378 static INLINE MESSAGE *get_next_message(IPC_QUEUE *pqueue) in get_next_message() function
|
/dports/devel/py-jeepney/jeepney-0.7.1/docs/api/ |
H A D | core.rst | 30 .. automethod:: get_next_message
|
/dports/devel/py-jeepney/jeepney-0.7.1/jeepney/io/ |
H A D | asyncio.py | 43 msg = self.parser.get_next_message()
|
H A D | tornado.py | 41 msg = self.parser.get_next_message()
|
H A D | blocking.py | 97 msg = self.parser.get_next_message()
|
H A D | trio.py | 131 msg = self.parser.get_next_message()
|
/dports/devel/py-jeepney/jeepney-0.7.1/jeepney/ |
H A D | low_level.py | 505 return list(iter(self.get_next_message, None)) 521 def get_next_message(self) -> Optional[Message]: member in Parser
|
/dports/www/tikiwiki/tiki-21.2/lib/messu/ |
H A D | messulib.php | 420 …function get_next_message($user, $msgId, $sort_mode, $find, $flag, $flagval, $prio, $dbsource = 'm… function in Messu
|