Skip to content

Commit 5160761

Browse files
author
Jinzhi Chen
committed
update release130.21
1 parent e22ee6a commit 5160761

File tree

11 files changed

+6578
-9
lines changed

11 files changed

+6578
-9
lines changed
Lines changed: 59 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,59 @@
1+
// Copyright 2008, Google Inc.
2+
// All rights reserved.
3+
//
4+
// Redistribution and use in source and binary forms, with or without
5+
// modification, are permitted provided that the following conditions are
6+
// met:
7+
//
8+
// * Redistributions of source code must retain the above copyright
9+
// notice, this list of conditions and the following disclaimer.
10+
// * Redistributions in binary form must reproduce the above
11+
// copyright notice, this list of conditions and the following disclaimer
12+
// in the documentation and/or other materials provided with the
13+
// distribution.
14+
// * Neither the name of Google Inc. nor the names of its
15+
// contributors may be used to endorse or promote products derived from
16+
// this software without specific prior written permission.
17+
//
18+
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
19+
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
20+
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
21+
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
22+
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
23+
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
24+
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
25+
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
26+
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
27+
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
28+
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
29+
//
30+
// Author: preston.a.jackson@gmail.com (Preston Jackson)
31+
//
32+
// Google Test - FrameworkSample
33+
// widget.h
34+
//
35+
36+
// Widget is a very simple class used for demonstrating the use of gtest. It
37+
// simply stores two values a string and an integer, which are returned via
38+
// public accessors in multiple forms.
39+
40+
#import <string>
41+
42+
class Widget {
43+
public:
44+
Widget(int number, const std::string& name);
45+
~Widget();
46+
47+
// Public accessors to number data
48+
float GetFloatValue() const;
49+
int GetIntValue() const;
50+
51+
// Public accessors to the string data
52+
std::string GetStringValue() const;
53+
void GetCharPtrValue(char* buffer, size_t max_size) const;
54+
55+
private:
56+
// Data members
57+
float number_;
58+
std::string name_;
59+
};

src/DictionaryImp.cpp

100644100755
File mode changed.

src/DictionaryImp.h

100644100755
File mode changed.

src/DomainImp.cpp

100644100755
File mode changed.

src/DomainImp.h

100644100755
File mode changed.

src/Exceptions.cpp

100644100755
File mode changed.

src/Format.h

100644100755
File mode changed.

src/MultithreadedTableWriter.cpp

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ MultithreadedTableWriter::MultithreadedTableWriter(const std::string& hostName,
5353
if (pHighAvailabilitySites != nullptr) {
5454
highAvailabilitySites.assign(pHighAvailabilitySites->begin(), pHighAvailabilitySites->end());
5555
}
56-
bool ret = pConn->connect(hostName, port, userId, password, "", enableHighAvailability, highAvailabilitySites);
56+
bool ret = pConn->connect(hostName, port, userId, password, "", enableHighAvailability, highAvailabilitySites, 30);
5757
if (!ret) {
5858
throw RuntimeException("Failed to connect to server " + hostName + ":" + std::to_string(port));
5959
}
@@ -211,15 +211,12 @@ MultithreadedTableWriter::MultithreadedTableWriter(const std::string& hostName,
211211
writerThread.sendingRows = 0;
212212
writerThread.exit = false;
213213
LockGuard<Mutex> _(&writerThread.mutex_);
214-
if (i == 0) {
215-
writerThread.conn = pConn;
216-
}
217-
else {
218-
writerThread.conn = new DBConnection(useSSL, false, keepAliveTime, isCompress);
219-
if (writerThread.conn->connect(hostName, port, userId, password, "", enableHighAvailability, highAvailabilitySites) == false) {
220-
throw RuntimeException("Failed to connect to server " + hostName + ":" + std::to_string(port));
221-
}
214+
215+
writerThread.conn = new DBConnection(useSSL, false, keepAliveTime, isCompress);
216+
if (writerThread.conn->connect(hostName, port, userId, password, "", enableHighAvailability, highAvailabilitySites, 30, true) == false) {
217+
throw RuntimeException("Failed to connect to server " + hostName + ":" + std::to_string(port));
222218
}
219+
223220
writerThread.writeThread = new Thread(new SendExecutor(*this, writerThread));
224221
writerThread.writeThread->start();
225222
}

0 commit comments

Comments
 (0)