‘nix-store --export’. * Add a Perl module that provides the functionality of ‘nix-copy-closure --to’. This is used by build-remote.pl so it no longer needs to start a separate nix-copy-closure process. Also, it uses the Perl API to do the export, so it doesn't need to start a separate nix-store process either. As a result, nix-copy-closure and build-remote.pl should no longer fail on very large closures due to an "Argument list too long" error. (Note that having very many dependencies in a single derivation can still fail because the environment can become too large. Can't be helped though.)
		
			
				
	
	
		
			161 lines
		
	
	
	
		
			4 KiB
		
	
	
	
		
			Text
		
	
	
	
	
	
			
		
		
	
	
			161 lines
		
	
	
	
		
			4 KiB
		
	
	
	
		
			Text
		
	
	
	
	
	
| #include "EXTERN.h"
 | |
| #include "perl.h"
 | |
| #include "XSUB.h"
 | |
| 
 | |
| /* Prevent a clash between some Perl and libstdc++ macros. */
 | |
| #undef do_open
 | |
| #undef do_close
 | |
| 
 | |
| #include <store-api.hh>
 | |
| #include <globals.hh>
 | |
| #include <misc.hh>
 | |
| #include <util.hh>
 | |
| 
 | |
| 
 | |
| using namespace nix;
 | |
| 
 | |
| 
 | |
| void doInit() 
 | |
| {
 | |
|     if (!store) {
 | |
|         try {
 | |
|             setDefaultsFromEnvironment();
 | |
|             store = openStore();
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
|     }
 | |
| }
 | |
| 
 | |
| 
 | |
| MODULE = Nix::Store PACKAGE = Nix::Store
 | |
| PROTOTYPES: ENABLE
 | |
| 
 | |
| 
 | |
| void init()
 | |
|     CODE:
 | |
|         doInit();
 | |
| 
 | |
| 
 | |
| int isValidPath(char * path)
 | |
|     CODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             RETVAL = store->isValidPath(path);
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
|     OUTPUT:
 | |
|         RETVAL
 | |
| 
 | |
| 
 | |
| SV * queryReferences(char * path)
 | |
|     PPCODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             PathSet paths;
 | |
|             store->queryReferences(path, paths);
 | |
|             for (PathSet::iterator i = paths.begin(); i != paths.end(); ++i)
 | |
|                 XPUSHs(sv_2mortal(newSVpv(i->c_str(), 0)));
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
| 
 | |
| 
 | |
| SV * queryPathHash(char * path)
 | |
|     PPCODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             Hash hash = store->queryPathHash(path);
 | |
|             string s = "sha256:" + printHash(hash);
 | |
|             XPUSHs(sv_2mortal(newSVpv(s.c_str(), 0)));
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
| 
 | |
| 
 | |
| SV * queryDeriver(char * path)
 | |
|     PPCODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             Path deriver = store->queryDeriver(path);
 | |
|             if (deriver == "") XSRETURN_UNDEF;
 | |
|             XPUSHs(sv_2mortal(newSVpv(deriver.c_str(), 0)));
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
| 
 | |
| 
 | |
| SV * queryPathInfo(char * path)
 | |
|     PPCODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             ValidPathInfo info = store->queryPathInfo(path);
 | |
|             if (info.deriver == "")
 | |
|                 XPUSHs(&PL_sv_undef);
 | |
|             else
 | |
|                 XPUSHs(sv_2mortal(newSVpv(info.deriver.c_str(), 0)));
 | |
|             string s = "sha256:" + printHash(info.hash);
 | |
|             XPUSHs(sv_2mortal(newSVpv(s.c_str(), 0)));
 | |
|             mXPUSHi(info.registrationTime);
 | |
|             mXPUSHi(info.narSize);
 | |
|             AV * arr = newAV();
 | |
|             for (PathSet::iterator i = info.references.begin(); i != info.references.end(); ++i)
 | |
|                 av_push(arr, newSVpv(i->c_str(), 0));
 | |
|             XPUSHs(sv_2mortal(newRV((SV *) arr)));
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
| 
 | |
| 
 | |
| SV * computeFSClosure(int flipDirection, int includeOutputs, ...)
 | |
|     PPCODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             PathSet paths;
 | |
|             for (int n = 2; n < items; ++n)
 | |
|                 computeFSClosure(*store, SvPV_nolen(ST(n)), paths, flipDirection, includeOutputs);
 | |
|             for (PathSet::iterator i = paths.begin(); i != paths.end(); ++i)
 | |
|                 XPUSHs(sv_2mortal(newSVpv(i->c_str(), 0)));
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
| 
 | |
| 
 | |
| SV * topoSortPaths(...)
 | |
|     PPCODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             PathSet paths;
 | |
|             for (int n = 0; n < items; ++n) paths.insert(SvPV_nolen(ST(n)));
 | |
|             Paths sorted = topoSortPaths(*store, paths);
 | |
|             for (Paths::iterator i = sorted.begin(); i != sorted.end(); ++i)
 | |
|                 XPUSHs(sv_2mortal(newSVpv(i->c_str(), 0)));
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
| 
 | |
| 
 | |
| SV * followLinksToStorePath(char * path)
 | |
|     CODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             RETVAL = newSVpv(followLinksToStorePath(path).c_str(), 0);
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 | |
|     OUTPUT:
 | |
|         RETVAL
 | |
| 
 | |
| 
 | |
| void exportPaths(int fd, int sign, ...)
 | |
|     PPCODE:
 | |
|         try {
 | |
|             doInit();
 | |
|             Paths paths;
 | |
|             for (int n = 2; n < items; ++n) paths.push_back(SvPV_nolen(ST(n)));
 | |
|             FdSink sink(fd);
 | |
|             exportPaths(*store, paths, sign, sink);
 | |
|         } catch (Error & e) {
 | |
|             croak(e.what());
 | |
|         }
 |