-
Notifications
You must be signed in to change notification settings - Fork 0
/
NetworkManager.m
140 lines (93 loc) · 2.59 KB
/
NetworkManager.m
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
//
// NetworkManager.m
// NekoLogic
//
// Created by Cory on 10/08/22.
// Copyright 2010 Cory R. Leach. All rights reserved.
//
#import "NetworkManager.h"
#import "NetInMsg.h"
#import "NetOutMsg.h"
@implementation NetworkManager
static NetworkManager* _sharedInstance = nil;
@synthesize session;
+ (id) alloc {
@synchronized([NetworkManager class]) {
NSAssert(_sharedInstance == nil, @"Attempted to allocate a second instance of a singleton.");
_sharedInstance = [super alloc];
return _sharedInstance;
}
return nil;
}
- (id) init {
if ( (self = [super init]) == nil ) {
return self;
}
//Init
handlers = [[NSMutableDictionary alloc] init];
registeredObjects = [[NSMutableDictionary alloc] init];
sendUpdateCounter = 0;
recieveUpdateCounter = 0;
return self;
}
- (void) dealloc {
[handlers release];
handlers = nil;
[registeredObjects release];
registeredObjects = nil;
[super dealloc];
}
+ (NetworkManager*) sharedInstance {
@synchronized([NetworkManager class])
{
if (!_sharedInstance) {
[[self alloc] init];
}
return _sharedInstance;
}
// to avoid compiler warning
return nil;
}
- (GKSessionMode) sessionMode {
return [session sessionMode];
}
- (BOOL) isServer {
return (self.sessionMode == GKSessionModeServer);
}
- (BOOL) isClient {
return (self.sessionMode == GKSessionModeClient);
}
- (BOOL) isPeer {
return (self.sessionMode == GKSessionModePeer);
}
- (BOOL) isConnected {
return ( [[session peersWithConnectionState:GKPeerStateConnected] count] > 0 );
}
- (void) setSession:(GKSession*)aSession {
[session release];
session = aSession;
[session retain];
[session setDataReceiveHandler:self withContext:NULL];
}
- (NSString*) myID {
return [session peerID];
}
- (NSArray*) peers {
return [session peersWithConnectionState:GKPeerStateConnected];
}
- (void) registerMessageHandler:(id<NetworkHandler>)handler withId:(NetworkHandlerID)handlerId {
[handlers setObject:handler forKey:[NSNumber numberWithUnsignedChar:handlerId]];
}
- (id) handlerWithId:(NetworkHandlerID)handlerId {
return [handlers objectForKey:[NSNumber numberWithUnsignedChar:handlerId]];
}
- (void) receiveData:(NSData *)data fromPeer:(NSString *)peer inSession:(GKSession *)aSession context:(void *)context {
NetInMsg* msg = [[NetInMsg alloc] initWithData:data];
//Send Message to Appropriate Hander
id<NetworkHandler> handler = [self handlerWithId:msg.handlerId];
if ( handler != nil ) {
[handler recieveMsg:msg fromPeer:peer onNetwork:self];
}
NSLog(@"NetworkManager: No Registered Handler For Message! %d",msg.handlerId);
}
@end