Lines Matching defs:connectionFd
189 int connectionFd = OHOS_TEMP_FAILURE_RETRY(accept(socketFd,
191 if (connectionFd < 0) {
196 AddEvent(eventFd_, connectionFd, EPOLLIN);
197 connectionMap_[connectionFd] = socketFd;
212 void FaultLoggerDaemon::HandleRequestForFuzzer(int32_t epollFd, int32_t connectionFd,
219 HandleRequest(epollFd, connectionFd);
220 HandleLogFileDesClientRequest(connectionFd, requestConst);
221 HandlePrintTHilogClientRequest(connectionFd, request);
222 HandlePermissionRequest(connectionFd, request);
223 HandleSdkDumpRequest(connectionFd, request);
224 HandleExceptionRequest(connectionFd, request);
242 void FaultLoggerDaemon::HandleRequestByClientType(int32_t connectionFd, FaultLoggerdRequest* request)
246 HandleDefaultClientRequest(connectionFd, request);
249 HandleLogFileDesClientRequest(connectionFd, request);
252 HandlePrintTHilogClientRequest(connectionFd, request);
255 HandlePermissionRequest(connectionFd, request);
258 HandleSdkDumpRequest(connectionFd, request);
261 HandlePipeFdClientRequest(connectionFd, request);
264 HandleExceptionRequest(connectionFd, request);
272 void FaultLoggerDaemon::HandleRequest(int32_t epollFd, int32_t connectionFd)
274 if (epollFd < 0 || connectionFd < 3) { // 3: not allow fd = 0,1,2 because they are reserved by system
281 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(connectionFd, buf.data(), REQUEST_BUF_SIZE));
283 HandleDumpStats(connectionFd, reinterpret_cast<FaultLoggerdStatsRequest *>(buf.data()));
290 if (!CheckRequestCredential(connectionFd, request)) {
294 HandleRequestByClientType(connectionFd, request);
296 DelEvent(eventFd_, connectionFd, EPOLLIN);
297 connectionMap_.erase(connectionFd);
316 void FaultLoggerDaemon::HandleDefaultClientRequest(int32_t connectionFd, const FaultLoggerdRequest * request)
326 SendFileDescriptorToSocket(connectionFd, fd);
331 void FaultLoggerDaemon::HandleLogFileDesClientRequest(int32_t connectionFd, const FaultLoggerdRequest * request)
339 SendFileDescriptorToSocket(connectionFd, fd);
344 void FaultLoggerDaemon::HandleExceptionRequest(int32_t connectionFd, FaultLoggerdRequest * request)
346 if (OHOS_TEMP_FAILURE_RETRY(write(connectionFd,
353 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(connectionFd, &exception, sizeof(CrashDumpException)));
362 void FaultLoggerDaemon::HandleReadBuf(int& fd, int32_t connectionFd, FaultLoggerdRequest* request,
365 FaultLoggerCheckPermissionResp resSecurityCheck = SecurityCheck(connectionFd, request);
381 void FaultLoggerDaemon::HandleReadRes(int& fd, int32_t connectionFd, FaultLoggerdRequest* request,
384 FaultLoggerCheckPermissionResp resSecurityCheck = SecurityCheck(connectionFd, request);
405 void FaultLoggerDaemon::HandleJsonReadBuf(int& fd, int32_t connectionFd, FaultLoggerdRequest* request,
408 FaultLoggerCheckPermissionResp resSecurityCheck = SecurityCheck(connectionFd, request);
424 void FaultLoggerDaemon::HandleJsonReadRes(int& fd, int32_t connectionFd, FaultLoggerdRequest* request,
427 FaultLoggerCheckPermissionResp resSecurityCheck = SecurityCheck(connectionFd, request);
443 void FaultLoggerDaemon::HandleRequestByPipeType(int& fd, int32_t connectionFd, FaultLoggerdRequest* request,
448 HandleReadBuf(fd, connectionFd, request, faultLoggerPipe);
456 HandleReadRes(fd, connectionFd, request, faultLoggerPipe);
468 HandleJsonReadBuf(fd, connectionFd, request, faultLoggerPipe);
476 HandleJsonReadRes(fd, connectionFd, request, faultLoggerPipe);
489 void FaultLoggerDaemon::HandlePipeFdClientRequest(int32_t connectionFd, FaultLoggerdRequest * request)
500 HandleRequestByPipeType(fd, connectionFd, request, faultLoggerPipe);
506 SendFileDescriptorToSocket(connectionFd, fd);
509 void FaultLoggerDaemon::HandlePrintTHilogClientRequest(int32_t const connectionFd, FaultLoggerdRequest * request)
513 if (OHOS_TEMP_FAILURE_RETRY(write(connectionFd,
518 int nread = OHOS_TEMP_FAILURE_RETRY(read(connectionFd, buf, sizeof(buf) - 1));
529 FaultLoggerCheckPermissionResp FaultLoggerDaemon::SecurityCheck(int32_t connectionFd, FaultLoggerdRequest * request)
536 if (OHOS_TEMP_FAILURE_RETRY(setsockopt(connectionFd,
542 if (OHOS_TEMP_FAILURE_RETRY(write(connectionFd, DAEMON_RESP.c_str(), DAEMON_RESP.length())) !=
548 if (!RecvMsgCredFromSocket(connectionFd, &rcred)) {
556 auto it = connectionMap_.find(connectionFd);
575 void FaultLoggerDaemon::HandlePermissionRequest(int32_t connectionFd, FaultLoggerdRequest * request)
577 FaultLoggerCheckPermissionResp resSecurityCheck = SecurityCheck(connectionFd, request);
579 OHOS_TEMP_FAILURE_RETRY(send(connectionFd, "1", strlen("1"), 0));
582 OHOS_TEMP_FAILURE_RETRY(send(connectionFd, "2", strlen("2"), 0));
586 void FaultLoggerDaemon::HandleSdkDumpRequest(int32_t connectionFd, FaultLoggerdRequest * request)
591 FaultLoggerCheckPermissionResp resSecurityCheck = SecurityCheck(connectionFd, request);
666 if (OHOS_TEMP_FAILURE_RETRY(send(connectionFd, retMsg.data(), retMsg.length(), 0)) !=
821 bool FaultLoggerDaemon::CheckRequestCredential(int32_t connectionFd, FaultLoggerdRequest* request)
827 auto it = connectionMap_.find(connectionFd);
830 connectionFd, connectionMap_.size());
841 int err = getsockopt(connectionFd, SOL_SOCKET, SO_PEERCRED, &creds, &credSize);
966 void FaultLoggerDaemon::HandleDumpStats(int32_t connectionFd, FaultLoggerdStatsRequest* request)