aboutsummaryrefslogtreecommitdiffstats
path: root/Frameworks
diff options
context:
space:
mode:
authorrowanbeentje <rowan@beent.je>2010-12-07 23:41:45 +0000
committerrowanbeentje <rowan@beent.je>2010-12-07 23:41:45 +0000
commitb05d20103968508fa41dc1fc1e1d8a111c93f84a (patch)
tree82b55d27e47bd33d52fbad529a089b33949c7bbc /Frameworks
parent1cb77dab41589b8055ada2034c258dd3bb18a451 (diff)
downloadsequelpro-b05d20103968508fa41dc1fc1e1d8a111c93f84a.tar.gz
sequelpro-b05d20103968508fa41dc1fc1e1d8a111c93f84a.tar.bz2
sequelpro-b05d20103968508fa41dc1fc1e1d8a111c93f84a.zip
- Fix a race condition in conditions where the network has dropped, preventing possible MySQL library crashes
Diffstat (limited to 'Frameworks')
-rw-r--r--Frameworks/MCPKit/MCPFoundationKit/MCPConnection.h1
-rw-r--r--Frameworks/MCPKit/MCPFoundationKit/MCPConnection.m20
2 files changed, 21 insertions, 0 deletions
diff --git a/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.h b/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.h
index ad30fa07..61ce1261 100644
--- a/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.h
+++ b/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.h
@@ -57,6 +57,7 @@ typedef struct {
BOOL useKeepAlive;
BOOL isDisconnecting;
+ BOOL isReconnecting;
BOOL userTriggeredDisconnect;
NSInteger connectionTimeout;
CGFloat keepAliveInterval;
diff --git a/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.m b/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.m
index af203222..03cade24 100644
--- a/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.m
+++ b/Frameworks/MCPKit/MCPFoundationKit/MCPConnection.m
@@ -141,6 +141,7 @@ static BOOL sTruncateLongFieldInLogs = YES;
serverVersionString = nil;
mTimeZone = nil;
isDisconnecting = NO;
+ isReconnecting = NO;
userTriggeredDisconnect = NO;
automaticReconnectAttempts = 0;
lastPingSuccess = NO;
@@ -554,6 +555,22 @@ static BOOL sTruncateLongFieldInLogs = YES;
NSString *currentEncoding = [NSString stringWithString:encoding];
BOOL currentEncodingUsesLatin1Transport = encodingUsesLatin1Transport;
NSString *currentDatabase = nil;
+
+ // Check whether a reconnection attempt is already being made - if so, wait and return the status of that reconnection attempt.
+ if (isReconnecting) {
+ NSDate *reconnectLoopStartdate = [NSDate date], *eventLoopStartDate;
+ while (isReconnecting) {
+ eventLoopStartDate = [NSDate date];
+ [[NSRunLoop currentRunLoop] runMode:NSModalPanelRunLoopMode beforeDate:[NSDate dateWithTimeIntervalSinceNow:0.1]];
+ if ([[NSDate date] timeIntervalSinceDate:eventLoopStartDate] < 0.1) {
+ usleep(100000 - (1000000 * [[NSDate date] timeIntervalSinceDate:eventLoopStartDate]));
+ }
+ }
+ [reconnectionPool drain];
+ return mConnected;
+ }
+
+ isReconnecting = YES;
// Store the currently selected database so it can be re-set if reconnection was successful
if (delegate && [delegate respondsToSelector:@selector(onReconnectShouldSelectDatabase:)] && [delegate onReconnectShouldSelectDatabase:self]) {
@@ -689,14 +706,17 @@ static BOOL sTruncateLongFieldInLogs = YES;
[self setLastErrorMessage:NSLocalizedString(@"User triggered disconnection", @"User triggered disconnection")];
userTriggeredDisconnect = YES;
[reconnectionPool release];
+ isReconnecting = NO;
return NO;
default:
[reconnectionPool release];
+ isReconnecting = NO;
return [self reconnect];
}
}
[reconnectionPool release];
+ isReconnecting = NO;
return mConnected;
}