blob: 5020b20817418211801a5a3a8c48607a4bbac2d2 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
//
// SDLIAPSession.m
//
#import "SDLIAPSession.h"
#import "SDLDebugTool.h"
#import "SDLStreamDelegate.h"
#import "SDLTimer.h"
@interface SDLIAPSession ()
@property (assign) BOOL isInputStreamOpen;
@property (assign) BOOL isOutputStreamOpen;
@end
@implementation SDLIAPSession
#pragma mark - Lifecycle
- (instancetype)initWithAccessory:(EAAccessory *)accessory forProtocol:(NSString *)protocol {
NSString *logMessage = [NSString stringWithFormat:@"SDLIAPSession initWithAccessory:%@ forProtocol:%@", accessory, protocol];
[SDLDebugTool logInfo:logMessage];
self = [super init];
if (self) {
_delegate = nil;
_accessory = accessory;
_protocol = protocol;
_streamDelegate = nil;
_easession = nil;
_isInputStreamOpen = NO;
_isOutputStreamOpen = NO;
}
return self;
}
#pragma mark - Public Stream Lifecycle
- (BOOL)start {
__weak typeof(self) weakSelf = self;
NSString *logMessage = [NSString stringWithFormat:@"Opening EASession withAccessory:%@ forProtocol:%@", _accessory.name, _protocol];
[SDLDebugTool logInfo:logMessage];
if ((self.easession = [[EASession alloc] initWithAccessory:_accessory forProtocol:_protocol])) {
__strong typeof(self) strongSelf = weakSelf;
[SDLDebugTool logInfo:@"Created Session Object"];
strongSelf.streamDelegate.streamErrorHandler = [self streamErroredHandler];
strongSelf.streamDelegate.streamOpenHandler = [self streamOpenedHandler];
[strongSelf startStream:weakSelf.easession.outputStream];
[strongSelf startStream:weakSelf.easession.inputStream];
return YES;
} else {
[SDLDebugTool logInfo:@"Error: Could Not Create Session Object"];
return NO;
}
}
- (void)stop {
[self stopStream:self.easession.outputStream];
[self stopStream:self.easession.inputStream];
self.easession = nil;
}
#pragma mark - Private Stream Lifecycle Helpers
- (void)startStream:(NSStream *)stream {
stream.delegate = self.streamDelegate;
[stream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
[stream open];
}
- (void)stopStream:(NSStream *)stream {
// Verify stream is in a state that can be closed.
// (N.B. Closing a stream that has not been opened has very, very bad effects.)
// When you disconect the cable you get a stream end event and come here but stream is already in closed state.
// Still need to remove from run loop.
NSUInteger status1 = stream.streamStatus;
if (status1 != NSStreamStatusNotOpen &&
status1 != NSStreamStatusClosed) {
[stream close];
}
[stream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
[stream setDelegate:nil];
NSUInteger status2 = stream.streamStatus;
if (status2 == NSStreamStatusClosed) {
if (stream == [self.easession inputStream]) {
[SDLDebugTool logInfo:@"Input Stream Closed"];
} else if (stream == [self.easession outputStream]) {
[SDLDebugTool logInfo:@"Output Stream Closed"];
}
}
}
#pragma mark - Stream Handlers
- (SDLStreamOpenHandler)streamOpenedHandler {
__weak typeof(self) weakSelf = self;
return ^(NSStream *stream) {
__strong typeof(weakSelf) strongSelf = weakSelf;
if (stream == [strongSelf.easession outputStream]) {
[SDLDebugTool logInfo:@"Output Stream Opened"];
strongSelf.isOutputStreamOpen = YES;
} else if (stream == [strongSelf.easession inputStream]) {
[SDLDebugTool logInfo:@"Input Stream Opened"];
strongSelf.isInputStreamOpen = YES;
}
// When both streams are open, session initialization is complete. Let the delegate know.
if (strongSelf.isInputStreamOpen && strongSelf.isOutputStreamOpen) {
[strongSelf.delegate onSessionInitializationCompleteForSession:weakSelf];
}
};
}
- (SDLStreamErrorHandler)streamErroredHandler {
__weak typeof(self) weakSelf = self;
return ^(NSStream *stream) {
__strong typeof(weakSelf) strongSelf = weakSelf;
[SDLDebugTool logInfo:@"Stream Error"];
[strongSelf.delegate onSessionStreamsEnded:strongSelf];
};
}
#pragma mark - Lifecycle Destruction
- (void)dealloc {
self.delegate = nil;
self.accessory = nil;
self.protocol = nil;
self.streamDelegate = nil;
self.easession = nil;
[SDLDebugTool logInfo:@"SDLIAPSession Dealloc"];
}
@end
|
