mirror of
https://github.com/sogou/workflow.git
synced 2026-10-21 22:56:42 +08:00
update CommService
This commit is contained in:
@@ -273,17 +273,6 @@ int CommService::drain(int max)
|
||||
return cnt;
|
||||
}
|
||||
|
||||
inline void CommService::incref()
|
||||
{
|
||||
this->ref++;
|
||||
}
|
||||
|
||||
inline void CommService::decref()
|
||||
{
|
||||
if (--this->ref == 0)
|
||||
this->handle_unbound();
|
||||
}
|
||||
|
||||
class CommServiceTarget : public CommTarget
|
||||
{
|
||||
public:
|
||||
|
||||
@@ -212,9 +212,17 @@ private:
|
||||
int ssl_accept_timeout;
|
||||
SSL_CTX *ssl_ctx;
|
||||
|
||||
private:
|
||||
void incref();
|
||||
void decref();
|
||||
public:
|
||||
void incref()
|
||||
{
|
||||
this->ref++;
|
||||
}
|
||||
|
||||
void decref()
|
||||
{
|
||||
if (--this->ref == 0)
|
||||
this->handle_unbound();
|
||||
}
|
||||
|
||||
private:
|
||||
SOCKET listen_sockfd;
|
||||
|
||||
Reference in New Issue
Block a user