network/tcp_shell/tcp_shell.cpp

129 tcp_segment_flags(net_buffer* buffer)
131 	NetBufferHeaderReader<tcp_header> bufferHeader(buffer);
141 is_syn(net_buffer* buffer)
143 	return (tcp_segment_flags(buffer) & TCP_FLAG_SYNCHRONIZE) != 0;
148 is_fin(net_buffer* buffer)
150 	return (tcp_segment_flags(buffer) & TCP_FLAG_FINISH) != 0;
428 	net_buffer *buffer = gNetBufferModule.create(256);
429 	if (buffer == NULL)
432 	// copy data into buffer
433 	if (gNetBufferModule.append(buffer, data, length) < B_OK) {
434 		gNetBufferModule.free(buffer);
438 	buffer->flags = flags;
439 	memcpy(buffer->source, &socket->address, socket->address.ss_len);
440 	memcpy(buffer->destination, &socket->peer, socket->peer.ss_len);
442 	status_t status = socket->first_info->send_data(socket->first_protocol, buffer);
444 		gNetBufferModule.free(buffer);
455 	net_buffer *buffer;
457 		socket->first_protocol, length, flags, &buffer);
461 	// if 0 bytes we're received, no buffer will be created
462 	if (buffer == NULL)
465 	ssize_t bytesReceived = buffer->size;
466 	gNetBufferModule.read(buffer, 0, data, bytesReceived);
467 	gNetBufferModule.free(buffer);
738 datalink_send_data(struct net_route *route, net_buffer *buffer)
742 	buffer->interface_address = &gInterfaceAddress;
745 	list_add_item(&context->list, buffer);
755 	net_buffer *buffer)
895 domain_send_data(net_protocol *protocol, net_buffer *buffer)
898 	struct net_route *route = get_route(&sDomain, (sockaddr *)&buffer->destination);
902 	return datalink_send_data(route, buffer);
908 	net_buffer *buffer)
910 	return datalink_send_data(route, buffer);
952 domain_receive_data(net_buffer *buffer)
972 		sPacketMonitor(buffer, packetNumber, drop);
977 		gNetBufferModule.free(buffer);
981 	return gTCPModule->receive_data(buffer);
1042 dump_printf(net_buffer* buffer, int32 packetNumber, bool willBeDropped)
1046 	NetBufferHeaderReader<tcp_header> bufferHeader(buffer);
1060 	if (is_server((sockaddr *)buffer->source))
1065 	int32 length = buffer->size - header.HeaderLength();
1090 		if (gBufferModule->direct_access(buffer, sizeof(tcp_header),
1097 			gBufferModule->read(buffer, sizeof(tcp_header), optionsBuffer, size);
1140 dump_pcap(net_buffer* buffer, int32 packetNumber, bool willBeDropped)
1152 	pcap_header.included_len = sizeof(struct ip) + buffer->size;
1159 	ip_header.ip_len = htons(sizeof(struct ip) + buffer->size);
1165 	ip_header.ip_src.s_addr = ((sockaddr_in*)buffer->source)->sin_addr.s_addr;
1166 	ip_header.ip_dst.s_addr = ((sockaddr_in*)buffer->destination)->sin_addr.s_addr;
1179 	used += gNetBufferModule.get_iovecs(buffer, vecs + used, count - used);
1240 			net_buffer* buffer = (net_buffer*)list_remove_head_item(
1244 			if (buffer == NULL)
1247 			if (sSimultaneousConnect && context->server && is_syn(buffer)) {
1262 			if (sSimultaneousClose && !context->server && is_fin(buffer)) {
1270 				reorderBuffer = buffer;
1272 				if (sDomain.module->receive_data(buffer) < B_OK)
1273 					gNetBufferModule.free(buffer);
1305 		char buffer[1024];
1307 		while ((bytesRead = socket_recv(connectionSocket, buffer,
1308 				sizeof(buffer), 0)) > 0) {
1485 	char *buffer = (char *)malloc(size);
1486 	if (buffer == NULL) {
1490 	MemoryDeleter bufferDeleter(buffer);
1492 	// initialize buffer with some not so random data
1494 		buffer[i] = (char)(i & 0xff);
1497 	ssize_t bytesWritten = socket_send(gClientSocket, buffer, size, 0);
1499 		fprintf(stderr, "failed sending buffer: %s\n", strerror(bytesWritten));
1517 	char *buffer = (char *)malloc(bufferSize);
1518 	if (buffer == NULL) {
1522 	MemoryDeleter bufferDeleter(buffer);
1524 	// initialize buffer with some not so random data
1526 		buffer[i] = (char)(i & 0xff);
1530 		ssize_t bytesWritten = socket_send(gClientSocket, buffer, bufferSize, 0);
1532 			fprintf(stderr, "failed sending buffer (after %" B_PRIdSSIZE "): %s\n",
1559 	char buffer[32767] = {'q'};
1560 	ssize_t bytesWritten = socket_send(gClientSocket, buffer, sizeof(buffer), 0);
1562 		fprintf(stderr, "failed sending buffer: %s\n", strerror(bytesWritten));