Impala Documentation

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

Reimplemented from Impala::Util::ChannelServer.

Definition at line 463 of file mainDataServer.cpp.

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

00464     {
00465         std::vector<BufInf> v = mFileBuffers.GetAllIdx();
00466         for (int i=0 ; i<v.size() ; i++)
00467         {
00468             BufInf inf = v[i];
00469             int p = BufInfPort(inf);
00470             if (p == port)
00471             {
00472                 ILOG_DEBUG("cleaning buffer " << BufInfPort(inf) << " " <<
00473                            BufInfBufferId(inf));
00474                 mFileBuffers.Remove(inf);
00475             }
00476         }
00477 
00478         std::vector<BufInf> w = mFileBuffersDiskImage.GetAllIdx();
00479         for (int i=0 ; i<w.size() ; i++)
00480         {
00481             BufInf inf = w[i];
00482             int p = BufInfPort(inf);
00483             if (p == port)
00484             {
00485                 ILOG_DEBUG("cleaning buffer " << BufInfPort(inf) << " " <<
00486                            BufInfBufferId(inf));
00487                 mFileBuffersDiskImage.Remove(inf);
00488             }
00489         }
00490     }

Here is the call graph for this function: