network/stack/net_socket.cpp

268 	net_buffer* buffer, msghdr* messageHeader)
282 		socket->first_protocol, buffer, dataBuffer,
512 socket_send_data(net_socket* socket, net_buffer* buffer)
515 		buffer);
986 		struct sockaddr buffer;
987 		memset(&buffer, 0, sizeof(buffer));
988 		buffer.sa_family = socket->family;
990 		memcpy(address, &buffer, min_c(*_addressLength, sizeof(buffer)));
991 		*_addressLength = sizeof(buffer);
1163 	net_buffer* buffer;
1165 		socket->first_protocol, totalLength, flags, &buffer);
1171 		if (buffer != NULL && header->msg_control != NULL) {
1173 				= gNetBufferModule.get_ancillary_data(buffer);
1177 				status = process_ancillary_data(socket, buffer, header);
1179 				gNetBufferModule.free(buffer);
1186 	// TODO: - returning a NULL buffer when received 0 bytes
1191 		// TODO: - consider the control buffer options
1197 	if (buffer == NULL)
1200 	const size_t bytesReceived = buffer->size;
1204 	status = gNetBufferModule.read(buffer, 0, data, toRead);
1206 		gNetBufferModule.free(buffer);
1221 			if (gNetBufferModule.read(buffer, bytesCopied, vec.iov_base,
1230 			header->msg_namelen = min_c(nameLen, buffer->source->sa_len);
1231 			memcpy(header->msg_name, buffer->source, header->msg_namelen);
1235 	gNetBufferModule.free(buffer);
1352 		net_buffer* buffer = gNetBufferModule.create(256);
1353 		if (buffer == NULL)
1356 		while (buffer->size < socket->send.buffer_size
1357 			&& buffer->size < bytesLeft) {
1359 				// retrieve next iovec buffer from header
1365 			if (buffer->size + bytes > socket->send.buffer_size)
1366 				bytes = socket->send.buffer_size - buffer->size;
1368 			if (gNetBufferModule.append(buffer, data, bytes) < B_OK) {
1369 				gNetBufferModule.free(buffer);
1379 				// proceed with next buffer, if any
1388 		// attach ancillary data to the first buffer
1391 			gNetBufferModule.set_ancillary_data(buffer, ancillaryData);
1396 		size_t bufferSize = buffer->size;
1397 		buffer->flags = flags;
1398 		memcpy(buffer->source, &socket->address, socket->address.ss_len);
1399 		memcpy(buffer->destination, address, addressLength);
1400 		buffer->destination->sa_len = addressLength;
1402 		status = socket->first_info->send_data(socket->first_protocol, buffer);
1408 			size_t sizeAfterSend = buffer->size;
1409 			gNetBufferModule.free(buffer);