Function fxMapArchive

xs/sources/xsAPI.c:2182–2361

}

void* fxMapArchive(txMachine* the, txPreparation* preparation, void* archive, size_t bufferSize, txArchiveRead read, txArchiveWrite write)
{
	txMapper mapper;
	txMapper* self = &mapper;
	Atom atom;
	txU1* p;
	txU1* q;
	txU1 major = 0, minor = 0, patch = 0;
	txID id;
	txID c, i;
	txFlag clean;

	c_memset(self, 0, sizeof(txMapper));
	if (c_setjmp(self->jmp_buf) == 0) {
		self->machine = the;
		self->archive = archive;
		self->read = read;
		self->write = write;
		
		self->scratchSize = 1024;
		self->scratch = c_malloc(self->scratchSize + bufferSize);
		mxElseNotEnoughMemory(self->scratch != C_NULL);
		self->bufferSize = bufferSize;
		self->buffer = self->scratch + self->scratchSize;
		
		mxElseFatalCheck(self->read(self->archive, 0, self->buffer, mxArchiveHeaderSize));
	
		p = self->buffer;
		mxMapAtom(p);
		if (atom.atomType != XS_ATOM_ARCHIVE) {
			self->archive = NULL;
			goto bail;
		}
		self->size = atom.atomSize;
		mxMapAtom(p);
		mxElseFatalCheck(atom.atomType == XS_ATOM_VERSION);
		mxElseFatalCheck(atom.atomSize == sizeof(Atom) + 4);
		major = *p++;
		minor = *p++;
		patch = *p++;
		txU2 mod = (major << 8) + minor;
		txU2 min = (XS_MOD_COMPATIBLE_MAJOR_VERSION << 8) + XS_MOD_COMPATIBLE_MINOR_VERSION;
		txU2 max = (XS_MAJOR_VERSION << 8) + XS_MINOR_VERSION;
		mxElseIncompatibleMod((min <= mod) && (mod <= max));
		p++;
		mxMapAtom(p);
		mxElseFatalCheck(atom.atomType == XS_ATOM_SIGNATURE);
		mxElseFatalCheck(atom.atomSize == sizeof(Atom) + XS_DIGEST_SIZE);
		p += XS_DIGEST_SIZE;
		
		self->bufferOffset = mxArchiveHeaderSize;
		if (self->bufferSize > self->size)
			self->bufferSize = self->size;
		mxElseFatalCheck(self->read(self->archive, mxArchiveHeaderSize, p, self->bufferSize - mxArchiveHeaderSize));
	
		fxMapperReadAtom(self, &atom);
		mxElseFatalCheck(atom.atomType == XS_ATOM_NAME);
		fxMapperSkip(self, atom.atomSize - sizeof(Atom));