Home
last modified time | relevance | path

Searched refs:GetSocketFd (Results 1 – 13 of 13) sorted by relevance

/base/startup/appspawn/test/unittest/client_socket_test/
Dclient_socket_test.cpp62 EXPECT_EQ(-1, clientSocket->GetSocketFd());
64 int32_t socketFd = clientSocket->GetSocketFd();
66 EXPECT_EQ(socketFd, clientSocket->GetSocketFd());
86 EXPECT_EQ(-1, clientSocket->GetSocketFd());
129 EXPECT_LE(0, clientSocket->GetSocketFd());
152 EXPECT_LE(0, clientSocket->GetSocketFd());
175 EXPECT_LE(0, clientSocket->GetSocketFd());
219 EXPECT_LE(0, clientSocket->GetSocketFd());
242 EXPECT_LE(0, clientSocket->GetSocketFd());
266 EXPECT_LE(0, clientSocket->GetSocketFd());
[all …]
/base/startup/init/services/loopevent/task/
Dle_streamtask.c31 int ret = write(GetSocketFd(taskHandle), buffer->data, buffer->dataSize); in HandleSendMsg_()
32 …LE_LOGV("HandleSendMsg_ fd:%d send data size %d %d", GetSocketFd(taskHandle), buffer->dataSize, re… in HandleSendMsg_()
41 LE_LOGV("HandleSendMsg_ fd:%d empty wait read", GetSocketFd(taskHandle)); in HandleSendMsg_()
55 readLen = recv(GetSocketFd(taskHandle), buffer->data, LOOP_DEFAULT_BUFFER, 0); in HandleRecvMsg_()
56 LE_LOGV("HandleRecvMsg fd:%d read msg len %d", GetSocketFd(taskHandle), readLen); in HandleRecvMsg_()
86 LE_LOGV("HandleStreamEvent_ fd:%d oper 0x%x", GetSocketFd(handle), oper); in HandleStreamEvent_()
96 loop->delEvent(loop, GetSocketFd(handle), Event_Read | Event_Write); in HandleStreamEvent_()
108 LE_LOGV("HandleClientEvent_ fd:%d oper 0x%x", GetSocketFd(handle), oper); in HandleClientEvent_()
141 LE_LOGV("HandleServerEvent_ fd %d oper 0x%x", GetSocketFd(serverTask), oper); in HandleServerEvent_()
150 LE_LOGE("HandleServerEvent_ fd %d do not accept socket", GetSocketFd(serverTask)); in HandleServerEvent_()
[all …]
Dle_asynctask.c68 LE_LOGV("HandleAsyncEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper); in HandleAsyncEvent_()
73 int ret = read(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
74 …LE_LOGV("HandleAsyncEvent_ read fd:%d ret: %d eventId %llu", GetSocketFd(taskHandle), ret, eventId… in HandleAsyncEvent_()
82 (void)write(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
Dle_watchtask.c20 LE_LOGV("HandleWatcherEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper); in HandleWatcherEvent_()
23 int fd = GetSocketFd(taskHandle); in HandleWatcherEvent_()
Dle_task.c30 int GetSocketFd(const TaskHandle task) in GetSocketFd() function
191 LE_LOGV("LE_CloseTask %d", GetSocketFd(taskHandle)); in LE_CloseTask()
Dle_task.h129 int GetSocketFd(const TaskHandle task);
/base/startup/init/services/loopevent/signal/
Dle_signal.c33 ssize_t s = read(GetSocketFd(task), &fdsi, sizeof(fdsi)); in HandleSignalEvent_()
81 int sfd = signalfd(GetSocketFd(signalHandle), &task->mask, SFD_NONBLOCK | SFD_CLOEXEC); in LE_AddSignal()
103 int sfd = signalfd(GetSocketFd(signalHandle), &task->mask, SFD_NONBLOCK | SFD_CLOEXEC); in LE_RemoveSignal()
106 loop->delEvent(loop, GetSocketFd(signalHandle), Event_Read); in LE_RemoveSignal()
/base/startup/init/services/loopevent/timer/
Dle_timer.c47 (void)read(GetSocketFd(task), &repeat, sizeof(repeat)); in HandleTimerEvent_()
49 int fd = GetSocketFd(task); in HandleTimerEvent_()
105 int ret = SetTimer_(GetSocketFd(timer), task->timeout); in LE_StartTimer()
/base/startup/appspawn/interfaces/innerkits/include/
Dappspawn_socket.h54 int GetSocketFd() const;
Dclient_socket.h78 using AppSpawnSocket::GetSocketFd;
/base/startup/init/services/loopevent/loop/
Dle_epoll.c53 int fd = GetSocketFd((const TaskHandle)task); in AddEvent_()
69 int fd = GetSocketFd((const TaskHandle)task); in ModEvent_()
/base/startup/appspawn/interfaces/innerkits/client/
Dappspawn_socket.cpp42 int AppSpawnSocket::GetSocketFd() const in GetSocketFd() function in OHOS::AppSpawn::AppSpawnSocket
/base/startup/appspawn/test/unittest/app_spawn_socket_test/
Dapp_spawn_socket_test.cpp61 EXPECT_EQ(-1, appSpawnSocket->GetSocketFd());