Lines Matching refs:aid
175 int WBTi_GetNextIterationAID(int aid, int mask) in WBTi_GetNextIterationAID() argument
177 ++aid; in WBTi_GetNextIterationAID()
178 if ((1 << aid) > mask) in WBTi_GetNextIterationAID()
180 aid = (int)MATH_CTZ((u32)mask); in WBTi_GetNextIterationAID()
182 return aid; in WBTi_GetNextIterationAID()
387 int aid; in WBTi_SwitchNextCommand() local
388 for (aid = 0; aid < 16; ++aid) in WBTi_SwitchNextCommand()
390 if ((current->target_bmp & (1 << aid)) != 0) in WBTi_SwitchNextCommand()
392 WBTPacketBitmap *pkt_bmp = &work->peer_param[aid].pkt_bmp; in WBTi_SwitchNextCommand()
394 current->get.pkt_bmp_table.packet_bitmap[aid], in WBTi_SwitchNextCommand()
395 current->get.recv_buf_table.recv_buf[aid], in WBTi_SwitchNextCommand()
430 static void WBTi_NotifySystemCallback(WBTContext * work, WBTCommandType event, int aid, in WBTi_NotifySystemCallback() argument
434 WBTRecvToken *peer = &work->peer_param[aid].recv_token; in WBTi_NotifySystemCallback()
460 cmd->peer_bmp = (u16)(1 << aid); in WBTi_NotifySystemCallback()
504 int WBTi_TryCreateResponse(WBTContext * work, int aid, void *buf, int size, int command, in WBTi_TryCreateResponse() argument
508 WBTRecvToken *token = &work->peer_param[aid].recv_token; in WBTi_TryCreateResponse()
513 WBTPacketFormat *format = WBTi_MakeCommandHeader(buf, WBT_CMD_RES_SYNC, (1 << aid), in WBTi_TryCreateResponse()
526 WBTi_MakeCommandHeader(buf, WBT_CMD_RES_GET_BLOCK_DONE, (1 << aid), in WBTi_TryCreateResponse()
531 WBT_DEBUG_OUTPUT1("send BlockDone to %d id = %d\n", aid, id); in WBTi_TryCreateResponse()
535 WBTPacketFormat *format = WBTi_MakeCommandHeader(buf, WBT_CMD_RES_USER_DATA, (1 << aid), in WBTi_TryCreateResponse()
610 WBT_DEBUG_OUTPUT1("send BlockData to %d id = %d seq no = %d pktsize %d\n", aid, in WBTi_TryCreateResponse()
622 WBTi_NotifySystemCallback(work, WBT_CMD_PREPARE_SEND_DATA, aid, in WBTi_TryCreateResponse()
659 WBT_DEBUG_OUTPUT1("send BlockData to %d id = %d seq no = %d pktsize %d\n", aid, id, index, in WBTi_TryCreateResponse()
685 work->req_bitmap &= ~(1 << aid); in WBTi_TryCreateResponse()
726 int aid; in WBTi_CheckRequest() local
727 for (aid = 0; aid < 16; ++aid) in WBTi_CheckRequest()
730 if ((current->target_bmp & (1 << aid)) != 0) in WBTi_CheckRequest()
732 WBTPacketBitmap *pkt_bmp = &work->peer_param[aid].pkt_bmp; in WBTi_CheckRequest()
739 (1 << aid), current->my_cmd_counter); in WBTi_CheckRequest()
743 WBT_DEBUG_OUTPUT0("send ReqBlockDone to %d 0x%04x\n", aid, (1 << aid)); in WBTi_CheckRequest()
809 int aid = WBTi_GetFirstIterationAID(work); in WBTi_CheckBlockResponse() local
812 aid = WBTi_GetNextIterationAID(aid, mask); in WBTi_CheckBlockResponse()
813 if ((work->req_bitmap & (1 << aid)) != 0) in WBTi_CheckBlockResponse()
815 WBTRecvToken *token = &work->peer_param[aid].recv_token; in WBTi_CheckBlockResponse()
829 WBTi_TryCreateResponse(work, aid, buffer, length, WBT_CMD_REQ_GET_BLOCK, in WBTi_CheckBlockResponse()
834 work->last_target_aid = aid; in WBTi_CheckBlockResponse()
838 while (aid != work->last_target_aid); in WBTi_CheckBlockResponse()
843 int aid = WBTi_GetFirstIterationAID(work); in WBTi_CheckBlockResponse() local
846 aid = WBTi_GetNextIterationAID(aid, mask); in WBTi_CheckBlockResponse()
847 if ((work->req_bitmap & (1 << aid)) != 0) in WBTi_CheckBlockResponse()
849 WBTRecvToken *token = &work->peer_param[aid].recv_token; in WBTi_CheckBlockResponse()
853 WBTi_TryCreateResponse(work, aid, buffer, length, WBT_CMD_REQ_GET_BLOCKINFO, in WBTi_CheckBlockResponse()
858 work->last_target_aid = aid; in WBTi_CheckBlockResponse()
862 while (aid != work->last_target_aid); in WBTi_CheckBlockResponse()
913 int aid = WBTi_GetFirstIterationAID(work); in WBT_CallPacketSendHook() local
916 aid = WBTi_GetNextIterationAID(aid, mask); in WBT_CallPacketSendHook()
917 if ((mask & (1 << aid)) != 0) in WBT_CallPacketSendHook()
926 WBTRecvToken *token = &work->peer_param[aid].recv_token; in WBT_CallPacketSendHook()
934 WBTi_TryCreateResponse(work, aid, buffer, length, tbl[i], FALSE); in WBT_CallPacketSendHook()
939 work->last_target_aid = aid; in WBT_CallPacketSendHook()
943 while (aid != work->last_target_aid); in WBT_CallPacketSendHook()
1017 static void WBTi_NotifyCompletionCallback(WBTContext * work, WBTCommandType event, int aid) in WBTi_NotifyCompletionCallback() argument
1021 WBTRecvToken *token = &work->peer_param[aid].recv_token; in WBTi_NotifyCompletionCallback()
1025 int peer_bmp = (1 << aid); in WBTi_NotifyCompletionCallback()
1068 void WBT_CallPacketRecvHook(WBTContext * work, int aid, const void *buffer, int length) in WBT_CallPacketRecvHook() argument
1070 WBTRecvToken *token = &work->peer_param[aid].recv_token; in WBT_CallPacketRecvHook()
1073 work->req_bitmap &= ~(1 << aid); in WBT_CallPacketRecvHook()
1122 work->req_bitmap |= (1 << aid); in WBT_CallPacketRecvHook()
1134 work->req_bitmap |= (1 << aid); in WBT_CallPacketRecvHook()
1142 work->req_bitmap |= (1 << aid); in WBT_CallPacketRecvHook()
1143 … WBT_DEBUG_OUTPUT1("get req Block from %d id = %d seq no = %d\n", aid, token->token_block_id, in WBT_CallPacketRecvHook()
1154 work->req_bitmap |= (1 << aid); in WBT_CallPacketRecvHook()
1196 WBT_DEBUG_OUTPUT0("Get res Sync from %d my %d peer %d\n", aid, in WBT_CallPacketRecvHook()
1199 WBTi_NotifyCompletionCallback(work, (WBTCommandType)command, aid); in WBT_CallPacketRecvHook()
1207 WBTi_NotifyCompletionCallback(work, (WBTCommandType)command, aid); in WBT_CallPacketRecvHook()
1224 if ((current->target_bmp & (1 << aid)) != 0) in WBT_CallPacketRecvHook()
1227 WBTPacketBitmap *pkt_bmp = &work->peer_param[aid].pkt_bmp; in WBT_CallPacketRecvHook()
1234 WBTi_NotifySystemCallback(work, WBT_CMD_RES_ERROR, aid, in WBT_CallPacketRecvHook()
1269 WBT_CMD_RES_GET_BLOCKINFO, aid); in WBT_CallPacketRecvHook()
1280 WBTi_NotifySystemCallback(work, WBT_CMD_RES_ERROR, aid, in WBT_CallPacketRecvHook()
1287 if ((work->req_bitmap & (1 << aid)) != 0) in WBT_CallPacketRecvHook()
1292 WBTi_NotifySystemCallback(work, (WBTCommandType)command, aid, WBT_RESULT_SUCCESS); in WBT_CallPacketRecvHook()
1430 int aid; in WBT_CancelCommand() local
1433 for (aid = 0;; ++aid) in WBT_CancelCommand()
1435 int bit = (1 << aid); in WBT_CancelCommand()
1506 void WBT_GetDownloadProgress(const WBTContext *work, u32 id, int aid, int *count, int *total) in WBT_GetDownloadProgress() argument
1512 const WBTPacketBitmap *pkt_bmp = &work->peer_param[aid].pkt_bmp; in WBT_GetDownloadProgress()