aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorEelco Dolstra <eelco.dolstra@logicblox.com>2016-08-29 17:28:20 +0200
committerEelco Dolstra <eelco.dolstra@logicblox.com>2016-08-29 19:36:54 +0200
commit26d92017d3b36cff940dcb7d1611c42232edb81a (patch)
tree856350170478111ea3a61b3b457e4fbee40826ce /src
parentc0a7b84748d5e27e6804117b8a57ce71269c3c66 (diff)
Add builtin function "partition"
The implementation of "partition" in Nixpkgs is O(n^2) (because of the use of ++), and for some reason was causing stack overflows in multi-threaded evaluation (not sure why). This reduces "nix-env -qa --drv-path" runtime by 0.197s and memory usage by 298 MiB (in non-Boehm mode).
Diffstat (limited to 'src')
-rw-r--r--src/libexpr/eval.cc2
-rw-r--r--src/libexpr/eval.hh3
-rw-r--r--src/libexpr/json-to-value.cc9
-rw-r--r--src/libexpr/primops.cc35
-rw-r--r--src/libexpr/value.hh9
5 files changed, 48 insertions, 10 deletions
diff --git a/src/libexpr/eval.cc b/src/libexpr/eval.cc
index ace0517fb..22396865f 100644
--- a/src/libexpr/eval.cc
+++ b/src/libexpr/eval.cc
@@ -293,6 +293,8 @@ EvalState::EvalState(const Strings & _searchPath, ref<Store> store)
, sColumn(symbols.create("column"))
, sFunctor(symbols.create("__functor"))
, sToString(symbols.create("__toString"))
+ , sRight(symbols.create("right"))
+ , sWrong(symbols.create("wrong"))
, store(store)
, baseEnv(allocEnv(128))
, staticBaseEnv(false, 0)
diff --git a/src/libexpr/eval.hh b/src/libexpr/eval.hh
index 47e4d99bf..6f1befa2a 100644
--- a/src/libexpr/eval.hh
+++ b/src/libexpr/eval.hh
@@ -71,7 +71,8 @@ public:
const Symbol sWith, sOutPath, sDrvPath, sType, sMeta, sName, sValue,
sSystem, sOverrides, sOutputs, sOutputName, sIgnoreNulls,
- sFile, sLine, sColumn, sFunctor, sToString;
+ sFile, sLine, sColumn, sFunctor, sToString,
+ sRight, sWrong;
Symbol sDerivationNix;
/* If set, force copying files to the Nix store even if they
diff --git a/src/libexpr/json-to-value.cc b/src/libexpr/json-to-value.cc
index 1daf84600..f671802bc 100644
--- a/src/libexpr/json-to-value.cc
+++ b/src/libexpr/json-to-value.cc
@@ -12,15 +12,6 @@ static void skipWhitespace(const char * & s)
}
-#if HAVE_BOEHMGC
-typedef std::vector<Value *, gc_allocator<Value *> > ValueVector;
-typedef std::map<Symbol, Value *, std::less<Symbol>, gc_allocator<Value *> > ValueMap;
-#else
-typedef std::vector<Value *> ValueVector;
-typedef std::map<Symbol, Value *> ValueMap;
-#endif
-
-
static string parseJSONString(const char * & s)
{
string res;
diff --git a/src/libexpr/primops.cc b/src/libexpr/primops.cc
index 51ee16353..5c0b77c15 100644
--- a/src/libexpr/primops.cc
+++ b/src/libexpr/primops.cc
@@ -1443,6 +1443,40 @@ static void prim_sort(EvalState & state, const Pos & pos, Value * * args, Value
}
+static void prim_partition(EvalState & state, const Pos & pos, Value * * args, Value & v)
+{
+ state.forceFunction(*args[0], pos);
+ state.forceList(*args[1], pos);
+
+ auto len = args[1]->listSize();
+
+ ValueVector right, wrong;
+
+ for (unsigned int n = 0; n < len; ++n) {
+ auto vElem = args[1]->listElems()[n];
+ state.forceValue(*vElem);
+ Value res;
+ state.callFunction(*args[0], *vElem, res, pos);
+ if (state.forceBool(res))
+ right.push_back(vElem);
+ else
+ wrong.push_back(vElem);
+ }
+
+ state.mkAttrs(v, 2);
+
+ Value * vRight = state.allocAttr(v, state.sRight);
+ state.mkList(*vRight, right.size());
+ memcpy(vRight->listElems(), right.data(), sizeof(Value *) * right.size());
+
+ Value * vWrong = state.allocAttr(v, state.sWrong);
+ state.mkList(*vWrong, wrong.size());
+ memcpy(vWrong->listElems(), wrong.data(), sizeof(Value *) * wrong.size());
+
+ v.attrs->sort();
+}
+
+
/*************************************************************
* Integer arithmetic
*************************************************************/
@@ -1881,6 +1915,7 @@ void EvalState::createBaseEnv()
addPrimOp("__all", 2, prim_all);
addPrimOp("__genList", 2, prim_genList);
addPrimOp("__sort", 2, prim_sort);
+ addPrimOp("__partition", 2, prim_partition);
// Integer arithmetic
addPrimOp("__add", 2, prim_add);
diff --git a/src/libexpr/value.hh b/src/libexpr/value.hh
index f5e485748..048522016 100644
--- a/src/libexpr/value.hh
+++ b/src/libexpr/value.hh
@@ -250,4 +250,13 @@ void mkPath(Value & v, const char * s);
size_t valueSize(Value & v);
+#if HAVE_BOEHMGC
+typedef std::vector<Value *, gc_allocator<Value *> > ValueVector;
+typedef std::map<Symbol, Value *, std::less<Symbol>, gc_allocator<Value *> > ValueMap;
+#else
+typedef std::vector<Value *> ValueVector;
+typedef std::map<Symbol, Value *> ValueMap;
+#endif
+
+
}