Home
last modified time | relevance | path

Searched refs:fd (Results 1 - 25 of 2001) sorted by relevance

12345678910>>...81

/foundation/resourceschedule/qos_manager/services/src/
H A Dqos_interface.cpp31 int fd = open(fileName, O_RDWR); in TrivalOpenRtgNode() local
32 if (fd < 0) { in TrivalOpenRtgNode()
36 return fd; in TrivalOpenRtgNode()
42 int fd = open(fileName, O_RDWR); in TrivalOpenAuthCtrlNode() local
43 if (fd < 0) { in TrivalOpenAuthCtrlNode()
47 return fd; in TrivalOpenAuthCtrlNode()
53 int fd = open(fileName, O_RDWR); in TrivalOpenQosCtrlNode() local
54 if (fd < 0) { in TrivalOpenQosCtrlNode()
58 return fd; in TrivalOpenQosCtrlNode()
70 int fd in EnableRtg() local
88 int fd; AuthEnable() local
115 int fd; AuthSwitch() local
142 int fd; AuthDelete() local
166 int fd; AuthPause() local
193 int fd; AuthGet() local
219 int fd = TrivalOpenAuthCtrlNode(); AuthEnhance() local
244 int fd; QosApplyForOther() local
268 int fd; QosLeave() local
290 int fd; QosLeaveForOther() local
311 int fd; QosPolicySet() local
335 int fd; QosGetForOther() local
[all...]
/foundation/resourceschedule/ffrt/src/eu/
H A Dqos_interface.cpp39 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, errn in TrivalOpenQosCtrlNode()
79 int fd = TrivalOpenRtgNode(); FFRTEnableRtg() local
97 int fd; FFRTAuthEnable() local
122 int fd; FFRTAuthSwitch() local
147 int fd; FFRTAuthDelete() local
169 int fd; FFRTAuthPause() local
194 int fd; FFRTAuthGet() local
229 int fd; FFRTQosApplyForOther() local
253 int fd; FFRTQosLeave() local
276 int fd; FFRTQosLeaveForOther() local
297 int fd; QosPolicy() local
316 int fd; FFRTThreadCtrl() local
340 int fd = TrivalOpenQosCtrlNode(); FFRTQosGetForOther() local
[all...]
H A Drtg_perf_ctrl.cpp33 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) != 0) { in SetTaskRtg()
58 close(fd); in SetTaskRtg()
61 close(fd); in SetTaskRtg()
66 int fd in SetRtgStatus() local
81 int fd = OpenPerfCtrl(); SetRtgQos() local
103 int fd = OpenPerfCtrl(); SetRtgLoadMode() local
120 int fd = OpenPerfCtrl(); set_task_min_util() local
[all...]
/foundation/CastEngine/castengine_wifi_display/services/network/socket/
H A Dtcp_socket.cpp36 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, backlo in Bind()
74 int32_t fd = -1; Connect() local
[all...]
H A Dudp_socket.cpp35 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, tru in Bind()
70 int32_t fd = -1; Connect() local
[all...]
H A Dsocket_utils.cpp32 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 ! in IsUdpPortAvailable()
99 CreateTcpClient(const char *ip, unsigned port, int32_t &fd, int32_t &ret) CreateTcpClient() argument
106 CreateUdpSession(unsigned port, int32_t &fd) CreateUdpSession() argument
112 CreateSocket(int32_t socketType, int32_t &fd) CreateSocket() argument
129 BindSocket(int32_t fd, const std::string &host, uint16_t port) BindSocket() argument
151 ListenSocket(int32_t fd, uint32_t backlog) ListenSocket() argument
162 ConnectSocket(int32_t fd, bool isAsync, const std::string &ip, uint16_t port, int32_t &ret) ConnectSocket() argument
201 CheckAsyncConnect(int32_t fd) CheckAsyncConnect() argument
232 ShutDownSocket(int32_t fd) ShutDownSocket() argument
241 SetReuseAddr(int32_t fd, bool isReuse) SetReuseAddr() argument
253 SetReusePort(int32_t fd, bool isReuse) SetReusePort() argument
265 SetCloseWait(int32_t fd, int32_t second) SetCloseWait() argument
279 SetCloExec(int32_t fd, bool isOn) SetCloExec() argument
304 SetNoDelay(int32_t fd, bool isOn) SetNoDelay() argument
323 SetNonBlocking(int32_t fd, bool isNonBlock, uint32_t writeTimeout) SetNonBlocking() argument
340 SetSendBuf(int32_t fd, int32_t size) SetSendBuf() argument
351 SetRecvBuf(int32_t fd, int32_t size) SetRecvBuf() argument
362 CloseSocket(int32_t fd) CloseSocket() argument
371 SendSocket(int32_t fd, const char *buf, int32_t len) SendSocket() argument
408 Sendto(int32_t fd, const char *buf, size_t len, const char *ip, int32_t nPort) Sendto() argument
431 ReadSocket(int32_t fd, char *buf, uint32_t len, int32_t &error) ReadSocket() argument
451 ReadSocket(int32_t fd, DataBuffer::Ptr buf, int32_t &error) ReadSocket() argument
482 RecvSocket(int32_t fd, char *buf, uint32_t len, int32_t flags, int32_t &error) RecvSocket() argument
502 AcceptSocket(int32_t fd, struct sockaddr_in *clientAddr, socklen_t *addrLen) AcceptSocket() argument
515 GetIpPortInfo(int32_t fd, std::string &strLocalAddr, std::string &strRemoteAddr, uint16_t &localPort, uint16_t &remotePort) GetIpPortInfo() argument
[all...]
H A Dsocket_utils.h29 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 &ret);
40 static bool SetReuseAddr(int32_t fd, bool isOn);
41 static bool SetReusePort(int32_t fd, boo
[all...]
/foundation/multimodalinput/input/service/event_dump/src/
H A Devent_dump.cpp62 void ChkConfig(int32_t fd) in ChkConfig() argument
64 mprintf(fd, "ChkMMIConfig: "); in ChkConfig()
65 mprintf(fd, "DEF_MMI_DATA_ROOT:%s\n", DEF_MMI_DATA_ROOT); in ChkConfig()
66 mprintf(fd, "EXP_CONFIG:%s\n", DEF_EXP_CONFIG); in ChkConfig()
67 mprintf(fd, "EXP_SOPATH:%s\n", DEF_EXP_SOPATH); in ChkConfig()
70 void EventDump::CheckCount(int32_t fd, const std::vector<std::string> &args, int32_t &count) in CheckCount() argument
85 void EventDump::ParseCommand(int32_t fd, const std::vector<std::string> &args) in ParseCommand() argument
89 CheckCount(fd, args, count); in ParseCommand()
92 mprintf(fd, "cmd param number not more than 32\n"); in ParseCommand()
139 DumpEventHelp(fd, arg in ParseCommand()
247 DumpEventHelp(int32_t fd, const std::vector<std::string> &args) DumpEventHelp() argument
252 DumpHelp(int32_t fd) DumpHelp() argument
[all...]
/foundation/resourceschedule/memmgr/services/memmgrservice/include/
H A Ddump_command_dispatcher.h36 #define CHECK_SIZE(container, len, fd, actionIfFailed) \
39 dprintf(fd, "size error\n"); \
50 void ShowHelpInfo(const int fd) in ShowHelpInfo() argument
52 dprintf(fd, "Usage:\n"); in ShowHelpInfo()
53 dprintf(fd, "-h |help for memmgrservice dumper\n"); in ShowHelpInfo()
54 dprintf(fd, "-a |dump all info\n"); in ShowHelpInfo()
55 dprintf(fd, "-e |dump event observer\n"); in ShowHelpInfo()
56 dprintf(fd, "-r |dump reclaim info and adj\n"); in ShowHelpInfo()
57 dprintf(fd, "-c |dump config\n"); in ShowHelpInfo()
58 dprintf(fd, " in ShowHelpInfo()
79 PrintOntrimError(const int fd) PrintOntrimError() argument
88 PrintReclaimError(const int fd) PrintReclaimError() argument
100 DispatchTriggerMemLevel(const int fd, std::map<std::string, std::vector<std::string>> &keyValuesMapping) DispatchTriggerMemLevel() argument
134 ParseForceReclaimType(const int fd, std::map<std::string, std::vector<std::string>> &keyValuesMapping, DumpReclaimInfo &dumpInfo) ParseForceReclaimType() argument
167 ParseForceReclaimId(const int fd, std::map<std::string, std::vector<std::string>> &keyValuesMapping, DumpReclaimInfo &dumpInfo) ParseForceReclaimId() argument
209 PurgeableMemoryDump(int fd, std::map<std::string, std::vector<std::string>> &keyValuesMapping) PurgeableMemoryDump() argument
248 DispatchDumpCommand(const int fd, std::map<std::string, std::vector<std::string>> &keyValuesMapping) DispatchDumpCommand() argument
[all...]
/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_tcp_socket.c33 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_SOCKE in SetSendBufFix()
91 SetRcvBufFix(int fd, int val) SetRcvBufFix() argument
102 SetSendBuf(int fd) SetSendBuf() argument
119 SetRecvBuf(int fd) SetRecvBuf() argument
136 SetServerOption(int fd) SetServerOption() argument
148 SetClientOption(int fd) SetClientOption() argument
161 BindLocalIP(int32_t domain, int fd, const char *localIP, uint16_t port) BindLocalIP() argument
184 SetIpTos(int fd, uint32_t tos) SetIpTos() argument
209 int fd; OpenTcpServerSocket() local
235 BindTcpClientAddr(int32_t domain, int fd, const char *inputAddr) BindTcpClientAddr() argument
255 SocketConnect(int32_t fd, int32_t domain, const ConnectOption *option) SocketConnect() argument
292 int32_t fd = -1; OpenTcpClientSocket() local
334 GetTcpSockPort(int32_t fd) GetTcpSockPort() argument
348 ConnSetTcpKeepalive(int32_t fd, int32_t seconds, int32_t keepAliveIntvl, int32_t keepAliveCount) ConnSetTcpKeepalive() argument
384 ConnSetTcpUserTimeOut(int32_t fd, uint32_t millSec) ConnSetTcpUserTimeOut() argument
398 ConnSetTcpUserTimeOut(int32_t fd, uint32_t millSec) ConnSetTcpUserTimeOut() argument
407 AcceptTcpClient(int32_t fd, ConnectOption *clientAddr, int32_t *cfd) AcceptTcpClient() argument
[all...]
/foundation/communication/dsoftbus/core/common/dfx/hidumper_adapter/
H A Dsoftbus_hidumper_stats.c36 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, "Maximu in SoftBusStatsDumpHander()
[all...]
H A Dsoftbus_hidumper.c35 void SoftBusDumpShowHelp(int fd) in SoftBusDumpShowHelp() argument
37 if (fd < 0) { in SoftBusDumpShowHelp()
38 COMM_LOGE(COMM_DFX, "fd is invalid."); in SoftBusDumpShowHelp()
42 SOFTBUS_DPRINTF(fd, "Usage: hidumper -s 4700 -a \"[Option]\" \n"); in SoftBusDumpShowHelp()
43 SOFTBUS_DPRINTF(fd, " Option: [-h] "); in SoftBusDumpShowHelp()
47 SOFTBUS_DPRINTF(fd, "| ["); in SoftBusDumpShowHelp()
48 SOFTBUS_DPRINTF(fd, "%s", itemNode->moduleName); in SoftBusDumpShowHelp()
49 SOFTBUS_DPRINTF(fd, "]"); in SoftBusDumpShowHelp()
51 SOFTBUS_DPRINTF(fd, "\n"); in SoftBusDumpShowHelp()
56 SOFTBUS_DPRINTF(fd, "\ in SoftBusDumpShowHelp()
64 SoftBusDumpErrInfo(int fd, const char *argv) SoftBusDumpErrInfo() argument
73 SoftBusDumpSubModuleHelp(int fd, char *moduleName, ListNode *varList) SoftBusDumpSubModuleHelp() argument
192 SoftBusDumpDispatch(int fd, int32_t argc, const char **argv) SoftBusDumpDispatch() argument
[all...]
/foundation/CastEngine/castengine_wifi_display/services/network/eventhandler/
H A Devent_descriptor_listener.cpp38 EventDescriptorListener::EventDescriptorListener(int32_t fd) : socketLocalFd_(fd) in EventDescriptorListener() argument
49 bool EventDescriptorListener::AddFdListener(int32_t fd, const std::shared_ptr<FileDescriptorListener> &listener, in AddFdListener() argument
53 SHARING_LOGI("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
94 OnReadable(int32_t fd) OnReadable() argument
113 OnWritable(int32_t fd) OnWritable() argument
118 OnShutdown(int32_t fd) OnShutdown() argument
124 OnException(int32_t fd) OnException() argument
129 OnReadData(int32_t fd, DataBuffer::Ptr &buf) OnReadData() argument
134 OnClose(int32_t fd) OnClose() argument
[all...]
/foundation/multimedia/media_foundation/test/scenetest/
H A Dtest_single_audio_recorder_fast_prepare.h45 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 in FIXTURE()
[all...]
H A Dtest_single_audio_recorder_fast_start_pause.h45 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 in FIXTURE()
[all...]
H A Dtest_single_audio_recorder_fast_stop_reset.h45 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 in FIXTURE()
[all...]
/foundation/window/window_manager/window_scene/test/dms_unittest/
H A Dscreen_session_dumper_test.cpp63 int fd = 1; in HWTEST_F() local
65 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args); in HWTEST_F()
76 int fd = 1; in HWTEST_F() local
78 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args); in HWTEST_F()
90 int fd = 1; in HWTEST_F() local
92 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args); in HWTEST_F()
104 int fd = 1; in HWTEST_F() local
106 sptr<ScreenSessionDumper> dumper = new ScreenSessionDumper(fd, args); in HWTEST_F()
113 * @tc.desc: Dump fd less 0
118 int fd in HWTEST_F() local
132 int fd = -1; HWTEST_F() local
146 int fd = 1; HWTEST_F() local
202 int fd = 1; HWTEST_F() local
217 int fd = 1; HWTEST_F() local
232 int fd = 1; HWTEST_F() local
246 int fd = 1; HWTEST_F() local
260 int fd = 1; HWTEST_F() local
274 int fd = 1; HWTEST_F() local
293 int fd = 1; HWTEST_F() local
312 int fd = 1; HWTEST_F() local
331 int fd = 1; HWTEST_F() local
350 int fd = 1; HWTEST_F() local
369 int fd = 1; HWTEST_F() local
392 int fd = 1; HWTEST_F() local
407 int fd = 1; HWTEST_F() local
421 int fd = 1; HWTEST_F() local
435 int fd = 1; HWTEST_F() local
449 int fd = 1; HWTEST_F() local
463 int fd = 1; HWTEST_F() local
477 int fd = 1; HWTEST_F() local
491 int fd = 1; HWTEST_F() local
505 int fd = 1; HWTEST_F() local
519 int fd = 1; HWTEST_F() local
533 int fd = 1; HWTEST_F() local
548 int fd = 1; HWTEST_F() local
562 int fd = 1; HWTEST_F() local
576 int fd = 1; HWTEST_F() local
590 int fd = 1; HWTEST_F() local
605 int fd = 1; HWTEST_F() local
619 int fd = 1; HWTEST_F() local
633 int fd = 1; HWTEST_F() local
647 int fd = 1; HWTEST_F() local
661 int fd = 1; HWTEST_F() local
675 int fd = 1; HWTEST_F() local
692 int fd = 1; HWTEST_F() local
723 int fd = 1; HWTEST_F() local
757 int fd = 1; HWTEST_F() local
[all...]
/foundation/resourceschedule/frame_aware_sched/qos_manager/src/
H A Dqos_common.cpp34 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 in AuthPause()
93 int fd; AuthDelete() local
[all...]
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_profiler/unittest/
H A Drs_profiler_utils_test.cpp55 auto fd = Utils::FileOpen("</,,,,,,,,,,,/>", "rb"); in HWTEST_F() local
56 EXPECT_FALSE(Utils::IsFileValid(fd)); in HWTEST_F()
57 EXPECT_EQ(fd, nullptr); in HWTEST_F()
58 EXPECT_EQ(Utils::FileSize(fd), 0); in HWTEST_F()
59 EXPECT_EQ(Utils::FileTell(fd), 0); in HWTEST_F()
61 fd = Utils::FileOpen("file.json", "invalid open options"); in HWTEST_F()
62 EXPECT_FALSE(Utils::IsFileValid(fd)); in HWTEST_F()
63 EXPECT_EQ(fd, nullptr); in HWTEST_F()
64 EXPECT_EQ(Utils::FileSize(fd), 0); in HWTEST_F()
65 EXPECT_EQ(Utils::FileTell(fd), in HWTEST_F()
89 auto fd = Utils::FileOpen("RECORD_IN_MEMORY", "rwbe"); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/adapter/common/kernel/liteos_m/
H A Dsoftbus_adapter_file.c24 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()
77 int32_t fd; SoftBusWriteFile() local
93 SoftBusWriteFileFd(int32_t fd, const char *writeBuf, uint32_t len) SoftBusWriteFileFd() argument
121 SoftBusCloseFile(int32_t fd) SoftBusCloseFile() argument
126 SoftBusPreadFile(int32_t fd, void *buf, uint64_t readBytes, uint64_t offset) SoftBusPreadFile() argument
135 SoftBusPwriteFile(int32_t fd, const void *buf, uint64_t writeBytes, uint64_t offset) SoftBusPwriteFile() argument
[all...]
/foundation/bundlemanager/bundle_framework/interfaces/inner_api/appexecfwk_core/src/bundlemgr/
H A Dbundle_stream_installer_proxy.cpp40 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()
118 int32_t fd = Constants::DEFAULT_STREAM_FD; CreateSharedBundleStream() local
160 int32_t fd = Constants::DEFAULT_STREAM_FD; CreatePgoFileStream() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/native/kv_store/src/kvstore_impl_hal/
H A Dkv_store.c39 int fd = UtilsFileOpen(key, O_RDONLY_FS, 0); in GetValueByFile() local
40 if (fd < 0) { in GetValueByFile()
43 int ret = UtilsFileRead(fd, value, valueLen); in GetValueByFile()
44 UtilsFileClose(fd); in GetValueByFile()
45 fd = -1; in GetValueByFile()
55 int fd = UtilsFileOpen(key, O_RDWR_FS | O_CREAT_FS | O_TRUNC_FS, 0); in SetValueToFile() local
56 if (fd < 0) { in SetValueToFile()
59 int ret = UtilsFileWrite(fd, value, strlen(value)); in SetValueToFile()
60 UtilsFileClose(fd); in SetValueToFile()
61 fd in SetValueToFile()
67 int fd = UtilsFileOpen(KV_SUM_FILE, O_RDWR_FS, 0); GetCurrentItem() local
84 int fd = UtilsFileOpen(KV_SUM_FILE, O_RDWR_FS | O_CREAT_FS, 0); SetCurrentItem() local
96 int fd = UtilsFileOpen(key, O_RDONLY_FS, 0); NewItem() local
[all...]
/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/src/
H A Dlnn_socket_mock.cpp53 ssize_t ConnSendSocketData(int32_t fd, const char *buf, size_t len, int32_t timeout) in ConnSendSocketData() argument
55 return GetSocketMockInterface()->ConnSendSocketData(fd, buf, len, timeout); in ConnSendSocketData()
58 void ConnShutdownSocket(int32_t fd) in ConnShutdownSocket() argument
60 return GetSocketMockInterface()->ConnShutdownSocket(fd); in ConnShutdownSocket()
63 int32_t ConnSetTcpKeepalive(int32_t fd, int32_t seconds, int32_t keepAliveIntvl, int32_t keepAliveCount) in ConnSetTcpKeepalive() argument
65 return GetSocketMockInterface()->ConnSetTcpKeepalive(fd, seconds, keepAliveIntvl, keepAliveCount); in ConnSetTcpKeepalive()
68 int32_t ConnSetTcpUserTimeOut(int32_t fd, uint32_t millSec) in ConnSetTcpUserTimeOut() argument
70 return GetSocketMockInterface()->ConnSetTcpUserTimeOut(fd, millSec); in ConnSetTcpUserTimeOut()
73 int32_t ConnToggleNonBlockMode(int32_t fd, bool isNonBlock) in ConnToggleNonBlockMode() argument
75 return GetSocketMockInterface()->ConnToggleNonBlockMode(fd, isNonBloc in ConnToggleNonBlockMode()
78 ConnGetSocketError(int32_t fd) ConnGetSocketError() argument
83 ConnGetLocalSocketPort(int32_t fd) ConnGetLocalSocketPort() argument
88 ConnGetPeerSocketAddr(int32_t fd, SocketAddr *socketAddr) ConnGetPeerSocketAddr() argument
[all...]
/foundation/communication/wifi/wifi/base/cRPC/src/
H A Devloop.c106 int AddFdEvent(EventLoop *loop, int fd, unsigned int addMask) in AddFdEvent() argument
112 if (fd >= loop->setSize) { in AddFdEvent()
115 if (loop->fdMasks[fd].mask & addMask) { in AddFdEvent()
118 int op = (loop->fdMasks[fd].mask == NONE_EVENT) ? EPOLL_CTL_ADD : EPOLL_CTL_MOD; in AddFdEvent()
119 addMask |= loop->fdMasks[fd].mask; in AddFdEvent()
127 pollEvent.data.fd = fd; in AddFdEvent()
128 if (epoll_ctl(loop->epfd, op, fd, &pollEvent) == -1) { in AddFdEvent()
131 loop->fdMasks[fd].fd in AddFdEvent()
139 DelFdEvent(EventLoop *loop, int fd, unsigned int delMask) DelFdEvent() argument
[all...]
/foundation/multimodalinput/input/frameworks/proxy/module_loader/src/
H A Dmmi_fd_listener.cpp36 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", recvSize, in OnReadable()
61 fd); in OnReadable()
71 MMI_HILOGW("received %{public}zu, fd %{public}d is interrupted by signal, continue to recv", recvSize, in OnReadable()
72 fd); in OnReadable()
87 OnShutdown(int32_t fd) OnShutdown() argument
97 OnException(int32_t fd) OnException() argument
[all...]

Completed in 11 milliseconds

12345678910>>...81