1// Protocol Buffers - Google's data interchange format 2// Copyright 2014 Google Inc. All rights reserved. 3// https://developers.google.com/protocol-buffers/ 4// 5// Redistribution and use in source and binary forms, with or without 6// modification, are permitted provided that the following conditions are 7// met: 8// 9// * Redistributions of source code must retain the above copyright 10// notice, this list of conditions and the following disclaimer. 11// * Redistributions in binary form must reproduce the above 12// copyright notice, this list of conditions and the following disclaimer 13// in the documentation and/or other materials provided with the 14// distribution. 15// * Neither the name of Google Inc. nor the names of its 16// contributors may be used to endorse or promote products derived from 17// this software without specific prior written permission. 18// 19// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 20// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 21// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 22// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 23// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 24// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 25// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 26// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 27// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 28// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 29// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 30 31#import "GPBTestUtilities.h" 32 33#import "google/protobuf/Unittest.pbobjc.h" 34#import "google/protobuf/UnittestObjc.pbobjc.h" 35 36static const int kNumThreads = 100; 37static const int kNumMessages = 100; 38 39// NOTE: Most of these tests don't "fail" in the sense that the XCTAsserts 40// trip. Rather, the asserts simply exercise the apis, and if there is 41// a concurancy issue, the NSAsserts in the runtime code fire and/or the 42// code just crashes outright. 43 44@interface ConcurrencyTests : GPBTestCase 45@end 46 47@implementation ConcurrencyTests 48 49- (NSArray *)createThreadsWithSelector:(SEL)selector object:(id)object { 50 NSMutableArray *array = [NSMutableArray array]; 51 for (NSUInteger i = 0; i < kNumThreads; i++) { 52 NSThread *thread = 53 [[NSThread alloc] initWithTarget:self selector:selector object:object]; 54 [array addObject:thread]; 55 [thread release]; 56 } 57 return array; 58} 59 60- (NSArray *)createMessagesWithType:(Class)msgType { 61 NSMutableArray *array = [NSMutableArray array]; 62 for (NSUInteger i = 0; i < kNumMessages; i++) { 63 [array addObject:[msgType message]]; 64 } 65 return array; 66} 67 68- (void)startThreads:(NSArray *)threads { 69 for (NSThread *thread in threads) { 70 [thread start]; 71 } 72} 73 74- (void)joinThreads:(NSArray *)threads { 75 for (NSThread *thread in threads) { 76 while (![thread isFinished]) 77 ; 78 } 79} 80 81- (void)readForeignMessage:(NSArray *)messages { 82 for (NSUInteger i = 0; i < 10; i++) { 83 for (TestAllTypes *message in messages) { 84 XCTAssertEqual(message.optionalForeignMessage.c, 0); 85 } 86 } 87} 88 89- (void)testConcurrentReadOfUnsetMessageField { 90 NSArray *messages = [self createMessagesWithType:[TestAllTypes class]]; 91 NSArray *threads = 92 [self createThreadsWithSelector:@selector(readForeignMessage:) 93 object:messages]; 94 [self startThreads:threads]; 95 [self joinThreads:threads]; 96 for (TestAllTypes *message in messages) { 97 XCTAssertFalse(message.hasOptionalForeignMessage); 98 } 99} 100 101- (void)readRepeatedInt32:(NSArray *)messages { 102 for (int i = 0; i < 10; i++) { 103 for (TestAllTypes *message in messages) { 104 XCTAssertEqual([message.repeatedInt32Array count], (NSUInteger)0); 105 } 106 } 107} 108 109- (void)testConcurrentReadOfUnsetRepeatedIntField { 110 NSArray *messages = [self createMessagesWithType:[TestAllTypes class]]; 111 NSArray *threads = 112 [self createThreadsWithSelector:@selector(readRepeatedInt32:) 113 object:messages]; 114 [self startThreads:threads]; 115 [self joinThreads:threads]; 116 for (TestAllTypes *message in messages) { 117 XCTAssertEqual([message.repeatedInt32Array count], (NSUInteger)0); 118 } 119} 120 121- (void)readRepeatedString:(NSArray *)messages { 122 for (int i = 0; i < 10; i++) { 123 for (TestAllTypes *message in messages) { 124 XCTAssertEqual([message.repeatedStringArray count], (NSUInteger)0); 125 } 126 } 127} 128 129- (void)testConcurrentReadOfUnsetRepeatedStringField { 130 NSArray *messages = [self createMessagesWithType:[TestAllTypes class]]; 131 NSArray *threads = 132 [self createThreadsWithSelector:@selector(readRepeatedString:) 133 object:messages]; 134 [self startThreads:threads]; 135 [self joinThreads:threads]; 136 for (TestAllTypes *message in messages) { 137 XCTAssertEqual([message.repeatedStringArray count], (NSUInteger)0); 138 } 139} 140 141- (void)readInt32Int32Map:(NSArray *)messages { 142 for (int i = 0; i < 10; i++) { 143 for (TestRecursiveMessageWithRepeatedField *message in messages) { 144 XCTAssertEqual([message.iToI count], (NSUInteger)0); 145 } 146 } 147} 148 149- (void)testConcurrentReadOfUnsetInt32Int32MapField { 150 NSArray *messages = 151 [self createMessagesWithType:[TestRecursiveMessageWithRepeatedField class]]; 152 NSArray *threads = 153 [self createThreadsWithSelector:@selector(readInt32Int32Map:) 154 object:messages]; 155 [self startThreads:threads]; 156 [self joinThreads:threads]; 157 for (TestRecursiveMessageWithRepeatedField *message in messages) { 158 XCTAssertEqual([message.iToI count], (NSUInteger)0); 159 } 160} 161 162- (void)readStringStringMap:(NSArray *)messages { 163 for (int i = 0; i < 10; i++) { 164 for (TestRecursiveMessageWithRepeatedField *message in messages) { 165 XCTAssertEqual([message.strToStr count], (NSUInteger)0); 166 } 167 } 168} 169 170- (void)testConcurrentReadOfUnsetStringStringMapField { 171 NSArray *messages = 172 [self createMessagesWithType:[TestRecursiveMessageWithRepeatedField class]]; 173 NSArray *threads = 174 [self createThreadsWithSelector:@selector(readStringStringMap:) 175 object:messages]; 176 [self startThreads:threads]; 177 [self joinThreads:threads]; 178 for (TestRecursiveMessageWithRepeatedField *message in messages) { 179 XCTAssertEqual([message.strToStr count], (NSUInteger)0); 180 } 181} 182 183- (void)readOptionalForeignMessageExtension:(NSArray *)messages { 184 for (int i = 0; i < 10; i++) { 185 for (TestAllExtensions *message in messages) { 186 ForeignMessage *foreign = 187 [message getExtension:[UnittestRoot optionalForeignMessageExtension]]; 188 XCTAssertEqual(foreign.c, 0); 189 } 190 } 191} 192 193- (void)testConcurrentReadOfUnsetExtensionField { 194 NSArray *messages = [self createMessagesWithType:[TestAllExtensions class]]; 195 SEL sel = @selector(readOptionalForeignMessageExtension:); 196 NSArray *threads = [self createThreadsWithSelector:sel object:messages]; 197 [self startThreads:threads]; 198 [self joinThreads:threads]; 199 GPBExtensionDescriptor *extension = 200 [UnittestRoot optionalForeignMessageExtension]; 201 for (TestAllExtensions *message in messages) { 202 XCTAssertFalse([message hasExtension:extension]); 203 } 204} 205 206@end 207