Lines Matching refs:connection
264 AppSpawnConnection *connection = (AppSpawnConnection *) LE_GetUserData(taskHandle);
274 return -1, "failed to recv fd %d %d", connection->receiverCtx.fdCount, fdCount);
275 APPSPAWN_CHECK(memcpy_s(connection->receiverCtx.fds, fdCount * sizeof(int), fd,
277 connection->receiverCtx.fdCount = fdCount;
302 TestConnection *connection = (TestConnection *)LE_GetUserData(stream);
303 APPSPAWN_CHECK(connection != nullptr, return -1, "Failed to alloc stream");
304 connection->connectionId = ++connectionId;
305 connection->stream = stream;
306 connection->msgRecvLen = 0;
307 (void)memset_s(&connection->msg, sizeof(connection->msg), 0, sizeof(connection->msg));
308 connection->buffer = nullptr;
309 connection->recvMsgProcess = serverInfo->recvMsgProcess;
310 APPSPAWN_LOGI("OnConnection connection.id %{public}d fd %{public}d ",
311 connection->connectionId, LE_GetSocketFd(stream));
322 TestConnection *connection = (TestConnection *)LE_GetUserData(taskHandle);
323 APPSPAWN_CHECK(connection != nullptr, return, "Invalid connection");
324 APPSPAWN_LOGI("OnClose connection.id %{public}d socket %{public}d",
325 connection->connectionId, LE_GetSocketFd(taskHandle));
341 TestConnection *connection = (TestConnection *)LE_GetUserData(taskHandle);
342 APPSPAWN_CHECK(connection != nullptr, LE_CloseTask(LE_GetDefaultLoop(), taskHandle);
345 if (connection->recvMsgProcess) {
346 connection->recvMsgProcess(connection, buffer, buffLen);