Cross Reference: /illumos-gate/usr/src/cmd/lms/LMEConnection.cpp

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