diff options
Diffstat (limited to 'third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m')
-rw-r--r-- | third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m | 206 |
1 files changed, 0 insertions, 206 deletions
diff --git a/third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m b/third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m deleted file mode 100644 index daf75e7e72..0000000000 --- a/third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m +++ /dev/null @@ -1,206 +0,0 @@ -// Protocol Buffers - Google's data interchange format -// Copyright 2014 Google Inc. All rights reserved. -// https://developers.google.com/protocol-buffers/ -// -// Redistribution and use in source and binary forms, with or without -// modification, are permitted provided that the following conditions are -// met: -// -// * Redistributions of source code must retain the above copyright -// notice, this list of conditions and the following disclaimer. -// * Redistributions in binary form must reproduce the above -// copyright notice, this list of conditions and the following disclaimer -// in the documentation and/or other materials provided with the -// distribution. -// * Neither the name of Google Inc. nor the names of its -// contributors may be used to endorse or promote products derived from -// this software without specific prior written permission. -// -// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT -// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT -// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, -// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT -// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE -// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - -#import "GPBTestUtilities.h" - -#import "google/protobuf/Unittest.pbobjc.h" -#import "google/protobuf/UnittestObjc.pbobjc.h" - -static const int kNumThreads = 100; -static const int kNumMessages = 100; - -// NOTE: Most of these tests don't "fail" in the sense that the XCTAsserts -// trip. Rather, the asserts simply exercise the apis, and if there is -// a concurancy issue, the NSAsserts in the runtime code fire and/or the -// code just crashes outright. - -@interface ConcurrencyTests : GPBTestCase -@end - -@implementation ConcurrencyTests - -- (NSArray *)createThreadsWithSelector:(SEL)selector object:(id)object { - NSMutableArray *array = [NSMutableArray array]; - for (NSUInteger i = 0; i < kNumThreads; i++) { - NSThread *thread = - [[NSThread alloc] initWithTarget:self selector:selector object:object]; - [array addObject:thread]; - [thread release]; - } - return array; -} - -- (NSArray *)createMessagesWithType:(Class)msgType { - NSMutableArray *array = [NSMutableArray array]; - for (NSUInteger i = 0; i < kNumMessages; i++) { - [array addObject:[msgType message]]; - } - return array; -} - -- (void)startThreads:(NSArray *)threads { - for (NSThread *thread in threads) { - [thread start]; - } -} - -- (void)joinThreads:(NSArray *)threads { - for (NSThread *thread in threads) { - while (![thread isFinished]) - ; - } -} - -- (void)readForeignMessage:(NSArray *)messages { - for (NSUInteger i = 0; i < 10; i++) { - for (TestAllTypes *message in messages) { - XCTAssertEqual(message.optionalForeignMessage.c, 0); - } - } -} - -- (void)testConcurrentReadOfUnsetMessageField { - NSArray *messages = [self createMessagesWithType:[TestAllTypes class]]; - NSArray *threads = - [self createThreadsWithSelector:@selector(readForeignMessage:) - object:messages]; - [self startThreads:threads]; - [self joinThreads:threads]; - for (TestAllTypes *message in messages) { - XCTAssertFalse(message.hasOptionalForeignMessage); - } -} - -- (void)readRepeatedInt32:(NSArray *)messages { - for (int i = 0; i < 10; i++) { - for (TestAllTypes *message in messages) { - XCTAssertEqual([message.repeatedInt32Array count], (NSUInteger)0); - } - } -} - -- (void)testConcurrentReadOfUnsetRepeatedIntField { - NSArray *messages = [self createMessagesWithType:[TestAllTypes class]]; - NSArray *threads = - [self createThreadsWithSelector:@selector(readRepeatedInt32:) - object:messages]; - [self startThreads:threads]; - [self joinThreads:threads]; - for (TestAllTypes *message in messages) { - XCTAssertEqual([message.repeatedInt32Array count], (NSUInteger)0); - } -} - -- (void)readRepeatedString:(NSArray *)messages { - for (int i = 0; i < 10; i++) { - for (TestAllTypes *message in messages) { - XCTAssertEqual([message.repeatedStringArray count], (NSUInteger)0); - } - } -} - -- (void)testConcurrentReadOfUnsetRepeatedStringField { - NSArray *messages = [self createMessagesWithType:[TestAllTypes class]]; - NSArray *threads = - [self createThreadsWithSelector:@selector(readRepeatedString:) - object:messages]; - [self startThreads:threads]; - [self joinThreads:threads]; - for (TestAllTypes *message in messages) { - XCTAssertEqual([message.repeatedStringArray count], (NSUInteger)0); - } -} - -- (void)readInt32Int32Map:(NSArray *)messages { - for (int i = 0; i < 10; i++) { - for (TestRecursiveMessageWithRepeatedField *message in messages) { - XCTAssertEqual([message.iToI count], (NSUInteger)0); - } - } -} - -- (void)testConcurrentReadOfUnsetInt32Int32MapField { - NSArray *messages = - [self createMessagesWithType:[TestRecursiveMessageWithRepeatedField class]]; - NSArray *threads = - [self createThreadsWithSelector:@selector(readInt32Int32Map:) - object:messages]; - [self startThreads:threads]; - [self joinThreads:threads]; - for (TestRecursiveMessageWithRepeatedField *message in messages) { - XCTAssertEqual([message.iToI count], (NSUInteger)0); - } -} - -- (void)readStringStringMap:(NSArray *)messages { - for (int i = 0; i < 10; i++) { - for (TestRecursiveMessageWithRepeatedField *message in messages) { - XCTAssertEqual([message.strToStr count], (NSUInteger)0); - } - } -} - -- (void)testConcurrentReadOfUnsetStringStringMapField { - NSArray *messages = - [self createMessagesWithType:[TestRecursiveMessageWithRepeatedField class]]; - NSArray *threads = - [self createThreadsWithSelector:@selector(readStringStringMap:) - object:messages]; - [self startThreads:threads]; - [self joinThreads:threads]; - for (TestRecursiveMessageWithRepeatedField *message in messages) { - XCTAssertEqual([message.strToStr count], (NSUInteger)0); - } -} - -- (void)readOptionalForeignMessageExtension:(NSArray *)messages { - for (int i = 0; i < 10; i++) { - for (TestAllExtensions *message in messages) { - ForeignMessage *foreign = - [message getExtension:[UnittestRoot optionalForeignMessageExtension]]; - XCTAssertEqual(foreign.c, 0); - } - } -} - -- (void)testConcurrentReadOfUnsetExtensionField { - NSArray *messages = [self createMessagesWithType:[TestAllExtensions class]]; - SEL sel = @selector(readOptionalForeignMessageExtension:); - NSArray *threads = [self createThreadsWithSelector:sel object:messages]; - [self startThreads:threads]; - [self joinThreads:threads]; - GPBExtensionDescriptor *extension = - [UnittestRoot optionalForeignMessageExtension]; - for (TestAllExtensions *message in messages) { - XCTAssertFalse([message hasExtension:extension]); - } -} - -@end |