rayelliott
/
barrier
mirror of https://github.com/debauchee/barrier.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fixed code style

This commit is contained in:
XinyuHou 2015-01-12 10:51:16 +00:00
parent f973d1498d
commit be2b87fd39
4 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/lib/net/SocketMultiplexer.h
View File

@ -96,15 +96,16 @@ private:
private: private:
Mutex* m_mutex; Mutex* m_mutex;
Thread* m_thread; Thread* m_thread;
bool m_update; bool m_update;
CondVar<bool>* m_jobsReady; CondVar<bool>* m_jobsReady;
CondVar<bool>* m_jobListLock; CondVar<bool>* m_jobListLock;
CondVar<bool>* m_jobListLockLocked; CondVar<bool>* m_jobListLockLocked;
Thread* m_jobListLocker; Thread* m_jobListLocker;
Thread* m_jobListLockLocker; Thread* m_jobListLockLocker;
SocketJobs m_socketJobs; SocketJobs m_socketJobs;
SocketJobMap m_socketJobMap; SocketJobMap m_socketJobMap;
ISocketMultiplexerJob* m_cursorMark; ISocketMultiplexerJob*
m_cursorMark;
}; };

5
src/lib/net/TCPListenSocket.h
View File

@ -41,7 +41,8 @@ public:
virtual void* getEventTarget() const; virtual void* getEventTarget() const;
// IListenSocket overrides // IListenSocket overrides
virtual IDataSocket* accept(); virtual IDataSocket*
accept();
private: private:
ISocketMultiplexerJob* ISocketMultiplexerJob*
@ -52,5 +53,5 @@ private:
ArchSocket m_socket; ArchSocket m_socket;
Mutex* m_mutex; Mutex* m_mutex;
IEventQueue* m_events; IEventQueue* m_events;
SocketMultiplexer* m_socketMultiplexer; SocketMultiplexer* m_socketMultiplexer;
}; };

2
src/lib/net/TCPSocket.h
View File

@ -87,5 +87,5 @@ private:
bool m_readable; bool m_readable;
bool m_writable; bool m_writable;
IEventQueue* m_events; IEventQueue* m_events;
SocketMultiplexer* m_socketMultiplexer; SocketMultiplexer* m_socketMultiplexer;
}; };

8
src/lib/net/TCPSocketFactory.h
View File

@ -30,10 +30,12 @@ public:
virtual ~TCPSocketFactory(); virtual ~TCPSocketFactory();
// ISocketFactory overrides // ISocketFactory overrides
virtual IDataSocket* create() const; virtual IDataSocket*
virtual IListenSocket* createListen() const; create() const;
virtual IListenSocket*
createListen() const;
private: private:
IEventQueue* m_events; IEventQueue* m_events;
SocketMultiplexer* m_socketMultiplexer; SocketMultiplexer* m_socketMultiplexer;
}; };