Lines Matching refs:conn
496 TcpKeepConn* conn = NULL; in GetTcpKeepConn() local
507 conn = _mem_queue.AllocPtr(); in GetTcpKeepConn()
508 if (conn) { in GetTcpKeepConn()
509 conn->SetDestAddr(dst); in GetTcpKeepConn()
514 conn = conn_list->GetFirstConn(); in GetTcpKeepConn()
515 conn_list->RemoveConn(conn); in GetTcpKeepConn()
516 conn->IdleDetach(); in GetTcpKeepConn()
519 return conn; in GetTcpKeepConn()
522 bool TcpKeepMgr::RemoveTcpKeepConn(TcpKeepConn* conn) in RemoveTcpKeepConn() argument
524 struct sockaddr_in* dst = conn->GetDestAddr(); in RemoveTcpKeepConn()
539 conn->IdleDetach(); in RemoveTcpKeepConn()
540 conn_list->RemoveConn(conn); in RemoveTcpKeepConn()
546 bool TcpKeepMgr::CacheTcpKeepConn(TcpKeepConn* conn) in CacheTcpKeepConn() argument
548 struct sockaddr_in* dst = conn->GetDestAddr(); in CacheTcpKeepConn()
559 conn_list = new TcpKeepKey(conn->GetDestAddr()); in CacheTcpKeepConn()
567 if (!conn->IdleAttach()) in CacheTcpKeepConn()
573 conn->ConnReuseClean(); in CacheTcpKeepConn()
574 conn_list->InsertConn(conn); in CacheTcpKeepConn()
581 void TcpKeepMgr::FreeTcpKeepConn(TcpKeepConn* conn, bool force_free) in FreeTcpKeepConn() argument
585 conn->Reset(); in FreeTcpKeepConn()
586 _mem_queue.FreePtr(conn); in FreeTcpKeepConn()
591 if (!CacheTcpKeepConn(conn)) in FreeTcpKeepConn()
593 conn->Reset(); in FreeTcpKeepConn()
594 _mem_queue.FreePtr(conn); in FreeTcpKeepConn()
741 void ConnectionMgr::FreeConnection(IMtConnection* conn, bool force_free) in FreeConnection() argument
743 if (!conn) { in FreeConnection()
746 CONN_OBJ_TYPE type = conn->GetConnType(); in FreeConnection()
751 conn->Reset(); in FreeConnection()
752 return _udp_short_queue.FreePtr(dynamic_cast<UdpShortConn*>(conn)); in FreeConnection()
756 return _tcp_keep_mgr.FreeTcpKeepConn(dynamic_cast<TcpKeepConn*>(conn), force_free); in FreeConnection()
760 conn->Reset(); in FreeConnection()
761 return _udp_session_queue.FreePtr(dynamic_cast<UdpSessionConn*>(conn)); in FreeConnection()
768 delete conn; in FreeConnection()
772 void ConnectionMgr::CloseIdleTcpKeep(TcpKeepConn* conn) in CloseIdleTcpKeep() argument
774 _tcp_keep_mgr.RemoveTcpKeepConn(conn); in CloseIdleTcpKeep()
775 _tcp_keep_mgr.FreeTcpKeepConn(conn, true); in CloseIdleTcpKeep()