ggml.go 24.7 KB
Newer Older
Michael Yang's avatar
Michael Yang committed
1
2
package ggml

3
4
5
6
7
8
// #cgo CPPFLAGS: -I${SRCDIR}/ggml/include
// #include <stdlib.h>
// #include <stdint.h>
// #include "ggml.h"
// #include "ggml-cpu.h"
// #include "ggml-backend.h"
Michael Yang's avatar
Michael Yang committed
9
10
11
import "C"

import (
12
	"errors"
Michael Yang's avatar
Michael Yang committed
13
14
15
	"fmt"
	"io"
	"log/slog"
16
	"maps"
Michael Yang's avatar
Michael Yang committed
17
	"os"
18
19
20
21
	"slices"
	"strconv"
	"strings"
	"unicode"
Michael Yang's avatar
Michael Yang committed
22
23
24
25
26
	"unsafe"

	"github.com/ollama/ollama/format"
	fs "github.com/ollama/ollama/fs/ggml"
	"github.com/ollama/ollama/ml"
27
	ggml "github.com/ollama/ollama/ml/backend/ggml/ggml/src"
Michael Yang's avatar
Michael Yang committed
28
29
30
	"golang.org/x/sync/errgroup"
)

Michael Yang's avatar
Michael Yang committed
31
32
33
34
35
func devices() []*C.struct_ggml_backend_device {
	ggml.OnceLoad()
	ds := make([]*C.struct_ggml_backend_device, C.ggml_backend_dev_count())
	for i := range ds {
		ds[i] = C.ggml_backend_dev_get(C.size_t(i))
Michael Yang's avatar
Michael Yang committed
36
	}
Michael Yang's avatar
Michael Yang committed
37
38

	return ds
39
}
Michael Yang's avatar
Michael Yang committed
40
41

type Backend struct {
42
43
44
	meta    *fs.GGML
	sched   *C.struct_ggml_backend_sched
	tensors map[string]*C.struct_ggml_tensor
Michael Yang's avatar
Michael Yang committed
45
46

	// input is the backend used for inputs
47
	input *C.struct_ggml_backend_buffer_type
Michael Yang's avatar
Michael Yang committed
48
49

	// output is the backend used for outputs
50
	output *C.struct_ggml_backend_buffer_type
Michael Yang's avatar
Michael Yang committed
51
52

	// layers is the backend used for repeating layers
53
	layers map[int]*C.struct_ggml_backend_buffer_type
54

55
	flashAttention bool
Michael Yang's avatar
Michael Yang committed
56
57
58

	// maxGraphNodes is the maximum allowed number of graph nodes in this scheduler
	maxGraphNodes int
Michael Yang's avatar
Michael Yang committed
59
60
}

61
func New(r *os.File, params ml.BackendParams) (ml.Backend, error) {
Michael Yang's avatar
Michael Yang committed
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
	meta, n, err := fs.Decode(r, -1)
	if err != nil {
		return nil, err
	}

	slog.Info(
		"",
		"architecture", meta.KV().Architecture(),
		"file_type", meta.KV().FileType(),
		"name", meta.KV().String("general.name"),
		"description", meta.KV().String("general.description"),
		"num_tensors", len(meta.Tensors().Items()),
		"num_key_values", len(meta.KV()),
	)

77
	type deviceBufferType struct {
78
79
80
81
82
		d   *C.struct_ggml_backend_device
		bts []*C.struct_ggml_backend_buffer_type
	}

	var cpus, accels, gpus []*C.struct_ggml_backend_device
Michael Yang's avatar
Michael Yang committed
83
	for _, d := range devices() {
84
85
		switch C.ggml_backend_dev_type(d) {
		case C.GGML_BACKEND_DEVICE_TYPE_CPU:
86
87
88
89
			if len(cpus) == 0 {
				// only the first cpu device should be used
				cpus = append(cpus, d)
			}
90
91
		case C.GGML_BACKEND_DEVICE_TYPE_ACCEL:
			accels = append(accels, d)
Michael Yang's avatar
Michael Yang committed
92
		case C.GGML_BACKEND_DEVICE_TYPE_GPU:
93
			gpus = append(gpus, d)
Michael Yang's avatar
Michael Yang committed
94
95
96
		}
	}

Michael Yang's avatar
Michael Yang committed
97
	// create list of buffer types for the cpu
Michael Yang's avatar
Michael Yang committed
98
	cpuDeviceBufferType := deviceBufferType{d: C.ggml_backend_dev_by_type(C.GGML_BACKEND_DEVICE_TYPE_CPU)}
99
100
101
102
	for _, d := range append(accels, append(gpus, cpus...)...) {
		switch C.ggml_backend_dev_type(d) {
		case C.GGML_BACKEND_DEVICE_TYPE_CPU,
			C.GGML_BACKEND_DEVICE_TYPE_ACCEL:
Michael Yang's avatar
Michael Yang committed
103
			cpuDeviceBufferType.bts = append(cpuDeviceBufferType.bts, C.ggml_backend_dev_buffer_type(d))
Michael Yang's avatar
Michael Yang committed
104
		}
105
106
	}

Michael Yang's avatar
Michael Yang committed
107
	// create list of buffer types for each gpu
108
	var gpuDeviceBufferTypes []deviceBufferType
109
110
	for _, d := range gpus {
		bt := C.ggml_backend_dev_buffer_type(d)
111
		gpuDeviceBufferTypes = append(gpuDeviceBufferTypes, deviceBufferType{
112
			d:   d,
Michael Yang's avatar
Michael Yang committed
113
			bts: append([]*C.struct_ggml_backend_buffer_type{bt}, cpuDeviceBufferType.bts...),
114
		})
Michael Yang's avatar
Michael Yang committed
115
116
	}

Michael Yang's avatar
Michael Yang committed
117
118
119
120
121
	useDefaultSplit := true
	for _, s := range params.TensorSplit {
		if s != 0 {
			useDefaultSplit = false
			break
122
		}
Michael Yang's avatar
Michael Yang committed
123
	}
124

Michael Yang's avatar
Michael Yang committed
125
126
127
128
	// calculate splits
	splits := make([]float32, len(gpus))
	if useDefaultSplit {
		// default: split on free memory
129
130
131
132
133
		for i := range splits {
			var free, total C.size_t
			C.ggml_backend_dev_memory(gpus[i], &free, &total)
			splits[i] = float32(free)
		}
Michael Yang's avatar
Michael Yang committed
134
135
	} else {
		splits = params.TensorSplit
136
137
138
	}

	var sum float32
Michael Yang's avatar
Michael Yang committed
139
	// cumulative sum of all splits
140
141
142
143
144
	for i := range splits {
		sum += splits[i]
		splits[i] = sum
	}

Michael Yang's avatar
Michael Yang committed
145
	// normalize splits
146
	for i := range splits {
147
		splits[i] /= sum
148
149
	}

Michael Yang's avatar
Michael Yang committed
150
	// inputs always use cpu
Michael Yang's avatar
Michael Yang committed
151
	input := cpuDeviceBufferType
152

153
	blocks := int(meta.KV().BlockCount())
Michael Yang's avatar
Michael Yang committed
154
155
156
157

	// define a range of gpu layers. anything outside of this range is assigned to the cpu
	gpuRangeStart := max(0, blocks-params.NumGPULayers)
	gpuRangeStop := min(gpuRangeStart+params.NumGPULayers, blocks+1)
Michael Yang's avatar
Michael Yang committed
158
	assignLayer := func(i int) deviceBufferType {
Michael Yang's avatar
Michael Yang committed
159
		if i < gpuRangeStart || i >= gpuRangeStop {
Michael Yang's avatar
Michael Yang committed
160
			return cpuDeviceBufferType
161
		}
162

Michael Yang's avatar
Michael Yang committed
163
		index := slices.IndexFunc(splits, func(f float32) bool { return float32(i-gpuRangeStart)/float32(gpuRangeStop-gpuRangeStart) < f })
164
		if index < 0 || index >= len(gpuDeviceBufferTypes) {
Michael Yang's avatar
Michael Yang committed
165
			return cpuDeviceBufferType
166
167
168
		}

		return gpuDeviceBufferTypes[index]
169
170
	}

Michael Yang's avatar
Michael Yang committed
171
	// repeating layers are assigned based on their index in reverse order, e.g. i / (block_count + 1)
172
	layers := make([]deviceBufferType, blocks)
173
	for i := range layers {
174
		layers[i] = assignLayer(i)
175
176
	}

Michael Yang's avatar
Michael Yang committed
177
	// outputs are assigned iff allowed by splits and configured number of gpu layers
178
	output := assignLayer(blocks)
179
180
181

	maxTensors := len(meta.Tensors().Items())
	maxTensors += 1
Michael Yang's avatar
Michael Yang committed
182
	// each layer has at most 2 extra tensors for rope operations
183
184
	maxTensors += blocks * 2

185
186
187
188
189
	type tensor struct {
		source *fs.Tensor
		target string
	}

Michael Yang's avatar
Michael Yang committed
190
	// some tensors are mapped to different names so keep a list
191
192
	targets := make(map[string][]string)

Michael Yang's avatar
Michael Yang committed
193
	// contexts are shared by tensors of the same buffer type
194
	ctxs := make(map[*C.struct_ggml_backend_buffer_type]*C.struct_ggml_context)
195
	createTensor := func(t tensor, bts []*C.struct_ggml_backend_buffer_type) *C.struct_ggml_tensor {
196
197
198
199
200
201
202
		for _, bt := range bts {
			if _, ok := ctxs[bt]; !ok {
				ctxs[bt] = C.ggml_init(C.struct_ggml_init_params{
					mem_size: C.ggml_tensor_overhead() * C.size_t(maxTensors),
					no_alloc: true,
				})
			}
Michael Yang's avatar
Michael Yang committed
203

204
205
206
207
208
209
210
211
			targets[t.source.Name] = append(targets[t.source.Name], t.target)

			name := t.source.Name
			if t.target != "" {
				name = t.target
			}

			cname := C.CString(name)
Michael Yang's avatar
Michael Yang committed
212
			defer C.free(unsafe.Pointer(cname))
213
214
215
216
			if tt := C.ggml_get_tensor(ctxs[bt], cname); tt != nil {
				return tt
			}

217
			tt := C.ggml_new_tensor(ctxs[bt], t.source.Kind, C.int(len(t.source.Shape)), (*C.int64_t)(unsafe.Pointer(&t.source.Shape[0])))
Michael Yang's avatar
Michael Yang committed
218
219
			C.ggml_set_name(tt, cname)

220
			slog.Debug("created tensor", "name", name, "shape", t.source.Shape, "dtype", t.source.Kind, "buffer_type", C.GoString(C.ggml_backend_buft_name(bt)))
221
222
223
224
225
			//nolint:staticcheck // TODO: check if buffer type supports this tensor
			return tt
		}

		return nil
Michael Yang's avatar
Michael Yang committed
226
227
	}

228
	contains := func(s string, parts ...string) bool {
229
230
231
232
233
234
235
236
		split := strings.Split(s, ".")
		for _, part := range parts {
			if slices.Contains(split, part) {
				return true
			}
		}

		return false
Michael Yang's avatar
Michael Yang committed
237
238
	}

239
240
	for _, t := range meta.Tensors().Items() {
		switch {
241
		case contains(t.Name, "position_embd", "token_embd", "token_norm_embd", "token_types"):
242
			createTensor(tensor{source: t}, input.bts)
Michael Yang's avatar
Michael Yang committed
243
244
245
			if _, ok := meta.Tensors().GroupLayers()["output"]; !ok && t.Name == "token_embd.weight" {
				createTensor(tensor{source: t, target: "output.weight"}, output.bts)
			}
246
		case contains(t.Name, "cls", "output", "output_norm"):
247
			createTensor(tensor{source: t}, output.bts)
248
		case strings.HasPrefix(t.Name, "v.") || strings.HasPrefix(t.Name, "mm."):
Michael Yang's avatar
Michael Yang committed
249
			// TODO: assign vision tensors to the gpu if possible
250
			createTensor(tensor{source: t}, input.bts)
Michael Yang's avatar
Michael Yang committed
251
252
253
254
255
256
257
258
		case contains(t.Name, "rope_freqs", "rope_factors_long", "rope_factors_short"):
			// these tensors should be repeated per layer
			for i, layer := range layers {
				createTensor(tensor{
					source: t,
					target: "blk." + strconv.Itoa(i) + "." + t.Name,
				}, layer.bts)
			}
259
		default:
Michael Yang's avatar
Michael Yang committed
260
261
262
263
			layerIndex := -1
			if fields := strings.FieldsFunc(t.Name, func(r rune) bool { return !unicode.IsNumber(r) }); len(fields) > 0 {
				if i, err := strconv.Atoi(fields[0]); err == nil {
					layerIndex = i
264
				}
Michael Yang's avatar
Michael Yang committed
265
			}
266

Michael Yang's avatar
Michael Yang committed
267
268
			if layerIndex >= 0 {
				createTensor(tensor{source: t}, layers[layerIndex].bts)
269
			} else {
Michael Yang's avatar
Michael Yang committed
270
271
				// load all other tensors on the cpu
				createTensor(tensor{source: t}, input.bts)
272
273
274
			}
		}
	}
Michael Yang's avatar
Michael Yang committed
275

Michael Yang's avatar
Michael Yang committed
276
277
	// allocate buffers for each context
	bbs := make(map[*C.struct_ggml_context]*C.struct_ggml_backend_buffer, len(ctxs))
278
279
280
281
282
283
284
	for bt, c := range ctxs {
		if C.ggml_get_first_tensor(c) == nil {
			continue
		}

		b := C.ggml_backend_alloc_ctx_tensors_from_buft(c, bt)
		C.ggml_backend_buffer_set_usage(b, C.GGML_BACKEND_BUFFER_USAGE_WEIGHTS)
Michael Yang's avatar
Michael Yang committed
285
		bbs[c] = b
286
287
288
	}

	for bs := range maps.Values(bbs) {
Michael Yang's avatar
Michael Yang committed
289
		slog.Info("model weights", "buffer", C.GoString(C.ggml_backend_buffer_name(bs)), "size", format.HumanBytes2(uint64(C.ggml_backend_buffer_get_size(bs))))
290
291
	}

Michael Yang's avatar
Michael Yang committed
292
	// map tensor names to tensors for easy lookup later
293
294
295
296
297
298
299
	tensors := make(map[string]*C.struct_ggml_tensor)
	for _, c := range ctxs {
		for t := C.ggml_get_first_tensor(c); t != nil; t = C.ggml_get_next_tensor(c, t) {
			tensors[C.GoString(C.ggml_get_name(t))] = t
		}
	}

Michael Yang's avatar
Michael Yang committed
300
	// concurrently read in tensor data. uses a section reader which is safe for concurrent reads
301
	sr := io.NewSectionReader(r, int64(meta.Tensors().Offset), n-int64(meta.Tensors().Offset))
Michael Yang's avatar
Michael Yang committed
302
	var g errgroup.Group
303
	for _, t := range meta.Tensors().Items() {
304
305
306
307
308
		for _, target := range targets[t.Name] {
			g.Go(func() error {
				if target == "" {
					target = t.Name
				}
309

310
311
312
313
				tt, ok := tensors[target]
				if !ok {
					return fmt.Errorf("unassigned tensor: %s", t.Name)
				}
Michael Yang's avatar
Michael Yang committed
314

315
316
317
318
319
				bts := make([]byte, t.Size())
				n, err := io.ReadFull(io.NewSectionReader(sr, int64(t.Offset), int64(t.Size())), bts)
				if err != nil {
					return err
				}
Michael Yang's avatar
Michael Yang committed
320

321
322
323
				if n != len(bts) {
					return errors.New("short read")
				}
Michael Yang's avatar
Michael Yang committed
324

325
326
327
328
				C.ggml_backend_tensor_set(tt, unsafe.Pointer(&bts[0]), 0, C.size_t(t.Size()))
				return nil
			})
		}
Michael Yang's avatar
Michael Yang committed
329
330
	}

331
	if g.Wait() != nil {
Michael Yang's avatar
Michael Yang committed
332
333
334
		return nil, err
	}

335
336
	// map devices to backend buffer types so new tensors can be assigned to the correct device
	deviceBufferTypes := make(map[*C.struct_ggml_backend_device]*C.struct_ggml_backend_buffer_type)
Michael Yang's avatar
Michael Yang committed
337
338
339
340

	// create backends and buffer types used for the compute graph scheduler
	var schedBackends []*C.struct_ggml_backend
	var schedBufts []*C.struct_ggml_backend_buffer_type
341
342
343
344
	for _, d := range append(gpus, append(accels, cpus...)...) {
		b := C.ggml_backend_dev_init(d, nil)
		bt := C.ggml_backend_get_default_buffer_type(b)
		if d := C.ggml_backend_get_device(b); C.ggml_backend_dev_type(d) == C.GGML_BACKEND_DEVICE_TYPE_CPU && len(gpus) > 0 {
345
346
			// use the first gpu host buffer type for gpu if possible
			if hbt := C.ggml_backend_dev_host_buffer_type(gpus[0]); hbt != nil {
347
348
349
350
				bt = hbt
			}
		}

351
352
353
		deviceBufferTypes[d] = bt

		schedBackends = append(schedBackends, b)
Michael Yang's avatar
Michael Yang committed
354
		schedBufts = append(schedBufts, bt)
355

356
		slog.Info("compute graph", "backend", C.GoString(C.ggml_backend_name(b)), "buffer_type", C.GoString(C.ggml_backend_buft_name(bt)))
357
358

		if C.ggml_backend_is_cpu(b) {
Michael Yang's avatar
Michael Yang committed
359
			// set number of threads for cpu backend
Michael Yang's avatar
Michael Yang committed
360
			C.ggml_backend_cpu_set_n_threads(b, C.int(Threads(params.NumThreads)))
361
		}
362
363
	}

Michael Yang's avatar
Michael Yang committed
364
	maxGraphNodes := max(8192, len(meta.Tensors().Items())*5)
Michael Yang's avatar
Michael Yang committed
365
	return &Backend{
366
		flashAttention: params.FlashAttention,
367
368
		meta:           meta,
		tensors:        tensors,
369
		sched: C.ggml_backend_sched_new(
Michael Yang's avatar
Michael Yang committed
370
371
372
373
			(*C.ggml_backend_t)(unsafe.Pointer(&schedBackends[0])),
			(*C.ggml_backend_buffer_type_t)(unsafe.Pointer(&schedBufts[0])),
			C.int(len(schedBackends)),
			C.size_t(maxGraphNodes),
374
375
			true,
		),
376
377
378
379
		input:  deviceBufferTypes[input.d],
		output: deviceBufferTypes[output.d],
		layers: func() map[int]*C.struct_ggml_backend_buffer_type {
			m := make(map[int]*C.struct_ggml_backend_buffer_type)
380
			for i, layer := range layers {
381
				m[i] = deviceBufferTypes[layer.d]
382
383
384
			}
			return m
		}(),
Michael Yang's avatar
Michael Yang committed
385
		maxGraphNodes: maxGraphNodes,
Michael Yang's avatar
Michael Yang committed
386
387
388
389
390
391
392
393
394
395
396
397
	}, nil
}

func init() {
	ml.RegisterBackend("ggml", New)
}

func (b *Backend) Config() ml.Config {
	return b.meta.KV()
}

func (b *Backend) Get(name string) ml.Tensor {
398
399
	if t, ok := b.tensors[name]; ok {
		return &Tensor{b: b, t: t}
Michael Yang's avatar
Michael Yang committed
400
401
402
403
404
405
	}

	return nil
}

func (b *Backend) NewContext() ml.Context {
Michael Yang's avatar
Michael Yang committed
406
	return b.NewContextSize(b.maxGraphNodes)
407
408
409
}

func (b *Backend) NewContextSize(n int) ml.Context {
Jesse Gross's avatar
Jesse Gross committed
410
411
412
413
	if n > b.maxGraphNodes {
		panic(fmt.Errorf("requested number of graph nodes (%v) for new context exceeds maximum (%v)", n, b.maxGraphNodes))
	}

Michael Yang's avatar
Michael Yang committed
414
	return &Context{
415
416
		b:             b,
		maxGraphNodes: n,
417
		ctx: C.ggml_init(C.struct_ggml_init_params{
418
			mem_size: C.size_t(n)*C.ggml_tensor_overhead() + C.ggml_graph_overhead_custom(C.size_t(n), false),
419
420
			no_alloc: true,
		}),
Michael Yang's avatar
Michael Yang committed
421
422
423
	}
}

424
func (b *Backend) CacheConfig() ml.CacheConfig {
425
426
427
428
429
	if b.flashAttention {
		return ml.CacheConfig{CachePadding: 256, MaskDType: ml.DTypeF16, MaskBatchPadding: C.GGML_KQ_MASK_PAD}
	} else {
		return ml.CacheConfig{CachePadding: 32, PermutedV: true}
	}
430
431
}

Michael Yang's avatar
Michael Yang committed
432
type Context struct {
433
	b *Backend
Michael Yang's avatar
Michael Yang committed
434

435
	ctx   *C.struct_ggml_context
Michael Yang's avatar
Michael Yang committed
436
	graph *C.struct_ggml_cgraph
437

438
439
	// buft is the buffer type used for new tensors
	buft *C.struct_ggml_backend_buffer_type
440

Michael Yang's avatar
Michael Yang committed
441
	// maxGraphNodes is the maximum allowed number of graph nodes in this context
442
	maxGraphNodes int
Michael Yang's avatar
Michael Yang committed
443
444
}

Michael Yang's avatar
Michael Yang committed
445
446
func (c Context) Input() ml.Context {
	if c.b.input != nil {
447
448
449
		return &Context{
			b:             c.b,
			ctx:           c.ctx,
450
			buft:          c.b.input,
451
452
453
454
			maxGraphNodes: c.maxGraphNodes,
		}
	}

Michael Yang's avatar
Michael Yang committed
455
	return &c
456
457
}

Michael Yang's avatar
Michael Yang committed
458
459
func (c Context) Output() ml.Context {
	if c.b.output != nil {
460
461
462
		return &Context{
			b:             c.b,
			ctx:           c.ctx,
463
			buft:          c.b.output,
464
465
466
467
			maxGraphNodes: c.maxGraphNodes,
		}
	}

Michael Yang's avatar
Michael Yang committed
468
	return &c
469
470
}

Michael Yang's avatar
Michael Yang committed
471
func (c Context) Layer(i int) ml.Context {
472
	if buft, ok := c.b.layers[i]; ok {
473
474
475
		return &Context{
			b:             c.b,
			ctx:           c.ctx,
476
			buft:          buft,
477
478
479
480
			maxGraphNodes: c.maxGraphNodes,
		}
	}

Michael Yang's avatar
Michael Yang committed
481
	return &c
482
483
}

484
func (c *Context) Forward(tensors ...ml.Tensor) ml.Context {
Michael Yang's avatar
Michael Yang committed
485
	if c.graph == nil {
486
		c.graph = C.ggml_new_graph_custom(c.ctx, C.size_t(c.maxGraphNodes), false)
Michael Yang's avatar
Michael Yang committed
487
488
	}

489
490
491
492
493
	for _, tensor := range tensors {
		C.ggml_build_forward_expand(c.graph, tensor.(*Tensor).t)
	}

	return c
Michael Yang's avatar
Michael Yang committed
494
495
}

Michael Yang's avatar
Michael Yang committed
496
func (c Context) Compute(tensors ...ml.Tensor) {
497
	C.ggml_backend_sched_graph_compute_async(c.b.sched, c.graph)
Michael Yang's avatar
Michael Yang committed
498
	C.ggml_backend_sched_reset(c.b.sched)
Michael Yang's avatar
Michael Yang committed
499

500
501
502
	needSync := true
	sync := func() {
		if needSync {
503
			C.ggml_backend_sched_synchronize(c.b.sched)
504
505
506
			needSync = false
		}
	}
Michael Yang's avatar
Michael Yang committed
507

508
509
510
	for _, t := range tensors {
		if C.ggml_nbytes(t.(*Tensor).t) > 0 {
			t.(*Tensor).sync = sync
511
512
		}
	}
Michael Yang's avatar
Michael Yang committed
513
514
}

Michael Yang's avatar
Michael Yang committed
515
func (c Context) MaxGraphNodes() int {
516
	return c.maxGraphNodes
Jesse Gross's avatar
Jesse Gross committed
517
518
}

519
520
521
func shapeToGGML(shape []int) *C.int64_t {
	sh := make([]C.int64_t, len(shape))
	for i, s := range shape {
522
		sh[i] = C.int64_t(s)
523
524
525
526
527
	}

	return &sh[0]
}

528
529
530
531
func pad(length, pad C.size_t) C.size_t {
	return ((length + pad - 1) / pad) * pad
}

532
func (c Context) newTensor(dtype ml.DType, shape []int) ml.Tensor {
533
534
535
536
	if c.buft == nil {
		panic("set Input, Output, or Layer before creating tensors")
	}

Michael Yang's avatar
Michael Yang committed
537
538
539
540
541
542
	var cdtype uint32
	switch dtype {
	case ml.DTypeF32:
		cdtype = C.GGML_TYPE_F32
	case ml.DTypeF16:
		cdtype = C.GGML_TYPE_F16
543
544
545
546
	case ml.DTypeQ80:
		cdtype = C.GGML_TYPE_Q8_0
	case ml.DTypeQ40:
		cdtype = C.GGML_TYPE_Q4_0
Michael Yang's avatar
Michael Yang committed
547
548
549
550
551
552
	case ml.DTypeI32:
		cdtype = C.GGML_TYPE_I32
	default:
		panic("unsupported dtype")
	}

Jesse Gross's avatar
Jesse Gross committed
553
	if len(shape) < 1 || shape[0] == 0 {
Michael Yang's avatar
Michael Yang committed
554
555
556
		var shape C.int64_t = 0
		return &Tensor{b: c.b, t: C.ggml_new_tensor(c.ctx, cdtype, 1, &shape)}
	} else if len(shape) > 4 {
Michael Yang's avatar
Michael Yang committed
557
558
559
560
561
562
563
564
565
		panic("unsupported number of dimensions")
	}

	for _, dim := range shape {
		if dim < 1 {
			panic("invalid shape")
		}
	}

Michael Yang's avatar
Michael Yang committed
566
	t := C.ggml_new_tensor(c.ctx, cdtype, C.int(len(shape)), shapeToGGML(shape))
567
568
	size := pad(C.ggml_backend_buft_get_alloc_size(c.buft, t), C.ggml_backend_buft_get_alignment(c.buft))
	b := C.ggml_backend_buft_alloc_buffer(c.buft, size)
Michael Yang's avatar
Michael Yang committed
569
	C.ggml_backend_tensor_alloc(b, t, C.ggml_backend_buffer_get_base(b))
570
	return &Tensor{b: c.b, t: t}
571
572
573
}

func (c Context) Empty(dtype ml.DType, shape ...int) ml.Tensor {
574
	return c.newTensor(dtype, shape)
575
576
577
}

func (c Context) Zeros(dtype ml.DType, shape ...int) ml.Tensor {
578
	t := c.newTensor(dtype, shape)
579
580
	C.ggml_set_zero(t.(*Tensor).t)
	return t
Michael Yang's avatar
Michael Yang committed
581
582
}

583
func checkShape[S ~[]E, E any](s S, shape ...int) error {
Michael Yang's avatar
Michael Yang committed
584
	n := len(s)
Jesse Gross's avatar
Jesse Gross committed
585
586
587
588
589

	if n == 0 {
		return nil
	}

Michael Yang's avatar
Michael Yang committed
590
591
592
593
594
	for _, v := range shape {
		n /= v
	}

	if n != 1 {
595
		return fmt.Errorf("invalid shape: %v", shape)
Michael Yang's avatar
Michael Yang committed
596
597
	}

598
	return nil
Michael Yang's avatar
Michael Yang committed
599
600
601
}

func (c Context) FromFloatSlice(s []float32, shape ...int) (ml.Tensor, error) {
Jesse Gross's avatar
Jesse Gross committed
602
	if err := checkShape(s, shape...); err != nil {
603
604
605
606
		return nil, err
	}

	t := c.newTensor(ml.DTypeF32, shape)
Jesse Gross's avatar
Jesse Gross committed
607
608
609
610
	if len(s) > 0 {
		C.ggml_backend_tensor_set(t.(*Tensor).t, unsafe.Pointer(&s[0]), 0, C.ggml_nbytes(t.(*Tensor).t))
	}

611
	return t, nil
Michael Yang's avatar
Michael Yang committed
612
613
614
}

func (c Context) FromIntSlice(s []int32, shape ...int) (ml.Tensor, error) {
Jesse Gross's avatar
Jesse Gross committed
615
	if err := checkShape(s, shape...); err != nil {
616
617
618
619
		return nil, err
	}

	t := c.newTensor(ml.DTypeI32, shape)
Jesse Gross's avatar
Jesse Gross committed
620
621
622
623
	if len(s) > 0 {
		C.ggml_backend_tensor_set(t.(*Tensor).t, unsafe.Pointer(&s[0]), 0, C.ggml_nbytes(t.(*Tensor).t))
	}

624
	return t, nil
Michael Yang's avatar
Michael Yang committed
625
626
}

Michael Yang's avatar
Michael Yang committed
627
628
func (c *Context) Close() {
	if c != nil {
629
630
		C.ggml_free(c.ctx)
	}
Michael Yang's avatar
Michael Yang committed
631
632
633
}

type Tensor struct {
634
	b    *Backend
Michael Yang's avatar
Michael Yang committed
635
	t    *C.struct_ggml_tensor
636
	sync func()
Michael Yang's avatar
Michael Yang committed
637
638
639
640
641
642
643
644
645
646
}

func (t *Tensor) LogValue() slog.Value {
	return slog.GroupValue(
		slog.String("name", C.GoString(C.ggml_get_name(t.t))),
		slog.String("type", C.GoString(C.ggml_type_name(t.t._type))),
		slog.Any("shape", t.Shape()),
	)
}

647
648
func (t *Tensor) Dim(n int) int {
	return int(t.t.ne[n])
Michael Yang's avatar
Michael Yang committed
649
650
}

651
652
func (t *Tensor) Stride(n int) int {
	return int(t.t.nb[n])
Michael Yang's avatar
Michael Yang committed
653
654
}

655
656
func (t *Tensor) Shape() []int {
	shape := make([]int, C.ggml_n_dims(t.t))
Michael Yang's avatar
Michael Yang committed
657
658
659
660
661
662
663
	for i := range shape {
		shape[i] = t.Dim(i)
	}

	return shape
}

664
665
666
667
668
669
670
671
672
func (t *Tensor) Bytes() (data []byte) {
	if t.sync != nil {
		data = make([]byte, C.ggml_nbytes(t.t))

		t.sync()
		C.ggml_backend_tensor_get(t.t, unsafe.Pointer(&data[0]), 0, C.ggml_nbytes(t.t))
	}

	return
Michael Yang's avatar
Michael Yang committed
673
674
}

675
676
677
678
679
680
func (t *Tensor) Floats() (data []float32) {
	if t.sync != nil {
		data = make([]float32, C.ggml_nelements(t.t))

		t.sync()
		C.ggml_backend_tensor_get(t.t, unsafe.Pointer(&data[0]), 0, C.ggml_nbytes(t.t))
Michael Yang's avatar
Michael Yang committed
681
682
683
684
685
686
687
688
689
	}

	return
}

func (t *Tensor) DType() ml.DType {
	switch t.t._type {
	case C.GGML_TYPE_F32:
		return ml.DTypeF32
Jesse Gross's avatar
Jesse Gross committed
690
691
	case C.GGML_TYPE_F16:
		return ml.DTypeF16
692
693
694
695
	case C.GGML_TYPE_Q8_0:
		return ml.DTypeQ80
	case C.GGML_TYPE_Q4_0:
		return ml.DTypeQ40
Michael Yang's avatar
Michael Yang committed
696
697
698
699
700
701
702
703
704
	case C.GGML_TYPE_I32:
		return ml.DTypeI32
	default:
		return ml.DTypeOther
	}
}

func (t *Tensor) Add(ctx ml.Context, t2 ml.Tensor) ml.Tensor {
	return &Tensor{
705
		b: t.b,
Michael Yang's avatar
Michael Yang committed
706
707
708
709
710
711
712
713
714
715
716
717
718
719
		t: C.ggml_add(ctx.(*Context).ctx, t.t, t2.(*Tensor).t),
	}
}

func (t *Tensor) Stack(ctx ml.Context, dim int, s ...ml.Tensor) ml.Tensor {
	if len(s) > 0 {
		return t.Concat(ctx, s[0].Stack(ctx, dim, s[1:]...), dim)
	}

	return t
}

func (t *Tensor) Concat(ctx ml.Context, t2 ml.Tensor, dim int) ml.Tensor {
	return &Tensor{
720
		b: t.b,
Michael Yang's avatar
Michael Yang committed
721
722
723
724
725
726
		t: C.ggml_concat(ctx.(*Context).ctx, t.t, t2.(*Tensor).t, C.int(dim)),
	}
}

func (t *Tensor) Contiguous(ctx ml.Context) ml.Tensor {
	return &Tensor{
727
		b: t.b,
Michael Yang's avatar
Michael Yang committed
728
729
730
731
732
733
		t: C.ggml_cont(ctx.(*Context).ctx, t.t),
	}
}

func (t *Tensor) Mul(ctx ml.Context, t2 ml.Tensor) ml.Tensor {
	return &Tensor{
734
		b: t.b,
Michael Yang's avatar
Michael Yang committed
735
736
737
738
739
740
		t: C.ggml_mul(ctx.(*Context).ctx, t.t, t2.(*Tensor).t),
	}
}

func (t *Tensor) Mulmat(ctx ml.Context, t2 ml.Tensor) ml.Tensor {
	return &Tensor{
741
		b: t.b,
Michael Yang's avatar
Michael Yang committed
742
743
744
745
		t: C.ggml_mul_mat(ctx.(*Context).ctx, t.t, t2.(*Tensor).t),
	}
}

746
747
748
749
750
func (t *Tensor) MulmatFullPrec(ctx ml.Context, t2 ml.Tensor) ml.Tensor {
	mul := C.ggml_mul_mat(ctx.(*Context).ctx, t.t, t2.(*Tensor).t)
	C.ggml_mul_mat_set_prec(mul, C.GGML_PREC_F32)

	return &Tensor{
751
		b: t.b,
752
753
754
755
		t: mul,
	}
}

Michael Yang's avatar
Michael Yang committed
756
func (t *Tensor) LayerNorm(ctx ml.Context, w, b ml.Tensor, eps float32) ml.Tensor {
757
	tt := (&Tensor{b: t.b, t: C.ggml_norm(ctx.(*Context).ctx, t.t, C.float(eps))}).Mul(ctx, w)
Michael Yang's avatar
Michael Yang committed
758
759
760
761
762
763
764
765
	if b != nil {
		tt = tt.Add(ctx, b)
	}

	return tt
}

func (t *Tensor) RMSNorm(ctx ml.Context, w ml.Tensor, eps float32) ml.Tensor {
766
	return (&Tensor{b: t.b, t: C.ggml_rms_norm(ctx.(*Context).ctx, t.t, C.float(eps))}).Mul(ctx, w)
Michael Yang's avatar
Michael Yang committed
767
768
}

769
func (t *Tensor) Pad(ctx ml.Context, shape ...int) ml.Tensor {
Michael Yang's avatar
Michael Yang committed
770
771
772
773
774
	if len(shape) != 4 {
		panic("expected 4 dimensions")
	}

	return &Tensor{
775
		b: t.b,
Michael Yang's avatar
Michael Yang committed
776
777
778
779
780
781
782
783
784
785
		t: C.ggml_pad(ctx.(*Context).ctx, t.t, C.int(shape[0]), C.int(shape[1]), C.int(shape[2]), C.int(shape[3])),
	}
}

func (t *Tensor) Permute(ctx ml.Context, shape ...int) ml.Tensor {
	if len(shape) != 4 {
		panic("expected 4 dimensions")
	}

	return &Tensor{
786
		b: t.b,
Michael Yang's avatar
Michael Yang committed
787
788
789
790
791
792
		t: C.ggml_permute(ctx.(*Context).ctx, t.t, C.int(shape[0]), C.int(shape[1]), C.int(shape[2]), C.int(shape[3])),
	}
}

func (t *Tensor) Rows(ctx ml.Context, t2 ml.Tensor) ml.Tensor {
	return &Tensor{
793
		b: t.b,
Michael Yang's avatar
Michael Yang committed
794
795
796
797
798
799
		t: C.ggml_get_rows(ctx.(*Context).ctx, t.t, t2.(*Tensor).t),
	}
}

func (t *Tensor) Copy(ctx ml.Context, t2 ml.Tensor) ml.Tensor {
	return &Tensor{
800
		b: t.b,
Michael Yang's avatar
Michael Yang committed
801
802
803
804
		t: C.ggml_cpy(ctx.(*Context).ctx, t.t, t2.(*Tensor).t),
	}
}

805
func (t *Tensor) Reshape(ctx ml.Context, shape ...int) ml.Tensor {
Michael Yang's avatar
Michael Yang committed
806
807
808
	switch len(shape) {
	case 1:
		return &Tensor{
809
			b: t.b,
Michael Yang's avatar
Michael Yang committed
810
811
812
813
			t: C.ggml_reshape_1d(ctx.(*Context).ctx, t.t, C.int64_t(shape[0])),
		}
	case 2:
		return &Tensor{
814
			b: t.b,
Michael Yang's avatar
Michael Yang committed
815
816
817
818
			t: C.ggml_reshape_2d(ctx.(*Context).ctx, t.t, C.int64_t(shape[0]), C.int64_t(shape[1])),
		}
	case 3:
		return &Tensor{
819
			b: t.b,
Michael Yang's avatar
Michael Yang committed
820
821
822
823
			t: C.ggml_reshape_3d(ctx.(*Context).ctx, t.t, C.int64_t(shape[0]), C.int64_t(shape[1]), C.int64_t(shape[2])),
		}
	case 4:
		return &Tensor{
824
			b: t.b,
Michael Yang's avatar
Michael Yang committed
825
826
827
828
829
830
831
832
833
			t: C.ggml_reshape_4d(ctx.(*Context).ctx, t.t, C.int64_t(shape[0]), C.int64_t(shape[1]), C.int64_t(shape[2]), C.int64_t(shape[3])),
		}
	default:
		panic("unsupported number of dimensions")
	}
}

func (t *Tensor) Scale(ctx ml.Context, s float64) ml.Tensor {
	return &Tensor{
834
		b: t.b,
Michael Yang's avatar
Michael Yang committed
835
836
837
838
839
840
		t: C.ggml_scale(ctx.(*Context).ctx, t.t, (C.float)(s)),
	}
}

func (t *Tensor) Softmax(ctx ml.Context) ml.Tensor {
	return &Tensor{
841
		b: t.b,
Michael Yang's avatar
Michael Yang committed
842
843
844
845
846
847
		t: C.ggml_soft_max(ctx.(*Context).ctx, t.t),
	}
}

func (t *Tensor) Tanh(ctx ml.Context) ml.Tensor {
	return &Tensor{
848
		b: t.b,
Michael Yang's avatar
Michael Yang committed
849
850
851
852
		t: C.ggml_tanh_inplace(ctx.(*Context).ctx, t.t),
	}
}

853
func (t *Tensor) Unpad(ctx ml.Context, shape ...int) ml.Tensor {
Michael Yang's avatar
Michael Yang committed
854
855
856
857
858
	if len(shape) != 4 {
		panic("expected 4 dimensions")
	}

	return &Tensor{
859
		b: t.b,
Michael Yang's avatar
Michael Yang committed
860
861
862
863
864
865
866
867
		t: C.ggml_unpad(ctx.(*Context).ctx, t.t, C.int(shape[0]), C.int(shape[1]), C.int(shape[2]), C.int(shape[3])),
	}
}

func (t *Tensor) View(ctx ml.Context, offset int, shape ...int) ml.Tensor {
	switch len(shape) {
	case 1:
		return &Tensor{
868
			b: t.b,
Michael Yang's avatar
Michael Yang committed
869
870
871
872
			t: C.ggml_view_1d(ctx.(*Context).ctx, t.t, C.int64_t(shape[0]), C.size_t(offset)),
		}
	case 3:
		return &Tensor{
873
			b: t.b,
Michael Yang's avatar
Michael Yang committed
874
875
876
877
878
879
880
			t: C.ggml_view_2d(ctx.(*Context).ctx, t.t,
				C.int64_t(shape[0]), C.int64_t(shape[2]),
				C.size_t(shape[1]),
				C.size_t(offset)),
		}
	case 5:
		return &Tensor{
881
			b: t.b,
Michael Yang's avatar
Michael Yang committed
882
883
884
885
886
887
888
			t: C.ggml_view_3d(ctx.(*Context).ctx, t.t,
				C.int64_t(shape[0]), C.int64_t(shape[2]), C.int64_t(shape[4]),
				C.size_t(shape[1]), C.size_t(shape[3]),
				C.size_t(offset)),
		}
	case 7:
		return &Tensor{
889
			b: t.b,
Michael Yang's avatar
Michael Yang committed
890
891
892
893
894
895
896
897
898
899
900
			t: C.ggml_view_4d(ctx.(*Context).ctx, t.t,
				C.int64_t(shape[0]), C.int64_t(shape[2]), C.int64_t(shape[4]), C.int64_t(shape[6]),
				C.size_t(shape[1]), C.size_t(shape[3]), C.size_t(shape[5]),
				C.size_t(offset)),
		}
	default:
		panic("unsupported number of dimensions")
	}
}

const (
Patrick Devine's avatar
Patrick Devine committed
901
902
903
904
	ropeTypeNorm   C.int = 0
	ropeTypeNeox   C.int = 2
	ropeTypeMrope  C.int = 8
	ropeTypeVision C.int = 24
Michael Yang's avatar
Michael Yang committed
905
906
)

Patrick Devine's avatar
Patrick Devine committed
907
func (t *Tensor) RoPE(ctx ml.Context, positionIDs, ropeFactors ml.Tensor, ropeDim, ropeType uint32, ropeBase, ropeScale float32) ml.Tensor {
Michael Yang's avatar
Michael Yang committed
908
	if ropeFactors == nil {
909
		ropeFactors = &Tensor{b: t.b}
Michael Yang's avatar
Michael Yang committed
910
911
	}

Jesse Gross's avatar
Jesse Gross committed
912
913
914
915
916
	dequant := t.t
	if C.ggml_is_quantized(t.t._type) {
		dequant = C.ggml_cast(ctx.(*Context).ctx, t.t, C.GGML_TYPE_F32)
	}

Michael Yang's avatar
Michael Yang committed
917
	return &Tensor{
918
		b: t.b,
Michael Yang's avatar
Michael Yang committed
919
		t: C.ggml_rope_ext(
Jesse Gross's avatar
Jesse Gross committed
920
			ctx.(*Context).ctx, dequant, positionIDs.(*Tensor).t, ropeFactors.(*Tensor).t,
Michael Yang's avatar
Michael Yang committed
921
			C.int(ropeDim),
Patrick Devine's avatar
Patrick Devine committed
922
923
			C.int(ropeType),
			131072, // YaRN n_ctx_train
Michael Yang's avatar
Michael Yang committed
924
925
926
927
928
929
930
931
932
933
934
935
			C.float(ropeBase),
			C.float(ropeScale),
			0.,  // YaRN ext_factor
			1.,  // YaRN attn_factor
			32., // YaRN beta_fast
			1.,  // YaRN beta_slow
		),
	}
}

func (t *Tensor) GELU(ctx ml.Context) ml.Tensor {
	return &Tensor{
936
		b: t.b,
Michael Yang's avatar
Michael Yang committed
937
938
939
940
941
942
		t: C.ggml_gelu_inplace(ctx.(*Context).ctx, t.t),
	}
}

func (t *Tensor) SILU(ctx ml.Context) ml.Tensor {
	return &Tensor{
943
		b: t.b,
Michael Yang's avatar
Michael Yang committed
944
945
946
947
948
949
		t: C.ggml_silu_inplace(ctx.(*Context).ctx, t.t),
	}
}

func (t *Tensor) Conv2D(ctx ml.Context, t2 ml.Tensor, s0, s1, p0, p1, d0, d1 int) ml.Tensor {
	return &Tensor{
950
		b: t.b,
Michael Yang's avatar
Michael Yang committed
951
952
953
		t: C.ggml_conv_2d(ctx.(*Context).ctx, t.t, t2.(*Tensor).t, C.int(s0), C.int(s1), C.int(p0), C.int(p1), C.int(d0), C.int(d1)),
	}
}
954

Michael Yang's avatar
Michael Yang committed
955
956
957
958
959
960
961
func (t *Tensor) AvgPool1D(ctx ml.Context, k, s, p int) ml.Tensor {
	return &Tensor{
		b: t.b,
		t: C.ggml_pool_1d(ctx.(*Context).ctx, t.t, C.GGML_OP_POOL_AVG, C.int(k), C.int(s), C.int(p)),
	}
}

Michael Yang's avatar
Michael Yang committed
962
963
964
965
func (t *Tensor) Set(ctx ml.Context, t2 ml.Tensor, offset int, strides ...int) ml.Tensor {
	var tt *C.struct_ggml_tensor
	switch len(strides) {
	case 0:
Michael Yang's avatar
Michael Yang committed
966
		tt = C.ggml_set_1d(ctx.(*Context).ctx, t.t, t2.(*Tensor).t, C.size_t(offset))
Michael Yang's avatar
Michael Yang committed
967
	case 1:
Michael Yang's avatar
Michael Yang committed
968
		tt = C.ggml_set_2d(ctx.(*Context).ctx, t.t, t2.(*Tensor).t, C.size_t(offset), C.size_t(strides[0]))
Michael Yang's avatar
Michael Yang committed
969
970
971
972
973
974
975
	default:
		panic("unsupported number of dimensions")
	}

	return &Tensor{b: t.b, t: tt}
}

976
977
978
979
980
981
func (t *Tensor) ScaledDotProductAttention(ctx ml.Context, key, value, mask ml.Tensor, scale float64) ml.Tensor {
	var kqMask *C.struct_ggml_tensor
	if mask != nil {
		kqMask = mask.(*Tensor).t
	}

982
983
984
	query := t.Permute(ctx, 0, 2, 1, 3)
	key = key.Permute(ctx, 0, 2, 1, 3)

985
986
	if t.b.flashAttention {
		value = value.Permute(ctx, 0, 2, 1, 3)
987

988
989
990
991
992
993
994
995
996
997
998
999
1000
		kqv := C.ggml_flash_attn_ext(ctx.(*Context).ctx, query.(*Tensor).t, key.(*Tensor).t, value.(*Tensor).t, kqMask, C.float(scale), 0, 0)
		C.ggml_flash_attn_ext_set_prec(kqv, C.GGML_PREC_F32)
		return &Tensor{b: t.b, t: kqv}
	} else {
		kq := key.MulmatFullPrec(ctx, query)
		kq = &Tensor{
			b: t.b,
			t: C.ggml_soft_max_ext(ctx.(*Context).ctx, kq.(*Tensor).t, kqMask, C.float(scale), 0),
		}

		kqv := value.Mulmat(ctx, kq)
		return kqv.Permute(ctx, 0, 2, 1, 3).Contiguous(ctx)
	}
1001
}