Index: third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m |
diff --git a/third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m b/third_party/protobuf/objectivec/Tests/GPBConcurrencyTests.m |
deleted file mode 100644 |
index daf75e7e7264c4818e95eae3ecc55af822e59e88..0000000000000000000000000000000000000000 |
--- 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 |