From a4fc1bad94f028111dcf36ac53c42e5dab79605d Mon Sep 17 00:00:00 2001 From: Polina Dudnik Date: Fri, 21 Aug 2009 15:52:46 -0500 Subject: [mq]: first_patch --- src/mem/ruby/system/Sequencer.cc | 55 ++++++++++++++++++++++++++-------------- 1 file changed, 36 insertions(+), 19 deletions(-) (limited to 'src/mem/ruby/system/Sequencer.cc') diff --git a/src/mem/ruby/system/Sequencer.cc b/src/mem/ruby/system/Sequencer.cc index 780c1128e..9549cc340 100644 --- a/src/mem/ruby/system/Sequencer.cc +++ b/src/mem/ruby/system/Sequencer.cc @@ -61,7 +61,7 @@ void Sequencer::init(const vector & argv) m_instCache_ptr = NULL; m_dataCache_ptr = NULL; m_controller = NULL; - m_servicing_atomic = -1; + m_servicing_atomic = 200; m_atomics_counter = 0; for (size_t i=0; iruby_request.paddr); WARN_EXPR(keys.size()); WARN_EXPR(current_time); WARN_EXPR(request->issue_time); @@ -344,13 +345,22 @@ void Sequencer::hitCallback(SequencerRequest* srequest, DataBlock& data) { data.setData(ruby_request.data, request_address.getOffset(), ruby_request.len); } } - + if (type == RubyRequestType_RMW_Write) { + if (m_servicing_atomic != ruby_request.proc_id) { + assert(0); + } + assert(m_atomics_counter > 0); + m_atomics_counter--; + if (m_atomics_counter == 0) { + m_servicing_atomic = 200; + } + } m_hit_callback(srequest->id); delete srequest; } // Returns true if the sequencer already has a load or store outstanding -bool Sequencer::isReady(const RubyRequest& request) { +bool Sequencer::isReady(const RubyRequest& request, bool dont_set) { // POLINA: check if we are currently flushing the write buffer, if so Ruby is returned as not ready // to simulate stalling of the front-end // Do we stall all the sequencers? If it is atomic instruction - yes! @@ -365,27 +375,30 @@ bool Sequencer::isReady(const RubyRequest& request) { return false; } - if (m_servicing_atomic != -1 && m_servicing_atomic != (int)request.proc_id) { + assert(request.proc_id != 100); + if (m_servicing_atomic != 200 && m_servicing_atomic != request.proc_id) { assert(m_atomics_counter > 0); return false; } else { - if (request.type == RubyRequestType_RMW_Read) { - if (m_servicing_atomic == -1) { - assert(m_atomics_counter == 0); - m_servicing_atomic = (int)request.proc_id; + if (!dont_set) { + if (request.type == RubyRequestType_RMW_Read) { + if (m_servicing_atomic == 200) { + assert(m_atomics_counter == 0); + m_servicing_atomic = request.proc_id; + } + else { + assert(m_servicing_atomic == request.proc_id); + } + m_atomics_counter++; } else { - assert(m_servicing_atomic == (int)request.proc_id); - } - m_atomics_counter++; - } - else if (request.type == RubyRequestType_RMW_Write) { - assert(m_servicing_atomic == (int)request.proc_id); - assert(m_atomics_counter > 0); - m_atomics_counter--; - if (m_atomics_counter == 0) { - m_servicing_atomic = -1; + if (m_servicing_atomic == request.proc_id) { + if (request.type != RubyRequestType_RMW_Write) { + m_servicing_atomic = 200; + m_atomics_counter = 0; + } + } } } } @@ -405,7 +418,7 @@ int64_t Sequencer::makeRequest(const RubyRequest & request) int64_t id = makeUniqueRequestID(); SequencerRequest *srequest = new SequencerRequest(request, id, g_eventQueue_ptr->getTime()); bool found = insertRequest(srequest); - if (!found) + if (!found) { if (request.type == RubyRequestType_Locked_Write) { // NOTE: it is OK to check the locked flag here as the mandatory queue will be checked first // ensuring that nothing comes between checking the flag and servicing the store @@ -423,6 +436,10 @@ int64_t Sequencer::makeRequest(const RubyRequest & request) // TODO: issue hardware prefetches here return id; + } + else { + assert(0); + } } else { return -1; -- cgit v1.2.3 From 3bb2fcfc8438d77efbab542cd93f4a9f09478da6 Mon Sep 17 00:00:00 2001 From: Derek Hower Date: Wed, 9 Sep 2009 12:39:10 -0500 Subject: ruby: made Locked read/write atomic requests within ruby --- src/mem/ruby/system/Sequencer.cc | 6 ------ 1 file changed, 6 deletions(-) (limited to 'src/mem/ruby/system/Sequencer.cc') diff --git a/src/mem/ruby/system/Sequencer.cc b/src/mem/ruby/system/Sequencer.cc index 9549cc340..a342550ef 100644 --- a/src/mem/ruby/system/Sequencer.cc +++ b/src/mem/ruby/system/Sequencer.cc @@ -461,14 +461,8 @@ void Sequencer::issueRequest(const RubyRequest& request) { ctype = CacheRequestType_ST; break; case RubyRequestType_Locked_Read: - ctype = CacheRequestType_ST; - break; case RubyRequestType_Locked_Write: - ctype = CacheRequestType_ST; - break; case RubyRequestType_RMW_Read: - ctype = CacheRequestType_ATOMIC; - break; case RubyRequestType_RMW_Write: ctype = CacheRequestType_ATOMIC; break; -- cgit v1.2.3 From 0637fe0bfd626711b2535cbdf5c40ba67fa7cdfe Mon Sep 17 00:00:00 2001 From: Derek Hower Date: Thu, 10 Sep 2009 21:19:54 -0500 Subject: ruby: removed SMT-related Sequencer assert --- src/mem/ruby/system/Sequencer.cc | 1 - 1 file changed, 1 deletion(-) (limited to 'src/mem/ruby/system/Sequencer.cc') diff --git a/src/mem/ruby/system/Sequencer.cc b/src/mem/ruby/system/Sequencer.cc index a342550ef..7d032992a 100644 --- a/src/mem/ruby/system/Sequencer.cc +++ b/src/mem/ruby/system/Sequencer.cc @@ -375,7 +375,6 @@ bool Sequencer::isReady(const RubyRequest& request, bool dont_set) { return false; } - assert(request.proc_id != 100); if (m_servicing_atomic != 200 && m_servicing_atomic != request.proc_id) { assert(m_atomics_counter > 0); return false; -- cgit v1.2.3