Lines Matching refs:pCurrent
177 unsigned char *pCurrent = buf; in ServiceAccept() local
178 *pCurrent = APF_SERVICE_ACCEPT; in ServiceAccept()
179 ++pCurrent; in ServiceAccept()
180 *((UINT32 *)pCurrent) = htonl(serviceName.size()); in ServiceAccept()
181 pCurrent += 4; in ServiceAccept()
183 memcpy(pCurrent, serviceName.c_str(), serviceName.size()); in ServiceAccept()
184 pCurrent += serviceName.size(); in ServiceAccept()
187 int len = pCurrent - buf; in ServiceAccept()
306 unsigned char *pCurrent = buf; in ChannelOpenForwardedRequest() local
312 *pCurrent = APF_CHANNEL_OPEN; in ChannelOpenForwardedRequest()
313 ++pCurrent; in ChannelOpenForwardedRequest()
315 *((UINT32 *)pCurrent) = htonl(APF_STR_SIZE_OF(APF_OPEN_CHANNEL_REQUEST_FORWARDED)); in ChannelOpenForwardedRequest()
316 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
318 …memcpy(pCurrent, APF_OPEN_CHANNEL_REQUEST_FORWARDED, APF_STR_SIZE_OF(APF_OPEN_CHANNEL_REQUEST_FORW… in ChannelOpenForwardedRequest()
319 pCurrent += APF_STR_SIZE_OF(APF_OPEN_CHANNEL_REQUEST_FORWARDED); in ChannelOpenForwardedRequest()
321 *((UINT32 *)pCurrent) = htonl(senderChannel); in ChannelOpenForwardedRequest()
322 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
324 *((UINT32 *)pCurrent) = htonl(RX_WINDOW_SIZE); in ChannelOpenForwardedRequest()
325 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
327 *((UINT32 *)pCurrent) = 0xFFFFFFFF; in ChannelOpenForwardedRequest()
328 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
330 *((UINT32 *)pCurrent) = htonl(APF_STR_SIZE_OF("127.0.0.1")); in ChannelOpenForwardedRequest()
331 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
333 memcpy(pCurrent, "127.0.0.1", APF_STR_SIZE_OF("127.0.0.1")); in ChannelOpenForwardedRequest()
334 pCurrent += APF_STR_SIZE_OF("127.0.0.1"); in ChannelOpenForwardedRequest()
336 *((UINT32 *)pCurrent) = htonl(connectedPort); in ChannelOpenForwardedRequest()
337 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
339 *((UINT32 *)pCurrent) = htonl((UINT32)originatorIP.size()); in ChannelOpenForwardedRequest()
340 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
342 memcpy(pCurrent, originatorIP.c_str(), originatorIP.size()); in ChannelOpenForwardedRequest()
343 pCurrent += originatorIP.size(); in ChannelOpenForwardedRequest()
345 *((UINT32 *)pCurrent) = htonl(originatorPort); in ChannelOpenForwardedRequest()
346 pCurrent += sizeof(UINT32); in ChannelOpenForwardedRequest()
350 int res = _sendMessage(buf, (int)(pCurrent - buf)); in ChannelOpenForwardedRequest()
352 return (res == pCurrent - buf); in ChannelOpenForwardedRequest()
781 unsigned char *pCurrent; in _apfChannelOpenDirect() local
792 pCurrent = rxBuffer + sizeof(APF_GENERIC_HEADER) + in _apfChannelOpenDirect()
798 channelOpenRequest.SenderChannel = ntohl(*((UINT32 *)pCurrent)); in _apfChannelOpenDirect()
802 pCurrent += sizeof(UINT32); in _apfChannelOpenDirect()
803 channelOpenRequest.InitialWindow = ntohl(*((UINT32 *)pCurrent)); in _apfChannelOpenDirect()
804 pCurrent += 2 * sizeof(UINT32); in _apfChannelOpenDirect()
806 UINT32 len = ntohl(*((UINT32 *)pCurrent)); in _apfChannelOpenDirect()
807 pCurrent += sizeof(UINT32); in _apfChannelOpenDirect()
808 channelOpenRequest.Address.append((char *)pCurrent, len); in _apfChannelOpenDirect()
809 pCurrent += len; in _apfChannelOpenDirect()
810 channelOpenRequest.Port = ntohl(*((UINT32 *)pCurrent)); in _apfChannelOpenDirect()
811 pCurrent += sizeof(UINT32); in _apfChannelOpenDirect()
818 unsigned char *pCurrent; in _apfGlobalRequest() local
828 pCurrent = rxBuffer + hsize; in _apfGlobalRequest()
837 UINT32 len = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
838 pCurrent += sizeof(UINT32); in _apfGlobalRequest()
846 tcpForwardRequest.Address.append((char *)pCurrent, len); in _apfGlobalRequest()
847 pCurrent += len; in _apfGlobalRequest()
848 tcpForwardRequest.Port = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
859 pCurrent = rxBuffer + hsize; in _apfGlobalRequest()
868 UINT32 len = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
869 pCurrent += sizeof(UINT32); in _apfGlobalRequest()
877 tcpForwardCancelRequest.Address.append((char *)pCurrent, len); in _apfGlobalRequest()
878 pCurrent += len; in _apfGlobalRequest()
879 tcpForwardCancelRequest.Port = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
889 pCurrent = rxBuffer + hsize; in _apfGlobalRequest()
898 UINT32 len = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
899 pCurrent += sizeof(UINT32); in _apfGlobalRequest()
909 address.append((char *)pCurrent, len); in _apfGlobalRequest()
910 pCurrent += len; in _apfGlobalRequest()
911 UINT32 port = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
912 pCurrent += sizeof(UINT32); in _apfGlobalRequest()
921 len = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
922 pCurrent += sizeof(UINT32); in _apfGlobalRequest()
931 pCurrent += len; in _apfGlobalRequest()
932 pCurrent += sizeof(UINT32); in _apfGlobalRequest()
941 len = ntohl(*((UINT32 *)pCurrent)); in _apfGlobalRequest()
942 pCurrent += sizeof(UINT32); in _apfGlobalRequest()
950 LMEUdpSendToMessage udpSendTo(address, port, len, pCurrent); in _apfGlobalRequest()
958 unsigned char *pCurrent = rxBuffer; in _apfUserAuthRequest() local
960 ++pCurrent; in _apfUserAuthRequest()
964 UINT32 len = ntohl(*((UINT32 *)pCurrent)); in _apfUserAuthRequest()
965 pCurrent += sizeof(UINT32); in _apfUserAuthRequest()
967 if ((bytesRead - (pCurrent - rxBuffer)) < len) { in _apfUserAuthRequest()
973 userAuthRequest.Username.append((char *)pCurrent, len); in _apfUserAuthRequest()
974 pCurrent += len; in _apfUserAuthRequest()
976 if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32)) { in _apfUserAuthRequest()
982 len = ntohl(*((UINT32 *)pCurrent)); in _apfUserAuthRequest()
983 pCurrent += sizeof(UINT32); in _apfUserAuthRequest()
985 if ((bytesRead - (pCurrent - rxBuffer)) < len) { in _apfUserAuthRequest()
991 userAuthRequest.ServiceName.append((char *)pCurrent, len); in _apfUserAuthRequest()
992 pCurrent += len; in _apfUserAuthRequest()
994 if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32)) { in _apfUserAuthRequest()
1000 len = ntohl(*((UINT32 *)pCurrent)); in _apfUserAuthRequest()
1001 pCurrent += sizeof(UINT32); in _apfUserAuthRequest()
1003 if ((bytesRead - (pCurrent - rxBuffer)) < len) { in _apfUserAuthRequest()
1009 userAuthRequest.MethodName.append((char *)pCurrent, len); in _apfUserAuthRequest()
1010 pCurrent += len; in _apfUserAuthRequest()
1015 if ((unsigned int)(bytesRead - (pCurrent - rxBuffer)) < sizeof(UINT32) + 1) { in _apfUserAuthRequest()
1021 ++pCurrent; in _apfUserAuthRequest()
1023 len = ntohl(*((UINT32 *)pCurrent)); in _apfUserAuthRequest()
1024 pCurrent += sizeof(UINT32); in _apfUserAuthRequest()
1026 if ((bytesRead - (pCurrent - rxBuffer)) < len) { in _apfUserAuthRequest()
1033 authData.Password.append((char *)pCurrent, len); in _apfUserAuthRequest()
1034 pCurrent += len; in _apfUserAuthRequest()