Throttle.cc (10919:80069a602c83) Throttle.cc (11021:e8a6637afa4c)
1/*
2 * Copyright (c) 1999-2008 Mark D. Hill and David A. Wood
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are
7 * met: redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer;

--- 86 unchanged lines hidden (view full) ---

95 m_units_remaining.push_back(0);
96 m_in.push_back(in_ptr);
97 m_out.push_back(out_ptr);
98
99 // Set consumer and description
100 in_ptr->setConsumer(this);
101 string desc = "[Queue to Throttle " + to_string(m_sID) + " " +
102 to_string(m_node) + "]";
1/*
2 * Copyright (c) 1999-2008 Mark D. Hill and David A. Wood
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are
7 * met: redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer;

--- 86 unchanged lines hidden (view full) ---

95 m_units_remaining.push_back(0);
96 m_in.push_back(in_ptr);
97 m_out.push_back(out_ptr);
98
99 // Set consumer and description
100 in_ptr->setConsumer(this);
101 string desc = "[Queue to Throttle " + to_string(m_sID) + " " +
102 to_string(m_node) + "]";
103 in_ptr->setDescription(desc);
104 }
105}
106
107void
108Throttle::operateVnet(int vnet, int &bw_remaining, bool &schedule_wakeup,
109 MessageBuffer *in, MessageBuffer *out)
110{
111 if (out == nullptr || in == nullptr) {

--- 162 unchanged lines hidden --- 		103 }
104}
105
106void
107Throttle::operateVnet(int vnet, int &bw_remaining, bool &schedule_wakeup,
108 MessageBuffer *in, MessageBuffer *out)
109{
110 if (out == nullptr || in == nullptr) {

--- 162 unchanged lines hidden ---