Lines Matching refs:action
40 IMtAction* action = NULL; in mt_multi_netfd_poll() local
43 action = *it; in mt_multi_netfd_poll()
44 if (action) { in mt_multi_netfd_poll()
45 obj = action->GetNtfyObj(); in mt_multi_netfd_poll()
47 if (!action || !obj) in mt_multi_netfd_poll()
49 action->SetErrno(ERR_FRAME_ERROR); in mt_multi_netfd_poll()
50 MTLOG_ERROR("input action %p, or ntify null, error", action); in mt_multi_netfd_poll()
82 action->SetErrno(ERR_KQUEUE_FAIL); in mt_multi_netfd_poll()
96 IMtAction* action = NULL; in mt_multi_newsock() local
101 action = *it; in mt_multi_newsock()
102 if (NULL == action) in mt_multi_newsock()
104 action->SetErrno(ERR_PARAM_ERROR); in mt_multi_newsock()
105 MTLOG_ERROR("Invalid param, conn %p null!!", action); in mt_multi_newsock()
109 if (action->GetErrno() != ERR_NONE) { in mt_multi_newsock()
113 net_handler = action->GetIConnection(); in mt_multi_newsock()
116 action->SetErrno(ERR_FRAME_ERROR); in mt_multi_newsock()
124 action->SetErrno(ERR_SOCKET_FAIL); in mt_multi_newsock()
130 if (action->GetProtoType() == MT_UDP) in mt_multi_newsock()
132 action->SetMsgFlag(MULTI_FLAG_OPEN); in mt_multi_newsock()
136 action->SetMsgFlag(MULTI_FLAG_INIT); in mt_multi_newsock()
157 IMtAction* action = NULL; in mt_multi_open() local
166 action = *it; in mt_multi_open()
167 if (action->GetErrno() != ERR_NONE) { in mt_multi_open()
171 if (action->GetMsgFlag() == MULTI_FLAG_OPEN) { in mt_multi_open()
176 net_handler = action->GetIConnection(); in mt_multi_open()
179 action->SetErrno(ERR_FRAME_ERROR); in mt_multi_open()
187 wait_list.push_back(action); in mt_multi_open()
191 action->SetMsgFlag(MULTI_FLAG_OPEN); in mt_multi_open()
233 IMtAction* action = NULL; in mt_multi_sendto() local
241 action = *it; in mt_multi_sendto()
242 if (action->GetErrno() != ERR_NONE) { in mt_multi_sendto()
246 if (action->GetMsgFlag() == MULTI_FLAG_SEND) { in mt_multi_sendto()
251 net_handler = action->GetIConnection(); in mt_multi_sendto()
254 action->SetErrno(ERR_FRAME_ERROR); in mt_multi_sendto()
262 action->SetErrno(ERR_SEND_FAIL); in mt_multi_sendto()
268 wait_list.push_back(action); in mt_multi_sendto()
273 action->SetMsgFlag(MULTI_FLAG_SEND); in mt_multi_sendto()
316 IMtAction* action = NULL; in mt_multi_recvfrom() local
324 action = *it; in mt_multi_recvfrom()
325 if (action->GetErrno() != ERR_NONE) { in mt_multi_recvfrom()
329 if (MULTI_FLAG_FIN == action->GetMsgFlag()) in mt_multi_recvfrom()
334 net_handler = action->GetIConnection(); in mt_multi_recvfrom()
337 action->SetErrno(ERR_FRAME_ERROR); in mt_multi_recvfrom()
345 action->SetErrno(ERR_RECV_FAIL); in mt_multi_recvfrom()
351 wait_list.push_back(action); in mt_multi_recvfrom()
356 action->SetMsgFlag(MULTI_FLAG_FIN); in mt_multi_recvfrom()
357 action->SetCost(MtFrame::Instance()->GetLastClock() - start_ms); in mt_multi_recvfrom()