Home
last modified time | relevance | path

Searched refs:socket_fd (Results 1 – 23 of 23) sorted by relevance

/aosp12/system/bt/vendor_libs/test_vendor_lib/desktop/
H A Dtest_environment.cc77 if (socket_fd == -1) { in SetUpHciServer()
82 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpHciServer() argument
83 int conn_fd = remote_hci_transport_.Accept(socket_fd); in SetUpHciServer()
103 if (socket_fd == -1) { in SetUpLinkLayerServer()
108 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpLinkLayerServer() argument
123 int socket_fd = socket(AF_INET, SOCK_STREAM, 0); in ConnectToRemoteServer() local
124 if (socket_fd < 1) { in ConnectToRemoteServer()
148 int flags = fcntl(socket_fd, F_GETFL, NULL); in ConnectToRemoteServer()
152 return socket_fd; in ConnectToRemoteServer()
167 if (socket_fd == -1) { in SetUpTestChannel()
[all …]
/aosp12/frameworks/native/libs/vr/libpdx_uds/private/uds/
H A Dipc_helper.h20 virtual ssize_t Send(int socket_fd, const void* data, size_t size,
30 virtual ssize_t Receive(int socket_fd, void* data, size_t size,
47 const BorrowedHandle& socket_fd, msghdr* msg);
61 Status<void> Send(const BorrowedHandle& socket_fd);
90 Status<void> Receive(const BorrowedHandle& socket_fd);
168 return payload.Send(socket_fd, nullptr, data_vec, vec_count);
172 inline Status<void> SendData(const BorrowedHandle& socket_fd,
189 Status<void> status = payload.Receive(socket_fd); in ReceiveData()
196 inline Status<void> ReceiveData(const BorrowedHandle& socket_fd, in ReceiveData() argument
199 Status<void> status = payload.Receive(socket_fd, &request->cred); in ReceiveData()
[all …]
H A Dservice_endpoint.h102 static std::unique_ptr<Endpoint> CreateFromSocketFd(LocalHandle socket_fd);
120 explicit Endpoint(LocalHandle socket_fd);
122 void Init(LocalHandle socket_fd);
/aosp12/frameworks/native/libs/vr/libpdx_uds/
H A Dipc_helper.cpp30 ssize_t Send(int socket_fd, const void* data, size_t size, in Send() argument
32 return send(socket_fd, data, size, flags); in Send()
35 return sendmsg(socket_fd, msg, flags); in SendMessage()
42 return recv(socket_fd, data, size, flags); in Receive()
45 return recvmsg(socket_fd, msg, flags); in ReceiveMessage()
177 return Send(socket_fd, nullptr); in Send()
230 return SendMsgAll(sender, socket_fd, &msg); in Send()
280 return Receive(socket_fd, nullptr); in Receive()
370 return SendAll(&g_socket_sender, socket_fd, data, size); in SendData()
378 return SendMsgAll(&g_socket_sender, socket_fd, &msg); in SendDataVector()
[all …]
H A Dclient_channel.cpp73 Status<void> ReadAndDiscardData(const BorrowedHandle& socket_fd, size_t size) { in ReadAndDiscardData() argument
79 auto status = ReceiveData(socket_fd, buffer, size_to_read); in ReadAndDiscardData()
89 Status<void> SendRequest(const BorrowedHandle& socket_fd, in SendRequest() argument
100 return SendData(socket_fd, transaction_state->request, send_vector, in SendRequest()
104 Status<void> ReceiveResponse(const BorrowedHandle& socket_fd, in ReceiveResponse() argument
108 auto status = ReceiveData(socket_fd, &transaction_state->response); in ReceiveResponse()
131 status = ReceiveDataVector(socket_fd, receive_vector, receive_count); in ReceiveResponse()
133 status = ReadAndDiscardData(socket_fd, size_remaining); in ReceiveResponse()
H A Dservice_endpoint.cpp171 Endpoint::Endpoint(LocalHandle socket_fd) { Init(std::move(socket_fd)); } in Endpoint() argument
173 void Endpoint::Init(LocalHandle socket_fd) { in Init() argument
174 if (socket_fd) { in Init()
175 CHECK_EQ(listen(socket_fd.Get(), kMaxBackLogForSocketListen), 0) in Init()
186 if (socket_fd) { in Init()
189 socket_event.data.fd = socket_fd.Get(); in Init()
190 int ret = epoll_ctl(epoll_fd_.Get(), EPOLL_CTL_ADD, socket_fd.Get(), in Init()
206 socket_fd_ = std::move(socket_fd); in Init()
770 std::unique_ptr<Endpoint> Endpoint::CreateFromSocketFd(LocalHandle socket_fd) { in CreateFromSocketFd() argument
771 return std::unique_ptr<Endpoint>(new Endpoint(std::move(socket_fd))); in CreateFromSocketFd()
H A Dipc_helper_tests.cpp34 MOCK_METHOD4(Send, ssize_t(int socket_fd, const void* data, size_t size,
37 ssize_t(int socket_fd, const msghdr* msg, int flags));
43 ssize_t(int socket_fd, void* data, size_t size, int flags));
44 MOCK_METHOD3(ReceiveMessage, ssize_t(int socket_fd, msghdr* msg, int flags));
/aosp12/system/bt/test/rootcanal/
H A Dbluetooth_hci.cc287 int socket_fd = remote_hci_transport_.SetUp(port); in SetUpHciServer() local
293 if (socket_fd == -1) { in SetUpHciServer()
298 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpHciServer() argument
320 if (socket_fd == -1) { in SetUpLinkLayerServer()
325 async_manager_.WatchFdForNonBlockingReads(socket_fd, [this, connection_callback](int socket_fd) { in SetUpLinkLayerServer() argument
340 int socket_fd = socket(AF_INET, SOCK_STREAM, 0); in ConnectToRemoteServer() local
341 if (socket_fd < 1) { in ConnectToRemoteServer()
367 int flags = fcntl(socket_fd, F_GETFL, NULL); in ConnectToRemoteServer()
371 return socket_fd; in ConnectToRemoteServer()
381 if (socket_fd == -1) { in SetUpTestChannel()
[all …]
/aosp12/packages/modules/adb/
H A Dsocket_test.cpp107 unique_fd socket_fd; member
152 int socket_fd[2]; in TEST_F() local
153 ASSERT_EQ(0, adb_socketpair(socket_fd)); in TEST_F()
157 arg.socket_fd.reset(socket_fd[1]); in TEST_F()
167 ASSERT_EQ(0, adb_close(socket_fd[0])); in TEST_F()
176 int socket_fd[2]; in TEST_F() local
181 arg.socket_fd.reset(socket_fd[1]); in TEST_F()
197 ASSERT_EQ(0, adb_close(socket_fd[0])); in TEST_F()
209 int socket_fd[2]; in TEST_F() local
214 arg.socket_fd.reset(socket_fd[1]); in TEST_F()
[all …]
/aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/mm-camera-interface/src/
H A Dmm_camera_sock.c52 int socket_fd; in mm_camera_socket_create() local
69 socket_fd = socket(AF_UNIX, sktype, 0); in mm_camera_socket_create()
70 if (socket_fd < 0) { in mm_camera_socket_create()
71 LOGE("error create socket fd =%d", socket_fd); in mm_camera_socket_create()
72 return socket_fd; in mm_camera_socket_create()
79 rc = connect(socket_fd, &sock_addr.addr, sizeof(sock_addr.addr_un)); in mm_camera_socket_create()
81 close(socket_fd); in mm_camera_socket_create()
82 socket_fd = -1; in mm_camera_socket_create()
83 LOGE("socket_fd=%d %s ", socket_fd, strerror(errno)); in mm_camera_socket_create()
86 LOGD("socket_fd=%d %s", socket_fd, in mm_camera_socket_create()
[all …]
/aosp12/system/bt/vendor_libs/test_vendor_lib/model/setup/
H A Dtest_model.cc177 void TestModel::IncomingLinkLayerConnection(int socket_fd) { in IncomingLinkLayerConnection() argument
179 AddLinkLayerConnection(socket_fd, Phy::Type::BR_EDR); in IncomingLinkLayerConnection()
183 int socket_fd = connect_to_remote_(server, port); in AddRemote() local
184 if (socket_fd < 0) { in AddRemote()
187 AddLinkLayerConnection(socket_fd, phy_type); in AddRemote()
190 void TestModel::IncomingHciConnection(int socket_fd) { in IncomingHciConnection() argument
191 auto dev = HciSocketDevice::Create(socket_fd); in IncomingHciConnection()
209 dev->RegisterCloseCallback([this, socket_fd, index, user_id] { in IncomingHciConnection()
211 [this, socket_fd, index, user_id]() { in IncomingHciConnection()
217 void TestModel::OnHciConnectionClosed(int socket_fd, size_t index, in OnHciConnectionClosed() argument
[all …]
H A Dtest_model.h72 void AddLinkLayerConnection(int socket_fd, Phy::Type phy_type);
73 void IncomingLinkLayerConnection(int socket_fd);
74 void IncomingHciConnection(int socket_fd);
77 void OnHciConnectionClosed(int socket_fd, size_t index, AsyncUserId user_id);
/aosp12/bootable/recovery/minadbd/
H A Dminadbd.cpp45 int socket_fd; in main() local
46 if (!android::base::ParseInt(argv[2], &socket_fd)) { in main()
50 if (fcntl(socket_fd, F_GETFD, 0) == -1) { in main()
54 SetMinadbdSocketFd(socket_fd); in main()
H A Dminadbd_services.h21 void SetMinadbdSocketFd(int socket_fd);
H A Dminadbd_services.cpp56 void SetMinadbdSocketFd(int socket_fd) { in SetMinadbdSocketFd() argument
57 minadbd_socket = socket_fd; in SetMinadbdSocketFd()
/aosp12/hardware/interfaces/bluetooth/1.0/default/test/
H A Dasync_fd_watcher_unittest.cc201 int socket_fd = StartServer(); in TEST_F() local
204 conn_watcher.WatchFdForNonBlockingReads(socket_fd, [this](int fd) { in TEST_F()
217 close(socket_fd); in TEST_F()
222 int socket_fd = StartServer(); in TEST_F() local
227 conn_watcher.WatchFdForNonBlockingReads(socket_fd, [this](int fd) { in TEST_F()
239 close(socket_fd); in TEST_F()
244 int socket_fd = StartServer(); in TEST_F() local
249 conn_watcher.WatchFdForNonBlockingReads(socket_fd, [this](int fd) { in TEST_F()
271 close(socket_fd); in TEST_F()
/aosp12/system/bt/vendor_libs/test_vendor_lib/model/devices/
H A Dhci_socket_device.h29 HciSocketDevice(int socket_fd);
32 static std::shared_ptr<HciSocketDevice> Create(int socket_fd) { in Create() argument
33 return std::make_shared<HciSocketDevice>(socket_fd); in Create()
H A Dlink_layer_socket_device.h31 LinkLayerSocketDevice(int socket_fd, Phy::Type phy_type);
35 static std::shared_ptr<Device> Create(int socket_fd, Phy::Type phy_type) { in Create() argument
36 return std::make_shared<LinkLayerSocketDevice>(socket_fd, phy_type); in Create()
H A Dlink_layer_socket_device.cc29 LinkLayerSocketDevice::LinkLayerSocketDevice(int socket_fd, Phy::Type phy_type) in LinkLayerSocketDevice() argument
30 : socket_(socket_fd), in LinkLayerSocketDevice()
/aosp12/system/bt/gd/hal/
H A Dhci_hal_host.cc174 int socket_fd = socket(AF_BLUETOOTH, SOCK_RAW, BTPROTO_HCI); in ConnectToSocket() local
175 if (socket_fd < 1) { in ConnectToSocket()
183 ::close(socket_fd); in ConnectToSocket()
192 if (bind(socket_fd, (struct sockaddr*)&addr, sizeof(addr)) < 0) { in ConnectToSocket()
194 ::close(socket_fd); in ConnectToSocket()
198 return socket_fd; in ConnectToSocket()
207 int socket_fd = socket(AF_INET, SOCK_STREAM, 0); in ConnectToSocket() local
208 if (socket_fd < 1) { in ConnectToSocket()
226 int result = connect(socket_fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)); in ConnectToSocket()
236 int ret = setsockopt(socket_fd, SOL_SOCKET, SO_RCVTIMEO, &socket_timeout, sizeof(socket_timeout)); in ConnectToSocket()
[all …]
/aosp12/bootable/recovery/install/
H A Dadb_install.cpp156 static bool HandleMessageFromMinadbd(int socket_fd, in HandleMessageFromMinadbd() argument
159 if (!android::base::ReadFully(socket_fd, buffer, kMinadbdMessageSize)) { in HandleMessageFromMinadbd()
181 socket_fd)) { in HandleMessageFromMinadbd()
189 RecoveryUI* ui, pid_t minadbd_pid, android::base::unique_fd&& socket_fd, in ListenAndExecuteMinadbdCommands() argument
201 ev.data.fd = socket_fd.get(); in ListenAndExecuteMinadbdCommands()
203 if (epoll_ctl(epoll_fd.get(), EPOLL_CTL_ADD, socket_fd.get(), &ev) == -1) { in ListenAndExecuteMinadbdCommands()
237 if (!HandleMessageFromMinadbd(socket_fd.get(), command_map)) { in ListenAndExecuteMinadbdCommands()
/aosp12/bootable/recovery/uncrypt/
H A Duncrypt.cpp674 android::base::unique_fd socket_fd(accept4(service_socket, nullptr, nullptr, SOCK_CLOEXEC)); in main() local
675 if (socket_fd == -1) { in main()
684 success = uncrypt_wrapper(input_path, map_file, socket_fd); in main()
687 success = setup_bcb(socket_fd); in main()
690 success = clear_bcb(socket_fd); in main()
701 if (android::base::ReadFully(socket_fd, &code, 4)) { in main()
/aosp12/packages/apps/Bluetooth/jni/
H A Dcom_android_bluetooth_btservice_AdapterService.cpp1601 int socket_fd = INVALID_FD; in connectSocketNative() local
1618 &btUuid, port, &socket_fd, flag, in connectSocketNative()
1620 socket_fd = INVALID_FD; in connectSocketNative()
1626 return socket_fd; in connectSocketNative()
1632 int socket_fd = INVALID_FD; in createSocketChannelNative() local
1651 &btUuid, port, &socket_fd, flag, in createSocketChannelNative()
1653 socket_fd = INVALID_FD; in createSocketChannelNative()
1660 return socket_fd; in createSocketChannelNative()