| /foundation/resourceschedule/ffrt/src/eu/ |
| D | qos_interface.cpp | 39 int fd = open(fileName, O_RDWR); in TrivalOpenRtgNode() local
40 if (fd < 0) { in TrivalOpenRtgNode()
44 return fd; in TrivalOpenRtgNode()
50 int fd = open(fileName, O_RDWR); in TrivalOpenAuthCtrlNode() local
51 if (fd < 0) { in TrivalOpenAuthCtrlNode()
55 return fd; in TrivalOpenAuthCtrlNode()
61 int fd = open(fileName, O_RDWR); in TrivalOpenQosCtrlNode() local
62 if (fd < 0) { in TrivalOpenQosCtrlNode()
63 FFRT_LOGW("pid %d belong to user %d open qos node warn, fd:%d, eno:%d, %s\n", in TrivalOpenQosCtrlNode()
64 getpid(), getuid(), fd, errno, strerror(errno)); in TrivalOpenQosCtrlNode()
[all …]
|
| D | rtg_perf_ctrl.cpp | 33 int fd = -1; in OpenPerfCtrl() local
39 fd = open("/dev/hisi_perf_ctrl", O_RDWR); in OpenPerfCtrl()
40 if (fd < 0) { in OpenPerfCtrl()
45 return fd; in OpenPerfCtrl()
51 int fd = OpenPerfCtrl(); in SetTaskRtg() local
52 if (fd < 0) { in SetTaskRtg()
56 if (ioctl(fd, PERF_CTRL_SET_TASK_RTG, &data)) { in SetTaskRtg()
58 close(fd); in SetTaskRtg()
61 close(fd); in SetTaskRtg()
66 int fd = OpenPerfCtrl(); in SetRtgStatus() local
[all …]
|
| /foundation/resourceschedule/qos_manager/services/src/ |
| D | qos_interface.cpp | 32 int fd = open(fileName, O_RDWR); in TrivalOpenRtgNode() local
33 if (fd < 0) { in TrivalOpenRtgNode()
37 return fd; in TrivalOpenRtgNode()
43 int fd = open(fileName, O_RDWR); in TrivalOpenAuthCtrlNode() local
44 if (fd < 0) { in TrivalOpenAuthCtrlNode()
48 return fd; in TrivalOpenAuthCtrlNode()
54 int fd = open(fileName, O_RDWR); in TrivalOpenQosCtrlNode() local
55 if (fd < 0) { in TrivalOpenQosCtrlNode()
59 return fd; in TrivalOpenQosCtrlNode()
71 int fd = TrivalOpenRtgNode(); in EnableRtg() local
[all …]
|
| /foundation/communication/dsoftbus/core/connection/common/src/ |
| D | softbus_tcp_socket.c | 33 static int SetReusePort(int fd, int on) in SetReusePort() argument
35 int rc = SoftBusSocketSetOpt(fd, SOFTBUS_SOL_SOCKET, SOFTBUS_SO_REUSEPORT, &on, sizeof(on)); in SetReusePort()
44 static int SetReuseAddr(int fd, int on) in SetReuseAddr() argument
46 int rc = SoftBusSocketSetOpt(fd, SOFTBUS_SOL_SOCKET, SOFTBUS_SO_REUSEADDR, &on, sizeof(on)); in SetReuseAddr()
54 static int SetNoDelay(int fd, int on) in SetNoDelay() argument
56 int rc = SoftBusSocketSetOpt(fd, SOFTBUS_IPPROTO_TCP, SOFTBUS_TCP_NODELAY, &on, sizeof(on)); in SetNoDelay()
68 static int SetQuickStart(int fd, int quick) in SetQuickStart() argument
71 int rc = setsockopt(fd, SOFTBUS_IPPROTO_TCP, TCP_QUICK_START, &quick, sizeof(quick)); in SetQuickStart()
80 static int SetSendBufFix(int fd, int val) in SetSendBufFix() argument
82 int rc = setsockopt(fd, SOFTBUS_SOL_SOCKET, SOFTBUS_SO_SNDBUF, &val, sizeof(val)); in SetSendBufFix()
[all …]
|
| /foundation/CastEngine/castengine_wifi_display/services/network/eventhandler/ |
| D | event_descriptor_listener.cpp | 38 EventDescriptorListener::EventDescriptorListener(int32_t fd) : socketLocalFd_(fd) in EventDescriptorListener() argument
49 bool EventDescriptorListener::AddFdListener(int32_t fd, const std::shared_ptr<FileDescriptorListene… in AddFdListener() argument
53 SHARING_LOGD("fd: %{public}d.", fd); in AddFdListener()
54 auto existHandler = EventHandlerManager::GetInstance().GetEventHandler(fd); in AddFdListener()
64 EventHandlerManager::GetInstance().AddEventHandler(fd, eventHandler); in AddFdListener()
65 EventHandlerManager::GetInstance().AddFdListener(fd, listener); in AddFdListener()
67 return ERR_OK == eventHandler->AddFileDescriptorListener(fd, events, listener, taskName); in AddFdListener()
70 void EventDescriptorListener::RemoveFdListener(int32_t fd, in RemoveFdListener() argument
73 SHARING_LOGD("fd: %{public}d.", fd); in RemoveFdListener()
74 auto existHandler = EventHandlerManager::GetInstance().GetEventHandler(fd); in RemoveFdListener()
[all …]
|
| /foundation/multimedia/media_foundation/test/scenetest/ |
| D | test_single_audio_recorder_fast_prepare.h | 45 int32_t fd; in FIXTURE() local
73 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
74 ASSERT_TRUE(fd >= 0); in FIXTURE()
75 recordSource.UseOutFd(fd); in FIXTURE()
78 ASSERT_EQ(0, close(fd)); in FIXTURE()
89 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
90 ASSERT_TRUE(fd >= 0); in FIXTURE()
91 recordSource.UseOutFd(fd); in FIXTURE()
96 ASSERT_EQ(0, close(fd)); in FIXTURE()
107 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
[all …]
|
| D | test_single_audio_recorder_fast_audio_function.h | 45 int32_t fd; in FIXTURE() local
99 // The recorder prepare fd source, start, stop, release in FIXTURE()
105 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
106 ASSERT_TRUE(fd >= 0); in FIXTURE()
107 recordSource.UseOutFd(fd); in FIXTURE()
115 ASSERT_EQ(0, close(fd)); in FIXTURE()
118 // The recorder prepare fd source, start, pause, stop, release in FIXTURE()
124 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
125 ASSERT_TRUE(fd >= 0); in FIXTURE()
126 recordSource.UseOutFd(fd); in FIXTURE()
[all …]
|
| D | test_single_audio_recorder_fast_stop_reset.h | 45 int32_t fd; in FIXTURE() local
113 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
114 ASSERT_TRUE(fd >= 0); in FIXTURE()
115 recordSource.UseOutFd(fd); in FIXTURE()
120 ASSERT_EQ(0, close(fd)); in FIXTURE()
131 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
132 ASSERT_TRUE(fd >= 0); in FIXTURE()
133 recordSource.UseOutFd(fd); in FIXTURE()
139 ASSERT_EQ(0, close(fd)); in FIXTURE()
150 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
[all …]
|
| D | test_single_audio_recorder_fast_start_pause.h | 45 int32_t fd; in FIXTURE() local
66 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
67 ASSERT_TRUE(fd >= 0); in FIXTURE()
68 recordSource.UseOutFd(fd); in FIXTURE()
73 ASSERT_EQ(0, close(fd)); in FIXTURE()
84 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
85 ASSERT_TRUE(fd >= 0); in FIXTURE()
86 recordSource.UseOutFd(fd); in FIXTURE()
93 ASSERT_EQ(0, close(fd)); in FIXTURE()
104 fd = open(filePath.c_str(), O_RDWR | O_CREAT | O_BINARY, 0644); // 0644, permission in FIXTURE()
[all …]
|
| /foundation/multimodalinput/input/service/module_loader/src/ |
| D | uds_server.cpp | 69 int32_t UDSServer::GetClientPid(int32_t fd) const in GetClientPid()
71 auto it = sessionsMap_.find(fd); in GetClientPid()
73 MMI_HILOGE("Not found fd:%{public}d", fd); in GetClientPid()
79 bool UDSServer::SendMsg(int32_t fd, NetPacket& pkt) in SendMsg() argument
81 if (fd < 0) { in SendMsg()
82 MMI_HILOGE("The fd is less than 0"); in SendMsg()
85 auto ses = GetSession(fd); in SendMsg()
87 MMI_HILOGE("The fd:%{public}d not found, The message was discarded. errCode:%{public}d", in SendMsg()
88 fd, SESSION_NOT_FOUND); in SendMsg()
186 void UDSServer::Dump(int32_t fd, const std::vector<std::string> &args) in Dump() argument
[all …]
|
| /foundation/CastEngine/castengine_wifi_display/services/network/socket/ |
| D | socket_utils.cpp | 32 bool SocketUtils::CreateTcpServer(const char *ip, unsigned port, int32_t &fd) in CreateTcpServer() argument
36 return CreateSocket(SOCK_STREAM, fd) && SetReuseAddr(fd, true) && SetNoDelay(fd, true) && in CreateTcpServer()
37 BindSocket(fd, ip, port) && ListenSocket(fd); in CreateTcpServer()
90 int32_t fd = -1; in IsUdpPortAvailable() local
91 auto ret = CreateSocket(SOCK_DGRAM, fd) && BindSocket(fd, "", port); in IsUdpPortAvailable()
92 if (fd != -1) { in IsUdpPortAvailable()
93 CloseSocket(fd); in IsUdpPortAvailable()
99 bool SocketUtils::CreateTcpClient(const char *ip, unsigned port, int32_t &fd, int32_t &ret) in CreateTcpClient() argument
103 return CreateSocket(SOCK_STREAM, fd) && ConnectSocket(fd, true, ip, port, ret); in CreateTcpClient()
106 bool SocketUtils::CreateUdpSession(unsigned port, int32_t &fd) in CreateUdpSession() argument
[all …]
|
| D | udp_socket.cpp | 35 int32_t fd = -1; in Bind() local
36 if (!SocketUtils::CreateSocket(SOCK_DGRAM, fd)) { in Bind()
40 socketLocalFd_ = fd; in Bind()
43 SocketUtils::SetReuseAddr(fd, enableReuse); in Bind()
44 SocketUtils::SetReusePort(fd, enableReuse); in Bind()
47 SocketUtils::SetNonBlocking(fd); in Bind()
48 SocketUtils::SetSendBuf(fd); in Bind()
49 SocketUtils::SetRecvBuf(fd); in Bind()
50 SocketUtils::SetCloseWait(fd); in Bind()
51 SocketUtils::SetCloExec(fd, true); in Bind()
[all …]
|
| D | socket_utils.h | 29 static bool CreateUdpSession(unsigned port, int32_t &fd);
30 static bool CreateSocket(int32_t socketType, int32_t &fd);
31 static bool CreateTcpServer(const char *ip, unsigned port, int32_t &fd);
32 static bool CreateTcpClient(const char *ip, unsigned port, int32_t &fd, int32_t &ret);
34 static bool CheckAsyncConnect(int32_t fd);
35 static bool ListenSocket(int32_t fd, uint32_t backlog = MAX_BACKLOG_NUM);
36 static bool BindSocket(int32_t fd, const std::string &host, uint16_t port);
37 …static bool ConnectSocket(int32_t fd, bool isAsync, const std::string &ip, uint16_t port, int32_t …
40 static bool SetReuseAddr(int32_t fd, bool isOn);
41 static bool SetReusePort(int32_t fd, bool isOn);
[all …]
|
| D | tcp_socket.cpp | 36 int32_t fd = -1; in Bind() local
37 if (!SocketUtils::CreateSocket(SOCK_STREAM, fd)) { in Bind()
41 socketLocalFd_ = fd; in Bind()
44 SocketUtils::SetReuseAddr(fd, enableReuse); in Bind()
45 SocketUtils::SetReusePort(fd, enableReuse); in Bind()
48 SocketUtils::SetCloseWait(fd); in Bind()
49 SocketUtils::SetCloExec(fd, true); in Bind()
51 if (!SocketUtils::BindSocket(fd, host, port)) { in Bind()
53 SocketUtils::ShutDownSocket(fd); in Bind()
57 if (!SocketUtils::ListenSocket(fd, backlog)) { in Bind()
[all …]
|
| /foundation/multimodalinput/input/service/event_dump/src/ |
| D | event_dump.cpp | 61 void ChkConfig(int32_t fd) in ChkConfig() argument
63 mprintf(fd, "ChkMMIConfig: "); in ChkConfig()
64 mprintf(fd, "DEF_MMI_DATA_ROOT:%s\n", DEF_MMI_DATA_ROOT); in ChkConfig()
65 mprintf(fd, "EXP_CONFIG:%s\n", DEF_EXP_CONFIG); in ChkConfig()
66 mprintf(fd, "EXP_SOPATH:%s\n", DEF_EXP_SOPATH); in ChkConfig()
69 void EventDump::CheckCount(int32_t fd, const std::vector<std::string> &args, int32_t &count) in CheckCount() argument
84 void EventDump::ParseCommand(int32_t fd, const std::vector<std::string> &args) in ParseCommand() argument
88 CheckCount(fd, args, count); in ParseCommand()
91 mprintf(fd, "cmd param number not more than 32\n"); in ParseCommand()
137 DumpEventHelp(fd, args); in ParseCommand()
[all …]
|
| /foundation/communication/dsoftbus/core/authentication/src/ |
| D | auth_tcp_connection.c | 121 static void NotifyConnected(ListenerModule module, int32_t fd, bool isClient) in NotifyConnected() argument
124 g_callback.onConnected(module, fd, isClient); in NotifyConnected()
128 static void NotifyDisconnected(int32_t fd) in NotifyDisconnected() argument
131 g_callback.onDisconnected(fd); in NotifyDisconnected()
133 NotifyChannelDisconnected(fd); in NotifyDisconnected()
153 static void NotifyDataReceived(ListenerModule module, int32_t fd, in NotifyDataReceived() argument
157 NotifyChannelDataReceived(fd, pktHead, data); in NotifyDataReceived()
161 AuthMetaNotifyDataReceived(fd, pktHead, data); in NotifyDataReceived()
172 g_callback.onDataReceived(module, fd, &head, data); in NotifyDataReceived()
176 static int32_t RecvPacketHead(ListenerModule module, int32_t fd, SocketPktHead *head) in RecvPacketHead() argument
[all …]
|
| /foundation/graphic/graphic_3d/lume/Lume_3D/assets/3d/shaders/shader/ |
| D | core3d_dm_fullscreen_deferred_shading.frag | 40 FullGBufferData fd;
41 fd.material = vec4(0.0, 1.0, 1.0, 0.04);
42 fd.baseColor = vec4(0.0, 0.0, 0.0, 1.0);
43 fd.normal = vec3(0.0, 1.0, 0.0);
44 fd.ao = 1.0;
45 fd.materialType = 0;
46 fd.materialFlags = 0;
49 …GetUnpackMaterialWithFlags(subpassLoad(uGBufferMaterial), fd.material, fd.materialType, fd.materia…
51 …npackMaterialWithFlags(textureLod(uGBufferMaterial, uv, 0), fd.material, fd.materialType, fd.mater…
53 return fd;
[all …]
|
| /foundation/bundlemanager/bundle_framework/interfaces/inner_api/appexecfwk_core/src/bundlemgr/ |
| D | bundle_stream_installer_proxy.cpp | 40 int32_t fd = Constants::DEFAULT_STREAM_FD; in CreateStream() local
43 return fd; in CreateStream()
48 return fd; in CreateStream()
52 return fd; in CreateStream()
58 return fd; in CreateStream()
64 return fd; in CreateStream()
67 fd = dup(sharedFd); in CreateStream()
71 return fd; in CreateStream()
78 int32_t fd = Constants::DEFAULT_STREAM_FD; in CreateSignatureFileStream() local
81 return fd; in CreateSignatureFileStream()
[all …]
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/ |
| D | client_trans_tcp_direct_listener.c | 61 static int32_t ClientTdcOnDataEvent(ListenerModule module, int events, int32_t fd) in ClientTdcOnDataEvent() argument
66 if (TransTdcGetInfoByFd(fd, &channel) == NULL) { in ClientTdcOnDataEvent()
67 TransTdcReleaseFd(fd); in ClientTdcOnDataEvent()
68 TRANS_LOGE(TRANS_SDK, "can not match fd. release fd=%{public}d", fd); in ClientTdcOnDataEvent()
90 int32_t TransTdcCreateListener(int32_t fd) in TransTdcCreateListener() argument
111 TRANS_LOGI(TRANS_SDK, "create sdk listener success. fd=%{public}d", fd); in TransTdcCreateListener()
115 return AddTrigger(DIRECT_CHANNEL_CLIENT, fd, READ_TRIGGER); in TransTdcCreateListener()
118 void TransTdcCloseFd(int32_t fd) in TransTdcCloseFd() argument
120 if (fd < 0) { in TransTdcCloseFd()
121 TRANS_LOGI(TRANS_SDK, "fd less than zero"); in TransTdcCloseFd()
[all …]
|
| /foundation/communication/dsoftbus/adapter/common/kernel/liteos_m/ |
| D | softbus_adapter_file.c | 24 int32_t SoftBusReadFile(int32_t fd, void *readBuf, uint32_t maxLen) in SoftBusReadFile() argument
26 (void)fd; in SoftBusReadFile()
38 int32_t fd = UtilsFileOpen(fileName, O_RDONLY_FS, 0); in SoftBusReadFullFile() local
39 if (fd < 0) { in SoftBusReadFullFile()
46 UtilsFileClose(fd); in SoftBusReadFullFile()
49 ret = UtilsFileSeek(fd, 0, SEEK_SET_FS); in SoftBusReadFullFile()
52 UtilsFileClose(fd); in SoftBusReadFullFile()
57 UtilsFileClose(fd); in SoftBusReadFullFile()
60 ret = UtilsFileRead(fd, readBuf, maxLen); in SoftBusReadFullFile()
63 UtilsFileClose(fd); in SoftBusReadFullFile()
[all …]
|
| /foundation/window/window_manager/window_scene/test/dms_unittest/ |
| D | screen_session_dumper_test.cpp | 62 int fd = 1; variable
64 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args);
75 int fd = 1; variable
77 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args);
89 int fd = 1; variable
91 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args);
103 int fd = 1; variable
105 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args);
112 * @tc.desc: Dump fd less 0
117 int fd = -1; variable
[all …]
|
| /foundation/resourceschedule/frame_aware_sched/qos_manager/src/ |
| D | qos_common.cpp | 34 int fd = open(fileName, O_RDWR); in TrivalOpenAuthCtrlNode() local
35 return fd; in TrivalOpenAuthCtrlNode()
41 int fd; in AuthEnable() local
44 fd = TrivalOpenAuthCtrlNode(); in AuthEnable()
45 if (fd < 0) { in AuthEnable()
47 return fd; in AuthEnable()
56 ret = ioctl(fd, BASIC_AUTH_CTRL_OPERATION, &data); in AuthEnable()
60 close(fd); in AuthEnable()
67 int fd; in AuthPause() local
70 fd = TrivalOpenAuthCtrlNode(); in AuthPause()
[all …]
|
| /foundation/multimodalinput/input/frameworks/proxy/module_loader/src/ |
| D | mmi_fd_listener.cpp | 36 void MMIFdListener::OnReadable(int32_t fd) in OnReadable() argument
38 if (fd < 0) { in OnReadable()
39 MMI_HILOGE("Invalid fd:%{public}d", fd); in OnReadable()
49 ssize_t size = recv(fd, szBuf + oneRecvSize, MAX_PACKET_BUF_SIZE - oneRecvSize, in OnReadable()
57 // size 0 means it the fd may be closed. in OnReadable()
60 …MMI_HILOGE("received %{public}zu, now received 0 from fd %{public}d, wait for next readable", recv… in OnReadable()
61 fd); in OnReadable()
71 …MMI_HILOGW("received %{public}zu, fd %{public}d is interrupted by signal, continue to recv", recvS… in OnReadable()
72 fd); in OnReadable()
76 …MMI_HILOGE("received %{public}zu, unexpected errno %{public}d on fd %{public}d, wait for next read… in OnReadable()
[all …]
|
| /foundation/communication/dsoftbus/core/common/dfx/hidumper_adapter/ |
| D | softbus_hidumper_stats.c | 36 static int32_t SoftBusStatsDumpHander(int fd, int32_t argc, const char **argv) in SoftBusStatsDumpHander() argument
38 if (fd < 0 || argc != 1 || argv == NULL) { in SoftBusStatsDumpHander()
44 SOFTBUS_DPRINTF(fd, "SoftBusStatsDumpHander result malloc fail!\n"); in SoftBusStatsDumpHander()
51 SOFTBUS_DPRINTF(fd, "SoftBusStatsDumpHander query fail!\n"); in SoftBusStatsDumpHander()
55 SOFTBUS_DPRINTF(fd, "SoftBus 15min Statistics:\n"); in SoftBusStatsDumpHander()
56 SOFTBUS_DPRINTF(fd, "BT traffic = NA\n"); in SoftBusStatsDumpHander()
57 SOFTBUS_DPRINTF(fd, "Connection success rate = %f\n", result->successRate); in SoftBusStatsDumpHander()
58 SOFTBUS_DPRINTF(fd, "Maximun concurrent number = %d\n", result->maxParaSessionNum); in SoftBusStatsDumpHander()
59 SOFTBUS_DPRINTF(fd, "Service delay threshold = %dms\n", result->sessionSuccessDuration); in SoftBusStatsDumpHander()
60 SOFTBUS_DPRINTF(fd, "Maximun online number = %d\n", result->deviceOnlineNum); in SoftBusStatsDumpHander()
[all …]
|
| /foundation/arkui/ui_lite/frameworks/imgdecode/ |
| D | file_img_decoder.cpp | 31 int32_t fd = open(dsc.path, O_RDONLY | O_BINARY); in Open() local
33 int32_t fd = open(dsc.path, O_RDONLY); in Open()
35 if (fd == -1) { in Open()
38 dsc.fd = fd; in Open()
56 if (dsc.fd && (dsc.fd != -1)) { in Close()
57 close(dsc.fd); in Close()
58 dsc.fd = -1; in Close()
66 int32_t fd; in GetHeader() local
69 fd = open(dsc.path, O_BINARY); in GetHeader()
71 fd = open(dsc.path, O_RDONLY); in GetHeader()
[all …]
|