Searched refs:socketPair (Results 1 - 5 of 5) sorted by relevance
| /foundation/graphic/graphic_2d/utils/socketpair/test/unittest/ |
| H A D | socketpair_test.cpp | 28 static void SendDataThread(LocalSocketPair *socketPair) in SendDataThread() argument
31 socketPair->SendData((void *)&data, sizeof(int32_t)); in SendDataThread()
55 LocalSocketPair socketPair; in HWTEST_F() local
56 socketPair.CreateChannel(8, 8); in HWTEST_F()
57 int32_t ret = socketPair.CreateChannel(8, 8); in HWTEST_F()
69 LocalSocketPair socketPair; in HWTEST_F() local
70 int32_t ret = socketPair.ReceiveData(nullptr, 0); in HWTEST_F()
72 socketPair.CreateChannel(8, 8); in HWTEST_F()
73 std::thread th(SendDataThread, &socketPair); in HWTEST_F()
77 ret = socketPair in HWTEST_F()
90 LocalSocketPair socketPair; HWTEST_F() local
105 LocalSocketPair socketPair; HWTEST_F() local
121 LocalSocketPair socketPair; HWTEST_F() local
[all...] |
| /foundation/graphic/graphic_2d/utils/socketpair/src/ |
| H A D | local_socketpair.cpp | 60 int32_t LocalSocketPair::SetSockopt(size_t sendSize, size_t receiveSize, int32_t* socketPair, int32_t socketPairSize)
in SetSockopt() argument
63 int32_t ret = setsockopt(socketPair[i], SOL_SOCKET, SO_SNDBUF, &sendSize, sizeof(sendSize));
in SetSockopt()
65 CloseFd(socketPair[0]);
in SetSockopt()
66 CloseFd(socketPair[1]);
in SetSockopt()
70 ret = setsockopt(socketPair[i], SOL_SOCKET, SO_RCVBUF, &receiveSize, sizeof(receiveSize));
in SetSockopt()
72 CloseFd(socketPair[0]);
in SetSockopt()
73 CloseFd(socketPair[1]);
in SetSockopt()
77 ret = fcntl(socketPair[i], F_SETFL, O_NONBLOCK);
in SetSockopt()
79 CloseFd(socketPair[0]);
in SetSockopt()
80 CloseFd(socketPair[ in SetSockopt()
95 int32_t socketPair[SOCKET_PAIR_SIZE] = { 0 }; CreateChannel() local
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket.cpp | 386 int socketPair[2] = {SOCK_INVALID_FD, SOCK_INVALID_FD}; in Connect() local
388 if (socketpair(AF_UNIX, SOCK_STREAM, 0, socketPair) == -1) { in Connect()
401 upperlayerFd_ = socketPair[0]; in Connect()
402 transportFd_ = socketPair[1]; in Connect()
419 int socketPair[2] = {SOCK_INVALID_FD, SOCK_INVALID_FD}; in Listen() local
420 if (socketpair(AF_UNIX, SOCK_STREAM, 0, socketPair) == -1) { in Listen()
424 upperlayerFd_ = socketPair[0]; in Listen()
425 transportFd_ = socketPair[1]; in Listen()
509 int socketPair[2] = {SOCK_INVALID_FD, SOCK_INVALID_FD}; in AddSocketInternal() local
510 if (socketpair(AF_UNIX, SOCK_STREAM, 0, socketPair) in AddSocketInternal()
[all...] |
| /foundation/graphic/graphic_2d/utils/socketpair/export/ |
| H A D | local_socketpair.h | 51 int32_t SetSockopt(size_t sendSize, size_t receiveSize, int32_t* socketPair, int32_t socketPairSize);
|
| /foundation/graphic/graphic_2d/rosen/modules/composer/vsync/src/ |
| H A D | vsync_distributor.cpp | 72 VLOGD("%{public}s: clear socketPair, conn name:%{public}s.", __func__, vsyncConn->info_.name_.c_str());
in OnRemoteDied()
151 VLOGE("%{public}s socketPair invalid fd:%{public}d.", __func__, fd);
in GetReceiveFd()
159 sptr<LocalSocketPair> socketPair;
in PostEvent() local
167 socketPair = socketPair_;
in PostEvent()
169 if (socketPair == nullptr) {
in PostEvent()
170 RS_TRACE_NAME_FMT("socketPair is null, conn: %s", info_.name_.c_str());
in PostEvent()
184 int32_t ret = socketPair->SendData(data, sizeof(data));
in PostEvent()
189 socketPair->ReceiveData(receiveData, sizeof(receiveData));
in PostEvent()
190 ret = socketPair->SendData(data, sizeof(data));
in PostEvent()
|
Completed in 5 milliseconds