Home
last modified time | relevance | path

Searched refs:get_next_message (Results 1 – 24 of 24) sorted by relevance

/dports/www/p5-AnyEvent-WebSocket-Client/AnyEvent-WebSocket-Client-0.44/t/
H A Danyevent_websocket_connection__payload_size.t35 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 D1instance.c48 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 Dcouch_server_tests.erl239 ?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 Ddebugger_unittest.py195 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 Dtornado.py45 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 Dtornado.py47 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 Dx_protocol.cc113 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 Dmessu-read_sent.php49 $next = $messulib->get_next_message($user, $_REQUEST['msgId'], $_REQUEST['sort_mode'], $_REQUEST['f…
H A Dmessu-read_archive.php50 $next = $messulib->get_next_message($user, $_REQUEST['msgId'], $_REQUEST['sort_mode'], $_REQUEST['f…
H A Dmessu-read.php51 $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 Drep_base.h106 int get_next_message __P((socket_t, DBT *, DBT *));
H A Drep_msg.c82 if ((ret = get_next_message(fd, &rec, &control)) != 0) {
H A Drep_net.c485 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 Drep_base.h109 int get_next_message __P((socket_t, DBT *, DBT *));
H A Drep_msg.c83 if ((ret = get_next_message(fd, &rec, &control)) != 0) {
H A Drep_net.c565 get_next_message(fd, rec, control) in get_next_message() function
/dports/textproc/c2man/c2man-2.0.42/tests/
H A Dsessipc.h378 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 Dcore.rst30 .. automethod:: get_next_message
/dports/devel/py-jeepney/jeepney-0.7.1/jeepney/io/
H A Dasyncio.py43 msg = self.parser.get_next_message()
H A Dtornado.py41 msg = self.parser.get_next_message()
H A Dblocking.py97 msg = self.parser.get_next_message()
H A Dtrio.py131 msg = self.parser.get_next_message()
/dports/devel/py-jeepney/jeepney-0.7.1/jeepney/
H A Dlow_level.py505 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 Dmessulib.php420 …function get_next_message($user, $msgId, $sort_mode, $find, $flag, $flagval, $prio, $dbsource = 'm… function in Messu