Home
last modified time | relevance | path

Searched refs:proto_factory (Results 1 – 25 of 32) sorted by relevance

12

/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/pydev/_pydev_comm/
H A Dpydev_rpc.py10 def make_rpc_client(client_service, host, port, proto_factory=TBinaryProtocolFactory(strict_read=Fa… argument
13 client_protocol = proto_factory.get_protocol(client_transport)
20 def start_rpc_server(server_transport, server_service, server_handler, proto_factory=TBinaryProtoco… argument
24 …rver = TSingleThreadedServer(processor, server_transport, daemon=True, iprot_factory=proto_factory)
30 … proto_factory=TBinaryProtocolFactory(strict_read=False, strict_write=False)): argument
37 …erver, args=(server_socket, server_service, client_service, server_handler_factory, proto_factory))
44 … _rpc_server(server_socket, server_service, client_service, server_handler_factory, proto_factory): argument
49 client_protocol = proto_factory.get_protocol(client_transport)
57 …rver = TSingleThreadedServer(processor, server_transport, daemon=True, iprot_factory=proto_factory)
/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/third_party/thriftpy/_shaded_thriftpy/
H A Drpc.py19 proto_factory=TBinaryProtocolFactory(), argument
30 protocol = proto_factory.get_protocol(transport)
37 proto_factory=TBinaryProtocolFactory(), argument
48 iprot_factory=proto_factory,
55 proto_factory=TBinaryProtocolFactory(), argument
76 protocol = proto_factory.get_protocol(transport)
H A Dutils.py11 def serialize(thrift_object, proto_factory=TBinaryProtocolFactory()): argument
13 protocol = proto_factory.get_protocol(transport)
19 def deserialize(thrift_object, buf, proto_factory=TBinaryProtocolFactory()): argument
21 protocol = proto_factory.get_protocol(transport)
H A Dtornado.py212 service, handler, proto_factory=TBinaryProtocolFactory(), argument
216 server = TTornadoServer(processor, iprot_factory=proto_factory,
224 service, host, port, proto_factory=TBinaryProtocolFactory(), argument
230 iprot = proto_factory.get_protocol(TMemoryBuffer())
231 oprot = proto_factory.get_protocol(transport)
/dports/devel/py-thriftpy2/thriftpy2-0.4.14/thriftpy2/
H A Dutils.py11 def serialize(thrift_object, proto_factory=TBinaryProtocolFactory()): argument
13 protocol = proto_factory.get_protocol(transport)
19 def deserialize(thrift_object, buf, proto_factory=TBinaryProtocolFactory()): argument
21 protocol = proto_factory.get_protocol(transport)
H A Drpc.py31 proto_factory=TBinaryProtocolFactory(), argument
55 protocol = proto_factory.get_protocol(transport)
62 proto_factory=TBinaryProtocolFactory(), argument
83 iprot_factory=proto_factory,
90 proto_factory=TBinaryProtocolFactory(), argument
128 protocol = proto_factory.get_protocol(transport)
H A Dtornado.py238 service, handler, proto_factory=TBinaryProtocolFactory(), argument
243 server = TTornadoServer(processor, iprot_factory=proto_factory,
247 server = TTornadoServer(processor, iprot_factory=proto_factory,
255 service, host='localhost', port=9090, proto_factory=TBinaryProtocolFactory(), argument
267 iprot = proto_factory.get_protocol(TMemoryBuffer())
268 oprot = proto_factory.get_protocol(transport)
H A Dhttp.py298 proto_factory=TBinaryProtocolFactory(), argument
312 iprot = proto_factory.get_protocol(transport)
319 proto_factory=TBinaryProtocolFactory(), argument
334 iprot = proto_factory.get_protocol(transport)
342 proto_factory=TBinaryProtocolFactory(), argument
347 iprot_factory=proto_factory)
/dports/devel/py-thriftpy2/thriftpy2-0.4.14/thriftpy2/contrib/aio/
H A Drpc.py23 proto_factory=TAsyncBinaryProtocolFactory(), argument
57 protocol = proto_factory.get_protocol(transport)
64 proto_factory=TAsyncBinaryProtocolFactory(), argument
83 iprot_factory=proto_factory,
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/afsocket/
H A Dafsocket-dest.c40 LogProtoClientFactory *proto_factory; member
48 item->proto_factory = afsocket_dd->proto_factory; in _reload_store_item_new()
77 return (self->proto_factory->construct == item->proto_factory->construct); in _is_protocol_compatible_with_writer_after_reload()
277 …proto = log_proto_client_factory_construct(self->proto_factory, transport, &self->writer_options.p… in afsocket_dd_connected()
440 if (!self->proto_factory) in afsocket_dd_setup_proto_factory()
441 …self->proto_factory = log_proto_client_get_factory(&cfg->plugin_context, self->transport_mapper->l… in afsocket_dd_setup_proto_factory()
443 if (!self->proto_factory) in afsocket_dd_setup_proto_factory()
450 self->transport_mapper->create_multitransport = self->proto_factory->use_multitransport; in afsocket_dd_setup_proto_factory()
596 if (!log_proto_client_factory_is_proto_stateful(self->proto_factory)) in _dd_rewind_stateless_proto_backlog()
H A Dafinet-source.c73 if (self->super.proto_factory->default_inet_port) in afinet_sd_setup_addresses()
74 …transport_mapper_inet_set_server_port(self->super.transport_mapper, self->super.proto_factory->def… in afinet_sd_setup_addresses()
H A Dafsocket-dest.h47 LogProtoClientFactory *proto_factory; member
H A Dafsocket-source.h53 LogProtoServerFactory *proto_factory; member
H A Dafsocket-source.c139 proto = log_proto_server_factory_construct(self->owner->proto_factory, transport, in afsocket_sc_init()
772 if (!self->proto_factory) in afsocket_sd_setup_transport()
773 …self->proto_factory = log_proto_server_get_factory(&cfg->plugin_context, self->transport_mapper->l… in afsocket_sd_setup_transport()
775 if (!self->proto_factory) in afsocket_sd_setup_transport()
782 self->transport_mapper->create_multitransport = self->proto_factory->use_multitransport; in afsocket_sd_setup_transport()
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/libtest/
H A Dproto_lib.c74 LogProtoServerFactory *proto_factory; in construct_server_proto_plugin() local
77 proto_factory = log_proto_server_get_factory(&configuration->plugin_context, name); in construct_server_proto_plugin()
78 cr_assert_not_null(proto_factory, "error looking up proto factory"); in construct_server_proto_plugin()
79 return log_proto_server_factory_construct(proto_factory, transport, &proto_server_options); in construct_server_proto_plugin()
/dports/devel/py-thriftpy2/thriftpy2-0.4.14/thriftpy2/protocol/
H A Dmultiplex.py28 def __init__(self, proto_factory, service_name): argument
29 self._proto_factory = proto_factory
/dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/third_party/thriftpy/_shaded_thriftpy/protocol/
H A Dmultiplex.py28 def __init__(self, proto_factory, service_name): argument
29 self._proto_factory = proto_factory
/dports/devel/py-thriftpy2/thriftpy2-0.4.14/tests/
H A Dtest_multiplexed.py69 proto_factory=multiplexing_factory)
78 proto_factory=multiplexing_factory)
H A Dtest_buffered_transport.py55 proto_factory=self.PROTOCOL_FACTORY,
63 proto_factory=self.PROTOCOL_FACTORY,
H A Dtest_framed_transport.py87 proto_factory=self.PROTOCOL_FACTORY,
92 proto_factory=self.PROTOCOL_FACTORY,
H A Dtest_aio.py135 proto_factory=cls.PROTOCOL_FACTORY,
157 proto_factory=self.PROTOCOL_FACTORY,
259 proto_factory=self.PROTOCOL_FACTORY,
/dports/www/py-ws4py/ws4py-0.3.4/ws4py/server/
H A Dtulipserver.py215 proto_factory = lambda: WebSocketProtocol(EchoWebSocket) function
216 return loop.create_server(proto_factory, '', 9007)
/dports/devel/grpc/grpc-1.42.0/third_party/upb/benchmarks/
H A Dbenchmark.cc230 Proto2Factory<AMode, P> proto_factory; in BM_Parse_Proto2() local
231 auto proto = proto_factory.GetProto(); in BM_Parse_Proto2()
/dports/devel/py-grpcio/grpcio-1.43.0/third_party/upb/benchmarks/
H A Dbenchmark.cc230 Proto2Factory<AMode, P> proto_factory; in BM_Parse_Proto2() local
231 auto proto = proto_factory.GetProto(); in BM_Parse_Proto2()
/dports/databases/py-asyncpg/asyncpg-0.25.0/asyncpg/
H A Dconnect_utils.py810 proto_factory = lambda: protocol.Protocol( function
815 connector = loop.create_unix_connection(proto_factory, addr)
818 proto_factory, *addr, loop=loop, ssl_context=params.ssl,
821 connector = loop.create_connection(proto_factory, *addr)

12