Home
last modified time | relevance | path

Searched refs:transport (Results 1 – 25 of 194) sorted by relevance

12345678

/external/dbus/dbus/
Ddbus-transport.c64 DBusTransport *transport = user_data; in live_messages_notify() local
66 _dbus_transport_ref (transport); in live_messages_notify()
78 if (transport->vtable->live_messages_changed) in live_messages_notify()
80 _dbus_connection_lock (transport->connection); in live_messages_notify()
81 (* transport->vtable->live_messages_changed) (transport); in live_messages_notify()
82 _dbus_connection_unlock (transport->connection); in live_messages_notify()
85 _dbus_transport_unref (transport); in live_messages_notify()
102 _dbus_transport_init_base (DBusTransport *transport, in _dbus_transport_init_base() argument
163 transport->refcount = 1; in _dbus_transport_init_base()
164 transport->vtable = vtable; in _dbus_transport_init_base()
[all …]
Ddbus-transport-socket.c72 free_watches (DBusTransport *transport) in free_watches() argument
74 DBusTransportSocket *socket_transport = (DBusTransportSocket*) transport; in free_watches()
80 if (transport->connection) in free_watches()
81 _dbus_connection_remove_watch_unlocked (transport->connection, in free_watches()
90 if (transport->connection) in free_watches()
91 _dbus_connection_remove_watch_unlocked (transport->connection, in free_watches()
102 socket_finalize (DBusTransport *transport) in socket_finalize() argument
104 DBusTransportSocket *socket_transport = (DBusTransportSocket*) transport; in socket_finalize()
108 free_watches (transport); in socket_finalize()
113 _dbus_transport_finalize_base (transport); in socket_finalize()
[all …]
Ddbus-transport.h37 DBusTransport* _dbus_transport_ref (DBusTransport *transport);
38 void _dbus_transport_unref (DBusTransport *transport);
39 void _dbus_transport_disconnect (DBusTransport *transport);
40 dbus_bool_t _dbus_transport_get_is_connected (DBusTransport *transport);
41 dbus_bool_t _dbus_transport_get_is_authenticated (DBusTransport *transport);
42 dbus_bool_t _dbus_transport_get_is_anonymous (DBusTransport *transport);
43 dbus_bool_t _dbus_transport_can_pass_unix_fd (DBusTransport *transport);
45 const char* _dbus_transport_get_address (DBusTransport *transport);
46 const char* _dbus_transport_get_server_id (DBusTransport *transport);
47 dbus_bool_t _dbus_transport_handle_watch (DBusTransport *transport,
[all …]
Ddbus-transport-protected.h43 void (* finalize) (DBusTransport *transport);
46 dbus_bool_t (* handle_watch) (DBusTransport *transport,
53 void (* disconnect) (DBusTransport *transport);
56 dbus_bool_t (* connection_set) (DBusTransport *transport);
59 void (* do_iteration) (DBusTransport *transport,
66 void (* live_messages_changed) (DBusTransport *transport);
69 dbus_bool_t (* get_socket_fd) (DBusTransport *transport,
122 dbus_bool_t _dbus_transport_init_base (DBusTransport *transport,
126 void _dbus_transport_finalize_base (DBusTransport *transport);
Ddbus-transport-unix.c63 DBusTransport *transport; in _dbus_transport_new_for_domain_socket() local
96 transport = _dbus_transport_new_for_socket (fd, NULL, &address); in _dbus_transport_new_for_domain_socket()
97 if (transport == NULL) in _dbus_transport_new_for_domain_socket()
105 return transport; in _dbus_transport_new_for_domain_socket()
131 DBusTransport *transport; in _dbus_transport_new_for_exec() local
197 transport = _dbus_transport_new_for_socket (fd, NULL, &address); in _dbus_transport_new_for_exec()
198 if (transport == NULL) in _dbus_transport_new_for_exec()
206 return transport; in _dbus_transport_new_for_exec()
/external/libbrillo/brillo/http/
Dhttp_utils_unittest.cc43 std::shared_ptr<fake::Transport> transport(new fake::Transport); in TEST() local
44 transport->AddHandler( in TEST()
56 transport, in TEST()
65 std::shared_ptr<fake::Transport> transport(new fake::Transport); in TEST() local
66 transport->AddHandler( in TEST()
88 transport, in TEST()
94 std::shared_ptr<fake::Transport> transport(new fake::Transport); in TEST() local
95 transport->AddHandler(kMethodEchoUrl, "*", base::Bind(EchoMethodHandler)); in TEST()
108 transport, in TEST()
116 std::shared_ptr<fake::Transport> transport(new fake::Transport); in TEST() local
[all …]
Dhttp_utils.cc26 std::shared_ptr<Transport> transport, in GetAndBlock() argument
29 request_type::kGet, url, headers, transport, error); in GetAndBlock()
34 std::shared_ptr<Transport> transport, in Get() argument
40 transport, in Get()
46 std::shared_ptr<Transport> transport, in HeadAndBlock() argument
49 request_type::kHead, url, {}, transport, error); in HeadAndBlock()
53 std::shared_ptr<Transport> transport, in Head() argument
59 transport, in Head()
68 std::shared_ptr<Transport> transport, in PostTextAndBlock() argument
71 url, data.data(), data.size(), mime_type, headers, transport, error); in PostTextAndBlock()
[all …]
Dhttp_utils.h63 std::shared_ptr<Transport> transport,
72 std::shared_ptr<Transport> transport,
86 std::shared_ptr<Transport> transport,
102 std::shared_ptr<Transport> transport,
113 std::shared_ptr<Transport> transport,
123 std::shared_ptr<Transport> transport,
132 std::shared_ptr<Transport> transport,
141 std::shared_ptr<Transport> transport,
149 std::shared_ptr<Transport> transport,
162 std::shared_ptr<Transport> transport,
[all …]
Dhttp_transport_curl.cc38 Transport* transport, in SocketPollData() argument
42 transport_(transport), in SocketPollData()
328 auto transport = static_cast<Transport*>(userp); in MultiSocketCallback() local
329 CHECK(transport) << "Transport must be set for this callback"; in MultiSocketCallback()
333 poll_data = new SocketPollData{transport->curl_interface_, in MultiSocketCallback()
334 transport->curl_multi_handle_, in MultiSocketCallback()
335 transport, in MultiSocketCallback()
337 transport->poll_data_map_.emplace(std::make_pair(easy, s), poll_data); in MultiSocketCallback()
338 transport->curl_interface_->MultiAssign( in MultiSocketCallback()
339 transport->curl_multi_handle_, s, poll_data); in MultiSocketCallback()
[all …]
Dhttp_connection_fake.cc20 const std::shared_ptr<http::Transport>& transport) in Connection() argument
21 : http::Connection(transport), request_(url, method) { in Connection()
45 fake::Transport* transport = static_cast<fake::Transport*>(transport_.get()); in FinishRequest() local
46 CHECK(transport) << "Expecting a fake transport"; in FinishRequest()
47 auto handler = transport->GetHandler(request_.GetURL(), request_.GetMethod()); in FinishRequest()
/external/nist-sip/java/gov/nist/javax/sip/stack/
DHopImpl.java56 protected String transport; field in HopImpl
65 return host + ":" + port + "/" + transport; in toString()
84 transport = trans; in HopImpl()
108 this.transport = hop.substring(slash+1); in HopImpl()
111 this.transport = "UDP"; in HopImpl()
121 this.transport = hop.substring(slash+1); in HopImpl()
122 this.port = transport.equalsIgnoreCase("TLS") ? 5061 : 5060; in HopImpl()
125 this.transport = "UDP"; in HopImpl()
136 this.transport = this.transport.trim(); in HopImpl()
142 if (transport.compareToIgnoreCase("UDP") != 0 in HopImpl()
[all …]
DMessageProcessor.java88 protected String transport; field in MessageProcessor
102 protected MessageProcessor( String transport ) { in MessageProcessor() argument
103 this.transport = transport; in MessageProcessor()
113 protected MessageProcessor( InetAddress ipAddress, int port, String transport, in MessageProcessor() argument
115 this( transport ); in MessageProcessor()
145 return this.transport; in getTransport()
349 public static int getDefaultPort(String transport) { in getDefaultPort() argument
351 return transport.equalsIgnoreCase("TLS")?5061:5060; in getDefaultPort()
/external/autotest/server/hosts/
Dparamiko_host.py102 def _check_transport_error(self, transport): argument
103 error = transport.get_exception()
105 transport.close()
118 transport = paramiko.Transport(self._connect_socket())
120 transport.start_client(completed)
123 self._check_transport_error(transport)
125 transport.auth_publickey(self.user, pkey, completed)
128 self._check_transport_error(transport)
129 if not transport.is_authenticated():
130 transport.close()
[all …]
/external/webrtc/webrtc/p2p/base/
Dtransportcontroller.cc155 Transport* transport = GetOrCreateTransport_w(transport_name); in CreateTransportChannel_w() local
156 TransportChannelImpl* channel = transport->CreateChannel(component); in CreateTransportChannel_w()
194 Transport* transport = GetTransport_w(transport_name); in DestroyTransportChannel_w() local
195 transport->DestroyChannel(component); in DestroyTransportChannel_w()
198 if (!transport->HasChannels()) { in DestroyTransportChannel_w()
214 Transport* transport = new DtlsTransport<P2PTransport>( in CreateTransport_w() local
216 return transport; in CreateTransport_w()
278 Transport* transport = GetTransport_w(transport_name); in GetOrCreateTransport_w() local
279 if (transport) { in GetOrCreateTransport_w()
280 return transport; in GetOrCreateTransport_w()
[all …]
/external/sl4a/ScriptingLayerForAndroid/src/org/connectbot/service/
DTerminalKeyListener.java36 import org.connectbot.transport.AbsTransport;
106 AbsTransport transport = bridge.getTransport(); in onKey() local
116 if (transport == null || !transport.isSessionOpen()) { in onKey()
123 transport.write('/'); in onKey()
127 transport.write(0x09); in onKey()
133 transport.write('/'); in onKey()
137 transport.write(0x09); in onKey()
145 if (keyCode == KeyEvent.KEYCODE_BACK && transport != null) { in onKey()
146 bridge.dispatchDisconnect(!transport.isSessionOpen()); in onKey()
160 if (transport == null || !transport.isSessionOpen()) { in onKey()
[all …]
DTerminalBridge.java53 import org.connectbot.transport.AbsTransport;
85 private AbsTransport transport; field in TerminalBridge
157 transport = null; in TerminalBridge()
176 transport = t; in TerminalBridge()
224 if (b != null && transport != null) { in TerminalBridge()
225 transport.write(b); in TerminalBridge()
235 if (transport != null) { in TerminalBridge()
236 transport.write(b); in TerminalBridge()
282 transport.setBridge(this); in connect()
283 transport.setManager(manager); in connect()
[all …]
DRelay.java25 import org.connectbot.transport.AbsTransport;
51 private AbsTransport transport; field in Relay
65 public Relay(TerminalBridge bridge, AbsTransport transport, vt320 buffer, String encoding) { in Relay() argument
68 this.transport = transport; in Relay()
125 bytesRead = transport.read(byteArray, offset, bytesToRead); in run()
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/share/
DJDWPUnitDebuggeeWrapper.java49 protected TransportWrapper transport; field in JDWPUnitDebuggeeWrapper
79 transport = createTransportWrapper(); in setUpConnection()
85 address = transport.startListening(address); in setUpConnection()
132 transport.stopListening(); in stop()
146 transport.accept(settings.getTimeout(), settings.getTimeout()); in openConnection()
150 transport.attach(address, settings.getTimeout(), settings.getTimeout()); in openConnection()
152 setConnection(transport); in openConnection()
/external/webrtc/webrtc/test/channel_transport/
Dudp_transport_unittest.cc112 UdpTransport* transport = UdpTransport::Create(id, threads); in TEST_F() local
113 UdpTransport::Destroy(transport); in TEST_F()
121 UdpTransport* transport = new UdpTransportImpl(id, in TEST_F() local
124 delete transport; in TEST_F()
132 UdpTransport* transport = new UdpTransportImpl(id, in TEST_F() local
135 EXPECT_EQ(0, transport->InitializeSourcePorts(4711, 4712)); in TEST_F()
138 delete transport; in TEST_F()
/external/nist-sip/java/gov/nist/javax/sip/
DListeningPointImpl.java60 protected String transport; field in ListeningPointImpl
91 public static String makeKey(String host, int port, String transport) { in makeKey() argument
96 .append(transport) in makeKey()
106 return makeKey(this.getIPAddress(), port, transport); in getKey()
131 String transport) { in ListeningPointImpl() argument
135 this.transport = transport; in ListeningPointImpl()
232 sipURI.setTransportParam(this.transport); in createContactHeader()
/external/nist-sip/java/gov/nist/javax/sip/header/
DProtocol.java60 protected String transport; field in Protocol
75 .append(transport.toUpperCase()); in encode()
116 return transport; in getTransport()
140 transport = t; in setTransport()
149 transport = "UDP"; in Protocol()
/external/curl/docs/examples/
Drtsp.c105 static void rtsp_setup(CURL *curl, const char *uri, const char *transport) in rtsp_setup() argument
109 printf(" TRANSPORT %s\n", transport); in rtsp_setup()
111 my_curl_easy_setopt(curl, CURLOPT_RTSP_TRANSPORT, transport); in rtsp_setup()
175 const char *transport = "RTP/AVP;unicast;client_port=1234-1235"; /* UDP */ in main() local
177 const char *transport = "RTP/AVP/TCP;unicast;client_port=1234-1235"; /* TCP */ in main()
201 printf(" default transport: %s\n", transport); in main()
212 transport = argv[2]; in main()
242 rtsp_setup(curl, uri, transport); in main()
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/protorpc/
Dtransport_test.py29 from protorpc import transport
41 MODULE = transport
57 class TestRpc(transport.Rpc):
100 transport.RpcStateError,
109 transport.RpcStateError,
129 transport.RpcStateError,
145 transport.RpcStateError,
186 trans = transport.Transport()
192 trans = transport.Transport(protocol=protojson)
200 trans = transport.Transport(protocol=protocol_config)
[all …]
/external/chromium-trace/catapult/third_party/gsutil/third_party/protorpc/protorpc/wsgi/
Dservice_test.py30 from protorpc import transport
68 self.connection = transport.HttpTransport(
78 self.connection = transport.HttpTransport(
104 transport = self.CreateTransport(service_url)
105 return registry.RegistryService.Stub(transport)
189 transport.HttpTransport(my_service_url))
191 transport.HttpTransport(my_other_service_url))
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/
DHttpEngine.java120 private Transport transport; field in HttpEngine
221 if (transport != null) throw new IllegalStateException(); in sendRequest()
249 transport = Internal.instance.newTransport(connection, this); in sendRequest()
265 transport.writeRequestHeaders(networkRequest); in sendRequest()
274 transport.writeRequestHeaders(networkRequest); in sendRequest()
275 requestBodyOut = transport.createRequestBody(networkRequest, contentLength); in sendRequest()
555 if (transport != null && connection != null) { in releaseConnection()
556 transport.releaseConnectionOnIdle(); in releaseConnection()
572 if (transport != null) { in disconnect()
573 transport.disconnect(this); in disconnect()
[all …]

12345678