Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 150) sorted by relevance

123456

/base/security/selinux_adapter/sepolicy/base/system/
Daccess_vectors42 common socket
171 class socket
172 inherits socket
174 inherits socket
180 inherits socket
185 inherits socket
200 inherits socket
202 inherits socket
204 inherits socket
206 inherits socket
[all …]
/base/security/selinux_adapter/sepolicy/min/
Daccess_vectors42 common socket
171 class socket
172 inherits socket
174 inherits socket
180 inherits socket
185 inherits socket
200 inherits socket
202 inherits socket
204 inherits socket
206 inherits socket
[all …]
/base/security/access_token/services/tokensyncmanager/src/remote/
Dsoft_bus_socket_listener.cpp36 void SoftBusSocketListener::OnBind(int32_t socket, PeerSocketInfo info) in OnBind() argument
38 ACCESSTOKEN_LOG_INFO(LABEL, "socket fd is %{public}d.", socket); in OnBind()
40 if (socket <= Constant::INVALID_SOCKET_FD) { in OnBind()
47 auto iter = socketBindMap_.find(socket); in OnBind()
49 socketBindMap_.insert(std::pair<int32_t, std::string>(socket, peerNetworkId)); in OnBind()
55 void SoftBusSocketListener::OnShutdown(int32_t socket, ShutdownReason reason) in OnShutdown() argument
57 … ACCESSTOKEN_LOG_INFO(LABEL, "socket fd %{public}d shutdown because %{public}u.", socket, reason); in OnShutdown()
59 if (socket <= Constant::INVALID_SOCKET_FD) { in OnShutdown()
66 auto iter = socketBindMap_.find(socket); in OnShutdown()
72 bool SoftBusSocketListener::GetNetworkIdBySocket(const int32_t socket, std::string& networkId) in GetNetworkIdBySocket() argument
[all …]
Dsoft_bus_channel.cpp72 int socket = SoftBusManager::GetInstance().BindService(deviceId_); in BuildConnection() local
73 if (socket == Constant::INVALID_SOCKET_FD) { in BuildConnection()
77 socketFd_ = socket; in BuildConnection()
207 void SoftBusChannel::HandleDataReceived(int socket, const unsigned char *bytes, int length) in HandleDataReceived() argument
213 if (socket <= 0 || length <= 0) { in HandleDataReceived()
214 …EN_LOG_ERROR(LABEL, "invalid params: socket: %{public}d, data length: %{public}d", socket, length); in HandleDataReceived()
235 … HandleRequest(socket, message->GetId(), message->GetCommandName(), message->GetJsonPayload()); in HandleDataReceived()
341 int socket = SoftBusManager::GetInstance().BindService(deviceId_); in CheckSessionMayReopenLocked() local
342 if (socket != Constant::INVALID_SESSION) { in CheckSessionMayReopenLocked()
343 socketFd_ = socket; in CheckSessionMayReopenLocked()
[all …]
/base/security/device_security_level/baselib/msglib/src/standard/
Dmessenger_device_socket_manager.c67 int32_t socket; member
160 static void RemoveSocketNode(int32_t socket, ShutdownReason reason, bool isServer) in RemoveSocketNode() argument
170 if (info->socket == socket) { in RemoveSocketNode()
179 static void ServerOnShutdown(int32_t socket, ShutdownReason reason) in ServerOnShutdown() argument
181 if (socket == 0) { in ServerOnShutdown()
184 RemoveSocketNode(socket, reason, true); in ServerOnShutdown()
187 static void ClientOnShutdown(int32_t socket, ShutdownReason reason) in ClientOnShutdown() argument
189 if (socket == 0) { in ClientOnShutdown()
192 RemoveSocketNode(socket, reason, false); in ClientOnShutdown()
205 uint32_t socket = (uint32_t)input; in TimerProcessWaitingTimeOut() local
[all …]
/base/security/access_token/services/tokensyncmanager/test/mock/include/
Dsocket.h255 void (*OnBind)(int32_t socket, PeerSocketInfo info);
267 void (*OnShutdown)(int32_t socket, ShutdownReason reason);
280 void (*OnBytes)(int32_t socket, const void *data, uint32_t dataLen);
293 void (*OnMessage)(int32_t socket, const void *data, uint32_t dataLen);
307 …void (*OnStream)(int32_t socket, const StreamData *data, const StreamData *ext, const StreamFrameI…
320 void (*OnFile)(int32_t socket, FileEvent *event);
333 void (*OnQos)(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount);
361 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene…
380 int32_t Bind(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listener);
401 int32_t SendBytes(int32_t socket, const void *data, uint32_t len);
[all …]
/base/msdp/device_status/intention/adapters/dsoftbus_adpater/src/
Ddsoftbus_adapter_impl.cpp116 int32_t socket = FindConnection(networkId); in SendPacket() local
117 if (socket < 0) { in SendPacket()
127 int32_t ret = ::SendBytes(socket, buffer.Data(), buffer.Size()); in SendPacket()
135 static void OnBindLink(int32_t socket, PeerSocketInfo info) in OnBindLink() argument
137 DSoftbusAdapterImpl::GetInstance()->OnBind(socket, info); in OnBindLink()
140 static void OnShutdownLink(int32_t socket, ShutdownReason reason) in OnShutdownLink() argument
142 DSoftbusAdapterImpl::GetInstance()->OnShutdown(socket, reason); in OnShutdownLink()
145 static void OnBytesAvailable(int32_t socket, const void *data, uint32_t dataLen) in OnBytesAvailable() argument
147 DSoftbusAdapterImpl::GetInstance()->OnBytes(socket, data, dataLen); in OnBytesAvailable()
150 void DSoftbusAdapterImpl::OnBind(int32_t socket, PeerSocketInfo info) in OnBind() argument
[all …]
/base/startup/init/services/modules/init_context/
Dinit_context.c46 static int CreateSocketPair(int socket[2]);
54 close(arg->socket[0]); in SubInitRun()
56 SubInitMain(arg->type, arg->socket[1], arg->socket[1]); in SubInitRun()
57 close(arg->socket[1]); in SubInitRun()
85 int ret = CreateSocketPair(arg.socket); in SubInitStart()
91 close(arg.socket[0]); in SubInitStart()
92 close(arg.socket[1]); in SubInitStart()
97 close(arg.socket[1]); in SubInitStart()
99 subInfo->sendFd = arg.socket[0]; in SubInitStart()
100 subInfo->recvFd = arg.socket[0]; in SubInitStart()
[all …]
/base/security/access_token/services/tokensyncmanager/include/remote/
Dsoft_bus_socket_listener.h30 static void OnBind(int32_t socket, PeerSocketInfo info);
31 static void OnShutdown(int32_t socket, ShutdownReason reason);
32 static void OnClientBytes(int32_t socket, const void *data, uint32_t dataLen);
33 static void OnServiceBytes(int32_t socket, const void *data, uint32_t dataLen);
35 static void OnQos(int32_t socket, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) {}; in OnQos() argument
41 static bool GetNetworkIdBySocket(const int32_t socket, std::string& networkId);
/base/msdp/device_status/services/interaction/coordination/include/
Dcoordination_softbus_adapter.h50 int32_t OnBind(int32_t socket, PeerSocketInfo info);
51 void OnShutdown(int32_t socket, ShutdownReason reason);
52 void OnBytes(int32_t socket, const void* data, uint32_t dataLen);
59 void ConfigTcpAlive(int32_t socket);
65 std::string FindDevice(int32_t socket);
66 int32_t SendMsg(int32_t socket, const std::string &message);
68 void HandleSessionData(int32_t socket, const std::string &messageData);
72 int32_t InitSocket(SocketInfo info, int32_t socketType, int32_t &socket);
/base/msdp/device_status/services/interaction/coordination/src/
Dcoordination_softbus_adapter.cpp122 static void BindLink(int32_t socket, PeerSocketInfo info) in BindLink() argument
124 COOR_SOFTBUS_ADAPTER->OnBind(socket, info); in BindLink()
127 static void ShutdownLink(int32_t socket, ShutdownReason reason) in ShutdownLink() argument
129 COOR_SOFTBUS_ADAPTER->OnShutdown(socket, reason); in ShutdownLink()
132 static void BytesReceived(int32_t socket, const void *data, uint32_t dataLen) in BytesReceived() argument
134 COOR_SOFTBUS_ADAPTER->OnBytes(socket, data, dataLen); in BytesReceived()
137 int32_t CoordinationSoftbusAdapter::InitSocket(SocketInfo info, int32_t socketType, int32_t &socket) in InitSocket() argument
140 socket = Socket(info); in InitSocket()
154 return Listen(socket, socketQos, QOS_LEN, &listener); in InitSocket()
156 return Bind(socket, socketQos, QOS_LEN, &listener); in InitSocket()
[all …]
/base/msdp/device_status/intention/adapters/dsoftbus_adpater/include/
Ddsoftbus_adapter_impl.h57 Session(int32_t socket) : socket_(socket) {} in Session()
83 void OnBind(int32_t socket, PeerSocketInfo info);
84 void OnShutdown(int32_t socket, ShutdownReason reason);
85 void OnBytes(int32_t socket, const void *data, uint32_t dataLen);
91 int32_t InitSocket(SocketInfo info, int32_t socketType, int32_t &socket);
95 void ConfigTcpAlive(int32_t socket);
/base/msdp/device_status/intention/ipc/socket/src/
Dsocket_client.cpp62 auto socket = SocketConnection::Connect( in Connect() local
66 CHKPF(socket); in Connect()
68 auto errCode = eventHandler_->AddFileDescriptorListener(socket->GetFd(), in Connect()
69 AppExecFwk::FILE_DESCRIPTOR_INPUT_EVENT, socket, "DeviceStatusTask"); in Connect()
71 … FI_HILOGE("AddFileDescriptorListener(%{public}d) failed (%{public}u)", socket->GetFd(), errCode); in Connect()
74 socket_ = socket; in Connect()
Dsocket_connection.cpp44 std::shared_ptr<SocketConnection> SocketConnection::Connect(std::function<int32_t()> socket, in Connect() argument
48 CHKPP(socket); in Connect()
49 int32_t sockFd = socket(); in Connect()
/base/tee/tee_client/services/teecd/src/
Dtee_ca_auth.c83 int RecvCaMsg(int socket, CaRevMsg *caInfo) in RecvCaMsg() argument
113 FD_SET(socket, &fds); in RecvCaMsg()
114 ret = select(socket + 1, &fds, NULL, NULL, &timeout); in RecvCaMsg()
119 ret = (int)recvmsg(socket, &message, 0); in RecvCaMsg()
Dtee_ca_daemon.c60 static int SendFileDescriptor(int cmd, int socket, int fd) in SendFileDescriptor() argument
106 ret = (int)sendmsg(socket, &hmsg, 0); in SendFileDescriptor()
114 static int ProcessCaMsg(const struct ucred *cr, const CaRevMsg *caInfo, int socket) in ProcessCaMsg() argument
119 ret = SendFileDescriptor(caInfo->cmd, socket, (int)g_version); in ProcessCaMsg()
140 ret = SendFileDescriptor(caInfo->cmd, socket, fd); in ProcessCaMsg()
220 int32_t s = socket(AF_UNIX, SOCK_STREAM, 0); in CreateSocket()
/base/security/device_security_level/test/dslm_fuzz_test/mock/
Dmock.cpp29 int32_t Listen(int32_t socket, const QosTV qos[], uint32_t qosCount, const ISocketListener *listene… in Listen() argument
34 void Shutdown(int32_t socket) in Shutdown() argument
/base/hiviewdfx/faultloggerd/services/config/
Dfaultloggerd.cfg9 "restorecon /dev/unix/socket/faultloggerd.server",
10 "restorecon /dev/unix/socket/faultloggerd.crash.server"
19 "socket" : [{
/base/security/selinux_adapter/sepolicy/ohos_policy/hiviewdfx/hilog/system/
Dfile_contexts17 /dev/unix/socket/hilogControl u:object_r:hilog_control_socket:s0
18 /dev/unix/socket/hilogOutput u:object_r:hilog_output_socket:s0
19 /dev/unix/socket/hilogInput u:object_r:hilog_input_socket:s0
/base/security/selinux_adapter/sepolicy/ohos_policy/hiviewdfx/faultloggerd/system/
Dfile_contexts24 # faultloggerd socket
25 /dev/unix/socket/faultloggerd.server u:object_r:faultloggerd_socket:s0
26 /dev/unix/socket/faultloggerd.crash.server u:object_r:faultloggerd_socket_crash:s0
/base/hiviewdfx/hilog/frameworks/libhilog/socket/
Dsocket.cpp50 int tmpFd = TEMP_FAILURE_RETRY(socket(AF_UNIX, socketType, 0)); in GenerateFD()
53 res = TEMP_FAILURE_RETRY(socket(AF_UNIX, socketType, 0)); in GenerateFD()
65 int fd = TEMP_FAILURE_RETRY(socket(AF_UNIX, socketType, 0)); in Create()
/base/startup/appspawn/
DREADME.md18 │ └── socket # encapsulation of socket basic library
/base/security/selinux_adapter/sepolicy/ohos_policy/communication/netmanager/system/
Dfile_contexts14 /dev/unix/socket/fwmarkd u:object_r:fwmark_service:s0
15 /dev/unix/socket/dnsproxyd u:object_r:dnsproxy_service:s0
/base/startup/init/test/unittest/modules/
Dcontext_unittest.cpp50 forkArg->args.socket[0] = args->socket[0]; in SubInitFork()
51 forkArg->args.socket[1] = args->socket[1]; in SubInitFork()
/base/security/selinux_adapter/sepolicy/ohos_policy/developtools/profiler/system/
Dfile_contexts22 /dev/unix/socket/hiprofiler_unix_socket u:object_r:hiprofiler_socket:s0
24 /dev/unix/socket/hook_unix_socket u:object_r:hiprofiler_socket:s0

123456