datalink_protocols/arp/arp.cpp

163 	static char buffer[20];
164 	snprintf(buffer, sizeof(buffer), "%02x:%02x:%02x:%02x:%02x:%02x",
166 	return buffer;
173 	static char buffer[20];
176 	snprintf(buffer, sizeof(buffer), "%d.%d.%d.%d",
179 	return buffer;
189 	net_buffer* buffer = entry->request_buffer;
190 	if (buffer == NULL || buffer == kDeletedBuffer)
193 	buffer = atomic_pointer_test_and_set(&entry->request_buffer,
194 		(net_buffer*)NULL, buffer);
195 	if (buffer == kDeletedBuffer)
198 	return buffer;
203 put_request_buffer(arp_entry* entry, net_buffer* buffer)
206 		&entry->request_buffer, buffer, (net_buffer*)NULL);
208 		// someone else took over ownership of the request buffer
209 		gBufferModule->free(buffer);
217 	net_buffer* buffer = atomic_pointer_get_and_set(&entry->request_buffer,
219 	if (buffer != NULL && buffer != kDeletedBuffer)
220 		gBufferModule->free(buffer);
315 		net_buffer *buffer = iterator.Next();
317 		gBufferModule->free(buffer);
342 		net_buffer *buffer = iterator.Next();
345 		TRACE(("  ARP Dequeing packet %p...\n", buffer));
347 		memcpy(buffer->destination, &hardware_address,
349 		protocol->next->module->send_data(protocol->next, buffer);
569 handle_arp_request(net_buffer *buffer, arp_header &header)
575 			(sockaddr_dl *)buffer->source, 0);
591 	// send a reply (by reusing the buffer we got)
603 	memcpy(LLADDR((sockaddr_dl *)buffer->source), header.hardware_sender,
605 	memcpy(LLADDR((sockaddr_dl *)buffer->destination), header.hardware_target,
608 	buffer->flags = 0;
611 	gBufferModule->trim(buffer, sizeof(arp_header));
613 		buffer);
618 handle_arp_reply(net_buffer *buffer, arp_header &header)
624 	arp_update_entry(header.protocol_sender, (sockaddr_dl *)buffer->source, 0);
629 arp_receive(void *cookie, net_device *device, net_buffer *buffer)
633 	NetBufferHeaderReader<arp_header> bufferHeader(buffer);
662 			if (handle_arp_request(buffer, header) == B_OK) {
663 				// the function will take care of the buffer if everything
670 			handle_arp_reply(buffer, header);
678 	gBufferModule->free(buffer);
737 				// we'll still need our buffer, so in order to prevent it being
837 arp_control(const char *subsystem, uint32 function, void *buffer,
843 	if (user_memcpy(&control, buffer, sizeof(struct arp_control)) < B_OK)
881 			return user_memcpy(buffer, &control, sizeof(struct arp_control));
904 			return user_memcpy(buffer, &control, sizeof(struct arp_control));
1016 arp_send_data(net_datalink_protocol *_protocol, net_buffer *buffer)
1022 		// Set buffer target and destination address
1024 		memcpy(buffer->source, &protocol->hardware_address,
1027 		if ((buffer->flags & MSG_MCAST) != 0) {
1030 				(sockaddr_in *)buffer->destination);
1031 			memcpy(buffer->destination, &multicastDestination,
1033 		} else if ((buffer->flags & MSG_BCAST) == 0) {
1036 				((struct sockaddr_in *)buffer->destination)->sin_addr.s_addr);
1039 					((struct sockaddr_in*)buffer->destination)->sin_addr.s_addr,
1051 					buffer));
1052 				entry->queue.Add(buffer);
1056 			memcpy(buffer->destination, &entry->hardware_address,
1061 	TRACE(("%s(%p): from %s\n", __FUNCTION__, buffer,
1062 		mac_to_string(LLADDR((sockaddr_dl*)buffer->source))));
1064 		mac_to_string(LLADDR((sockaddr_dl*)buffer->destination))));
1066 	return protocol->next->module->send_data(protocol->next, buffer);