| /hardware/qcom/sm7250/gps/utils/ |
| D | LocIpc.cpp | 134 shared_ptr<Sock> mSock; member in loc_util::LocIpcLocalSender
136 inline virtual bool isOperable() const override { return mSock != nullptr && mSock->isValid(); } in isOperable()
138 return mSock->send(data, length, 0, (struct sockaddr*)&mAddr, sizeof(mAddr)); in send()
142 mSock(nullptr), in LocIpcLocalSender()
155 mSock.reset(new Sock(fd));
156 if (mSock != nullptr && mSock->isValid()) {
166 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
177 if (mSock->isValid() && ::bind(mSock->mSid, (struct sockaddr*)&mAddr, sizeof(mAddr)) < 0) { in LocIpcLocalRecver()
178 LOC_LOGe("bind socket error. sock fd: %d: %s, reason: %s", mSock->mSid, in LocIpcLocalRecver()
180 mSock->close(); in LocIpcLocalRecver()
[all …]
|
| D | LocIpc.h | 223 shared_ptr<Sock> mSock; variable
226 return mSock->recv(*this, mDataCb, 0, nullptr, nullptr); in recv()
231 LocIpcRecver(listener, sender), mSock(sock) { in SockRecver()
|
| /hardware/qcom/sm8150/gps/utils/ |
| D | LocIpc.cpp | 134 shared_ptr<Sock> mSock; member in loc_util::LocIpcLocalSender
136 inline virtual bool isOperable() const override { return mSock != nullptr && mSock->isValid(); } in isOperable()
138 return mSock->send(data, length, 0, (struct sockaddr*)&mAddr, sizeof(mAddr)); in send()
142 mSock(nullptr), in LocIpcLocalSender()
155 mSock.reset(new Sock(fd));
156 if (mSock != nullptr && mSock->isValid()) {
166 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
177 if (mSock->isValid() && ::bind(mSock->mSid, (struct sockaddr*)&mAddr, sizeof(mAddr)) < 0) { in LocIpcLocalRecver()
178 LOC_LOGe("bind socket error. sock fd: %d: %s, reason: %s", mSock->mSid, in LocIpcLocalRecver()
180 mSock->close(); in LocIpcLocalRecver()
[all …]
|
| D | LocIpc.h | 223 shared_ptr<Sock> mSock; variable
226 return mSock->recv(*this, mDataCb, 0, nullptr, nullptr); in recv()
231 LocIpcRecver(listener, sender), mSock(sock) { in SockRecver()
|
| /hardware/qcom/sm7150/gps/utils/ |
| D | LocIpc.cpp | 134 shared_ptr<Sock> mSock; member in loc_util::LocIpcLocalSender
136 inline virtual bool isOperable() const override { return mSock != nullptr && mSock->isValid(); } in isOperable()
138 return mSock->send(data, length, 0, (struct sockaddr*)&mAddr, sizeof(mAddr)); in send()
142 mSock(nullptr), in LocIpcLocalSender()
155 mSock.reset(new Sock(fd));
156 if (mSock != nullptr && mSock->isValid()) {
166 return mSock->recv(*this, mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
177 if (mSock->isValid() && ::bind(mSock->mSid, (struct sockaddr*)&mAddr, sizeof(mAddr)) < 0) { in LocIpcLocalRecver()
178 LOC_LOGe("bind socket error. sock fd: %d: %s, reason: %s", mSock->mSid, in LocIpcLocalRecver()
180 mSock->close(); in LocIpcLocalRecver()
[all …]
|
| D | LocIpc.h | 188 shared_ptr<Sock> mSock; variable
191 return mSock->recv(*this, mDataCb, 0, nullptr, nullptr); in recv()
196 LocIpcRecver(listener, sender), mSock(sock) { in SockRecver()
|
| /hardware/qcom/sm8150p/gps/utils/ |
| D | LocIpc.cpp | 135 shared_ptr<Sock> mSock; member in loc_util::LocIpcLocalSender
137 inline virtual bool isOperable() const override { return mSock != nullptr && mSock->isValid(); } in isOperable()
139 return mSock->send(data, length, 0, (struct sockaddr*)&mAddr, sizeof(mAddr)); in send()
143 mSock(make_shared<Sock>((nullptr == name) ? -1 : (::socket(AF_UNIX, SOCK_DGRAM, 0)))), in LocIpcLocalSender()
145 if (mSock != nullptr && mSock->isValid()) {
155 return mSock->recv(mDataCb, 0, (struct sockaddr*)&mAddr, &size); in recv()
166 if (mSock->isValid() && ::bind(mSock->mSid, (struct sockaddr*)&mAddr, sizeof(mAddr)) < 0) { in LocIpcLocalRecver()
167 LOC_LOGe("bind socket error. sock fd: %d: %s, reason: %s", mSock->mSid, in LocIpcLocalRecver()
169 mSock->close(); in LocIpcLocalRecver()
176 mSock->sendAbort(0, (struct sockaddr*)&mAddr, sizeof(mAddr)); in abort()
[all …]
|