| 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
|
|
|