Lines Matching refs:proxy
41 void ISessionNtfy::InsertWriteWait(SessionProxy* proxy) in InsertWriteWait() argument
43 if (!proxy->_flag) { in InsertWriteWait()
44 TAILQ_INSERT_TAIL(&_write_list, proxy, _write_entry); in InsertWriteWait()
45 proxy->_flag = 1; in InsertWriteWait()
49 void ISessionNtfy::RemoveWriteWait(SessionProxy* proxy) in RemoveWriteWait() argument
51 if (proxy->_flag) { in RemoveWriteWait()
52 TAILQ_REMOVE(&_write_list, proxy, _write_entry); in RemoveWriteWait()
53 proxy->_flag = 0; in RemoveWriteWait()
60 SessionProxy* proxy = NULL; in NotifyWriteWait() local
62 TAILQ_FOREACH(proxy, &_write_list, _write_entry) in NotifyWriteWait()
64 proxy->SetRcvEvents(KQ_EVENT_WRITE); in NotifyWriteWait()
66 thread = proxy->GetOwnerThread(); in NotifyWriteWait()
388 SessionProxy* proxy = NULL; in GetNtfyObj() local
397 proxy = _udp_proxy_pool.AllocPtr(); in GetNtfyObj()
398 obj = proxy; in GetNtfyObj()
408 if (proxy) { in GetNtfyObj()
412 this->FreeNtfyObj(proxy); in GetNtfyObj()
415 proxy->SetRealNtfyObj(ntfy); in GetNtfyObj()
425 SessionProxy* proxy = NULL; in FreeNtfyObj() local
440 proxy = dynamic_cast<SessionProxy*>(obj); in FreeNtfyObj()
441 return _udp_proxy_pool.FreePtr(proxy); in FreeNtfyObj()