| /base/startup/init/services/loopevent/socket/ |
| D | le_socket.c | 31 static int CreatePipeServerSocket_(const char *server, int maxClient) in CreatePipeServerSocket_() argument
36 unlink(server); in CreatePipeServerSocket_()
42 ret = strcpy_s(serverAddr.sun_path, sizeof(serverAddr.sun_path), server); in CreatePipeServerSocket_()
45 uint32_t size = offsetof(struct sockaddr_un, sun_path) + strlen(server); in CreatePipeServerSocket_()
54 ret = chmod(server, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH); in CreatePipeServerSocket_()
55 LE_CHECK(ret == 0, return -1, "Failed to chmod %s, err %d. ", server, errno); in CreatePipeServerSocket_()
60 static int CreatePipeSocket_(const char *server) in CreatePipeSocket_() argument
75 ret = strcpy_s(serverAddr.sun_path, sizeof(serverAddr.sun_path), server); in CreatePipeSocket_()
86 static LE_STATUS GetSockaddrFromServer_(const char *server, struct sockaddr_in *addr) in GetSockaddrFromServer_() argument
91 const char *portStr = strstr(server, ":"); in GetSockaddrFromServer_()
[all …]
|
| D | le_socket.h | 28 int CreateSocket(int flags, const char *server);
|
| /base/security/device_auth/test/unittest/tdd_framework/unit_test/services/session_manager/session/v2/auth_sub_session/ |
| D | auth_sub_session_test.cpp | 115 AuthSubSession *server; variable
116 res = CreateAuthSubSession(PROTOCOL_TYPE_ISO, (void *)&g_paramsS, false, &server);
118 ASSERT_NE(server, nullptr);
122 res = server->setPsk(server, &g_psk);
132 res = server->setSelfProtectedMsg(server, &g_msgS);
134 res = server->setPeerProtectedMsg(server, &g_msgC);
142 res = server->process(server, clientOut, &serverOut);
158 res = server->getSessionKey(server, &serverKey);
163 server->destroy(server);
173 AuthSubSession *server; variable
[all …]
|
| /base/security/device_auth/test/unittest/tdd_framework/unit_test/services/session_manager/session/v2/auth_sub_session/protocol_lib/ |
| D | ec_speke_protocol_test.cpp | 111 BaseProtocol *server; variable
112 res = CreateEcSpekeProtocol(&g_X25519ParamsS, false, &server);
114 ASSERT_NE(server, nullptr);
118 res = server->setPsk(server, &g_psk);
128 res = server->setSelfProtectedMsg(server, &g_msgS);
130 res = server->setPeerProtectedMsg(server, &g_msgC);
138 res = server->process(server, clientOut, &serverOut);
154 res = server->getSessionKey(server, &serverKey);
159 server->destroy(server);
169 BaseProtocol *server; variable
[all …]
|
| D | iso_protocol_test.cpp | 108 BaseProtocol *server; variable
109 res = CreateIsoProtocol(&g_paramsS, false, &server);
111 ASSERT_NE(server, nullptr);
115 res = server->setPsk(server, &g_psk);
125 res = server->setSelfProtectedMsg(server, &g_msgS);
127 res = server->setPeerProtectedMsg(server, &g_msgC);
135 res = server->process(server, clientOut, &serverOut);
151 res = server->getSessionKey(server, &serverKey);
156 server->destroy(server);
166 BaseProtocol *server; variable
[all …]
|
| /base/hiviewdfx/faultloggerd/interfaces/innerkits/faultloggerd_client/ |
| D | faultloggerd_socket.cpp | 55 struct sockaddr_un server; in StartConnect() local
56 (void)memset_s(&server, sizeof(server), 0, sizeof(server)); in StartConnect()
57 server.sun_family = AF_LOCAL; in StartConnect()
58 errno_t err = strncpy_s(server.sun_path, sizeof(server.sun_path), fullPath.c_str(), in StartConnect()
59 sizeof(server.sun_path) - 1); in StartConnect()
65 … int len = static_cast<int>(offsetof(struct sockaddr_un, sun_path) + strlen(server.sun_path) + 1); in StartConnect()
66 int connected = connect(sockfd, reinterpret_cast<struct sockaddr *>(&server), len); in StartConnect()
90 struct sockaddr_un server; in GetServerSocket() local
91 (void)memset_s(&server, sizeof(server), 0, sizeof(server)); in GetServerSocket()
92 server.sun_family = AF_LOCAL; in GetServerSocket()
[all …]
|
| /base/startup/init/services/loopevent/task/ |
| D | le_streamtask.c | 145 StreamServerTask *server = (StreamServerTask *)serverTask; in HandleServerEvent_() local
146 LE_ONLY_CHECK(server->incommingConnect != NULL, return LE_SUCCESS); in HandleServerEvent_()
148 int ret = server->incommingConnect(loopHandle, serverTask); in HandleServerEvent_()
161 LE_CHECK(info->server != NULL, return LE_INVALID_PARAM, "Invalid parameters server"); in LE_CreateStreamServer()
163 "Invalid parameters incommingConnect %s", info->server); in LE_CreateStreamServer()
167 fd = CreateSocket(info->baseInfo.flags, info->server); in LE_CreateStreamServer()
168 LE_CHECK(fd > 0, return LE_FAILURE, "Failed to create socket %s", info->server); in LE_CreateStreamServer()
173 sizeof(StreamServerTask) + strlen(info->server) + 1); in LE_CreateStreamServer()
180 …int ret = memcpy_s(task->server, strlen(info->server) + 1, info->server, strlen(info->server) + 1); in LE_CreateStreamServer()
181 LE_CHECK(ret == 0, return LE_FAILURE, "Failed to copy server name %s", info->server); in LE_CreateStreamServer()
[all …]
|
| /base/security/device_auth/frameworks/deviceauth_lite/unittest/ |
| D | deviceauth_test.cpp | 109 hc_handle server = get_instance(&g_serverIdentity, HC_ACCESSORY, &callBack); variable
110 ASSERT_TRUE(server != NULL);
111 destroy(&server);
126 hc_handle server = get_instance(&g_serverIdentity, HC_ACCESSORY, &callBack); variable
128 int32_t ret = start_pake(server, ¶ms);
130 destroy(&server);
145 hc_handle server = get_instance(&g_serverIdentity, HC_ACCESSORY, &callBack); variable
147 int32_t ret = is_trust_peer(server, &userInfo);
149 destroy(&server);
|
| /base/security/device_auth/frameworks/deviceauth_lite/source/key_agreement/ |
| D | key_agreement_server.c | 42 struct key_agreement_server *server = handle; in send_start_response() local
43 struct key_agreement_protocol *base = &server->protocol_base_info; in send_start_response()
46 if (is_state_error(server, SEND_START_RESPONSE)) { in send_start_response()
50 const struct server_virtual_func_group *funcs = &server->package_funcs; in send_start_response()
74 struct key_agreement_server *server = handle; in send_end_response() local
75 struct key_agreement_protocol *base = &server->protocol_base_info; in send_end_response()
78 if (is_state_error(server, SEND_END_RESPONSE)) { in send_end_response()
82 const struct server_virtual_func_group *funcs = &server->package_funcs; in send_end_response()
|
| D | pake_server.h | 114 static inline uint32_t pake_server_sn(struct pake_server *server) in pake_server_sn() argument
116 return server->server_info.protocol_base_info.sn; in pake_server_sn()
131 const struct hc_auth_id *server);
|
| D | sts_server.h | 133 static inline uint32_t sts_server_sn(struct sts_server *server) in sts_server_sn() argument
135 return server->server_info.protocol_base_info.sn; in sts_server_sn()
144 const struct hc_auth_id *client, const struct hc_auth_id *server);
|
| /base/security/device_auth/test/unittest/tdd_framework/unit_test/services/session_manager/session/v2/expand_sub_session/ |
| D | expand_sub_session_test.cpp | 118 ExpandSubSession *server; variable
119 res = CreateExpandSubSession(&g_nonce, &g_encryptionKey, &server);
121 ASSERT_NE(server, nullptr);
125 …res = server->addCmd(server, AUTH_CODE_IMPORT_CMD_TYPE, (void *)&g_paramsS, false, ABORT_IF_ERROR);
129 …res = server->addCmd(server, PUB_KEY_EXCHANGE_CMD_TYPE, (void *)&g_25519ParamsS, false, ABORT_IF_E…
139 res = server->process(server, clientOut, &serverOut);
144 ASSERT_EQ(server->state, EXPAND_STATE_FINISH);
154 server->destroy(server);
383 static int32_t LoopProcess(ExpandSubSession *client, ExpandSubSession *server) in LoopProcess() argument
393 res = server->process(server, clientOut, &serverOut); in LoopProcess()
[all …]
|
| /base/startup/appspawn/test/moduletest/ |
| D | appspawn_test_cmd.cpp | 23 static int DoRun(const char *server, const AppParameter *request) in DoRun() argument
25 int ret = g_testClient.ClientCreateSocket(server); in DoRun()
68 const char *server = "/dev/unix/socket/AppSpawn"; in main() local
75 server = "/dev/unix/socket/NWebSpawn"; in main()
97 return DoRun(server, &request); in main()
|
| /base/hiviewdfx/faultloggerd/services/config/ |
| D | faultloggerd.cfg | 9 "restorecon /dev/unix/socket/faultloggerd.server",
10 "restorecon /dev/unix/socket/faultloggerd.crash.server"
20 "name" : "faultloggerd.server",
31 "name" : "faultloggerd.crash.server",
|
| /base/security/device_auth/test/unittest/tdd_framework/unit_test/services/session_manager/session/v2/expand_sub_session/expand_process_lib/ |
| D | save_trusted_info_test.cpp | 235 BaseCmd *server = CreateSaveTrustedInfoCmd((void *)&g_paramsS, false, ABORT_IF_ERROR); variable
236 ASSERT_NE(server, nullptr);
249 res = server->process(server, clientOut, &serverOut, &serverState);
265 server->destroy(server);
283 BaseCmd *server = CreateSaveTrustedInfoCmd((void *)&g_paramsS, false, ABORT_IF_ERROR); variable
284 ASSERT_NE(server, nullptr);
297 res = server->process(server, clientOut, &serverOut, &serverState);
313 server->destroy(server);
583 BaseCmd *server = CreateSaveTrustedInfoCmd((void *)&g_paramsS, false, ABORT_IF_ERROR); in TestMemoryInner() local
584 if (server == nullptr) { in TestMemoryInner()
[all …]
|
| D | auth_code_import_test.cpp | 104 BaseCmd *server = CreateAuthCodeImportCmd((void *)&g_paramsS, false, ABORT_IF_ERROR); variable
105 ASSERT_NE(server, nullptr);
116 res = server->process(server, clientOut, &serverOut, &serverState);
131 server->destroy(server);
393 BaseCmd *server = CreateAuthCodeImportCmd((void *)&g_paramsS, false, ABORT_IF_ERROR); in TestMemoryInner() local
394 if (server == nullptr) { in TestMemoryInner()
397 *serverPtr = server; in TestMemoryInner()
408 res = server->process(server, clientOut, &serverOut, &serverState); in TestMemoryInner()
429 BaseCmd *server = nullptr; in TestMemoryException() local
430 int32_t res = TestMemoryInner(&client, &server); in TestMemoryException()
[all …]
|
| D | pub_key_exchange_test.cpp | 104 BaseCmd *server = CreatePubKeyExchangeCmd((void *)&g_paramsS, false, ABORT_IF_ERROR); variable
105 ASSERT_NE(server, nullptr);
116 res = server->process(server, clientOut, &serverOut, &serverState);
131 server->destroy(server);
393 BaseCmd *server = CreatePubKeyExchangeCmd((void *)&g_paramsS, false, ABORT_IF_ERROR); in TestMemoryInner() local
394 if (server == nullptr) { in TestMemoryInner()
397 *serverPtr = server; in TestMemoryInner()
408 res = server->process(server, clientOut, &serverOut, &serverState); in TestMemoryInner()
429 BaseCmd *server = nullptr; in TestMemoryException() local
430 int32_t res = TestMemoryInner(&client, &server); in TestMemoryException()
[all …]
|
| /base/hiviewdfx/hiview/plugins/eventlogger/log_catcher/ |
| D | peer_binder_catcher.cpp | 141 std::string server = stringSplit(strList[2], 0); in BinderInfoParser() local
146 if (server == "" || client == "" || wait == "") { in BinderInfoParser()
149 info.server = std::strtol(server.c_str(), nullptr, DECIMAL); in BinderInfoParser()
152 …HIVIEW_LOGI("server:%{public}d, client:%{public}d, wait:%{public}d", info.server, info.client, inf… in BinderInfoParser()
186 pids.insert(each.server); in GetBinderPeerPids()
198 if (pids.find(each.server) != pids.end()) { in ParseBinderCallChain()
201 pids.insert(each.server); in ParseBinderCallChain()
202 ParseBinderCallChain(manager, pids, each.server); in ParseBinderCallChain()
|
| /base/msdp/device_status/ |
| D | BUILD.gn | 22 "${device_status_root_path}/rust/ipc/server:fusion_ipc_server_ffi",
23 "${device_status_root_path}/rust/modules/coordination/server:fusion_coordination_server_ffi",
24 "${device_status_root_path}/rust/modules/drag/server:fusion_drag_server_ffi",
|
| /base/startup/init/services/param/linux/ |
| D | param_message.h | 77 char *server; member
88 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server,
105 int OnIncomingConnect(LoopHandle loop, TaskHandle server);
|
| D | param_msgadp.c | 53 info.server = streamInfo->server; in ParamServerCreate()
59 int ParamStreamCreate(ParamTaskPtr *stream, ParamTaskPtr server, in ParamStreamCreate() argument
76 LE_STATUS status = LE_AcceptStreamClient(LE_GetDefaultLoop(), server, stream, &info); in ParamStreamCreate()
|
| /base/startup/init/test/unittest/loopevent/ |
| D | loopevent_unittest.cpp | 68 static int IncomingConnect(LoopHandle loop, TaskHandle server) in IncomingConnect() argument
71 UNUSED(server); in IncomingConnect()
97 info.server = const_cast<char *>(PIPE_NAME); in CreateServerTask()
109 streamInfo.server = (char *)"/data/testpipea"; in StreamTaskTest()
122 streamInfo.server = (char *)"0.0.0.0:10110"; in StreamTaskTest()
129 streamInfo.server = (char *)"127.0.0.1:10111"; in StreamTaskTest()
139 info.server = (char *)"/data/testpipe"; in LeTaskTest()
151 paramStreamInfo.server = nullptr; in LeTaskTest()
222 info.server = (char *)"/data/testpipe"; in CreateSocketTest()
|
| D | loopserver_unittest.cpp | 140 static int TestTcpIncomingConnect(LoopHandle loop, TaskHandle server) in TestTcpIncomingConnect() argument
142 PARAM_CHECK(server != nullptr, return -1, "Error server"); in TestTcpIncomingConnect()
152 LE_STATUS ret = LE_AcceptStreamClient(loop, server, &stream, &info); in TestTcpIncomingConnect()
157 static int TestPipIncomingConnect(LoopHandle loop, TaskHandle server) in TestPipIncomingConnect() argument
159 PARAM_CHECK(server != nullptr, return -1, "Error server"); in TestPipIncomingConnect()
169 LE_STATUS ret = LE_AcceptStreamClient(loop, server, &stream, &info); in TestPipIncomingConnect()
243 info.server = const_cast<char *>(TCP_SERVER.c_str()); in RunServer()
251 info.server = const_cast<char *>(PIPE_SERVER.c_str()); in RunServer()
286 info.server = const_cast<char *>(tcpServer); in CreateConnect()
|
| /base/startup/init/test/exec_test/ |
| D | BUILD.gn | 57 ohos_executable("server") {
58 sources = [ "server.c" ]
96 ":server",
|
| /base/security/selinux_adapter/sepolicy/ohos_policy/hiviewdfx/faultloggerd/system/ |
| D | file_contexts | 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
|