| /packages/modules/adb/ |
| D | sysdeps.h | 86 static inline void close_on_exec(borrowed_fd fd) { in close_on_exec() argument
103 extern int adb_read(borrowed_fd fd, void* buf, int len);
104 extern int adb_pread(borrowed_fd fd, void* buf, int len, off64_t offset);
105 extern int adb_write(borrowed_fd fd, const void* buf, int len);
106 extern int adb_pwrite(borrowed_fd fd, const void* buf, int len, off64_t offset);
107 extern int64_t adb_lseek(borrowed_fd fd, int64_t pos, int where);
108 extern int adb_shutdown(borrowed_fd fd, int direction = SHUT_RDWR);
109 extern int adb_close(int fd);
111 extern HANDLE adb_get_os_handle(borrowed_fd fd);
117 static inline int unix_close(int fd) { in unix_close() argument
[all …]
|
| D | adb_io.cpp | 37 bool SendProtocolString(borrowed_fd fd, std::string_view s) { in SendProtocolString() argument
47 return WriteFdExactly(fd, str); in SendProtocolString()
50 bool ReadProtocolString(borrowed_fd fd, std::string* s, std::string* error) { in ReadProtocolString() argument
52 if (!ReadFdExactly(fd, buf, 4)) { in ReadProtocolString()
60 if (!ReadFdExactly(fd, &(*s)[0], len)) { in ReadProtocolString()
68 bool SendOkay(borrowed_fd fd) { in SendOkay() argument
69 return WriteFdExactly(fd, "OKAY", 4); in SendOkay()
72 bool SendFail(borrowed_fd fd, std::string_view reason) { in SendFail() argument
73 return WriteFdExactly(fd, "FAIL", 4) && SendProtocolString(fd, reason); in SendFail()
76 bool ReadFdExactly(borrowed_fd fd, void* buf, size_t len) { in ReadFdExactly() argument
[all …]
|
| D | adb_io_test.cpp | 48 ASSERT_NE(-1, tf.fd); in POSIX_TEST()
50 ASSERT_TRUE(android::base::WriteStringToFd(expected, tf.fd)) << strerror(errno); in POSIX_TEST()
51 ASSERT_EQ(0, lseek(tf.fd, 0, SEEK_SET)); in POSIX_TEST()
55 ASSERT_TRUE(ReadFdExactly(tf.fd, buf, sizeof(buf) - 1)) << strerror(errno); in POSIX_TEST()
62 ASSERT_NE(-1, tf.fd); in POSIX_TEST()
64 ASSERT_TRUE(android::base::WriteStringToFd(expected, tf.fd)) << strerror(errno); in POSIX_TEST()
65 ASSERT_EQ(0, lseek(tf.fd, 0, SEEK_SET)); in POSIX_TEST()
69 ASSERT_FALSE(ReadFdExactly(tf.fd, buf, sizeof(buf))); in POSIX_TEST()
76 ASSERT_NE(-1, tf.fd); in POSIX_TEST()
78 ASSERT_TRUE(android::base::WriteStringToFd(input, tf.fd)) << strerror(errno); in POSIX_TEST()
[all …]
|
| D | services.cpp | 47 unique_fd fd) { in service_bootstrap_func() argument
48 adb_thread_setname(android::base::StringPrintf("%s svc %d", service_name.c_str(), fd.get())); in service_bootstrap_func()
49 func(std::move(fd)); in service_bootstrap_func()
137 static void connect_service(unique_fd fd, std::string host) { in connect_service() argument
146 SendProtocolString(fd.get(), response); in connect_service()
149 static void pair_service(unique_fd fd, std::string host, std::string password) { in pair_service() argument
153 SendProtocolString(fd.get(), response); in pair_service()
155 SendFail(fd, response); in pair_service()
159 static void wait_service(unique_fd fd, std::string serial, TransportId transport_id, in wait_service() argument
163 SendFail(fd, "short wait-for-: " + spec); in wait_service()
[all …]
|
| /packages/modules/Connectivity/tests/cts/net/jni/ |
| D | NativeMultinetworkJni.cpp | 91 int getAsyncResponse(JNIEnv* env, int fd, int timeoutMs, int* rcode, uint8_t* buf, size_t bufLen) { in getAsyncResponse() argument
92 struct pollfd wait_fd = { .fd = fd, .events = POLLIN }; in getAsyncResponse()
96 int n = android_res_nresult(fd, rcode, buf, bufLen); in getAsyncResponse()
99 EXPECT_EQ(env, -1, read(fd, &dummy, sizeof(dummy)), "res_nresult check for closing fd"); in getAsyncResponse()
146 int expectAnswersValid(JNIEnv* env, int fd, int family, int expectedRcode) { in expectAnswersValid() argument
149 int res = getAsyncResponse(env, fd, TIMEOUT_MS, &rcode, buf, MAXPACKET); in expectAnswersValid()
162 int expectAnswersNotValid(JNIEnv* env, int fd, int expectedErrno) { in expectAnswersNotValid() argument
165 int res = getAsyncResponse(env, fd, TIMEOUT_MS, &rcode, buf, MAXPACKET); in expectAnswersNotValid()
179 int fd = android_res_nquery(handle, kHostname, ns_c_in, ns_t_a, 0); in Java_android_net_cts_MultinetworkApiTest_runResNqueryCheck() local
180 EXPECT_GE(env, fd, 0, "v4 res_nquery"); in Java_android_net_cts_MultinetworkApiTest_runResNqueryCheck()
[all …]
|
| /packages/services/Car/cpp/libsysfsmonitor/src/ |
| D | SysfsMonitor.cpp | 53 eventItem.data.fd = mPipefd[0]; in init()
77 Result<void> SysfsMonitor::registerFd(int32_t fd) { in registerFd() argument
78 if (fd < 0) { in registerFd()
79 return Error() << StringPrintf("fd(%d) is invalid", fd); in registerFd()
81 if (mMonitoringFds.count(fd) > 0) { in registerFd()
82 return Error() << StringPrintf("fd(%d) is already being monitored", fd); in registerFd()
89 eventItem.data.fd = fd; in registerFd()
90 if (int result = epoll_ctl(mEpollFd, EPOLL_CTL_ADD, fd, &eventItem); result != 0) { in registerFd()
91 return Error() << StringPrintf("Failed to add fd(%d) to epoll instance: errno = %d", fd, in registerFd()
94 mMonitoringFds.insert(fd); in registerFd()
[all …]
|
| /packages/modules/Bluetooth/system/gd/hal/ |
| D | syscall_wrapper_impl.cc | 34 int SyscallWrapperImpl::Bind(int fd, const struct sockaddr* addr, socklen_t len) { in Bind() argument
35 int ret = bind(fd, addr, len); in Bind()
40 int SyscallWrapperImpl::Connect(int fd, const struct sockaddr* addr, socklen_t len) { in Connect() argument
41 int ret = connect(fd, addr, len); in Connect()
46 ssize_t SyscallWrapperImpl::Send(int fd, const void* buf, size_t n, int flags) { in Send() argument
47 int ret = send(fd, buf, n, flags); in Send()
52 ssize_t SyscallWrapperImpl::Recv(int fd, void* buf, size_t n, int flags) { in Recv() argument
53 int ret = recv(fd, buf, n, flags); in Recv()
58 int SyscallWrapperImpl::Setsockopt(int fd, int level, int optname, const void* optval, socklen_t op… in Setsockopt() argument
59 int ret = setsockopt(fd, level, optname, optval, optlen); in Setsockopt()
[all …]
|
| D | snoop_logger_socket_test.cc | 50 ON_CALL(mock, Socket).WillByDefault((Return(fd))); in InitializeCommunicationsSuccess()
51 ON_CALL(mock, Setsockopt(Eq(fd), _, _, _, _)).WillByDefault((Return(0))); in InitializeCommunicationsSuccess()
52 ON_CALL(mock, Bind(Eq(fd), _, _)).WillByDefault((Return(0))); in InitializeCommunicationsSuccess()
53 ON_CALL(mock, Listen(Eq(fd), _)).WillByDefault((Return(0))); in InitializeCommunicationsSuccess()
58 EXPECT_CALL(mock, FDSet(Eq(fd), _)); in InitializeCommunicationsSuccess()
67 EXPECT_CALL(mock, Close(Eq(fd))); in InitializeCommunicationsSuccess()
68 EXPECT_CALL(mock, FDClr(Eq(fd), _)); in InitializeCommunicationsSuccess()
77 int fd = 11; member in testing::SnoopLoggerSocketModuleTest
104 ON_CALL(mock, Socket(_, _, _)).WillByDefault((Return(fd))); in TEST_F()
110 EXPECT_CALL(mock, FDClr(Eq(fd), _)); in TEST_F()
[all …]
|
| D | mgmt.cc | 54 int fd = socket(PF_BLUETOOTH, SOCK_RAW | SOCK_NONBLOCK, BTPROTO_HCI); in btsocket_open_mgmt() local
55 if (fd < 0) { in btsocket_open_mgmt()
66 int ret = bind(fd, (struct sockaddr*)&addr, sizeof(addr)); in btsocket_open_mgmt()
69 close(fd); in btsocket_open_mgmt()
73 return fd; in btsocket_open_mgmt()
86 int fd = btsocket_open_mgmt(hci); in get_vs_opcode() local
89 if (fd < 0) { in get_vs_opcode()
90 log::error("Failed to open mgmt channel for hci {}, error= {}.", hci, fd); in get_vs_opcode()
105 writable[0].fd = fd; in get_vs_opcode()
111 RETRY_ON_INTR(ret = write(fd, &ev, MGMT_PKT_HDR_SIZE + ev.len)); in get_vs_opcode()
[all …]
|
| /packages/modules/adb/client/ |
| D | incremental_utils.cpp | 67 static inline int32_t read_int32(borrowed_fd fd) { in read_int32() argument
69 return ReadFdExactly(fd, &result, sizeof(result)) ? result : -1; in read_int32()
72 static inline int32_t skip_int(borrowed_fd fd) { in skip_int() argument
73 return adb_lseek(fd, 4, SEEK_CUR); in skip_int()
76 static inline void append_int(borrowed_fd fd, std::vector<char>* bytes) { in append_int() argument
77 int32_t le_val = read_int32(fd); in append_int()
83 static inline bool append_bytes_with_size(borrowed_fd fd, std::vector<char>* bytes, in append_bytes_with_size() argument
85 int32_t le_size = read_int32(fd); in append_bytes_with_size()
100 ReadFdExactly(fd, bytes->data() + old_size + sizeof(le_size), size); in append_bytes_with_size()
104 static inline int32_t skip_bytes_with_size(borrowed_fd fd) { in skip_bytes_with_size() argument
[all …]
|
| D | adb_client.cpp | 81 static std::optional<TransportId> switch_socket_transport(int fd, std::string* error) { in switch_socket_transport() argument
114 if (!SendProtocolString(fd, service)) { in switch_socket_transport()
121 if (!adb_status(fd, error)) { in switch_socket_transport()
127 if (!ReadFdExactly(fd, &result, sizeof(result))) { in switch_socket_transport()
137 bool adb_status(borrowed_fd fd, std::string* error) { in adb_status() argument
139 if (!ReadFdExactly(fd, buf, 4)) { in adb_status()
154 ReadProtocolString(fd, error, error); in adb_status()
167 unique_fd fd; in _adb_connect() local
168 if (!socket_spec_connect(&fd, __adb_server_socket_spec, nullptr, nullptr, &reason)) { in _adb_connect()
175 std::optional<TransportId> transport_result = switch_socket_transport(fd.get(), error); in _adb_connect()
[all …]
|
| /packages/modules/Connectivity/service/src/com/android/server/connectivity/ |
| D | TcpKeepaliveController.java | 128 public static TcpKeepalivePacketData getTcpKeepalivePacket(@NonNull FileDescriptor fd) in getTcpKeepalivePacket() argument
131 final TcpKeepalivePacketDataParcelable tcpDetails = switchToRepairMode(fd); in getTcpKeepalivePacket()
137 switchOutOfRepairMode(fd); in getTcpKeepalivePacket()
140 switchOutOfRepairMode(fd); in getTcpKeepalivePacket()
219 private static TcpKeepalivePacketDataParcelable switchToRepairMode(FileDescriptor fd) in switchToRepairMode() argument
221 if (DBG) Log.i(TAG, "switchToRepairMode to start tcp keepalive : " + fd); in switchToRepairMode()
229 srcSockAddr = Os.getsockname(fd); in switchToRepairMode()
243 dstSockAddr = Os.getpeername(fd); in switchToRepairMode()
257 dropAllIncomingPackets(fd, true); in switchToRepairMode()
260 Os.setsockoptInt(fd, IPPROTO_TCP, TCP_REPAIR, TCP_REPAIR_ON); in switchToRepairMode()
[all …]
|
| /packages/modules/StatsD/statsd/src/storage/ |
| D | StorageManager.cpp | 136 int fd = open(file, O_WRONLY | O_CREAT | O_CLOEXEC | O_TRUNC, S_IRUSR | S_IWUSR); in writeFile() local
137 if (fd == -1) { in writeFile()
144 if (android::base::WriteFully(fd, buffer, numBytes)) { in writeFile()
150 int result = fchown(fd, AID_STATSD, AID_STATSD); in writeFile()
155 close(fd); in writeFile()
170 int fd = open(fileName.c_str(), O_WRONLY | O_CREAT | O_CLOEXEC, S_IRUSR | S_IWUSR); in writeTrainInfo() local
171 if (fd == -1) { in writeTrainInfo()
178 result = write(fd, &TRAIN_INFO_FILE_MAGIC, sizeof(TRAIN_INFO_FILE_MAGIC)); in writeTrainInfo()
181 close(fd); in writeTrainInfo()
187 result = write(fd, &trainInfo.trainVersionCode, trainVersionCodeByteCount); in writeTrainInfo()
[all …]
|
| /packages/modules/Connectivity/tests/cts/net/native/dns/ |
| D | NativeDnsAsyncTest.cpp | 38 int getAsyncResponse(int fd, int timeoutMs, int* rcode, uint8_t* buf, size_t bufLen) { in getAsyncResponse() argument
40 wait_fd[0].fd = fd; in getAsyncResponse()
47 int n = android_res_nresult(fd, rcode, buf, bufLen); in getAsyncResponse()
50 EXPECT_EQ(-1, read(fd, &dummy, sizeof dummy)); in getAsyncResponse()
79 void expectAnswersValid(int fd, int ipType, int expectedRcode) { in expectAnswersValid() argument
82 int res = getAsyncResponse(fd, TIMEOUT_MS, &rcode, buf, MAXPACKET); in expectAnswersValid()
96 void expectAnswersNotValid(int fd, int expectedErrno) { in expectAnswersNotValid() argument
99 int res = getAsyncResponse(fd, TIMEOUT_MS, &rcode, buf, MAXPACKET); in expectAnswersNotValid()
198 int fd = android_res_nquery( in TEST_F() local
201 android_res_cancel(fd); in TEST_F()
[all …]
|
| /packages/modules/Bluetooth/system/osi/src/ |
| D | socket.cc | 42 int fd; member
56 ret->fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in socket_new()
57 if (ret->fd == INVALID_FD) { in socket_new()
62 if (setsockopt(ret->fd, SOL_SOCKET, SO_REUSEADDR, &enable, sizeof(enable)) == in socket_new()
71 if (ret) close(ret->fd); in socket_new()
76 socket_t* socket_new_from_fd(int fd) { in socket_new_from_fd() argument
77 log::assert_that(fd != INVALID_FD, "assert failed: fd != INVALID_FD"); in socket_new_from_fd()
81 ret->fd = fd; in socket_new_from_fd()
89 close(socket->fd); in socket_free()
100 if (bind(socket->fd, (struct sockaddr*)&addr, sizeof(addr)) == -1) { in socket_listen()
[all …]
|
| /packages/modules/Bluetooth/system/udrv/ulinux/ |
| D | uipc.cc | 66 #define SAFE_FD_ISSET(fd, set) (((fd) == -1) ? false : FD_ISSET((fd), (set))) argument
138 int fd; in accept_server_socket() local
144 pfd.fd = sfd; in accept_server_socket()
154 OSI_NO_INTR(fd = accept(sfd, (struct sockaddr*)&remote, &len)); in accept_server_socket()
155 if (fd == -1) { in accept_server_socket()
163 setsockopt(fd, SOL_SOCKET, SO_RCVBUF, (char*)&size, (int)sizeof(size)); in accept_server_socket()
168 return fd; in accept_server_socket()
201 p->fd = UIPC_DISCONNECTED; in uipc_main_init()
242 if (uipc.ch[ch_id].fd != UIPC_DISCONNECTED) { in uipc_check_fd_locked()
243 log::debug("CLOSE CONNECTION (FD {})", uipc.ch[ch_id].fd); in uipc_check_fd_locked()
[all …]
|
| /packages/modules/Connectivity/staticlibs/testutils/devicetests/com/android/testutils/async/ |
| D | FakeOsAccess.java | 74 public FileDescriptor getInnerFileDescriptor(ParcelFileDescriptor fd) { in getInnerFileDescriptor() argument
76 return (FileDescriptor) PFD_FIELD_DESCRIPTOR.get(fd); in getInnerFileDescriptor()
83 public void close(ParcelFileDescriptor fd) { in close() argument
84 if (fd != null) { in close()
85 close(getInnerFileDescriptor(fd)); in close()
89 Object guard = PFD_FIELD_GUARD.get(fd); in close()
97 public synchronized void close(FileDescriptor fd) { in close() argument
98 if (fd != null) { in close()
99 File file = getFileOrNull(fd); in close()
102 mFiles.remove(getFileDescriptorNumber(fd)); in close()
[all …]
|
| /packages/modules/Connectivity/staticlibs/native/bpfmapjni/ |
| D | com_android_net_module_util_BpfMap.cpp | 38 jint fd = -1; in com_android_net_module_util_BpfMap_nativeBpfFdGet() local
41 fd = bpf::mapRetrieveRW(pathname.c_str()); in com_android_net_module_util_BpfMap_nativeBpfFdGet()
44 fd = bpf::mapRetrieveRO(pathname.c_str()); in com_android_net_module_util_BpfMap_nativeBpfFdGet()
47 fd = bpf::mapRetrieveWO(pathname.c_str()); in com_android_net_module_util_BpfMap_nativeBpfFdGet()
50 fd = bpf::mapRetrieveExclusiveRW(pathname.c_str()); in com_android_net_module_util_BpfMap_nativeBpfFdGet()
57 if (fd < 0) { in com_android_net_module_util_BpfMap_nativeBpfFdGet()
64 if (bpf::bpfGetFdKeySize(fd) != keySize) { in com_android_net_module_util_BpfMap_nativeBpfFdGet()
65 close(fd); in com_android_net_module_util_BpfMap_nativeBpfFdGet()
69 if (bpf::bpfGetFdValueSize(fd) != valueSize) { in com_android_net_module_util_BpfMap_nativeBpfFdGet()
70 close(fd); in com_android_net_module_util_BpfMap_nativeBpfFdGet()
[all …]
|
| /packages/modules/Bluetooth/system/osi/src/internal/ |
| D | semaphore.cc | 41 int fd; member
46 ret->fd = eventfd(value, EFD_SEMAPHORE); in semaphore_new()
47 if (ret->fd == INVALID_FD) { in semaphore_new()
58 if (semaphore->fd != INVALID_FD) close(semaphore->fd); in semaphore_free()
64 log::assert_that(semaphore->fd != INVALID_FD, in semaphore_wait()
68 if (eventfd_read(semaphore->fd, &value) == -1) in semaphore_wait()
74 log::assert_that(semaphore->fd != INVALID_FD, in semaphore_try_wait()
77 int flags = fcntl(semaphore->fd, F_GETFL); in semaphore_try_wait()
82 if (fcntl(semaphore->fd, F_SETFL, flags | O_NONBLOCK) == -1) { in semaphore_try_wait()
90 if (eventfd_read(semaphore->fd, &value) == -1) rc = false; in semaphore_try_wait()
[all …]
|
| /packages/providers/MediaProvider/src/com/android/providers/media/util/ |
| D | IsoInterface.java | 119 private static int readInt(@NonNull FileDescriptor fd) in readInt() argument
122 if (Os.read(fd, buf, 0, 4) == 4) { in readInt()
129 private static @NonNull UUID readUuid(@NonNull FileDescriptor fd) in readUuid() argument
131 final long high = (((long) readInt(fd)) << 32L) | (((long) readInt(fd)) & 0xffffffffL); in readUuid()
132 final long low = (((long) readInt(fd)) << 32L) | (((long) readInt(fd)) & 0xffffffffL); in readUuid()
136 private static @Nullable Box parseNextBox(@NonNull FileDescriptor fd, long end, int parentType, in parseNextBox() argument
138 final long pos = Os.lseek(fd, 0, OsConstants.SEEK_CUR); in parseNextBox()
145 long len = Integer.toUnsignedLong(readInt(fd)); in parseNextBox()
146 final int type = readInt(fd); in parseNextBox()
154 long high = readInt(fd); in parseNextBox()
[all …]
|
| /packages/modules/Virtualization/authfs/fd_server/src/ |
| D | main.rs | 42 fn is_fd_valid(fd: i32) -> bool { in is_fd_valid()
44 let retval = unsafe { libc::fcntl(fd, libc::F_GETFD) }; in is_fd_valid()
48 fn fd_to_owned<T: FromRawFd>(fd: i32) -> Result<T> { in fd_to_owned()
49 if !is_fd_valid(fd) { in fd_to_owned()
50 bail!("Bad FD: {}", fd); in fd_to_owned()
53 Ok(unsafe { T::from_raw_fd(fd) }) in fd_to_owned()
69 .map(|fd| fd_to_owned(*fd)) in parse_arg_ro_fds()
104 let (fd, config) = parse_arg_ro_fds(&arg)?; in convert_args()
105 fd_pool.insert(fd, config); in convert_args()
107 for fd in args.rw_fds { in convert_args()
[all …]
|
| /packages/modules/adb/daemon/ |
| D | restart_service.cpp | 31 void restart_root_service(unique_fd fd) { in restart_root_service() argument
33 WriteFdExactly(fd.get(), "adbd is already running as root\n"); in restart_root_service()
37 WriteFdExactly(fd.get(), "adbd cannot run as root in production builds\n"); in restart_root_service()
43 WriteFdExactly(fd.get(), "restarting adbd as root\n"); in restart_root_service()
46 void restart_unroot_service(unique_fd fd) { in restart_unroot_service() argument
48 WriteFdExactly(fd.get(), "adbd not running as root\n"); in restart_unroot_service()
54 WriteFdExactly(fd.get(), "restarting adbd as non root\n"); in restart_unroot_service()
57 void restart_tcp_service(unique_fd fd, int port) { in restart_tcp_service() argument
59 WriteFdFmt(fd.get(), "invalid port %d\n", port); in restart_tcp_service()
65 WriteFdFmt(fd.get(), "restarting in TCP mode port: %d\n", port); in restart_tcp_service()
[all …]
|
| /packages/modules/Bluetooth/system/gd/os/fake_timer/ |
| D | fake_timerfd.cc | 30 int fd; member in bluetooth::os::fake_timer::FakeTimerFd
45 int fd = eventfd(0, EFD_SEMAPHORE); in fake_timerfd_create() local
46 if (fd == -1) { in fake_timerfd_create()
47 return fd; in fake_timerfd_create()
51 fake_timers[fd] = entry; in fake_timerfd_create()
52 entry->fd = fd; in fake_timerfd_create()
53 return fd; in fake_timerfd_create()
57 int fd, in fake_timerfd_settime() argument
61 if (fake_timers.find(fd) == fake_timers.end()) { in fake_timerfd_settime()
65 FakeTimerFd* entry = fake_timers[fd]; in fake_timerfd_settime()
[all …]
|
| /packages/services/Car/cpp/car_binder_lib/largeParcelable/tests/ |
| D | MappedFileSharedMemoryTest.cpp | 38 unique_fd fd(-1); in TEST() local
39 SharedMemory sm(std::move(fd)); in TEST()
46 unique_fd fd(0); in TEST() local
47 SharedMemory sm(std::move(fd)); in TEST()
53 borrowed_fd fd(0); in TEST() local
54 SharedMemory sm(std::move(fd)); in TEST()
67 unique_fd fd(ashmem_create_region("SharedMemory", TEST_SIZE)); in TEST() local
68 ASSERT_TRUE(fd.ok()); in TEST()
69 SharedMemory sm(std::move(fd)); in TEST()
111 unique_fd fd(ashmem_create_region("SharedMemory", TEST_SIZE)); in TEST() local
[all …]
|
| /packages/modules/NeuralNetworks/driver/cache/nnCache/ |
| D | nnCache.cpp | 171 int fd = open(fname, O_CREAT | O_EXCL | O_RDWR, 0); in saveBlobCacheLocked() local
172 if (fd == -1) { in saveBlobCacheLocked()
181 fd = open(fname, O_CREAT | O_EXCL | O_RDWR, 0); in saveBlobCacheLocked()
183 if (fd == -1) { in saveBlobCacheLocked()
194 close(fd); in saveBlobCacheLocked()
203 close(fd); in saveBlobCacheLocked()
213 if (write(fd, buf, fileSize) == -1) { in saveBlobCacheLocked()
216 close(fd); in saveBlobCacheLocked()
222 fchmod(fd, S_IRUSR); in saveBlobCacheLocked()
223 close(fd); in saveBlobCacheLocked()
[all …]
|