| /third_party/cef/libcef/browser/ |
| D | server_impl.cc | 103 int connection_id, in AcceptWebSocketCallback() argument
106 connection_id_(connection_id), in AcceptWebSocketCallback()
210 bool CefServerImpl::IsValidConnection(int connection_id) { in IsValidConnection() argument
212 return connection_info_map_.find(connection_id) != connection_info_map_.end(); in IsValidConnection()
215 void CefServerImpl::SendHttp200Response(int connection_id, in SendHttp200Response() argument
219 SendHttp200ResponseInternal(connection_id, content_type, in SendHttp200Response()
223 void CefServerImpl::SendHttp404Response(int connection_id) { in SendHttp404Response() argument
226 connection_id)); in SendHttp404Response()
233 ConnectionInfo* info = GetConnectionInfo(connection_id); in SendHttp404Response()
239 << connection_id; in SendHttp404Response()
[all …]
|
| D | server_impl.h | 36 bool IsValidConnection(int connection_id) override;
37 void SendHttp200Response(int connection_id,
41 void SendHttp404Response(int connection_id) override;
42 void SendHttp500Response(int connection_id,
44 void SendHttpResponse(int connection_id,
49 void SendRawData(int connection_id,
52 void CloseConnection(int connection_id) override;
53 void SendWebSocketMessage(int connection_id,
57 void ContinueWebSocketRequest(int connection_id,
62 void SendHttp200ResponseInternal(int connection_id,
[all …]
|
| /third_party/cef/include/ |
| D | cef_server.h | 122 virtual bool IsValidConnection(int connection_id) = 0;
132 virtual void SendHttp200Response(int connection_id,
143 virtual void SendHttp404Response(int connection_id) = 0;
152 virtual void SendHttp500Response(int connection_id,
170 virtual void SendHttpResponse(int connection_id,
185 virtual void SendRawData(int connection_id,
194 virtual void CloseConnection(int connection_id) = 0;
203 virtual void SendWebSocketMessage(int connection_id,
245 int connection_id) = 0;
257 int connection_id) = 0;
[all …]
|
| /third_party/cef/tests/ceftests/ |
| D | test_server.cc | 55 int connection_id) override { in OnClientConnected() argument
57 DCHECK(server->IsValidConnection(connection_id)); in OnClientConnected()
58 NotifyClientConnected(server, connection_id); in OnClientConnected()
62 int connection_id) override { in OnClientDisconnected() argument
63 DCHECK(!server->IsValidConnection(connection_id)); in OnClientDisconnected()
64 NotifyClientDisconnected(server, connection_id); in OnClientDisconnected()
68 int connection_id, in OnHttpRequest() argument
71 NotifyHttpRequest(server, connection_id, client_address, request); in OnHttpRequest()
75 int connection_id, in OnWebSocketRequest() argument
80 int connection_id) override {} in OnWebSocketConnected() argument
[all …]
|
| D | server_unittest.cc | 44 int connection_id,
57 int connection_id,
62 int connection_id) = 0;
64 int connection_id,
205 int connection_id) override { in OnClientConnected() argument
208 EXPECT_TRUE(server->IsValidConnection(connection_id)); in OnClientConnected()
210 EXPECT_TRUE(connection_id_set_.find(connection_id) == in OnClientConnected()
212 connection_id_set_.insert(connection_id); in OnClientConnected()
218 int connection_id) override { in OnClientDisconnected() argument
220 EXPECT_FALSE(server->IsValidConnection(connection_id)); in OnClientDisconnected()
[all …]
|
| D | test_server.h | 51 int connection_id) { in OnClientConnected() argument
55 int connection_id) { in OnClientDisconnected() argument
59 int connection_id,
81 int connection_id,
|
| D | test_server_unittest.cc | 81 int connection_id) override { in OnClientConnected() argument
103 int connection_id, in OnHttpRequest() argument
119 connection_id_ = connection_id; in OnHttpRequest()
121 server->SendHttp200Response(connection_id, "text/plain", kResponseData, in OnHttpRequest()
151 int connection_id) override { in OnClientDisconnected() argument
153 if (connection_id != connection_id_) { in OnClientDisconnected()
|
| D | urlrequest_unittest.cc | 1312 int connection_id) override { in OnClientConnected() argument
1316 EXPECT_TRUE(connection_id_set_.find(connection_id) == in OnClientConnected()
1318 connection_id_set_.insert(connection_id); in OnClientConnected()
1327 int connection_id) override { in OnClientDisconnected() argument
1331 ConnectionIdSet::iterator it = connection_id_set_.find(connection_id); in OnClientDisconnected()
1340 int connection_id, in OnHttpRequest() argument
1345 EXPECT_TRUE(VerifyConnection(connection_id)); in OnHttpRequest()
1359 server->SendHttp404Response(connection_id); in OnHttpRequest()
1363 HandleRequest(server, connection_id, request); in OnHttpRequest()
1371 bool VerifyConnection(int connection_id) { in VerifyConnection() argument
[all …]
|
| /third_party/cef/include/capi/ |
| D | cef_server_capi.h | 105 int connection_id);
115 int connection_id,
126 int connection_id);
135 int connection_id,
153 int connection_id,
168 int connection_id,
177 int connection_id);
186 int connection_id,
250 int connection_id);
263 int connection_id);
[all …]
|
| /third_party/cef/libcef_dll/cpptoc/ |
| D | server_cpptoc.cc | 130 int connection_id) { in server_is_valid_connection() argument
140 bool _retval = CefServerCppToC::Get(self)->IsValidConnection(connection_id); in server_is_valid_connection()
147 int connection_id, in server_send_http200response() argument
169 connection_id, CefString(content_type), data, data_size); in server_send_http200response()
173 int connection_id) { in server_send_http404response() argument
183 CefServerCppToC::Get(self)->SendHttp404Response(connection_id); in server_send_http404response()
188 int connection_id, in server_send_http500response() argument
203 CefServerCppToC::Get(self)->SendHttp500Response(connection_id, in server_send_http500response()
209 int connection_id, in server_send_http_response() argument
233 connection_id, response_code, CefString(content_type), content_length, in server_send_http_response()
[all …]
|
| D | server_handler_cpptoc.cc | 68 int connection_id) { in server_handler_on_client_connected() argument
83 CefServerCToCpp::Wrap(server), connection_id); in server_handler_on_client_connected()
89 int connection_id) { in server_handler_on_client_disconnected() argument
104 CefServerCToCpp::Wrap(server), connection_id); in server_handler_on_client_disconnected()
110 int connection_id, in server_handler_on_http_request() argument
135 CefServerCToCpp::Wrap(server), connection_id, CefString(client_address), in server_handler_on_http_request()
142 int connection_id, in server_handler_on_web_socket_request() argument
172 CefServerCToCpp::Wrap(server), connection_id, CefString(client_address), in server_handler_on_web_socket_request()
179 int connection_id) { in server_handler_on_web_socket_connected() argument
194 CefServerCToCpp::Wrap(server), connection_id); in server_handler_on_web_socket_connected()
[all …]
|
| /third_party/cef/libcef_dll/ctocpp/ |
| D | server_ctocpp.cc | 129 bool CefServerCToCpp::IsValidConnection(int connection_id) { in IsValidConnection() argument
139 int _retval = _struct->is_valid_connection(_struct, connection_id); in IsValidConnection()
146 void CefServerCToCpp::SendHttp200Response(int connection_id, in SendHttp200Response() argument
168 _struct->send_http200response(_struct, connection_id, in SendHttp200Response()
173 void CefServerCToCpp::SendHttp404Response(int connection_id) { in SendHttp404Response() argument
183 _struct->send_http404response(_struct, connection_id); in SendHttp404Response()
187 void CefServerCToCpp::SendHttp500Response(int connection_id, in SendHttp500Response() argument
203 _struct->send_http500response(_struct, connection_id, in SendHttp500Response()
208 void CefServerCToCpp::SendHttpResponse(int connection_id, in SendHttpResponse() argument
234 _struct->send_http_response(_struct, connection_id, response_code, in SendHttpResponse()
[all …]
|
| D | server_ctocpp.h | 41 bool IsValidConnection(int connection_id) override;
42 void SendHttp200Response(int connection_id,
46 void SendHttp404Response(int connection_id) override;
47 void SendHttp500Response(int connection_id,
49 void SendHttpResponse(int connection_id,
54 void SendRawData(int connection_id,
57 void CloseConnection(int connection_id) override;
58 void SendWebSocketMessage(int connection_id,
|
| D | server_handler_ctocpp.cc | 63 int connection_id) { in OnClientConnected() argument
79 connection_id); in OnClientConnected()
84 int connection_id) { in OnClientDisconnected() argument
100 connection_id); in OnClientDisconnected()
105 int connection_id, in OnHttpRequest() argument
131 connection_id, client_address.GetStruct(), in OnHttpRequest()
138 int connection_id, in OnWebSocketRequest() argument
169 connection_id, client_address.GetStruct(), in OnWebSocketRequest()
176 int connection_id) { in OnWebSocketConnected() argument
192 connection_id); in OnWebSocketConnected()
[all …]
|
| D | server_handler_ctocpp.h | 41 int connection_id) override;
43 int connection_id) override;
45 int connection_id,
49 int connection_id,
54 int connection_id) override;
56 int connection_id,
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_request.h | 59 connection_id_type connection_id; member
173 explicit FreeSharedBlockRequest(connection_id_type connection_id, int32_t client_id, int64_t addr) in FreeSharedBlockRequest() argument
175 rq_.set_connection_id(connection_id); in FreeSharedBlockRequest()
219 return std::make_shared<FreeSharedBlockRequest>(rq_.connection_id(), rq_.client_id(), addr_); in GenerateFreeBlockRequest()
272 …explicit GetCacheMissKeysRequest(connection_id_type connection_id) : BaseRequest(RequestType::kGet… in GetCacheMissKeysRequest() argument
273 rq_.set_connection_id(connection_id); in GetCacheMissKeysRequest()
282 …explicit DestroyCacheRequest(connection_id_type connection_id) : BaseRequest(RequestType::kDestroy… in DestroyCacheRequest() argument
283 rq_.set_connection_id(connection_id); in DestroyCacheRequest()
293 explicit GetStatRequest(connection_id_type connection_id) : BaseRequest(RequestType::kGetStat) { in GetStatRequest() argument
294 rq_.set_connection_id(connection_id); in GetStatRequest()
[all …]
|
| D | cache_server.cc | 201 auto connection_id = GetConnectionID(session_id, crc); in CreateService() local
220 CacheService *curr_cs = GetService(connection_id); in CreateService()
225 std::to_string(connection_id) + " to create cache service"; in CreateService()
240 all_caches_.emplace(connection_id, std::move(cs)); in CreateService()
259 bld.add_connection_id(connection_id); in CreateService()
275 auto id = rq->connection_id(); in DestroyCache()
293 auto connection_id = rq->connection_id(); in CacheRow() local
296 CacheService *cs = GetService(connection_id); in CacheRow()
298 std::string errMsg = "Cache id " + std::to_string(connection_id) + " not found"; in CacheRow()
326 auto connection_id = rq->connection_id(); in FastCacheRow() local
[all …]
|
| D | de_tensor.fbs | 94 connection_id:uint64;
101 connection_id:uint64;
120 connection_id:uint64;
|
| D | cache_request.cc | 61 …auto mem_rq = std::make_shared<AllocateSharedBlockRequest>(rq_.connection_id(), cc->GetClientId(),… in SerializeCacheRowRequest()
233 cc_->server_connection_id_ = p->connection_id(); in PostReply()
326 current_info.connection_id = current_session_info->connection_id(); in PostReply()
|
| /third_party/cef/tests/cefclient/browser/ |
| D | server_test.cc | 83 int connection_id) override {} in OnClientConnected() argument
86 int connection_id) override {} in OnClientDisconnected() argument
89 int connection_id, in OnHttpRequest() argument
128 SendHttpResponseStream(server, connection_id, mime_type, stream, in OnHttpRequest()
131 server->SendHttp404Response(connection_id); in OnHttpRequest()
136 int connection_id, in OnWebSocketRequest() argument
145 int connection_id) override {} in OnWebSocketConnected() argument
148 int connection_id, in OnWebSocketMessage() argument
155 server->SendWebSocketMessage(connection_id, message.data(), message.size()); in OnWebSocketMessage()
174 int connection_id, in SendHttpResponseStream() argument
[all …]
|
| /third_party/gstreamer/gstplugins_bad/ext/dtls/ |
| D | gstdtlsenc.c | 188 self->connection_id = NULL; in gst_dtls_enc_init()
220 if (self->connection_id) { in gst_dtls_enc_finalize()
221 g_free (self->connection_id); in gst_dtls_enc_finalize()
222 self->connection_id = NULL; in gst_dtls_enc_finalize()
246 if (self->connection_id != NULL) { in gst_dtls_enc_set_property()
247 g_free (self->connection_id); in gst_dtls_enc_set_property()
248 self->connection_id = NULL; in gst_dtls_enc_set_property()
250 self->connection_id = g_value_dup_string (value); in gst_dtls_enc_set_property()
268 g_value_set_string (value, self->connection_id); in gst_dtls_enc_get_property()
311 if (self->connection_id) { in gst_dtls_enc_change_state()
[all …]
|
| D | gstdtlsdec.c | 199 self->connection_id = NULL; in gst_dtls_dec_init()
230 g_free (self->connection_id); in gst_dtls_dec_finalize()
231 self->connection_id = NULL; in gst_dtls_dec_finalize()
269 g_free (self->connection_id); in gst_dtls_dec_set_property()
270 self->connection_id = g_value_dup_string (value); in gst_dtls_dec_set_property()
272 create_connection (self, self->connection_id); in gst_dtls_dec_set_property()
279 if (self->connection_id) { in gst_dtls_dec_set_property()
280 create_connection (self, self->connection_id); in gst_dtls_dec_set_property()
296 g_value_set_string (value, self->connection_id); in gst_dtls_dec_get_property()
613 self->connection_id, gst_buffer_get_size (buffer)); in sink_chain()
|
| D | gstdtlsdec.h | 60 gchar *connection_id; member
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/webrtc/ |
| D | dtlstransport.c | 184 gchar *connection_id; in gst_webrtc_dtls_transport_constructed() local
189 connection_id = g_strdup_printf ("rtp_%u_%u", webrtc->session_id, in gst_webrtc_dtls_transport_constructed()
193 g_object_set (webrtc->dtlssrtpenc, "connection-id", connection_id, in gst_webrtc_dtls_transport_constructed()
197 g_object_set (webrtc->dtlssrtpdec, "connection-id", connection_id, NULL); in gst_webrtc_dtls_transport_constructed()
198 g_free (connection_id); in gst_webrtc_dtls_transport_constructed()
|
| /third_party/gstreamer/gstplugins_bad/sys/dvb/ |
| D | camtransport.c | 280 guint8 connection_id; in cam_tl_read_tpdu_next() local
301 connection_id = tpdu[1]; in cam_tl_read_tpdu_next()
304 GINT_TO_POINTER ((guint) connection_id)); in cam_tl_read_tpdu_next()
307 GST_ERROR ("CAM sent a TPDU on an unknown connection: %d", connection_id); in cam_tl_read_tpdu_next()
|