protocols/tcp/tcp.cpp

97 add_options(tcp_segment_header &segment, uint8 *buffer, size_t bufferSize)
102 	tcp_option *option = (tcp_option *)buffer;
184 process_options(tcp_segment_header &segment, net_buffer *buffer, size_t size)
192 	if (gBufferModule->direct_access(buffer, sizeof(tcp_header), size,
199 		gBufferModule->read(buffer, sizeof(tcp_header), optionsBuffer, size);
391 /*!	Constructs a TCP header on \a buffer with the specified values
396 	tcp_segment_header& segment, net_buffer* buffer)
398 	buffer->protocol = IPPROTO_TCP;
404 	NetBufferPrepend<tcp_header> bufferHeader(buffer,
411 	header.source_port = addressModule->get_port(buffer->source);
412 	header.destination_port = addressModule->get_port(buffer->destination);
424 	// not have a contiguous buffer.
428 		gBufferModule->write(buffer, sizeof(tcp_header), optionsBuffer,
432 	TRACE(("add_tcp_header(): buffer %p, flags 0x%x, seq %" B_PRIu32 ", ack %" B_PRIu32 ", up %u, "
433 		"win %u\n", buffer, segment.flags, segment.sequence,
436 	*TCPChecksumField(buffer) = Checksum::PseudoHeader(addressModule,
437 		gBufferModule, buffer, IPPROTO_TCP);
628 tcp_send_data(net_protocol* protocol, net_buffer* buffer)
630 	return ((TCPEndpoint*)protocol)->SendData(buffer);
636 	net_buffer* buffer)
680 tcp_receive_data(net_buffer* buffer)
682 	TRACE(("TCP: Received buffer %p\n", buffer));
684 	if (buffer->interface_address == NULL
685 		|| buffer->interface_address->domain == NULL)
688 	net_domain* domain = buffer->interface_address->domain;
691 	NetBufferHeaderReader<tcp_header> bufferHeader(buffer);
701 	if (Checksum::PseudoHeader(addressModule, gBufferModule, buffer,
705 	addressModule->set_port(buffer->source, header.source_port);
706 	addressModule->set_port(buffer->destination, header.destination_port);
709 		AddressString(domain, buffer->source, true).Data(),
710 		AddressString(domain, buffer->destination, true).Data()));
712 	//gBufferModule->dump(buffer);
719 	process_options(segment, buffer, headerLength - sizeof(tcp_header));
733 		buffer->destination, buffer->source);
735 		segmentAction = endpoint->SegmentReceived(segment, buffer);
749 		endpointManager->ReplyWithReset(segment, buffer);
752 		gBufferModule->free(buffer);