Impala Documentation

virtual void Impala::Application::DataServer::AcceptDisconnect ( int port ) [inline, protected, virtual]

Reimplemented from Impala::Util::ChannelServer.

Definition at line 490 of file mainDataServer.cpp.

References BufInfBufferId(), BufInfPort(), ILOG_DEBUG, mFileBuffers, and mFileBuffersDiskImage.

00491     {
00492         std::vector<BufInf> v = mFileBuffers.GetAllIdx();
00493         for (int i=0 ; i<v.size() ; i++)
00494         {
00495             BufInf inf = v[i];
00496             int p = BufInfPort(inf);
00497             if (p == port)
00498             {
00499                 ILOG_DEBUG("cleaning buffer " << BufInfPort(inf) << " " <<
00500                            BufInfBufferId(inf));
00501                 mFileBuffers.Remove(inf);
00502             }
00503         }
00504 
00505         std::vector<BufInf> w = mFileBuffersDiskImage.GetAllIdx();
00506         for (int i=0 ; i<w.size() ; i++)
00507         {
00508             BufInf inf = w[i];
00509             int p = BufInfPort(inf);
00510             if (p == port)
00511             {
00512                 ILOG_DEBUG("cleaning buffer " << BufInfPort(inf) << " " <<
00513                            BufInfBufferId(inf));
00514                 mFileBuffersDiskImage.Remove(inf);
00515             }
00516         }
00517     }

Here is the call graph for this function: