kits/app/Message.cpp

46 		find_thread(NULL), this, fHeader, fFields, fData, what, (char*)&what, \
167 		fHeader->what = _what;
197 	fHeader = (message_header*)malloc(sizeof(message_header));
198 	if (fHeader == NULL)
201 	if (other.fHeader == NULL)
204 	memcpy(fHeader, other.fHeader, sizeof(message_header));
208 	fHeader->flags &= ~(MESSAGE_FLAG_REPLY_REQUIRED | MESSAGE_FLAG_REPLY_DONE
213 	if (fHeader->field_count > 0) {
214 		size_t fieldsSize = fHeader->field_count * sizeof(field_header);
219 			fHeader->field_count = 0;
220 			fHeader->data_size = 0;
225 	if (fHeader->data_size > 0) {
227 			fData = (uint8*)malloc(fHeader->data_size);
230 			fHeader->field_count = 0;
234 			memcpy(fData, other.fData, fHeader->data_size);
237 	fHeader->what = what = other.what;
238 	fHeader->message_area = -1;
287 	if (fHeader == NULL)
288 		return other.fHeader == NULL;
290 	if (fHeader->field_count != other.fHeader->field_count)
293 	for (uint32 i = 0; i < fHeader->field_count; i++) {
350 	fHeader = NULL;
373 	if (fHeader == NULL) {
374 		fHeader = (message_header*)malloc(sizeof(message_header));
375 		if (fHeader == NULL)
379 	memset(fHeader, 0, sizeof(message_header) - sizeof(fHeader->hash_table));
381 	fHeader->format = MESSAGE_FORMAT_HAIKU;
382 	fHeader->flags = MESSAGE_FLAG_VALID;
383 	fHeader->what = what;
384 	fHeader->current_specifier = -1;
385 	fHeader->message_area = -1;
387 	fHeader->target = B_NULL_TOKEN;
388 	fHeader->reply_target = B_NULL_TOKEN;
389 	fHeader->reply_port = -1;
390 	fHeader->reply_team = -1;
393 	fHeader->hash_table_size = MESSAGE_BODY_HASH_TABLE_SIZE;
394 	memset(&fHeader->hash_table, 255, sizeof(fHeader->hash_table));
403 	if (fHeader != NULL) {
410 		if (fHeader->message_area >= 0)
413 		free(fHeader);
414 		fHeader = NULL;
439 	if (fHeader == NULL)
442 	if (index < 0 || (uint32)index >= fHeader->field_count)
457 	for (uint32 i = 0; i < fHeader->field_count; i++, field++) {
545 	if (fHeader == NULL)
549 		return fHeader->field_count;
553 	for (uint32 i = 0; i < fHeader->field_count; i++, field++) {
566 	return fHeader == NULL || fHeader->field_count == 0;
596 	return fHeader != NULL && (fHeader->flags & MESSAGE_FLAG_IS_REPLY) != 0;
621 	if (fHeader == NULL || fFields == NULL || fData == NULL)
625 	for (uint32 i = 0; i < fHeader->field_count; i++, field++) {
777 	if (fHeader == NULL)
781 	if (fHeader->message_area >= 0) {
787 	uint32 hash = _HashName(oldEntry) % fHeader->hash_table_size;
788 	int32* nextField = &fHeader->hash_table[hash];
800 			hash = _HashName(newEntry) % fHeader->hash_table_size;
801 			nextField = &fHeader->hash_table[hash];
828 	return fHeader != NULL
829 		&& (fHeader->flags & MESSAGE_FLAG_WAS_DELIVERED) != 0;
837 	return fHeader != NULL
838 		&& (fHeader->flags & MESSAGE_FLAG_REPLY_REQUIRED) != 0
839 		&& (fHeader->flags & MESSAGE_FLAG_REPLY_DONE) == 0;
847 	return fHeader != NULL
848 		&& (fHeader->flags & MESSAGE_FLAG_WAS_DELIVERED) != 0
849 		&& fHeader->reply_team != BPrivate::current_team();
857 	if (fHeader == NULL || (fHeader->flags & MESSAGE_FLAG_WAS_DELIVERED) == 0)
861 	BMessenger::Private(messenger).SetTo(fHeader->reply_team,
862 		fHeader->reply_port, fHeader->reply_target);
889 	return fHeader != NULL
890 		&& (fHeader->flags & MESSAGE_FLAG_WAS_DROPPED) != 0;
927 	if (fHeader == NULL)
932 	messengerPrivate.SetTo(fHeader->reply_team, fHeader->reply_port,
933 		fHeader->reply_target);
934 	if ((fHeader->flags & MESSAGE_FLAG_REPLY_AS_KMESSAGE) != 0)
935 		reply->fHeader->flags |= MESSAGE_FLAG_REPLY_AS_KMESSAGE;
937 	if ((fHeader->flags & MESSAGE_FLAG_REPLY_REQUIRED) != 0) {
938 		if ((fHeader->flags & MESSAGE_FLAG_REPLY_DONE) != 0)
941 		fHeader->flags |= MESSAGE_FLAG_REPLY_DONE;
942 		reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY;
944 		reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
955 	if ((fHeader->flags & MESSAGE_FLAG_WAS_DELIVERED) == 0)
959 	reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY;
961 	reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
981 	if (fHeader == NULL)
986 	messengerPrivate.SetTo(fHeader->reply_team, fHeader->reply_port,
987 		fHeader->reply_target);
989 	if ((fHeader->flags & MESSAGE_FLAG_REPLY_REQUIRED) != 0) {
990 		if ((fHeader->flags & MESSAGE_FLAG_REPLY_DONE) != 0)
993 		fHeader->flags |= MESSAGE_FLAG_REPLY_DONE;
994 		reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY;
997 		reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
1010 	if ((fHeader->flags & MESSAGE_FLAG_WAS_DELIVERED) == 0)
1014 	reply->fHeader->flags |= MESSAGE_FLAG_IS_REPLY
1015 		| (fHeader->flags & MESSAGE_FLAG_REPLY_AS_KMESSAGE);
1018 	reply->fHeader->flags &= ~MESSAGE_FLAG_IS_REPLY;
1028 	if (fHeader == NULL)
1031 	return sizeof(message_header) + fHeader->field_count * sizeof(field_header)
1032 		+ fHeader->data_size;
1043 	if (fHeader == NULL)
1050 	fHeader->what = what;
1052 	memcpy(buffer, fHeader, sizeof(message_header));
1055 	size_t fieldsSize = fHeader->field_count * sizeof(field_header);
1059 	memcpy(buffer, fData, fHeader->data_size);
1072 	if (fHeader == NULL)
1076 	fHeader->what = what;
1078 	ssize_t result1 = stream->Write(fHeader, sizeof(message_header));
1083 	if (fHeader->field_count > 0) {
1084 		ssize_t fieldsSize = fHeader->field_count * sizeof(field_header);
1091 	if (fHeader->data_size > 0) {
1092 		result3 = stream->Write(fData, fHeader->data_size);
1093 		if (result3 != (ssize_t)fHeader->data_size)
1137 	if (fHeader == NULL)
1144 	memcpy(header, fHeader, sizeof(message_header));
1167 	memcpy(address + fieldsSize, fData, fHeader->data_size);
1178 	if (fHeader == NULL)
1181 	fHeader->flags &= ~MESSAGE_FLAG_PASS_BY_AREA;
1184 	if (fHeader->field_count == 0 && fHeader->data_size == 0)
1188 	status_t result = get_area_info(fHeader->message_area, &areaInfo);
1195 	set_area_protection(fHeader->message_area, B_READ_AREA);
1200 	fData = address + fHeader->field_count * sizeof(field_header);
1209 	if (fHeader == NULL)
1212 	delete_area(fHeader->message_area);
1213 	fHeader->message_area = -1;
1224 	if (fHeader == NULL)
1230 	if (fHeader->field_count > 0) {
1231 		size_t fieldsSize = fHeader->field_count * sizeof(field_header);
1239 	if (fHeader->data_size > 0) {
1240 		newData = (uint8*)malloc(fHeader->data_size);
1246 		memcpy(newData, fData, fHeader->data_size);
1264 	if (fHeader == NULL)
1267 	if (fHeader->field_count == 0)
1273 	for (uint32 i = 0; i < fHeader->field_count; i++) {
1276 				&& (uint32)field->next_field > fHeader->field_count)
1278 				> fHeader->data_size)) {
1321 	fHeader = (message_header*)malloc(sizeof(message_header));
1322 	if (fHeader == NULL)
1325 	fHeader->format = format;
1326 	uint8* header = (uint8*)fHeader;
1330 		|| (fHeader->flags & MESSAGE_FLAG_VALID) == 0) {
1335 	what = fHeader->what;
1337 	if ((fHeader->flags & MESSAGE_FLAG_PASS_BY_AREA) != 0
1338 		&& fHeader->message_area >= 0) {
1345 		fHeader->message_area = -1;
1347 		if (fHeader->field_count > 0) {
1348 			ssize_t fieldsSize = fHeader->field_count * sizeof(field_header);
1360 		if (fHeader->data_size > 0) {
1361 			fData = (uint8*)malloc(fHeader->data_size);
1369 			result = stream->Read(fData, fHeader->data_size);
1370 			if (result != (ssize_t)fHeader->data_size)
1458 	fHeader->current_specifier++;
1459 	fHeader->flags |= MESSAGE_FLAG_HAS_SPECIFIERS;
1480 	fHeader->current_specifier = index;
1490 	if (fHeader == NULL)
1494 		*index = fHeader->current_specifier;
1496 	if (fHeader->current_specifier < 0
1497 		|| (fHeader->flags & MESSAGE_FLAG_WAS_DELIVERED) == 0)
1501 		if (FindMessage(B_SPECIFIER_ENTRY, fHeader->current_specifier,
1522 	return fHeader != NULL
1523 		&& (fHeader->flags & MESSAGE_FLAG_HAS_SPECIFIERS) != 0;
1531 	if (fHeader == NULL)
1534 	if (fHeader->current_specifier < 0 ||
1535 		(fHeader->flags & MESSAGE_FLAG_WAS_DELIVERED) == 0)
1538 	if (fHeader->current_specifier >= 0)
1539 		fHeader->current_specifier--;
1549 	if (offset < fHeader->data_size) {
1551 		for (uint32 i = 0; i < fHeader->field_count; i++, field++) {
1573 			if (offset < fHeader->data_size) {
1575 					fHeader->data_size - offset);
1581 			fHeader->data_size += change;
1587 		size_t size = fHeader->data_size * 2;
1588 		size = min_c(size, fHeader->data_size + MAX_DATA_PREALLOCATION);
1589 		size = max_c(size, fHeader->data_size + change);
1596 		if (offset < fHeader->data_size) {
1598 				fHeader->data_size - offset);
1601 		fHeader->data_size += change;
1602 		fDataAvailable = size - fHeader->data_size;
1604 		ssize_t length = fHeader->data_size - offset + change;
1609 		fHeader->data_size += change;
1614 			ssize_t size = fHeader->data_size + available;
1655 	if (fHeader == NULL)
1658 	if (fHeader->field_count == 0 || fFields == NULL || fData == NULL)
1661 	uint32 hash = _HashName(name) % fHeader->hash_table_size;
1662 	int32 nextField = fHeader->hash_table[hash];
1689 	if (fHeader == NULL)
1693 		uint32 count = fHeader->field_count * 2 + 1;
1694 		count = min_c(count, fHeader->field_count + MAX_FIELD_PREALLOCATION);
1702 		fFieldsAvailable = count - fHeader->field_count;
1705 	uint32 hash = _HashName(name) % fHeader->hash_table_size;
1706 	int32* nextField = &fHeader->hash_table[hash];
1709 	*nextField = fHeader->field_count;
1711 	field_header* field = &fFields[fHeader->field_count];
1716 	field->offset = fHeader->data_size;
1728 	fHeader->field_count++;
1747 	int32* value = fHeader->hash_table;
1748 	for (uint32 i = 0; i < fHeader->hash_table_size; i++, value++) {
1756 	for (uint32 i = 0; i < fHeader->field_count; i++, other++) {
1763 	size_t size = (fHeader->field_count - index - 1) * sizeof(field_header);
1765 	fHeader->field_count--;
1770 		size = (fHeader->field_count + available) * sizeof(field_header);
1796 	if (fHeader == NULL)
1800 	if (fHeader->message_area >= 0) {
1861 	if (fHeader == NULL)
1865 	if (fHeader->message_area >= 0) {
1914 	if (fHeader == NULL)
1918 	if (fHeader->message_area >= 0) {
1987 	if (fHeader->message_area >= 0) {
2146 			header = copy->fHeader;
2147 			header->flags = fHeader->flags;
2153 	} else if ((fHeader->flags & MESSAGE_FLAG_REPLY_AS_KMESSAGE) != 0) {
2160 	} else if (fHeader->data_size > B_PAGE_SIZE * 10) {
2210 		BMessenger::Private(replyTo).SetTo(fHeader->reply_team,
2211 			fHeader->reply_port, fHeader->reply_target);
2244 		fHeader->flags |= MESSAGE_FLAG_REPLY_DONE;
2811 	for (uint32 i = 0; i < other.fHeader->field_count; i++, field++) {