Commit 38a58d5a authored by Kevin Modzelewski's avatar Kevin Modzelewski

I think I understand what I was doing 6 weeks ago... let's see if I'm right

parent 37b5d25f
...@@ -1205,6 +1205,8 @@ void RewriterVar::bumpUse() { ...@@ -1205,6 +1205,8 @@ void RewriterVar::bumpUse() {
} }
this->locations.clear(); this->locations.clear();
} else {
assert(vrefcount > 0);
} }
} }
......
...@@ -251,8 +251,15 @@ public: ...@@ -251,8 +251,15 @@ public:
assert(vrefcount > 0); assert(vrefcount > 0);
vrefcount--; vrefcount--;
if (reftype == RefType::OWNED && vrefcount == 0) if (vrefcount == 0) {
decref(); // Assert that there are no more uses of the this at the machine-code level.
// This is kind of weird to cross this abstraction boundary like this, but
// I think it's a good safety net.
assert(next_use == uses.size());
if (reftype == RefType::OWNED)
decref();
}
return this; return this;
} }
...@@ -262,10 +269,17 @@ public: ...@@ -262,10 +269,17 @@ public:
vrefcount--; vrefcount--;
if (reftype == RefType::OWNED && vrefcount == 0) { if (reftype == RefType::OWNED && vrefcount == 0) {
// handoff, do nothing // handoff, do nothing;
// we skip this incref because we skipped the decref in decvref (by touching vrefcount manually)
} else { } else {
incref(); incref();
} }
if (vrefcount == 0) {
// See the comment in decvref.
// This is similar, except that we want there to be exactly one more use of this variable:
// whatever consumes the vref. We want that to happen after the materializeVref call.
}
return this; return this;
} }
...@@ -274,16 +288,17 @@ public: ...@@ -274,16 +288,17 @@ public:
bool isConstant() { return is_constant; } bool isConstant() { return is_constant; }
protected:
void incref();
void decref();
void xdecref();
private: private:
Rewriter* rewriter; Rewriter* rewriter;
llvm::SmallVector<Location, 4> locations; llvm::SmallVector<Location, 4> locations;
bool isInLocation(Location l); bool isInLocation(Location l);
void incref();
void decref();
void xdecref();
// uses is a vector of the indices into the Rewriter::actions vector // uses is a vector of the indices into the Rewriter::actions vector
// indicated the actions that use this variable. // indicated the actions that use this variable.
// During the assembly-emitting phase, next_use is used to keep track of the next // During the assembly-emitting phase, next_use is used to keep track of the next
......
...@@ -328,8 +328,8 @@ RewriterVar* JitFragmentWriter::emitGetGlobal(Box* global, BoxedString* s) { ...@@ -328,8 +328,8 @@ RewriterVar* JitFragmentWriter::emitGetGlobal(Box* global, BoxedString* s) {
} }
RewriterVar* args[] = { NULL, NULL }; RewriterVar* args[] = { NULL, NULL };
args[0] = imm(global)->asBorrowed()->decvref(); args[0] = imm(global);
args[1] = imm(s)->asBorrowed()->decvref(); args[1] = imm(s);
return emitPPCall((void*)getGlobal, args, 2, 512)->setType(RefType::OWNED); return emitPPCall((void*)getGlobal, args, 2, 512)->setType(RefType::OWNED);
} }
...@@ -550,7 +550,7 @@ void JitFragmentWriter::emitSetItemName(BoxedString* s, RewriterVar* v) { ...@@ -550,7 +550,7 @@ void JitFragmentWriter::emitSetItemName(BoxedString* s, RewriterVar* v) {
emitSetItem(emitGetBoxedLocals(), imm(s), v); emitSetItem(emitGetBoxedLocals(), imm(s), v);
} }
void JitFragmentWriter::emitSetLocal(InternedString s, int vreg, bool set_closure, RewriterVar* v) { void JitFragmentWriter::emitSetLocal(InternedString s, int vreg, bool set_closure, STOLEN(RewriterVar*) v) {
assert(vreg >= 0); assert(vreg >= 0);
if (set_closure) { if (set_closure) {
assert(0 && "check refcounting"); assert(0 && "check refcounting");
...@@ -566,7 +566,7 @@ void JitFragmentWriter::emitSetLocal(InternedString s, int vreg, bool set_closur ...@@ -566,7 +566,7 @@ void JitFragmentWriter::emitSetLocal(InternedString s, int vreg, bool set_closur
vregs_array->setAttr(8 * vreg, v); vregs_array->setAttr(8 * vreg, v);
// XXX: this either needs to be an xdecref or we should check liveness analysis. // XXX: this either needs to be an xdecref or we should check liveness analysis.
prev->decvref(); prev->decvref();
//prev->xdecref(); //prev->xdecvref();
} }
} }
......
...@@ -264,7 +264,7 @@ public: ...@@ -264,7 +264,7 @@ public:
void emitSetGlobal(Box* global, BoxedString* s, RewriterVar* v); void emitSetGlobal(Box* global, BoxedString* s, RewriterVar* v);
void emitSetItemName(BoxedString* s, RewriterVar* v); void emitSetItemName(BoxedString* s, RewriterVar* v);
void emitSetItem(RewriterVar* target, RewriterVar* slice, RewriterVar* value); void emitSetItem(RewriterVar* target, RewriterVar* slice, RewriterVar* value);
void emitSetLocal(InternedString s, int vreg, bool set_closure, RewriterVar* v); void emitSetLocal(InternedString s, int vreg, bool set_closure, STOLEN(RewriterVar*) v);
void emitSideExit(STOLEN(RewriterVar*) v, Box* cmp_value, CFGBlock* next_block); void emitSideExit(STOLEN(RewriterVar*) v, Box* cmp_value, CFGBlock* next_block);
void emitUncacheExcInfo(); void emitUncacheExcInfo();
......
...@@ -3564,6 +3564,22 @@ void rearrangeArgumentsInternal(ParamReceiveSpec paramspec, const ParamNames* pa ...@@ -3564,6 +3564,22 @@ void rearrangeArgumentsInternal(ParamReceiveSpec paramspec, const ParamNames* pa
Py_INCREF(oargs[i]); Py_INCREF(oargs[i]);
} }
} }
if (rewrite_args) {
// TODO should probably rethink the whole vrefcounting thing here.
// which ones actually need new vrefs?
if (num_output_args >= 1)
rewrite_args->arg1->incvref();
if (num_output_args >= 2)
rewrite_args->arg2->incvref();
if (num_output_args >= 3)
rewrite_args->arg3->incvref();
if (num_output_args >= 3) {
RELEASE_ASSERT(0, "not sure what to do here\n");
for (int i = 0; i < num_output_args - 3; i++) {
rewrite_args->args->getAttr(i * sizeof(Box*))->incref();
}
}
}
return; return;
} }
...@@ -4729,8 +4745,6 @@ Box* binopInternal(Box* lhs, Box* rhs, int op_type, bool inplace, BinopRewriteAr ...@@ -4729,8 +4745,6 @@ Box* binopInternal(Box* lhs, Box* rhs, int op_type, bool inplace, BinopRewriteAr
if (rewrite_args) { if (rewrite_args) {
CallattrRewriteArgs srewrite_args(rewrite_args->rewriter, rewrite_args->lhs, rewrite_args->destination); CallattrRewriteArgs srewrite_args(rewrite_args->rewriter, rewrite_args->lhs, rewrite_args->destination);
srewrite_args.arg1 = rewrite_args->rhs; srewrite_args.arg1 = rewrite_args->rhs;
rewrite_args->lhs->incvref();
rewrite_args->rhs->incvref();
lrtn = callattrInternal1<CXX, REWRITABLE>(lhs, op_name, CLASS_ONLY, &srewrite_args, ArgPassSpec(1), rhs); lrtn = callattrInternal1<CXX, REWRITABLE>(lhs, op_name, CLASS_ONLY, &srewrite_args, ArgPassSpec(1), rhs);
if (!srewrite_args.isSuccessful()) { if (!srewrite_args.isSuccessful()) {
...@@ -4754,8 +4768,6 @@ Box* binopInternal(Box* lhs, Box* rhs, int op_type, bool inplace, BinopRewriteAr ...@@ -4754,8 +4768,6 @@ Box* binopInternal(Box* lhs, Box* rhs, int op_type, bool inplace, BinopRewriteAr
if (lrtn) { if (lrtn) {
if (lrtn != NotImplemented) { if (lrtn != NotImplemented) {
if (rewrite_args) { if (rewrite_args) {
rewrite_args->lhs->decvref();
rewrite_args->rhs->decvref();
assert(rewrite_args->out_rtn); assert(rewrite_args->out_rtn);
rewrite_args->out_success = true; rewrite_args->out_success = true;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment