| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #ifndef NET_TOOLS_FLIP_SERVER_OUTPUT_ORDERING_H_ | |
| 6 #define NET_TOOLS_FLIP_SERVER_OUTPUT_ORDERING_H_ | |
| 7 | |
| 8 #include <stdint.h> | |
| 9 | |
| 10 #include <list> | |
| 11 #include <map> | |
| 12 #include <string> | |
| 13 | |
| 14 #include "base/compiler_specific.h" | |
| 15 #include "net/tools/epoll_server/epoll_server.h" | |
| 16 #include "net/tools/flip_server/constants.h" | |
| 17 #include "net/tools/flip_server/mem_cache.h" | |
| 18 | |
| 19 namespace net { | |
| 20 | |
| 21 class SMConnectionInterface; | |
| 22 | |
| 23 class OutputOrdering { | |
| 24 public: | |
| 25 typedef std::list<MemCacheIter> PriorityRing; | |
| 26 typedef std::map<uint32_t, PriorityRing> PriorityMap; | |
| 27 | |
| 28 struct PriorityMapPointer { | |
| 29 PriorityMapPointer(); | |
| 30 PriorityMapPointer(const PriorityMapPointer& other); | |
| 31 ~PriorityMapPointer(); | |
| 32 PriorityRing* ring; | |
| 33 PriorityRing::iterator it; | |
| 34 bool alarm_enabled; | |
| 35 EpollServer::AlarmRegToken alarm_token; | |
| 36 }; | |
| 37 | |
| 38 typedef std::map<uint32_t, PriorityMapPointer> StreamIdToPriorityMap; | |
| 39 | |
| 40 StreamIdToPriorityMap stream_ids_; | |
| 41 PriorityMap priority_map_; | |
| 42 PriorityRing first_data_senders_; | |
| 43 uint32_t first_data_senders_threshold_; // when you've passed this, you're no | |
| 44 // longer a first_data_sender... | |
| 45 SMConnectionInterface* connection_; | |
| 46 EpollServer* epoll_server_; | |
| 47 | |
| 48 explicit OutputOrdering(SMConnectionInterface* connection); | |
| 49 ~OutputOrdering(); | |
| 50 void Reset(); | |
| 51 bool ExistsInPriorityMaps(uint32_t stream_id) const; | |
| 52 | |
| 53 struct BeginOutputtingAlarm : public EpollAlarmCallbackInterface { | |
| 54 public: | |
| 55 BeginOutputtingAlarm(OutputOrdering* oo, | |
| 56 OutputOrdering::PriorityMapPointer* pmp, | |
| 57 const MemCacheIter& mci); | |
| 58 ~BeginOutputtingAlarm() override; | |
| 59 | |
| 60 // EpollAlarmCallbackInterface: | |
| 61 int64_t OnAlarm() override; | |
| 62 void OnRegistration(const EpollServer::AlarmRegToken& tok, | |
| 63 EpollServer* eps) override; | |
| 64 void OnUnregistration() override; | |
| 65 void OnShutdown(EpollServer* eps) override; | |
| 66 | |
| 67 private: | |
| 68 OutputOrdering* output_ordering_; | |
| 69 OutputOrdering::PriorityMapPointer* pmp_; | |
| 70 MemCacheIter mci_; | |
| 71 EpollServer* epoll_server_; | |
| 72 }; | |
| 73 | |
| 74 void MoveToActive(PriorityMapPointer* pmp, MemCacheIter mci); | |
| 75 void AddToOutputOrder(const MemCacheIter& mci); | |
| 76 void SpliceToPriorityRing(PriorityRing::iterator pri); | |
| 77 MemCacheIter* GetIter(); | |
| 78 void RemoveStreamId(uint32_t stream_id); | |
| 79 | |
| 80 static double server_think_time_in_s() { return server_think_time_in_s_; } | |
| 81 static void set_server_think_time_in_s(double value) { | |
| 82 server_think_time_in_s_ = value; | |
| 83 } | |
| 84 | |
| 85 private: | |
| 86 static double server_think_time_in_s_; | |
| 87 }; | |
| 88 | |
| 89 } // namespace net | |
| 90 | |
| 91 #endif // NET_TOOLS_FLIP_SERVER_OUTPUT_ORDERING_H_ | |
| OLD | NEW |