Function AsyncIndexer

shock-server/node/index.go:15–171

(idxType string, nid string, colNum int, ctx context.Context)

)

func AsyncIndexer(idxType string, nid string, colNum int, ctx context.Context) {
	// use function closure to get current value of err at return time
	var err error
	defer func() {
		locker.IndexLockMgr.Error(nid, idxType, err)
	}()

	// get node - this is read only
	var n *Node
	n, err = Load(nid)
	if err != nil {
		return
	}

	avgSize := int64(0)
	subsetSize := int64(0)
	count := int64(0)
	indexFormat := ""
	subsetName := ""

	var f *os.File
	if idxType == "bai" {
		err = index.CreateBamIndex(n.FilePath())
		if err != nil {
			return
		}
		indexFormat = "bai"
	} else if idxType == "column" {
		idxType = fmt.Sprintf("%s%d", idxType, colNum)
		f, err = os.Open(n.FilePath())
		if err != nil {
			return
		}
		defer f.Close()
		idxer := index.NewColumnIndexer(f)
		count, indexFormat, err = index.CreateColumnIndex(&idxer, colNum, n.IndexPath()+"/"+idxType+".idx")
		if err != nil {
			return
		}
	} else if idxType == "subset" {
		// Utilizing the multipart form parser since we need to upload a file.
		var params map[string]string
		var files file.FormFiles
		params, files, err = request.ParseMultipartForm(ctx.HttpRequest())
		// clean up temp dir !!
		defer file.RemoveAllFormFiles(files)
		if err != nil {
			return
		}

		parentIndex, hasParent := params["parent_index"]
		if !hasParent {
			err = errors.New("Index type subset requires parent_index param.")
			return
		} else if _, has := n.Indexes[parentIndex]; !has {
			err = fmt.Errorf("Node %s does not have index of type %s.", n.Id, parentIndex)
			return
		}