finetune.cpp 90 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935
  1. #include "ggml.h"
  2. #include "ggml-alloc.h"
  3. #include "llama.h"
  4. #include "common.h"
  5. #include "train.h"
  6. #include <unordered_map>
  7. #include <vector>
  8. #include <cassert>
  9. #include <climits>
  10. #include <cstring>
  11. #include <cstdarg>
  12. #include <ctime>
  13. #include <random>
  14. #include <stdexcept>
  15. #include <algorithm>
  16. #include <string>
  17. #if defined(_MSC_VER)
  18. #pragma warning(disable: 4244 4267) // possible loss of data
  19. #endif
  20. static const size_t tensor_alignment = 32;
  21. struct my_llama_hparams {
  22. uint32_t n_vocab = 32000;
  23. uint32_t n_ctx = 512;
  24. uint32_t n_embd = 4096;
  25. uint32_t n_ff = 11008;
  26. uint32_t n_head = 32;
  27. uint32_t n_head_kv = 32;
  28. uint32_t n_layer = 32;
  29. // float f_norm_eps = 1e-5f; // falcon
  30. float f_norm_rms_eps = 1e-5f; // llama
  31. float rope_freq_base = 10000.0f;
  32. float rope_freq_scale = 1.0f;
  33. uint32_t n_gqa() const {
  34. return n_head/n_head_kv;
  35. }
  36. uint32_t n_embd_head() const {
  37. return n_embd/n_head;
  38. }
  39. uint32_t n_embd_gqa() const {
  40. return n_embd/n_gqa();
  41. }
  42. bool operator!=(const my_llama_hparams& other) const {
  43. return memcmp(this, &other, sizeof(other));
  44. }
  45. };
  46. struct my_llama_layer {
  47. // normalization
  48. struct ggml_tensor * attention_norm;
  49. // attention
  50. struct ggml_tensor * wq;
  51. struct ggml_tensor * wk;
  52. struct ggml_tensor * wv;
  53. struct ggml_tensor * wo;
  54. // normalization
  55. struct ggml_tensor * ffn_norm;
  56. // ff
  57. struct ggml_tensor * w1;
  58. struct ggml_tensor * w2;
  59. struct ggml_tensor * w3;
  60. };
  61. struct my_llama_model {
  62. struct my_llama_hparams hparams;
  63. struct ggml_tensor * tok_embeddings;
  64. struct ggml_tensor * norm;
  65. struct ggml_tensor * output;
  66. std::vector<my_llama_layer> layers;
  67. };
  68. struct my_llama_lora_hparams {
  69. uint32_t lora_r = 1;
  70. uint32_t lora_alpha = 1;
  71. uint32_t n_rank_attention_norm = 1;
  72. uint32_t n_rank_wq = 4;
  73. uint32_t n_rank_wk = 4;
  74. uint32_t n_rank_wv = 4;
  75. uint32_t n_rank_wo = 4;
  76. uint32_t n_rank_ffn_norm = 1;
  77. uint32_t n_rank_w1 = 4;
  78. uint32_t n_rank_w2 = 4;
  79. uint32_t n_rank_w3 = 4;
  80. uint32_t n_rank_tok_embeddings = 4;
  81. uint32_t n_rank_norm = 1;
  82. uint32_t n_rank_output = 4;
  83. bool operator!=(const my_llama_lora_hparams& other) const {
  84. return memcmp(this, &other, sizeof(other));
  85. }
  86. };
  87. struct my_llama_lora_layer {
  88. // normalization
  89. struct ggml_tensor * attention_norm_a;
  90. struct ggml_tensor * attention_norm_b;
  91. // attention
  92. struct ggml_tensor * wq_a;
  93. struct ggml_tensor * wq_b;
  94. struct ggml_tensor * wk_a;
  95. struct ggml_tensor * wk_b;
  96. struct ggml_tensor * wv_a;
  97. struct ggml_tensor * wv_b;
  98. struct ggml_tensor * wo_a;
  99. struct ggml_tensor * wo_b;
  100. // normalization
  101. struct ggml_tensor * ffn_norm_a;
  102. struct ggml_tensor * ffn_norm_b;
  103. // ff
  104. struct ggml_tensor * w1_a;
  105. struct ggml_tensor * w1_b;
  106. struct ggml_tensor * w2_a;
  107. struct ggml_tensor * w2_b;
  108. struct ggml_tensor * w3_a;
  109. struct ggml_tensor * w3_b;
  110. };
  111. struct my_llama_lora {
  112. struct ggml_context * ctx = NULL;
  113. std::vector<uint8_t> data;
  114. my_llama_lora_hparams hparams;
  115. struct ggml_tensor * tok_embeddings_a;
  116. struct ggml_tensor * tok_embeddings_b;
  117. struct ggml_tensor * norm_a;
  118. struct ggml_tensor * norm_b;
  119. struct ggml_tensor * output_a;
  120. struct ggml_tensor * output_b;
  121. std::vector<my_llama_lora_layer> layers;
  122. };
  123. // gguf constants
  124. static const char * LLM_KV_TRAINING_TYPE_FINETUNE_LORA = "finetune_lora";
  125. static const char * LLM_KV_TRAINING_TYPE = "training.type";
  126. static const char * LLM_KV_TRAINING_LORA_RANK_TOKEN_EMBD = "training.lora.rank.token_embd";
  127. static const char * LLM_KV_TRAINING_LORA_RANK_OUTPUT_NORM = "training.lora.rank.output_norm";
  128. static const char * LLM_KV_TRAINING_LORA_RANK_OUTPUT = "training.lora.rank.output";
  129. static const char * LLM_KV_TRAINING_LORA_RANK_ATTN_NORM = "training.lora.rank.attn_norm";
  130. static const char * LLM_KV_TRAINING_LORA_RANK_ATTN_Q = "training.lora.rank.attn_q";
  131. static const char * LLM_KV_TRAINING_LORA_RANK_ATTN_K = "training.lora.rank.attn_k";
  132. static const char * LLM_KV_TRAINING_LORA_RANK_ATTN_V = "training.lora.rank.attn_v";
  133. static const char * LLM_KV_TRAINING_LORA_RANK_ATTN_OUT = "training.lora.rank.attn_output";
  134. static const char * LLM_KV_TRAINING_LORA_RANK_FFN_NORM = "training.lora.rank.ffn_norm";
  135. static const char * LLM_KV_TRAINING_LORA_RANK_FFN_GATE = "training.lora.rank.ffn_gate";
  136. static const char * LLM_KV_TRAINING_LORA_RANK_FFN_DOWN = "training.lora.rank.ffn_down";
  137. static const char * LLM_KV_TRAINING_LORA_RANK_FFN_UP = "training.lora.rank.ffn_up";
  138. // gguf constants (sync with gguf.py)
  139. static const char * LLM_KV_GENERAL_ARCHITECTURE = "general.architecture";
  140. static const char * LLM_KV_GENERAL_FILE_TYPE = "general.file_type";
  141. static const char * LLM_KV_CONTEXT_LENGTH = "%s.context_length";
  142. static const char * LLM_KV_EMBEDDING_LENGTH = "%s.embedding_length";
  143. static const char * LLM_KV_BLOCK_COUNT = "%s.block_count";
  144. static const char * LLM_KV_FEED_FORWARD_LENGTH = "%s.feed_forward_length";
  145. static const char * LLM_KV_ATTENTION_HEAD_COUNT = "%s.attention.head_count";
  146. static const char * LLM_KV_ATTENTION_HEAD_COUNT_KV = "%s.attention.head_count_kv";
  147. static const char * LLM_KV_ATTENTION_LAYERNORM_RMS_EPS = "%s.attention.layer_norm_rms_epsilon";
  148. static const char * LLM_KV_ROPE_DIMENSION_COUNT = "%s.rope.dimension_count";
  149. static const char * LLM_KV_ROPE_FREQ_BASE = "%s.rope.freq_base"; // TODO load in llama.cpp
  150. static const char * LLM_KV_ROPE_SCALE_LINEAR = "%s.rope.scale_linear";
  151. static const char * LLM_TENSOR_TOKEN_EMBD = "token_embd";
  152. static const char * LLM_TENSOR_OUTPUT_NORM = "output_norm";
  153. static const char * LLM_TENSOR_OUTPUT = "output";
  154. static const char * LLM_TENSOR_ATTN_NORM = "blk.%d.attn_norm";
  155. static const char * LLM_TENSOR_ATTN_Q = "blk.%d.attn_q";
  156. static const char * LLM_TENSOR_ATTN_K = "blk.%d.attn_k";
  157. static const char * LLM_TENSOR_ATTN_V = "blk.%d.attn_v";
  158. static const char * LLM_TENSOR_ATTN_OUT = "blk.%d.attn_output";
  159. static const char * LLM_TENSOR_FFN_NORM = "blk.%d.ffn_norm";
  160. static const char * LLM_TENSOR_FFN_GATE = "blk.%d.ffn_gate";
  161. static const char * LLM_TENSOR_FFN_DOWN = "blk.%d.ffn_down";
  162. static const char * LLM_TENSOR_FFN_UP = "blk.%d.ffn_up";
  163. static void print_params(struct my_llama_hparams * params) {
  164. printf("%s: n_vocab: %u\n", __func__, params->n_vocab);
  165. printf("%s: n_ctx: %u\n", __func__, params->n_ctx);
  166. printf("%s: n_embd: %u\n", __func__, params->n_embd);
  167. printf("%s: n_ff: %u\n", __func__, params->n_ff);
  168. printf("%s: n_head: %u\n", __func__, params->n_head);
  169. printf("%s: n_head_kv: %u\n", __func__, params->n_head_kv);
  170. printf("%s: n_layer: %u\n", __func__, params->n_layer);
  171. printf("%s: norm_rms_eps : %f\n", __func__, params->f_norm_rms_eps);
  172. printf("%s: rope_freq_base : %f\n", __func__, params->rope_freq_base);
  173. printf("%s: rope_freq_scale : %f\n", __func__, params->rope_freq_scale);
  174. }
  175. static void print_lora_params(struct my_llama_lora_hparams * params) {
  176. printf("%s: n_rank_attention_norm : %u\n", __func__, params->n_rank_attention_norm);
  177. printf("%s: n_rank_wq : %u\n", __func__, params->n_rank_wq);
  178. printf("%s: n_rank_wk : %u\n", __func__, params->n_rank_wk);
  179. printf("%s: n_rank_wv : %u\n", __func__, params->n_rank_wv);
  180. printf("%s: n_rank_wo : %u\n", __func__, params->n_rank_wo);
  181. printf("%s: n_rank_ffn_norm : %u\n", __func__, params->n_rank_ffn_norm);
  182. printf("%s: n_rank_w1 : %u\n", __func__, params->n_rank_w1);
  183. printf("%s: n_rank_w2 : %u\n", __func__, params->n_rank_w2);
  184. printf("%s: n_rank_w3 : %u\n", __func__, params->n_rank_w3);
  185. printf("%s: n_rank_tok_embeddings : %u\n", __func__, params->n_rank_tok_embeddings);
  186. printf("%s: n_rank_norm : %u\n", __func__, params->n_rank_norm);
  187. printf("%s: n_rank_output : %u\n", __func__, params->n_rank_output);
  188. }
  189. #define GGUF_GET_KEY(ctx, dst, func, type, req, key) \
  190. { \
  191. const std::string skey(key); \
  192. const int kid = gguf_find_key(ctx, skey.c_str()); \
  193. if (kid >= 0) { \
  194. enum gguf_type ktype = gguf_get_kv_type(ctx, kid); \
  195. if (ktype != (type)) { \
  196. die_fmt("key %s has wrong type: %s", skey.c_str(), gguf_type_name(ktype)); \
  197. } \
  198. (dst) = func(ctx, kid); \
  199. } else if (req) { \
  200. die_fmt("key not found in model: %s", skey.c_str()); \
  201. } \
  202. }
  203. static void load_model_hparams_gguf(struct gguf_context * ctx, struct my_llama_hparams * hparams, const char * expected_arch) {
  204. std::string arch;
  205. GGUF_GET_KEY(ctx, arch, gguf_get_val_str, GGUF_TYPE_STRING, true, LLM_KV_GENERAL_ARCHITECTURE);
  206. if (expected_arch != NULL) {
  207. if (arch != expected_arch) {
  208. printf("%s: arch=%s expected_arch=%s\n", __func__, arch.c_str(), expected_arch);
  209. }
  210. GGML_ASSERT(arch == expected_arch);
  211. }
  212. std::vector<char> keybuf;
  213. keybuf.resize(512);
  214. auto kv = [&arch, &keybuf](const char * key) -> const char * {
  215. snprintf(keybuf.data(), keybuf.size(), key, arch.c_str());
  216. return keybuf.data();
  217. };
  218. GGUF_GET_KEY(ctx, hparams->n_embd, gguf_get_val_u32, GGUF_TYPE_UINT32, true, kv(LLM_KV_EMBEDDING_LENGTH));
  219. GGUF_GET_KEY(ctx, hparams->n_ctx, gguf_get_val_u32, GGUF_TYPE_UINT32, false, kv(LLM_KV_CONTEXT_LENGTH));
  220. GGUF_GET_KEY(ctx, hparams->n_ff, gguf_get_val_u32, GGUF_TYPE_UINT32, true, kv(LLM_KV_FEED_FORWARD_LENGTH));
  221. GGUF_GET_KEY(ctx, hparams->n_head, gguf_get_val_u32, GGUF_TYPE_UINT32, true, kv(LLM_KV_ATTENTION_HEAD_COUNT));
  222. GGUF_GET_KEY(ctx, hparams->n_layer, gguf_get_val_u32, GGUF_TYPE_UINT32, true, kv(LLM_KV_BLOCK_COUNT));
  223. // n_head_kv is optional, default to n_head
  224. hparams->n_head_kv = hparams->n_head;
  225. GGUF_GET_KEY(ctx, hparams->n_head_kv, gguf_get_val_u32, GGUF_TYPE_UINT32, false, kv(LLM_KV_ATTENTION_HEAD_COUNT_KV));
  226. float rope_freq_scale = 1.0f;
  227. GGUF_GET_KEY(ctx, hparams->f_norm_rms_eps, gguf_get_val_f32, GGUF_TYPE_FLOAT32, false, kv(LLM_KV_ATTENTION_LAYERNORM_RMS_EPS));
  228. GGUF_GET_KEY(ctx, hparams->rope_freq_base, gguf_get_val_f32, GGUF_TYPE_FLOAT32, false, kv(LLM_KV_ROPE_FREQ_BASE));
  229. GGUF_GET_KEY(ctx, rope_freq_scale, gguf_get_val_f32, GGUF_TYPE_FLOAT32, false, kv(LLM_KV_ROPE_SCALE_LINEAR));
  230. if (rope_freq_scale != 1.0f) {
  231. hparams->rope_freq_scale = 1.0f / rope_freq_scale;
  232. }
  233. }
  234. static void init_model(struct llama_model * input, struct my_llama_model * model, const char * fn_model, uint32_t n_ctx) {
  235. auto & hparams = model->hparams;
  236. std::vector<char> tn_buf;
  237. tn_buf.resize(GGML_MAX_NAME);
  238. auto tn = [&tn_buf](const char * key) -> const char * {
  239. snprintf(tn_buf.data(), tn_buf.size(), "%s.weight", key);
  240. return tn_buf.data();
  241. };
  242. auto tni = [&tn_buf](const char * key, int bid) -> const char * {
  243. snprintf(tn_buf.data(), tn_buf.size(), key, bid);
  244. std::string s = tn_buf.data();
  245. snprintf(tn_buf.data(), tn_buf.size(), "%s.weight", s.c_str());
  246. return tn_buf.data();
  247. };
  248. // get parameters directly from gguf file
  249. {
  250. struct gguf_init_params params = {
  251. /*.no_alloc = */ false,
  252. /*.ctx = */ NULL,
  253. };
  254. struct gguf_context * mctx = gguf_init_from_file(fn_model, params);
  255. load_model_hparams_gguf(mctx, &hparams, "llama");
  256. gguf_free(mctx);
  257. }
  258. hparams.n_vocab = llama_model_n_vocab(input);
  259. hparams.n_ctx = n_ctx;
  260. // get tensors from llama_model (possibly mmapped)
  261. model->tok_embeddings = llama_get_model_tensor(input, tn(LLM_TENSOR_TOKEN_EMBD));
  262. model->norm = llama_get_model_tensor(input, tn(LLM_TENSOR_OUTPUT_NORM));
  263. model->output = llama_get_model_tensor(input, tn(LLM_TENSOR_OUTPUT));
  264. assert_shape_2d(model->tok_embeddings, hparams.n_embd, hparams.n_vocab);
  265. assert_shape_1d(model->norm, hparams.n_embd);
  266. assert_shape_2d(model->output, hparams.n_embd, hparams.n_vocab);
  267. model->layers.resize(hparams.n_layer);
  268. for (uint32_t i = 0; i < hparams.n_layer; ++i) {
  269. auto & layer = model->layers[i];
  270. layer.attention_norm = llama_get_model_tensor(input, tni(LLM_TENSOR_ATTN_NORM, i));
  271. layer.wq = llama_get_model_tensor(input, tni(LLM_TENSOR_ATTN_Q, i));
  272. layer.wk = llama_get_model_tensor(input, tni(LLM_TENSOR_ATTN_K, i));
  273. layer.wv = llama_get_model_tensor(input, tni(LLM_TENSOR_ATTN_V, i));
  274. layer.wo = llama_get_model_tensor(input, tni(LLM_TENSOR_ATTN_OUT, i));
  275. layer.ffn_norm = llama_get_model_tensor(input, tni(LLM_TENSOR_FFN_NORM, i));
  276. layer.w1 = llama_get_model_tensor(input, tni(LLM_TENSOR_FFN_GATE, i));
  277. layer.w2 = llama_get_model_tensor(input, tni(LLM_TENSOR_FFN_DOWN, i));
  278. layer.w3 = llama_get_model_tensor(input, tni(LLM_TENSOR_FFN_UP, i));
  279. assert_shape_1d(layer.attention_norm, hparams.n_embd);
  280. assert_shape_2d(layer.wq, hparams.n_embd, hparams.n_embd);
  281. assert_shape_2d(layer.wk, hparams.n_embd, hparams.n_embd);
  282. assert_shape_2d(layer.wv, hparams.n_embd, hparams.n_embd);
  283. assert_shape_2d(layer.wo, hparams.n_embd, hparams.n_embd);
  284. assert_shape_1d(layer.ffn_norm, hparams.n_embd);
  285. assert_shape_2d(layer.w1, hparams.n_embd, hparams.n_ff);
  286. assert_shape_2d(layer.w2, hparams.n_ff, hparams.n_embd);
  287. assert_shape_2d(layer.w3, hparams.n_embd, hparams.n_ff);
  288. }
  289. }
  290. static void set_param_lora(struct my_llama_lora * lora) {
  291. const uint32_t n_layer = lora->layers.size();
  292. struct ggml_context* ctx = lora->ctx;
  293. ggml_set_param(ctx, lora->tok_embeddings_a);
  294. ggml_set_param(ctx, lora->tok_embeddings_b);
  295. ggml_set_param(ctx, lora->norm_a);
  296. ggml_set_param(ctx, lora->norm_b);
  297. ggml_set_param(ctx, lora->output_a);
  298. ggml_set_param(ctx, lora->output_b);
  299. for (uint32_t i = 0; i < n_layer; ++i) {
  300. auto & layer = lora->layers[i];
  301. ggml_set_param(ctx, layer.attention_norm_a);
  302. ggml_set_param(ctx, layer.attention_norm_b);
  303. ggml_set_param(ctx, layer.wq_a);
  304. ggml_set_param(ctx, layer.wq_b);
  305. ggml_set_param(ctx, layer.wk_a);
  306. ggml_set_param(ctx, layer.wk_b);
  307. ggml_set_param(ctx, layer.wv_a);
  308. ggml_set_param(ctx, layer.wv_b);
  309. ggml_set_param(ctx, layer.wo_a);
  310. ggml_set_param(ctx, layer.wo_b);
  311. ggml_set_param(ctx, layer.ffn_norm_a);
  312. ggml_set_param(ctx, layer.ffn_norm_b);
  313. ggml_set_param(ctx, layer.w1_a);
  314. ggml_set_param(ctx, layer.w1_b);
  315. ggml_set_param(ctx, layer.w2_a);
  316. ggml_set_param(ctx, layer.w2_b);
  317. ggml_set_param(ctx, layer.w3_a);
  318. ggml_set_param(ctx, layer.w3_b);
  319. }
  320. }
  321. static void alloc_lora(struct ggml_allocr * alloc, struct my_llama_lora * lora) {
  322. ggml_allocr_alloc(alloc, lora->tok_embeddings_a);
  323. ggml_allocr_alloc(alloc, lora->tok_embeddings_b);
  324. ggml_allocr_alloc(alloc, lora->norm_a);
  325. ggml_allocr_alloc(alloc, lora->norm_b);
  326. ggml_allocr_alloc(alloc, lora->output_a);
  327. ggml_allocr_alloc(alloc, lora->output_b);
  328. for (uint32_t i = 0; i < lora->layers.size(); ++i) {
  329. auto & layer = lora->layers[i];
  330. ggml_allocr_alloc(alloc, layer.attention_norm_a);
  331. ggml_allocr_alloc(alloc, layer.attention_norm_b);
  332. ggml_allocr_alloc(alloc, layer.wq_a);
  333. ggml_allocr_alloc(alloc, layer.wq_b);
  334. ggml_allocr_alloc(alloc, layer.wk_a);
  335. ggml_allocr_alloc(alloc, layer.wk_b);
  336. ggml_allocr_alloc(alloc, layer.wv_a);
  337. ggml_allocr_alloc(alloc, layer.wv_b);
  338. ggml_allocr_alloc(alloc, layer.wo_a);
  339. ggml_allocr_alloc(alloc, layer.wo_b);
  340. ggml_allocr_alloc(alloc, layer.ffn_norm_a);
  341. ggml_allocr_alloc(alloc, layer.ffn_norm_b);
  342. ggml_allocr_alloc(alloc, layer.w1_a);
  343. ggml_allocr_alloc(alloc, layer.w1_b);
  344. ggml_allocr_alloc(alloc, layer.w2_a);
  345. ggml_allocr_alloc(alloc, layer.w2_b);
  346. ggml_allocr_alloc(alloc, layer.w3_a);
  347. ggml_allocr_alloc(alloc, layer.w3_b);
  348. }
  349. ggml_allocr_alloc(alloc, lora->tok_embeddings_a->grad);
  350. ggml_allocr_alloc(alloc, lora->tok_embeddings_b->grad);
  351. ggml_allocr_alloc(alloc, lora->norm_a->grad);
  352. ggml_allocr_alloc(alloc, lora->norm_b->grad);
  353. ggml_allocr_alloc(alloc, lora->output_a->grad);
  354. ggml_allocr_alloc(alloc, lora->output_b->grad);
  355. for (uint32_t i = 0; i < lora->layers.size(); ++i) {
  356. auto & layer = lora->layers[i];
  357. ggml_allocr_alloc(alloc, layer.attention_norm_a->grad);
  358. ggml_allocr_alloc(alloc, layer.attention_norm_b->grad);
  359. ggml_allocr_alloc(alloc, layer.wq_a->grad);
  360. ggml_allocr_alloc(alloc, layer.wq_b->grad);
  361. ggml_allocr_alloc(alloc, layer.wk_a->grad);
  362. ggml_allocr_alloc(alloc, layer.wk_b->grad);
  363. ggml_allocr_alloc(alloc, layer.wv_a->grad);
  364. ggml_allocr_alloc(alloc, layer.wv_b->grad);
  365. ggml_allocr_alloc(alloc, layer.wo_a->grad);
  366. ggml_allocr_alloc(alloc, layer.wo_b->grad);
  367. ggml_allocr_alloc(alloc, layer.ffn_norm_a->grad);
  368. ggml_allocr_alloc(alloc, layer.ffn_norm_b->grad);
  369. ggml_allocr_alloc(alloc, layer.w1_a->grad);
  370. ggml_allocr_alloc(alloc, layer.w1_b->grad);
  371. ggml_allocr_alloc(alloc, layer.w2_a->grad);
  372. ggml_allocr_alloc(alloc, layer.w2_b->grad);
  373. ggml_allocr_alloc(alloc, layer.w3_a->grad);
  374. ggml_allocr_alloc(alloc, layer.w3_b->grad);
  375. }
  376. }
  377. static void init_lora(const struct my_llama_model * model, struct my_llama_lora * lora) {
  378. const auto & lparams = lora->hparams;
  379. const uint32_t n_embd = model->hparams.n_embd;
  380. const uint32_t n_embd_gqa = model->hparams.n_embd_gqa();
  381. const uint32_t n_layer = model->hparams.n_layer;
  382. const uint32_t n_vocab = model->hparams.n_vocab;
  383. const uint32_t n_ff = model->hparams.n_ff;
  384. std::vector<char> tn_buf;
  385. tn_buf.resize(GGML_MAX_NAME);
  386. auto tn = [&tn_buf](const char * key, const char * suffix) -> const char * {
  387. snprintf(tn_buf.data(), tn_buf.size(), "%s%s", key, suffix);
  388. return tn_buf.data();
  389. };
  390. auto tni = [&tn_buf](const char * key, const char * suffix, int bid) -> const char * {
  391. snprintf(tn_buf.data(), tn_buf.size(), key, bid);
  392. std::string s = tn_buf.data();
  393. snprintf(tn_buf.data(), tn_buf.size(), "%s%s", s.c_str(), suffix);
  394. return tn_buf.data();
  395. };
  396. // context for lora tensors without their data
  397. struct ggml_init_params ctx_lora_params;
  398. ctx_lora_params.mem_size = ggml_tensor_overhead()*2*(6 + n_layer*18);
  399. ctx_lora_params.mem_buffer = NULL;
  400. ctx_lora_params.no_alloc = true;
  401. struct ggml_context * ctx = ggml_init(ctx_lora_params);
  402. lora->ctx = ctx;
  403. lora->tok_embeddings_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_tok_embeddings, n_embd);
  404. lora->tok_embeddings_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_tok_embeddings, n_vocab);
  405. lora->norm_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_norm, n_embd);
  406. lora->norm_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_norm, 1);
  407. lora->output_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_output, n_embd);
  408. lora->output_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_output, n_vocab);
  409. ggml_set_name(lora->tok_embeddings_a, tn(LLM_TENSOR_TOKEN_EMBD, ".weight.lora_a"));
  410. ggml_set_name(lora->tok_embeddings_b, tn(LLM_TENSOR_TOKEN_EMBD, ".weight.lora_b"));
  411. ggml_set_name(lora->norm_a, tn(LLM_TENSOR_OUTPUT_NORM, ".weight.lora_a"));
  412. ggml_set_name(lora->norm_b, tn(LLM_TENSOR_OUTPUT_NORM, ".weight.lora_b"));
  413. ggml_set_name(lora->output_a, tn(LLM_TENSOR_OUTPUT, ".weight.lora_a"));
  414. ggml_set_name(lora->output_b, tn(LLM_TENSOR_OUTPUT, ".weight.lora_b"));
  415. lora->layers.resize(n_layer);
  416. for (uint32_t i = 0; i < n_layer; ++i) {
  417. auto & layer = lora->layers[i];
  418. layer.attention_norm_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_attention_norm, n_embd);
  419. layer.attention_norm_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_attention_norm, 1);
  420. layer.wq_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wq, n_embd);
  421. layer.wq_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wq, n_embd);
  422. layer.wk_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wk, n_embd);
  423. layer.wk_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wk, n_embd_gqa);
  424. layer.wv_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wv, n_embd);
  425. layer.wv_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wv, n_embd_gqa);
  426. layer.wo_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wo, n_embd);
  427. layer.wo_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_wo, n_embd);
  428. layer.ffn_norm_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_ffn_norm, n_embd);
  429. layer.ffn_norm_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_ffn_norm, 1);
  430. layer.w1_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_w1, n_embd);
  431. layer.w1_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_w1, n_ff);
  432. layer.w2_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_w2, n_ff);
  433. layer.w2_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_w2, n_embd);
  434. layer.w3_a = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_w3, n_embd);
  435. layer.w3_b = ggml_new_tensor_2d(ctx, GGML_TYPE_F32, lparams.n_rank_w3, n_ff);
  436. ggml_set_name(layer.attention_norm_a, tni(LLM_TENSOR_ATTN_NORM, ".weight.lora_a", i));
  437. ggml_set_name(layer.attention_norm_b, tni(LLM_TENSOR_ATTN_NORM, ".weight.lora_b", i));
  438. ggml_set_name(layer.wq_a, tni(LLM_TENSOR_ATTN_Q, ".weight.lora_a", i));
  439. ggml_set_name(layer.wq_b, tni(LLM_TENSOR_ATTN_Q, ".weight.lora_b", i));
  440. ggml_set_name(layer.wk_a, tni(LLM_TENSOR_ATTN_K, ".weight.lora_a", i));
  441. ggml_set_name(layer.wk_b, tni(LLM_TENSOR_ATTN_K, ".weight.lora_b", i));
  442. ggml_set_name(layer.wv_a, tni(LLM_TENSOR_ATTN_V, ".weight.lora_a", i));
  443. ggml_set_name(layer.wv_b, tni(LLM_TENSOR_ATTN_V, ".weight.lora_b", i));
  444. ggml_set_name(layer.wo_a, tni(LLM_TENSOR_ATTN_OUT, ".weight.lora_a", i));
  445. ggml_set_name(layer.wo_b, tni(LLM_TENSOR_ATTN_OUT, ".weight.lora_b", i));
  446. ggml_set_name(layer.ffn_norm_a, tni(LLM_TENSOR_FFN_NORM, ".weight.lora_a", i));
  447. ggml_set_name(layer.ffn_norm_b, tni(LLM_TENSOR_FFN_NORM, ".weight.lora_b", i));
  448. ggml_set_name(layer.w1_a, tni(LLM_TENSOR_FFN_GATE, ".weight.lora_a", i));
  449. ggml_set_name(layer.w1_b, tni(LLM_TENSOR_FFN_GATE, ".weight.lora_b", i));
  450. ggml_set_name(layer.w2_a, tni(LLM_TENSOR_FFN_DOWN, ".weight.lora_a", i));
  451. ggml_set_name(layer.w2_b, tni(LLM_TENSOR_FFN_DOWN, ".weight.lora_b", i));
  452. ggml_set_name(layer.w3_a, tni(LLM_TENSOR_FFN_UP, ".weight.lora_a", i));
  453. ggml_set_name(layer.w3_b, tni(LLM_TENSOR_FFN_UP, ".weight.lora_b", i));
  454. }
  455. set_param_lora(lora);
  456. // measure data size
  457. struct ggml_allocr * alloc = NULL;
  458. alloc = ggml_allocr_new_measure(tensor_alignment);
  459. alloc_lora(alloc, lora);
  460. // allocate data
  461. lora->data.resize(ggml_allocr_max_size(alloc) + tensor_alignment);
  462. ggml_allocr_free(alloc);
  463. alloc = ggml_allocr_new(lora->data.data(), lora->data.size(), tensor_alignment);
  464. alloc_lora(alloc, lora);
  465. ggml_allocr_free(alloc);
  466. }
  467. static void randomize_lora(struct my_llama_lora * lora, int seed, float mean, float std, float min, float max) {
  468. const uint32_t n_layer = lora->layers.size();
  469. struct random_normal_distribution * rnd = init_random_normal_distribution(seed, mean, std, min, max);
  470. randomize_tensor_normal(lora->tok_embeddings_a, rnd);
  471. randomize_tensor_normal(lora->tok_embeddings_b, rnd);
  472. randomize_tensor_normal(lora->norm_a, rnd);
  473. randomize_tensor_normal(lora->norm_b, rnd);
  474. randomize_tensor_normal(lora->output_a, rnd);
  475. randomize_tensor_normal(lora->output_b, rnd);
  476. for (uint32_t i = 0; i < n_layer; ++i) {
  477. auto & layer = lora->layers[i];
  478. randomize_tensor_normal(layer.attention_norm_a, rnd);
  479. randomize_tensor_normal(layer.attention_norm_b, rnd);
  480. randomize_tensor_normal(layer.wq_a, rnd);
  481. randomize_tensor_normal(layer.wq_b, rnd);
  482. randomize_tensor_normal(layer.wk_a, rnd);
  483. randomize_tensor_normal(layer.wk_b, rnd);
  484. randomize_tensor_normal(layer.wv_a, rnd);
  485. randomize_tensor_normal(layer.wv_b, rnd);
  486. randomize_tensor_normal(layer.wo_a, rnd);
  487. randomize_tensor_normal(layer.wo_b, rnd);
  488. randomize_tensor_normal(layer.ffn_norm_a, rnd);
  489. randomize_tensor_normal(layer.ffn_norm_b, rnd);
  490. randomize_tensor_normal(layer.w1_a, rnd);
  491. randomize_tensor_normal(layer.w1_b, rnd);
  492. randomize_tensor_normal(layer.w2_a, rnd);
  493. randomize_tensor_normal(layer.w2_b, rnd);
  494. randomize_tensor_normal(layer.w3_a, rnd);
  495. randomize_tensor_normal(layer.w3_b, rnd);
  496. }
  497. free_random_normal_distribution(rnd);
  498. }
  499. static struct ggml_tensor * llama_build_lora_finetune_graphs(
  500. struct my_llama_model * model,
  501. struct my_llama_lora * lora,
  502. struct ggml_allocr * alloc,
  503. struct ggml_context * ctx,
  504. struct ggml_cgraph * gf,
  505. struct ggml_cgraph * gb,
  506. struct ggml_cgraph * gb_tmp,
  507. struct ggml_tensor * * logits,
  508. struct ggml_tensor * tokens_input,
  509. struct ggml_tensor * targets,
  510. const int n_tokens,
  511. const int n_batch,
  512. const bool enable_flash_attn,
  513. const bool enable_checkpointing) {
  514. ggml_set_scratch(ctx, { 0, 0, nullptr, });
  515. const int n_past = 0;
  516. const int N = n_tokens;
  517. const auto & hparams = model->hparams;
  518. const int n_ctx = hparams.n_ctx;
  519. const int n_vocab = hparams.n_vocab;
  520. const int n_embd = hparams.n_embd;
  521. const int n_layer = hparams.n_layer;
  522. const int n_head = hparams.n_head;
  523. const int n_head_kv = hparams.n_head_kv;
  524. const int n_ff = hparams.n_ff;
  525. const int n_rot = hparams.n_embd_head();
  526. const int n_embd_head = hparams.n_embd_head();
  527. const int n_embd_gqa = hparams.n_embd_gqa();
  528. const float rms_norm_eps = hparams.f_norm_rms_eps;
  529. const float rope_freq_base = hparams.rope_freq_base;
  530. const float rope_freq_scale = hparams.rope_freq_scale;
  531. GGML_ASSERT((size_t) n_layer == lora->layers.size());
  532. auto set_name = [](struct ggml_tensor * t, const char * n) {
  533. ggml_set_name(t, n);
  534. if (t->grad) {
  535. ggml_format_name(t->grad, "%s->grad", n);
  536. }
  537. };
  538. // KQ_pos - contains the positions
  539. struct ggml_tensor * KQ_pos = ggml_new_tensor_1d(ctx, GGML_TYPE_I32, N);
  540. {
  541. int * data = (int *) KQ_pos->data;
  542. for (int i = 0; i < N; ++i) {
  543. data[i] = n_past + i;
  544. }
  545. }
  546. // rope has so much parameters that we make a custom function for it
  547. auto rope = [ctx, KQ_pos, n_rot, n_ctx, rope_freq_base, rope_freq_scale]
  548. (struct ggml_tensor * t) -> struct ggml_tensor * {
  549. // not capturing these, to silcence warnings
  550. const int rope_mode = 0;
  551. return ggml_rope_custom(ctx,
  552. t, KQ_pos, n_rot, rope_mode, n_ctx,
  553. rope_freq_base, rope_freq_scale);
  554. };
  555. set_name(tokens_input, "tokens_input");
  556. set_name(targets, "targets");
  557. GGML_ASSERT(tokens_input->type == GGML_TYPE_I32);
  558. auto add_to_f32 = [] (struct ggml_context * ctx, struct ggml_tensor * a, struct ggml_tensor * b) {
  559. if (ggml_is_quantized(a->type)) {
  560. return ggml_add_cast(ctx, a, b, GGML_TYPE_F32);
  561. } else if (a->type == GGML_TYPE_F32) {
  562. return ggml_add(ctx, a, b);
  563. } else {
  564. die_fmt("%s: Finetuning on tensors with type '%s' is not yet supported.\n",
  565. __func__, ggml_type_name(a->type));
  566. }
  567. };
  568. struct ggml_tensor * tok_embeddings = add_to_f32(ctx, model->tok_embeddings, ggml_mul_mat(ctx, lora->tok_embeddings_a, lora->tok_embeddings_b));
  569. struct ggml_tensor * norm = add_to_f32(ctx, model->norm, ggml_mul_mat(ctx, lora->norm_a, lora->norm_b));
  570. struct ggml_tensor * output = add_to_f32(ctx, model->output, ggml_mul_mat(ctx, lora->output_a, lora->output_b));
  571. struct ggml_tensor * t00 = ggml_reshape_1d(ctx, tokens_input, N*n_batch); set_name(t00, "t00"); assert_shape_1d(t00, N*n_batch);
  572. struct ggml_tensor * t01 = ggml_get_rows(ctx, tok_embeddings, t00); set_name(t01, "t01"); assert_shape_2d(t01, n_embd, N*n_batch);
  573. struct ggml_tensor * cur = t01;
  574. std::vector<struct ggml_tensor *> checkpoints;
  575. if (enable_checkpointing) {
  576. checkpoints.push_back(tokens_input);
  577. checkpoints.push_back(targets);
  578. checkpoints.push_back(t00);
  579. checkpoints.push_back(t01);
  580. }
  581. struct ggml_tensor * kv_scale = NULL;
  582. if (!enable_flash_attn) {
  583. kv_scale = ggml_new_f32(ctx, 1.0f/sqrtf(float(n_embd)/n_head));
  584. }
  585. for (int il = 0; il < n_layer; ++il) {
  586. struct my_llama_layer & layer = model->layers[il];
  587. struct my_llama_lora_layer & llayer = lora->layers[il];
  588. struct ggml_tensor * attention_norm = add_to_f32(ctx, layer.attention_norm, ggml_mul_mat(ctx, llayer.attention_norm_a, llayer.attention_norm_b));
  589. struct ggml_tensor * ffn_norm = add_to_f32(ctx, layer.ffn_norm, ggml_mul_mat(ctx, llayer.ffn_norm_a, llayer.ffn_norm_b));
  590. struct ggml_tensor * wq = add_to_f32(ctx, layer.wq, ggml_mul_mat(ctx, llayer.wq_a, llayer.wq_b));
  591. struct ggml_tensor * wk = add_to_f32(ctx, layer.wk, ggml_mul_mat(ctx, llayer.wk_a, llayer.wk_b));
  592. struct ggml_tensor * wv = add_to_f32(ctx, layer.wv, ggml_mul_mat(ctx, llayer.wv_a, llayer.wv_b));
  593. struct ggml_tensor * wo = add_to_f32(ctx, layer.wo, ggml_mul_mat(ctx, llayer.wo_a, llayer.wo_b));
  594. struct ggml_tensor * w1 = add_to_f32(ctx, layer.w1, ggml_mul_mat(ctx, llayer.w1_a, llayer.w1_b));
  595. struct ggml_tensor * w2 = add_to_f32(ctx, layer.w2, ggml_mul_mat(ctx, llayer.w2_a, llayer.w2_b));
  596. struct ggml_tensor * w3 = add_to_f32(ctx, layer.w3, ggml_mul_mat(ctx, llayer.w3_a, llayer.w3_b));
  597. struct ggml_tensor * t02 = ggml_rms_norm (ctx, cur, rms_norm_eps); set_name(t02, "t02"); assert_shape_2d(t02, n_embd, N*n_batch);
  598. struct ggml_tensor * t03 = ggml_repeat (ctx, attention_norm, t02); set_name(t03, "t03"); assert_shape_2d(t03, n_embd, N*n_batch);
  599. struct ggml_tensor * t04 = ggml_mul (ctx, t03, t02); set_name(t04, "t04"); assert_shape_2d(t04, n_embd, N*n_batch);
  600. struct ggml_tensor * t05 = ggml_mul_mat (ctx, wq, t04); set_name(t05, "t05"); assert_shape_2d(t05, n_embd, N*n_batch);
  601. struct ggml_tensor * t06 = ggml_reshape_4d (ctx, t05, n_embd_head, n_head, N, n_batch); set_name(t06, "t06"); assert_shape_4d(t06, n_embd_head, n_head, N, n_batch);
  602. struct ggml_tensor * t07 = rope (t06); set_name(t07, "t07"); assert_shape_4d(t07, n_embd_head, n_head, N, n_batch);
  603. struct ggml_tensor * t08 = ggml_mul_mat (ctx, wk, t04); set_name(t08, "t08"); assert_shape_2d(t08, n_embd_gqa, N*n_batch);
  604. struct ggml_tensor * t09 = ggml_reshape_4d (ctx, t08, n_embd_head, n_head_kv, N, n_batch); set_name(t09, "t09"); assert_shape_4d(t09, n_embd_head, n_head_kv, N, n_batch);
  605. struct ggml_tensor * t10 = rope (t09); set_name(t10, "t10"); assert_shape_4d(t10, n_embd_head, n_head_kv, N, n_batch);
  606. struct ggml_tensor * t11;
  607. if (ggml_is_quantized(wv->type)) {
  608. struct ggml_tensor * t11_1 = ggml_mul_mat (ctx, wv, t04); set_name(t11_1, "t11_1"); assert_shape_2d(t11_1, n_embd_gqa, N*n_batch);
  609. struct ggml_tensor * t11_2 = ggml_transpose(ctx, t11_1); set_name(t11_2, "t11_2"); assert_shape_2d(t11_2, N*n_batch, n_embd_gqa);
  610. t11 = ggml_cont (ctx, t11_2); set_name(t11, "t11"); assert_shape_2d(t11, N*n_batch, n_embd_gqa);
  611. } else {
  612. t11 = ggml_mul_mat (ctx, t04, wv); set_name(t11, "t11"); assert_shape_2d(t11, N*n_batch, n_embd_gqa);
  613. }
  614. struct ggml_tensor * t12 = ggml_reshape_4d (ctx, t11, N, n_batch, n_embd_head, n_head_kv); set_name(t12, "t12"); assert_shape_4d(t12, N, n_batch, n_embd_head, n_head_kv);
  615. struct ggml_tensor * t13 = ggml_permute (ctx, t07, 0, 2, 1, 3); set_name(t13, "t13"); assert_shape_4d(t13, n_embd_head, N, n_head, n_batch);
  616. struct ggml_tensor * t14 = ggml_permute (ctx, t10, 0, 2, 1, 3); set_name(t14, "t14"); assert_shape_4d(t14, n_embd_head, N, n_head_kv, n_batch);
  617. struct ggml_tensor * t15 = ggml_permute (ctx, t12, 0, 3, 1, 2); set_name(t15, "t15"); assert_shape_4d(t15, N, n_embd_head, n_head_kv, n_batch);
  618. struct ggml_tensor * t16;
  619. if (enable_flash_attn) {
  620. t16 = ggml_flash_attn(ctx, t13, t14, t15, true); set_name(t16, "t16"); assert_shape_4d(t16, n_embd_head, N, n_head, n_batch);
  621. } else {
  622. struct ggml_tensor * t16_0 = ggml_mul_mat (ctx, t14, t13); set_name(t16_0, "t16_0"); assert_shape_4d(t16_0, N, N, n_head, n_batch);
  623. struct ggml_tensor * t16_1 = ggml_scale_inplace (ctx, t16_0, kv_scale); set_name(t16_1, "t16_1"); assert_shape_4d(t16_1, N, N, n_head, n_batch);
  624. struct ggml_tensor * t16_2 = ggml_diag_mask_inf_inplace(ctx, t16_1, n_past); set_name(t16_2, "t16_2"); assert_shape_4d(t16_2, N, N, n_head, n_batch);
  625. struct ggml_tensor * t16_3 = ggml_soft_max_inplace (ctx, t16_2); set_name(t16_3, "t16_3"); assert_shape_4d(t16_3, N, N, n_head, n_batch);
  626. t16 = ggml_mul_mat(ctx, t15, t16_3); set_name(t16, "t16"); assert_shape_4d(t16, n_embd_head, N, n_head, n_batch);
  627. }
  628. struct ggml_tensor * t17 = ggml_permute (ctx, t16, 0, 2, 1, 3); set_name(t17, "t17"); assert_shape_4d(t17, n_embd_head, n_head, N, n_batch);
  629. struct ggml_tensor * t18 = ggml_cont (ctx, t17); set_name(t18, "t18"); assert_shape_4d(t18, n_embd_head, n_head, N, n_batch);
  630. struct ggml_tensor * t19 = ggml_reshape_2d (ctx, t18, n_embd, N*n_batch); set_name(t19, "t19"); assert_shape_2d(t19, n_embd, N*n_batch);
  631. struct ggml_tensor * t20 = ggml_mul_mat (ctx, wo, t19); set_name(t20, "t20"); assert_shape_2d(t20, n_embd, N*n_batch);
  632. struct ggml_tensor * t21 = ggml_add (ctx, t20, cur); set_name(t21, "t21"); assert_shape_2d(t21, n_embd, N*n_batch);
  633. struct ggml_tensor * t22 = ggml_rms_norm (ctx, t21, rms_norm_eps); set_name(t22, "t22"); assert_shape_2d(t22, n_embd, N*n_batch);
  634. struct ggml_tensor * t23 = ggml_repeat (ctx, ffn_norm, t22); set_name(t23, "t23"); assert_shape_2d(t23, n_embd, N*n_batch);
  635. struct ggml_tensor * t24 = ggml_mul (ctx, t23, t22); set_name(t24, "t24"); assert_shape_2d(t24, n_embd, N*n_batch);
  636. struct ggml_tensor * t25 = ggml_mul_mat (ctx, w3, t24); set_name(t25, "t25"); assert_shape_2d(t25, n_ff, N*n_batch);
  637. struct ggml_tensor * t26 = ggml_mul_mat (ctx, w1, t24); set_name(t26, "t26"); assert_shape_2d(t26, n_ff, N*n_batch);
  638. struct ggml_tensor * t27 = ggml_silu (ctx, t26); set_name(t27, "t27"); assert_shape_2d(t27, n_ff, N*n_batch);
  639. struct ggml_tensor * t28 = ggml_mul (ctx, t27, t25); set_name(t28, "t28"); assert_shape_2d(t28, n_ff, N*n_batch);
  640. struct ggml_tensor * t29 = ggml_mul_mat (ctx, w2, t28); set_name(t29, "t29"); assert_shape_2d(t29, n_embd, N*n_batch);
  641. struct ggml_tensor * t30 = ggml_add (ctx, t29, t21); set_name(t30, "t30"); assert_shape_2d(t30, n_embd, N*n_batch);
  642. cur = t30;
  643. if (enable_checkpointing) {
  644. checkpoints.push_back(cur);
  645. }
  646. }
  647. struct ggml_tensor * t31 = ggml_rms_norm (ctx, cur, rms_norm_eps); set_name(t31, "t31"); assert_shape_2d(t31, n_embd, N*n_batch);
  648. struct ggml_tensor * t32 = ggml_repeat (ctx, norm, t31); set_name(t32, "t32"); assert_shape_2d(t32, n_embd, N*n_batch);
  649. struct ggml_tensor * t33 = ggml_mul (ctx, t32, t31); set_name(t33, "t33"); assert_shape_2d(t33, n_embd, N*n_batch);
  650. struct ggml_tensor * t34 = ggml_mul_mat (ctx, output, t33); set_name(t34, "t34"); assert_shape_2d(t34, n_vocab, N*n_batch);
  651. struct ggml_tensor * t35 = ggml_reshape_3d (ctx, t34, n_vocab, N, n_batch); set_name(t35, "t35"); assert_shape_3d(t35, n_vocab, N, n_batch);
  652. struct ggml_tensor * t36 = ggml_cross_entropy_loss(ctx, t35, targets); set_name(t36, "t36"); assert_shape_1d(t36, 1);
  653. if (enable_checkpointing) {
  654. checkpoints.push_back(t31);
  655. checkpoints.push_back(t32);
  656. checkpoints.push_back(t33);
  657. checkpoints.push_back(t34);
  658. checkpoints.push_back(t35);
  659. checkpoints.push_back(t36);
  660. }
  661. ggml_build_forward_expand(gf, t36);
  662. if (enable_checkpointing) {
  663. ggml_build_backward_gradient_checkpointing(ctx, gf, gb, gb_tmp, checkpoints.data(), (int) checkpoints.size());
  664. } else {
  665. *gb = *gf;
  666. ggml_build_backward_expand(ctx, gf, gb, true);
  667. }
  668. GGML_ASSERT(alloc != NULL);
  669. // make sure some tensors are not reallocated by inserting new temporary nodes depending on them
  670. int n_leafs_before = gb->n_leafs;
  671. int n_nodes_before = gb->n_nodes;
  672. struct ggml_tensor * one = ggml_new_f32(ctx, 1.0f);
  673. // output tensors
  674. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, t35, one));
  675. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, t36, one));
  676. // input gradient
  677. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, t36->grad, one));
  678. GGML_ASSERT(t36->grad->data == NULL && t36->grad->view_src == NULL);
  679. ggml_allocr_alloc(alloc, t36->grad);
  680. // make sure base model tensors data cannot be used in viewable operations
  681. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, model->tok_embeddings, one));
  682. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, model->norm, one));
  683. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, model->output, one));
  684. for (int il = 0; il < n_layer; ++il) {
  685. struct my_llama_layer & layer = model->layers[il];
  686. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.attention_norm, one));
  687. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.ffn_norm, one));
  688. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.wq, one));
  689. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.wk, one));
  690. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.wv, one));
  691. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.wo, one));
  692. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.w1, one));
  693. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.w2, one));
  694. ggml_build_forward_expand(gb, ggml_scale_inplace(ctx, layer.w3, one));
  695. }
  696. // allocating checkpoints in one block to reduce memory fragmentation
  697. // note: they will be freed in reverse order
  698. for (unsigned int i = 0; i < checkpoints.size(); ++i) {
  699. if (checkpoints[i]->data == NULL && checkpoints[i]->view_src == NULL) {
  700. ggml_allocr_alloc(alloc, checkpoints[i]);
  701. }
  702. }
  703. ggml_allocr_alloc_graph(alloc, gb);
  704. // remove the additional nodes and leafs
  705. for (int i = n_leafs_before; i < gb->n_leafs; ++i) {
  706. gb->leafs[i] = NULL;
  707. }
  708. for (int i = n_nodes_before; i < gb->n_nodes; ++i) {
  709. gb->nodes[i] = NULL;
  710. }
  711. gb->n_leafs = n_leafs_before;
  712. gb->n_nodes = n_nodes_before;
  713. *logits = t35;
  714. return t36;
  715. }
  716. static void load_llama_lora_gguf(struct gguf_context * fctx, struct ggml_context * f_ggml_ctx, struct my_llama_model * model, struct my_llama_lora * lora) {
  717. // NOTE: gguf_context must be initialized with f_ggml_ctx and no_alloc=false, otherwise tensor data can not be read
  718. std::string arch;
  719. std::vector<char> keybuf;
  720. keybuf.resize(512);
  721. GGUF_GET_KEY(fctx, arch, gguf_get_val_str, GGUF_TYPE_STRING, true, LLM_KV_GENERAL_ARCHITECTURE);
  722. GGML_ASSERT(arch == "llama");
  723. uint32_t ftype_u;
  724. GGUF_GET_KEY(fctx, ftype_u, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_GENERAL_FILE_TYPE);
  725. GGML_ASSERT((enum llama_ftype) ftype_u == LLAMA_FTYPE_ALL_F32);
  726. struct my_llama_hparams hparams;
  727. load_model_hparams_gguf(fctx, &hparams, arch.c_str());
  728. // parameters that define tensor shapes must match
  729. GGML_ASSERT(hparams.n_embd == model->hparams.n_embd);
  730. GGML_ASSERT(hparams.n_ff == model->hparams.n_ff);
  731. GGML_ASSERT(hparams.n_head == model->hparams.n_head);
  732. GGML_ASSERT(hparams.n_head_kv == model->hparams.n_head_kv);
  733. GGML_ASSERT(hparams.n_layer == model->hparams.n_layer);
  734. GGUF_GET_KEY(fctx, lora->hparams.n_rank_tok_embeddings, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_TOKEN_EMBD);
  735. GGUF_GET_KEY(fctx, lora->hparams.n_rank_norm, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_OUTPUT_NORM);
  736. GGUF_GET_KEY(fctx, lora->hparams.n_rank_output, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_OUTPUT);
  737. GGUF_GET_KEY(fctx, lora->hparams.n_rank_attention_norm, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_ATTN_NORM);
  738. GGUF_GET_KEY(fctx, lora->hparams.n_rank_wq, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_ATTN_Q);
  739. GGUF_GET_KEY(fctx, lora->hparams.n_rank_wk, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_ATTN_K);
  740. GGUF_GET_KEY(fctx, lora->hparams.n_rank_wv, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_ATTN_V);
  741. GGUF_GET_KEY(fctx, lora->hparams.n_rank_wo, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_ATTN_OUT);
  742. GGUF_GET_KEY(fctx, lora->hparams.n_rank_ffn_norm, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_FFN_NORM);
  743. GGUF_GET_KEY(fctx, lora->hparams.n_rank_w1, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_FFN_GATE);
  744. GGUF_GET_KEY(fctx, lora->hparams.n_rank_w2, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_FFN_DOWN);
  745. GGUF_GET_KEY(fctx, lora->hparams.n_rank_w3, gguf_get_val_u32, GGUF_TYPE_UINT32, true, LLM_KV_TRAINING_LORA_RANK_FFN_UP);
  746. init_lora(model, lora);
  747. copy_tensor_by_name(lora->tok_embeddings_a, f_ggml_ctx, ggml_get_name(lora->tok_embeddings_a));
  748. copy_tensor_by_name(lora->tok_embeddings_b, f_ggml_ctx, ggml_get_name(lora->tok_embeddings_b));
  749. copy_tensor_by_name(lora->norm_a, f_ggml_ctx, ggml_get_name(lora->norm_a));
  750. copy_tensor_by_name(lora->norm_b, f_ggml_ctx, ggml_get_name(lora->norm_b));
  751. copy_tensor_by_name(lora->output_a, f_ggml_ctx, ggml_get_name(lora->output_a));
  752. copy_tensor_by_name(lora->output_b, f_ggml_ctx, ggml_get_name(lora->output_b));
  753. for (uint32_t i = 0; i < lora->layers.size(); ++i) {
  754. auto & layer = lora->layers[i];
  755. copy_tensor_by_name(layer.attention_norm_a, f_ggml_ctx, ggml_get_name(layer.attention_norm_a));
  756. copy_tensor_by_name(layer.attention_norm_b, f_ggml_ctx, ggml_get_name(layer.attention_norm_b));
  757. copy_tensor_by_name(layer.wq_a, f_ggml_ctx, ggml_get_name(layer.wq_a));
  758. copy_tensor_by_name(layer.wq_b, f_ggml_ctx, ggml_get_name(layer.wq_b));
  759. copy_tensor_by_name(layer.wk_a, f_ggml_ctx, ggml_get_name(layer.wk_a));
  760. copy_tensor_by_name(layer.wk_b, f_ggml_ctx, ggml_get_name(layer.wk_b));
  761. copy_tensor_by_name(layer.wv_a, f_ggml_ctx, ggml_get_name(layer.wv_a));
  762. copy_tensor_by_name(layer.wv_b, f_ggml_ctx, ggml_get_name(layer.wv_b));
  763. copy_tensor_by_name(layer.wo_a, f_ggml_ctx, ggml_get_name(layer.wo_a));
  764. copy_tensor_by_name(layer.wo_b, f_ggml_ctx, ggml_get_name(layer.wo_b));
  765. copy_tensor_by_name(layer.ffn_norm_a, f_ggml_ctx, ggml_get_name(layer.ffn_norm_a));
  766. copy_tensor_by_name(layer.ffn_norm_b, f_ggml_ctx, ggml_get_name(layer.ffn_norm_b));
  767. copy_tensor_by_name(layer.w1_a, f_ggml_ctx, ggml_get_name(layer.w1_a));
  768. copy_tensor_by_name(layer.w1_b, f_ggml_ctx, ggml_get_name(layer.w1_b));
  769. copy_tensor_by_name(layer.w2_a, f_ggml_ctx, ggml_get_name(layer.w2_a));
  770. copy_tensor_by_name(layer.w2_b, f_ggml_ctx, ggml_get_name(layer.w2_b));
  771. copy_tensor_by_name(layer.w3_a, f_ggml_ctx, ggml_get_name(layer.w3_a));
  772. copy_tensor_by_name(layer.w3_b, f_ggml_ctx, ggml_get_name(layer.w3_b));
  773. }
  774. }
  775. static void save_llama_lora_gguf(struct gguf_context * fctx, struct my_llama_model * model, struct my_llama_lora * lora) {
  776. const char * arch = "llama";
  777. enum llama_ftype ftype = LLAMA_FTYPE_ALL_F32;
  778. std::vector<char> keybuf;
  779. keybuf.resize(512);
  780. auto kv = [arch, &keybuf](const char * key) -> const char * {
  781. snprintf(keybuf.data(), keybuf.size(), key, arch);
  782. return keybuf.data();
  783. };
  784. gguf_set_val_str(fctx, LLM_KV_GENERAL_ARCHITECTURE, arch);
  785. gguf_set_val_u32(fctx, LLM_KV_GENERAL_FILE_TYPE, ftype);
  786. gguf_set_val_u32(fctx, kv(LLM_KV_CONTEXT_LENGTH), model->hparams.n_ctx);
  787. gguf_set_val_u32(fctx, kv(LLM_KV_EMBEDDING_LENGTH), model->hparams.n_embd);
  788. gguf_set_val_u32(fctx, kv(LLM_KV_FEED_FORWARD_LENGTH), model->hparams.n_ff);
  789. gguf_set_val_u32(fctx, kv(LLM_KV_ATTENTION_HEAD_COUNT), model->hparams.n_head);
  790. gguf_set_val_u32(fctx, kv(LLM_KV_ATTENTION_HEAD_COUNT_KV), model->hparams.n_head_kv);
  791. gguf_set_val_u32(fctx, kv(LLM_KV_BLOCK_COUNT), model->hparams.n_layer);
  792. gguf_set_val_u32(fctx, kv(LLM_KV_ROPE_DIMENSION_COUNT), model->hparams.n_embd_head());
  793. gguf_set_val_f32(fctx, kv(LLM_KV_ATTENTION_LAYERNORM_RMS_EPS), model->hparams.f_norm_rms_eps);
  794. gguf_set_val_f32(fctx, kv(LLM_KV_ROPE_FREQ_BASE), model->hparams.rope_freq_base);
  795. gguf_set_val_f32(fctx, kv(LLM_KV_ROPE_SCALE_LINEAR), model->hparams.rope_freq_scale);
  796. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_TOKEN_EMBD, lora->hparams.n_rank_tok_embeddings);
  797. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_OUTPUT_NORM, lora->hparams.n_rank_norm);
  798. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_OUTPUT, lora->hparams.n_rank_output);
  799. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_ATTN_NORM, lora->hparams.n_rank_attention_norm);
  800. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_ATTN_Q, lora->hparams.n_rank_wq);
  801. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_ATTN_K, lora->hparams.n_rank_wk);
  802. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_ATTN_V, lora->hparams.n_rank_wv);
  803. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_ATTN_OUT, lora->hparams.n_rank_wo);
  804. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_FFN_NORM, lora->hparams.n_rank_ffn_norm);
  805. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_FFN_GATE, lora->hparams.n_rank_w1);
  806. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_FFN_DOWN, lora->hparams.n_rank_w2);
  807. gguf_set_val_u32(fctx, LLM_KV_TRAINING_LORA_RANK_FFN_UP, lora->hparams.n_rank_w3);
  808. gguf_add_tensor(fctx, lora->tok_embeddings_a);
  809. gguf_add_tensor(fctx, lora->tok_embeddings_b);
  810. gguf_add_tensor(fctx, lora->norm_a);
  811. gguf_add_tensor(fctx, lora->norm_b);
  812. gguf_add_tensor(fctx, lora->output_a);
  813. gguf_add_tensor(fctx, lora->output_b);
  814. for (uint32_t i = 0; i < lora->layers.size(); ++i) {
  815. auto & layer = lora->layers[i];
  816. gguf_add_tensor(fctx, layer.attention_norm_a);
  817. gguf_add_tensor(fctx, layer.attention_norm_b);
  818. gguf_add_tensor(fctx, layer.wq_a);
  819. gguf_add_tensor(fctx, layer.wq_b);
  820. gguf_add_tensor(fctx, layer.wk_a);
  821. gguf_add_tensor(fctx, layer.wk_b);
  822. gguf_add_tensor(fctx, layer.wv_a);
  823. gguf_add_tensor(fctx, layer.wv_b);
  824. gguf_add_tensor(fctx, layer.wo_a);
  825. gguf_add_tensor(fctx, layer.wo_b);
  826. gguf_add_tensor(fctx, layer.ffn_norm_a);
  827. gguf_add_tensor(fctx, layer.ffn_norm_b);
  828. gguf_add_tensor(fctx, layer.w1_a);
  829. gguf_add_tensor(fctx, layer.w1_b);
  830. gguf_add_tensor(fctx, layer.w2_a);
  831. gguf_add_tensor(fctx, layer.w2_b);
  832. gguf_add_tensor(fctx, layer.w3_a);
  833. gguf_add_tensor(fctx, layer.w3_b);
  834. }
  835. }
  836. static void load_checkpoint_lora_gguf(struct gguf_context * fctx, struct ggml_context * f_ggml_ctx, struct my_llama_model * model, struct my_llama_lora * lora, struct train_state * train) {
  837. std::string train_type = LLM_KV_TRAINING_TYPE_FINETUNE_LORA;
  838. GGUF_GET_KEY(fctx, train_type, gguf_get_val_str, GGUF_TYPE_STRING, false, LLM_KV_TRAINING_TYPE);
  839. GGML_ASSERT(train_type == LLM_KV_TRAINING_TYPE_FINETUNE_LORA);
  840. load_train_state_gguf(fctx, f_ggml_ctx, train);
  841. load_llama_lora_gguf(fctx, f_ggml_ctx, model, lora);
  842. }
  843. static void save_checkpoint_lora_gguf(struct gguf_context * fctx, struct my_llama_model * model, struct my_llama_lora * lora, struct train_state * train) {
  844. gguf_set_val_str(fctx, LLM_KV_TRAINING_TYPE, LLM_KV_TRAINING_TYPE_FINETUNE_LORA);
  845. save_llama_lora_gguf(fctx, model, lora);
  846. save_train_state_gguf(fctx, train);
  847. }
  848. static bool load_checkpoint_lora_file(const char * filename, struct my_llama_model * model, struct my_llama_lora * lora, struct train_state * train) {
  849. struct ggml_context * f_ggml_ctx;
  850. struct gguf_init_params params;
  851. params.no_alloc = false;
  852. params.ctx = &f_ggml_ctx;
  853. struct gguf_context * fctx = gguf_init_from_file(filename, params);
  854. if (fctx == NULL) {
  855. return false;
  856. }
  857. load_checkpoint_lora_gguf(fctx, f_ggml_ctx, model, lora, train);
  858. gguf_free(fctx);
  859. return true;
  860. }
  861. static void save_checkpoint_lora_file(const char * filename, struct my_llama_model * model, struct my_llama_lora * lora, struct train_state * train) {
  862. printf("%s: saving to %s\n", __func__, filename);
  863. struct gguf_context * fctx = gguf_init_empty();
  864. save_checkpoint_lora_gguf(fctx, model, lora, train);
  865. // write file
  866. const bool only_meta = false;
  867. gguf_write_to_file(fctx, filename, only_meta);
  868. gguf_free(fctx);
  869. }
  870. struct llama_file {
  871. // use FILE * so we don't have to re-open the file to mmap
  872. FILE * fp;
  873. size_t size;
  874. llama_file(const char * fname, const char * mode) {
  875. fp = std::fopen(fname, mode);
  876. if (fp == NULL) {
  877. size = 0;
  878. } else {
  879. seek(0, SEEK_END);
  880. size = tell();
  881. seek(0, SEEK_SET);
  882. }
  883. }
  884. size_t tell() const {
  885. #ifdef _WIN32
  886. __int64 ret = _ftelli64(fp);
  887. #else
  888. long ret = std::ftell(fp);
  889. #endif
  890. GGML_ASSERT(ret != -1); // this really shouldn't fail
  891. return (size_t) ret;
  892. }
  893. void seek(size_t offset, int whence) {
  894. #ifdef _WIN32
  895. int ret = _fseeki64(fp, (__int64) offset, whence);
  896. #else
  897. int ret = std::fseek(fp, (long) offset, whence);
  898. #endif
  899. GGML_ASSERT(ret == 0); // same
  900. }
  901. void read_raw(void * ptr, size_t size) {
  902. if (size == 0) {
  903. return;
  904. }
  905. errno = 0;
  906. std::size_t ret = std::fread(ptr, size, 1, fp);
  907. if (ferror(fp)) {
  908. die_fmt("read error: %s", strerror(errno));
  909. }
  910. if (ret != 1) {
  911. die("unexpectedly reached end of file");
  912. }
  913. }
  914. std::uint32_t read_u32() {
  915. std::uint32_t ret;
  916. read_raw(&ret, sizeof(ret));
  917. return ret;
  918. }
  919. std::string read_string(std::uint32_t len) {
  920. std::vector<char> chars(len);
  921. read_raw(chars.data(), len);
  922. return std::string(chars.data(), len);
  923. }
  924. void write_raw(const void * ptr, size_t size) {
  925. if (size == 0) {
  926. return;
  927. }
  928. errno = 0;
  929. size_t ret = std::fwrite(ptr, size, 1, fp);
  930. if (ret != 1) {
  931. die_fmt("write error: %s", strerror(errno));
  932. }
  933. }
  934. void write_u32(std::uint32_t val) {
  935. write_raw(&val, sizeof(val));
  936. }
  937. ~llama_file() {
  938. if (fp) {
  939. std::fclose(fp);
  940. }
  941. }
  942. };
  943. static void write_tensor(struct llama_file * file, struct ggml_tensor * tensor, const char * name) {
  944. if (tensor == NULL) {
  945. file->write_u32(0);
  946. file->write_u32(0);
  947. file->write_u32(GGML_TYPE_F32);
  948. file->seek((0-file->tell()) & 31, SEEK_CUR);
  949. return;
  950. }
  951. if (name == NULL) {
  952. name = ggml_get_name(tensor);
  953. }
  954. uint32_t name_len = strlen(name);
  955. uint32_t nd = tensor->n_dims;
  956. uint32_t ne[4] = { (uint32_t)tensor->ne[0],
  957. (uint32_t)tensor->ne[1],
  958. (uint32_t)tensor->ne[2],
  959. (uint32_t)tensor->ne[3] };
  960. file->write_u32(nd);
  961. file->write_u32(name_len);
  962. file->write_u32(tensor->type);
  963. file->write_raw(ne, sizeof(ne[0]) * nd);
  964. file->write_raw(name, name_len);
  965. file->seek((0-file->tell()) & 31, SEEK_CUR);
  966. file->write_raw(tensor->data, ggml_nbytes(tensor));
  967. }
  968. static void save_as_llama_lora(const char * filename, struct my_llama_lora * lora) {
  969. printf("%s: saving to %s\n", __func__, filename);
  970. struct llama_file file(filename, "wb");
  971. if (file.fp == NULL) {
  972. return;
  973. }
  974. std::vector<char> tn_buf;
  975. tn_buf.resize(GGML_MAX_NAME);
  976. auto tn = [&tn_buf](const char * key, const char * suffix) -> const char * {
  977. snprintf(tn_buf.data(), tn_buf.size(), "%s%s", key, suffix);
  978. return tn_buf.data();
  979. };
  980. auto tni = [&tn_buf](const char * key, int bid, const char * suffix) -> const char * {
  981. snprintf(tn_buf.data(), tn_buf.size(), key, bid);
  982. std::string s = tn_buf.data();
  983. snprintf(tn_buf.data(), tn_buf.size(), "%s%s", s.c_str(), suffix);
  984. return tn_buf.data();
  985. };
  986. uint32_t LLAMA_FILE_MAGIC_LORA = 0x67676C61; // 'ggla'
  987. // write_magic
  988. file.write_u32(LLAMA_FILE_MAGIC_LORA); // magic
  989. file.write_u32(1); // version
  990. // write_hparams
  991. file.write_u32(lora->hparams.lora_r);
  992. file.write_u32(lora->hparams.lora_alpha);
  993. // write tensors
  994. write_tensor(&file, lora->tok_embeddings_a, tn(LLM_TENSOR_TOKEN_EMBD, ".weight.loraA"));
  995. write_tensor(&file, lora->tok_embeddings_b, tn(LLM_TENSOR_TOKEN_EMBD, ".weight.loraB"));
  996. write_tensor(&file, lora->norm_a, tn(LLM_TENSOR_OUTPUT_NORM, ".weight.loraA"));
  997. write_tensor(&file, lora->norm_b, tn(LLM_TENSOR_OUTPUT_NORM, ".weight.loraB"));
  998. write_tensor(&file, lora->output_a, tn(LLM_TENSOR_OUTPUT, ".weight.loraA"));
  999. write_tensor(&file, lora->output_b, tn(LLM_TENSOR_OUTPUT, ".weight.loraB"));
  1000. for (uint32_t i = 0; i < lora->layers.size(); ++i) {
  1001. auto & layer = lora->layers[i];
  1002. write_tensor(&file, layer.attention_norm_a, tni(LLM_TENSOR_ATTN_NORM, i, ".weight.loraA"));
  1003. write_tensor(&file, layer.attention_norm_b, tni(LLM_TENSOR_ATTN_NORM, i, ".weight.loraB"));
  1004. write_tensor(&file, layer.wq_a, tni(LLM_TENSOR_ATTN_Q, i, ".weight.loraA"));
  1005. write_tensor(&file, layer.wq_b, tni(LLM_TENSOR_ATTN_Q, i, ".weight.loraB"));
  1006. write_tensor(&file, layer.wk_a, tni(LLM_TENSOR_ATTN_K, i, ".weight.loraA"));
  1007. write_tensor(&file, layer.wk_b, tni(LLM_TENSOR_ATTN_K, i, ".weight.loraB"));
  1008. write_tensor(&file, layer.wv_a, tni(LLM_TENSOR_ATTN_V, i, ".weight.loraA"));
  1009. write_tensor(&file, layer.wv_b, tni(LLM_TENSOR_ATTN_V, i, ".weight.loraB"));
  1010. write_tensor(&file, layer.wo_a, tni(LLM_TENSOR_ATTN_OUT, i, ".weight.loraA"));
  1011. write_tensor(&file, layer.wo_b, tni(LLM_TENSOR_ATTN_OUT, i, ".weight.loraB"));
  1012. write_tensor(&file, layer.ffn_norm_a, tni(LLM_TENSOR_FFN_NORM, i, ".weight.loraA"));
  1013. write_tensor(&file, layer.ffn_norm_b, tni(LLM_TENSOR_FFN_NORM, i, ".weight.loraB"));
  1014. write_tensor(&file, layer.w1_a, tni(LLM_TENSOR_FFN_GATE, i, ".weight.loraA"));
  1015. write_tensor(&file, layer.w1_b, tni(LLM_TENSOR_FFN_GATE, i, ".weight.loraB"));
  1016. write_tensor(&file, layer.w2_a, tni(LLM_TENSOR_FFN_DOWN, i, ".weight.loraA"));
  1017. write_tensor(&file, layer.w2_b, tni(LLM_TENSOR_FFN_DOWN, i, ".weight.loraB"));
  1018. write_tensor(&file, layer.w3_a, tni(LLM_TENSOR_FFN_UP, i, ".weight.loraA"));
  1019. write_tensor(&file, layer.w3_b, tni(LLM_TENSOR_FFN_UP, i, ".weight.loraB"));
  1020. }
  1021. }
  1022. struct train_params {
  1023. struct train_params_common common;
  1024. const char * fn_model_base;
  1025. const char * fn_lora_out;
  1026. bool only_write_lora;
  1027. float f_norm_rms_eps;
  1028. float rope_freq_base;
  1029. float rope_freq_scale;
  1030. bool custom_f_norm_rms_eps;
  1031. bool custom_rope_freq_base;
  1032. bool custom_rope_freq_scale;
  1033. int32_t lora_r;
  1034. int32_t lora_alpha;
  1035. bool custom_lora_alpha;
  1036. uint32_t n_rank_attention_norm;
  1037. uint32_t n_rank_wq;
  1038. uint32_t n_rank_wk;
  1039. uint32_t n_rank_wv;
  1040. uint32_t n_rank_wo;
  1041. uint32_t n_rank_ffn_norm;
  1042. uint32_t n_rank_w1;
  1043. uint32_t n_rank_w2;
  1044. uint32_t n_rank_w3;
  1045. uint32_t n_rank_tok_embeddings;
  1046. uint32_t n_rank_norm;
  1047. uint32_t n_rank_output;
  1048. bool custom_n_rank_attention_norm;
  1049. bool custom_n_rank_wq;
  1050. bool custom_n_rank_wk;
  1051. bool custom_n_rank_wv;
  1052. bool custom_n_rank_wo;
  1053. bool custom_n_rank_ffn_norm;
  1054. bool custom_n_rank_w1;
  1055. bool custom_n_rank_w2;
  1056. bool custom_n_rank_w3;
  1057. bool custom_n_rank_tok_embeddings;
  1058. bool custom_n_rank_norm;
  1059. bool custom_n_rank_output;
  1060. };
  1061. static struct train_params get_default_train_params() {
  1062. struct train_params params;
  1063. params.common = get_default_train_params_common();
  1064. params.fn_model_base = "";
  1065. params.fn_lora_out = "ggml-lora-ITERATION-f32.gguf";
  1066. params.only_write_lora = false;
  1067. params.f_norm_rms_eps = 1e-5f;
  1068. params.rope_freq_base = 10000.0f;
  1069. params.rope_freq_scale = 1.0f;
  1070. params.custom_f_norm_rms_eps = false;
  1071. params.custom_rope_freq_base = false;
  1072. params.custom_rope_freq_scale = false;
  1073. params.lora_r = 4;
  1074. params.lora_alpha = 4;
  1075. params.custom_lora_alpha = false;
  1076. params.n_rank_attention_norm = 1;
  1077. params.n_rank_wq = 4;
  1078. params.n_rank_wk = 4;
  1079. params.n_rank_wv = 4;
  1080. params.n_rank_wo = 4;
  1081. params.n_rank_ffn_norm = 1;
  1082. params.n_rank_w1 = 4;
  1083. params.n_rank_w2 = 4;
  1084. params.n_rank_w3 = 4;
  1085. params.n_rank_tok_embeddings = 4;
  1086. params.n_rank_norm = 1;
  1087. params.n_rank_output = 4;
  1088. params.custom_n_rank_attention_norm = false;
  1089. params.custom_n_rank_wq = false;
  1090. params.custom_n_rank_wk = false;
  1091. params.custom_n_rank_wv = false;
  1092. params.custom_n_rank_wo = false;
  1093. params.custom_n_rank_ffn_norm = false;
  1094. params.custom_n_rank_w1 = false;
  1095. params.custom_n_rank_w2 = false;
  1096. params.custom_n_rank_w3 = false;
  1097. params.custom_n_rank_tok_embeddings = false;
  1098. params.custom_n_rank_norm = false;
  1099. params.custom_n_rank_output = false;
  1100. return params;
  1101. }
  1102. static void train_print_usage(int argc, char ** argv, const struct train_params * params) {
  1103. fprintf(stderr, "usage: %s [options]\n", argv[0]);
  1104. fprintf(stderr, "\n");
  1105. fprintf(stderr, "options:\n");
  1106. fprintf(stderr, " -h, --help show this help message and exit\n");
  1107. fprintf(stderr, " --model-base FNAME model path from which to load base model (default '%s')\n", params->fn_model_base);
  1108. fprintf(stderr, " --lora-out FNAME path to save llama lora (default '%s')\n", params->fn_lora_out);
  1109. fprintf(stderr, " --only-write-lora only save llama lora, don't do any training. use this if you only want to convert a checkpoint to a lora adapter.\n");
  1110. fprintf(stderr, " --norm-rms-eps F RMS-Norm epsilon value (default %f)\n", params->f_norm_rms_eps);
  1111. fprintf(stderr, " --rope-freq-base F Frequency base for ROPE (default %f)\n", params->rope_freq_base);
  1112. fprintf(stderr, " --rope-freq-scale F Frequency scale for ROPE (default %f)\n", params->rope_freq_scale);
  1113. fprintf(stderr, " --lora-alpha N LORA alpha : resulting LORA scaling is alpha/r. (default %d)\n", params->lora_alpha);
  1114. fprintf(stderr, " --lora-r N LORA r: default rank. Also specifies resulting scaling together with lora-alpha. (default %d)\n", params->lora_r);
  1115. fprintf(stderr, " --rank-att-norm N LORA rank for attention norm tensor, overrides default rank. Norm tensors should generally have rank 1.\n");
  1116. fprintf(stderr, " --rank-ffn-norm N LORA rank for feed-forward norm tensor, overrides default rank. Norm tensors should generally have rank 1.\n");
  1117. fprintf(stderr, " --rank-out-norm N LORA rank for output norm tensor, overrides default rank. Norm tensors should generally have rank 1.\n");
  1118. fprintf(stderr, " --rank-tok-embd N LORA rank for token embeddings tensor, overrides default rank.\n");
  1119. fprintf(stderr, " --rank-out N LORA rank for output tensor, overrides default rank.\n");
  1120. fprintf(stderr, " --rank-wq N LORA rank for wq tensor, overrides default rank.\n");
  1121. fprintf(stderr, " --rank-wk N LORA rank for wk tensor, overrides default rank.\n");
  1122. fprintf(stderr, " --rank-wv N LORA rank for wv tensor, overrides default rank.\n");
  1123. fprintf(stderr, " --rank-wo N LORA rank for wo tensor, overrides default rank.\n");
  1124. fprintf(stderr, " --rank-w1 N LORA rank for w1 tensor, overrides default rank.\n");
  1125. fprintf(stderr, " --rank-w2 N LORA rank for w2 tensor, overrides default rank.\n");
  1126. fprintf(stderr, " --rank-w3 N LORA rank for w3 tensor, overrides default rank.\n");
  1127. print_common_train_usage(argc, argv, &params->common);
  1128. }
  1129. static bool train_params_parse(int argc, char ** argv, struct train_params * params) {
  1130. bool invalid_param = false;
  1131. std::string arg;
  1132. struct train_params default_params = get_default_train_params();
  1133. const std::string arg_prefix = "--";
  1134. for (int i = 1; i < argc; i++) {
  1135. arg = argv[i];
  1136. if (arg.compare(0, arg_prefix.size(), arg_prefix) == 0) {
  1137. std::replace(arg.begin(), arg.end(), '_', '-');
  1138. }
  1139. if (consume_common_train_arg(argc, argv, &i, &params->common, &invalid_param)) {
  1140. if (invalid_param) {
  1141. break;
  1142. } else if (params->common.print_usage) {
  1143. train_print_usage(argc, argv, &default_params);
  1144. exit(0);
  1145. }
  1146. } else if (arg == "--model-base") {
  1147. if (++i >= argc) {
  1148. invalid_param = true;
  1149. break;
  1150. }
  1151. params->fn_model_base = argv[i];
  1152. } else if (arg == "--lora-out") {
  1153. if (++i >= argc) {
  1154. invalid_param = true;
  1155. break;
  1156. }
  1157. params->fn_lora_out = argv[i];
  1158. } else if (arg == "--only-write-lora") {
  1159. params->only_write_lora = true;
  1160. } else if (arg == "--norm-rms-eps") {
  1161. if (++i >= argc) {
  1162. invalid_param = true;
  1163. break;
  1164. }
  1165. params->f_norm_rms_eps = std::stof(argv[i]);
  1166. params->custom_f_norm_rms_eps = true;
  1167. } else if (arg == "--rope-freq-base") {
  1168. if (++i >= argc) {
  1169. invalid_param = true;
  1170. break;
  1171. }
  1172. params->rope_freq_base = std::stof(argv[i]);
  1173. params->custom_rope_freq_base = true;
  1174. } else if (arg == "--rope-freq-scale") {
  1175. if (++i >= argc) {
  1176. invalid_param = true;
  1177. break;
  1178. }
  1179. params->rope_freq_scale = std::stof(argv[i]);
  1180. params->custom_rope_freq_scale = true;
  1181. } else if (arg == "--lora-alpha") {
  1182. if (++i >= argc) {
  1183. invalid_param = true;
  1184. break;
  1185. }
  1186. params->lora_alpha = std::stoi(argv[i]);
  1187. params->custom_lora_alpha = true;
  1188. } else if (arg == "--lora-r") {
  1189. if (++i >= argc) {
  1190. invalid_param = true;
  1191. break;
  1192. }
  1193. params->lora_r = std::stoi(argv[i]);
  1194. } else if (arg == "--rank-att-norm") {
  1195. if (++i >= argc) {
  1196. invalid_param = true;
  1197. break;
  1198. }
  1199. params->n_rank_attention_norm = std::stoi(argv[i]);
  1200. params->custom_n_rank_attention_norm = true;
  1201. } else if (arg == "--rank-ffn-norm") {
  1202. if (++i >= argc) {
  1203. invalid_param = true;
  1204. break;
  1205. }
  1206. params->n_rank_ffn_norm = std::stoi(argv[i]);
  1207. params->custom_n_rank_ffn_norm = true;
  1208. } else if (arg == "--rank-out-norm") {
  1209. if (++i >= argc) {
  1210. invalid_param = true;
  1211. break;
  1212. }
  1213. params->n_rank_norm = std::stoi(argv[i]);
  1214. params->custom_n_rank_norm = true;
  1215. } else if (arg == "--rank-tok-embd") {
  1216. if (++i >= argc) {
  1217. invalid_param = true;
  1218. break;
  1219. }
  1220. params->n_rank_tok_embeddings = std::stoi(argv[i]);
  1221. params->custom_n_rank_tok_embeddings = true;
  1222. } else if (arg == "--rank-out") {
  1223. if (++i >= argc) {
  1224. invalid_param = true;
  1225. break;
  1226. }
  1227. params->n_rank_output = std::stoi(argv[i]);
  1228. params->custom_n_rank_output = true;
  1229. } else if (arg == "--rank-wq") {
  1230. if (++i >= argc) {
  1231. invalid_param = true;
  1232. break;
  1233. }
  1234. params->n_rank_wq = std::stoi(argv[i]);
  1235. params->custom_n_rank_wq = true;
  1236. } else if (arg == "--rank-wk") {
  1237. if (++i >= argc) {
  1238. invalid_param = true;
  1239. break;
  1240. }
  1241. params->n_rank_wk = std::stoi(argv[i]);
  1242. params->custom_n_rank_wk = true;
  1243. } else if (arg == "--rank-wv") {
  1244. if (++i >= argc) {
  1245. invalid_param = true;
  1246. break;
  1247. }
  1248. params->n_rank_wv = std::stoi(argv[i]);
  1249. params->custom_n_rank_wv = true;
  1250. } else if (arg == "--rank-wo") {
  1251. if (++i >= argc) {
  1252. invalid_param = true;
  1253. break;
  1254. }
  1255. params->n_rank_wo = std::stoi(argv[i]);
  1256. params->custom_n_rank_wo = true;
  1257. } else if (arg == "--rank-w1") {
  1258. if (++i >= argc) {
  1259. invalid_param = true;
  1260. break;
  1261. }
  1262. params->n_rank_w1 = std::stoi(argv[i]);
  1263. params->custom_n_rank_w1 = true;
  1264. } else if (arg == "--rank-w2") {
  1265. if (++i >= argc) {
  1266. invalid_param = true;
  1267. break;
  1268. }
  1269. params->n_rank_w2 = std::stoi(argv[i]);
  1270. params->custom_n_rank_w2 = true;
  1271. } else if (arg == "--rank-w3") {
  1272. if (++i >= argc) {
  1273. invalid_param = true;
  1274. break;
  1275. }
  1276. params->n_rank_w3 = std::stoi(argv[i]);
  1277. params->custom_n_rank_w3 = true;
  1278. } else {
  1279. fprintf(stderr, "error: unknown argument: %s\n", arg.c_str());
  1280. train_print_usage(argc, argv, &default_params);
  1281. exit(1);
  1282. }
  1283. }
  1284. if (invalid_param) {
  1285. fprintf(stderr, "error: invalid parameter for argument: %s\n", arg.c_str());
  1286. train_print_usage(argc, argv, &default_params);
  1287. exit(1);
  1288. }
  1289. finish_processing_train_args(&params->common);
  1290. return true;
  1291. }
  1292. struct save_train_files_data {
  1293. const char * fn_checkpoint_out;
  1294. const char * fn_lora_out;
  1295. const char * pattern_fn_it;
  1296. const char * fn_latest;
  1297. struct my_llama_model * model;
  1298. struct my_llama_lora * lora;
  1299. };
  1300. static void save_train_files(void * vdata, struct train_state * train) {
  1301. struct save_train_files_data * data = (struct save_train_files_data *) vdata;
  1302. int64_t iter = train->opt->iter;
  1303. if (strlen(data->fn_checkpoint_out) > 0) {
  1304. save_checkpoint_lora_file(get_train_filename(data->fn_checkpoint_out, data->pattern_fn_it, data->fn_latest, iter).c_str(), data->model, data->lora, train);
  1305. save_checkpoint_lora_file(get_train_filename(data->fn_checkpoint_out, data->pattern_fn_it, data->fn_latest, -1 ).c_str(), data->model, data->lora, train);
  1306. }
  1307. if (strlen(data->fn_lora_out) > 0) {
  1308. save_as_llama_lora(get_train_filename(data->fn_lora_out, data->pattern_fn_it, data->fn_latest, iter).c_str(), data->lora);
  1309. save_as_llama_lora(get_train_filename(data->fn_lora_out, data->pattern_fn_it, data->fn_latest, -1 ).c_str(), data->lora);
  1310. }
  1311. }
  1312. static int64_t get_parameter_count(struct my_llama_lora* lora) {
  1313. int64_t nx = 0;
  1314. nx += ggml_nelements(lora->tok_embeddings_a);
  1315. nx += ggml_nelements(lora->tok_embeddings_b);
  1316. nx += ggml_nelements(lora->norm_a);
  1317. nx += ggml_nelements(lora->norm_b);
  1318. nx += ggml_nelements(lora->output_a);
  1319. nx += ggml_nelements(lora->output_b);
  1320. for (uint32_t i = 0; i < lora->layers.size(); ++i) {
  1321. auto & layer = lora->layers[i];
  1322. nx += ggml_nelements(layer.attention_norm_a);
  1323. nx += ggml_nelements(layer.attention_norm_b);
  1324. nx += ggml_nelements(layer.wq_a);
  1325. nx += ggml_nelements(layer.wq_b);
  1326. nx += ggml_nelements(layer.wk_a);
  1327. nx += ggml_nelements(layer.wk_b);
  1328. nx += ggml_nelements(layer.wv_a);
  1329. nx += ggml_nelements(layer.wv_b);
  1330. nx += ggml_nelements(layer.wo_a);
  1331. nx += ggml_nelements(layer.wo_b);
  1332. nx += ggml_nelements(layer.ffn_norm_a);
  1333. nx += ggml_nelements(layer.ffn_norm_b);
  1334. nx += ggml_nelements(layer.w1_a);
  1335. nx += ggml_nelements(layer.w1_b);
  1336. nx += ggml_nelements(layer.w2_a);
  1337. nx += ggml_nelements(layer.w2_b);
  1338. nx += ggml_nelements(layer.w3_a);
  1339. nx += ggml_nelements(layer.w3_b);
  1340. }
  1341. return nx;
  1342. }
  1343. int main(int argc, char ** argv) {
  1344. struct train_params params = get_default_train_params();
  1345. if (!train_params_parse(argc, argv, &params)) {
  1346. return 1;
  1347. }
  1348. if (params.common.seed == LLAMA_DEFAULT_SEED) {
  1349. params.common.seed = time(NULL);
  1350. }
  1351. printf("%s: seed: %u\n", __func__, params.common.seed);
  1352. srand(params.common.seed);
  1353. struct llama_context_params llama_params = llama_context_default_params();
  1354. llama_params.vocab_only = false;
  1355. printf("%s: model base = '%s'\n", __func__, params.fn_model_base);
  1356. struct llama_model * lmodel = llama_load_model_from_file(params.fn_model_base, llama_params);
  1357. struct llama_context * lctx = llama_new_context_with_model(lmodel, llama_params);
  1358. struct my_llama_model model;
  1359. init_model(lmodel, &model, params.fn_model_base, params.common.n_ctx);
  1360. struct my_llama_lora lora;
  1361. struct train_state * train = init_train_state();
  1362. struct ggml_opt_context * opt = train->opt;
  1363. // set params from command line
  1364. if (params.custom_f_norm_rms_eps) {
  1365. model.hparams.f_norm_rms_eps = params.f_norm_rms_eps;
  1366. }
  1367. if (params.custom_rope_freq_base) {
  1368. model.hparams.rope_freq_base = params.rope_freq_base;
  1369. }
  1370. if (params.custom_rope_freq_scale) {
  1371. model.hparams.rope_freq_scale = params.rope_freq_scale;
  1372. }
  1373. lora.hparams.lora_r = params.lora_r;
  1374. lora.hparams.lora_alpha = params.custom_lora_alpha ? params.lora_alpha : params.lora_r;
  1375. uint32_t n_rank_attention_norm = params.custom_n_rank_attention_norm ? params.n_rank_attention_norm : 1;
  1376. uint32_t n_rank_wq = params.custom_n_rank_wq ? params.n_rank_wq : params.lora_r;
  1377. uint32_t n_rank_wk = params.custom_n_rank_wk ? params.n_rank_wk : params.lora_r;
  1378. uint32_t n_rank_wv = params.custom_n_rank_wv ? params.n_rank_wv : params.lora_r;
  1379. uint32_t n_rank_wo = params.custom_n_rank_wo ? params.n_rank_wo : params.lora_r;
  1380. uint32_t n_rank_ffn_norm = params.custom_n_rank_ffn_norm ? params.n_rank_ffn_norm : 1;
  1381. uint32_t n_rank_w1 = params.custom_n_rank_w1 ? params.n_rank_w1 : params.lora_r;
  1382. uint32_t n_rank_w2 = params.custom_n_rank_w2 ? params.n_rank_w2 : params.lora_r;
  1383. uint32_t n_rank_w3 = params.custom_n_rank_w3 ? params.n_rank_w3 : params.lora_r;
  1384. uint32_t n_rank_tok_embeddings = params.custom_n_rank_tok_embeddings ? params.n_rank_tok_embeddings : params.lora_r;
  1385. uint32_t n_rank_norm = params.custom_n_rank_norm ? params.n_rank_norm : 1;
  1386. uint32_t n_rank_output = params.custom_n_rank_output ? params.n_rank_output : params.lora_r;
  1387. lora.hparams.n_rank_attention_norm = n_rank_attention_norm;
  1388. lora.hparams.n_rank_wq = n_rank_wq;
  1389. lora.hparams.n_rank_wk = n_rank_wk;
  1390. lora.hparams.n_rank_wv = n_rank_wv;
  1391. lora.hparams.n_rank_wo = n_rank_wo;
  1392. lora.hparams.n_rank_ffn_norm = n_rank_ffn_norm;
  1393. lora.hparams.n_rank_w1 = n_rank_w1;
  1394. lora.hparams.n_rank_w2 = n_rank_w2;
  1395. lora.hparams.n_rank_w3 = n_rank_w3;
  1396. lora.hparams.n_rank_tok_embeddings = n_rank_tok_embeddings;
  1397. lora.hparams.n_rank_norm = n_rank_norm;
  1398. lora.hparams.n_rank_output = n_rank_output;
  1399. // set opt params from command line
  1400. opt->params = ggml_opt_default_params(GGML_OPT_ADAM);
  1401. opt->params.print_forward_graph = false;
  1402. opt->params.print_backward_graph = false;
  1403. opt->params.n_threads = params.common.n_threads;
  1404. opt->params.past = params.common.opt_past;
  1405. opt->params.delta = params.common.opt_delta;
  1406. opt->params.max_no_improvement = params.common.opt_max_no_improvement;
  1407. opt->params.n_gradient_accumulation = params.common.n_gradient_accumulation;
  1408. opt->params.adam.n_iter = params.common.adam_n_iter;
  1409. opt->params.adam.sched = 1.0f;
  1410. opt->params.adam.alpha = params.common.adam_alpha;
  1411. opt->params.adam.decay = params.common.adam_decay;
  1412. opt->params.adam.decay_min_ndim = params.common.adam_decay_min_ndim;
  1413. opt->params.adam.beta1 = params.common.adam_beta1;
  1414. opt->params.adam.beta2 = params.common.adam_beta2;
  1415. opt->params.adam.gclip = params.common.adam_gclip;
  1416. opt->params.adam.eps_f = params.common.adam_eps_f;
  1417. ggml_allocr * alloc = NULL;
  1418. printf("%s: init model\n", __func__);
  1419. bool existed = load_checkpoint_lora_file(params.common.fn_checkpoint_in, &model, &lora, train);
  1420. if (existed) {
  1421. // overwrite last n_ctx with user provided n_ctx
  1422. if (params.common.custom_n_ctx) {
  1423. model.hparams.n_ctx = params.common.n_ctx;
  1424. }
  1425. const bool opt_param_count_changed = (
  1426. (lora.hparams.n_rank_attention_norm != n_rank_attention_norm)
  1427. || (lora.hparams.n_rank_wq != n_rank_wq)
  1428. || (lora.hparams.n_rank_wk != n_rank_wk)
  1429. || (lora.hparams.n_rank_wv != n_rank_wv)
  1430. || (lora.hparams.n_rank_wo != n_rank_wo)
  1431. || (lora.hparams.n_rank_ffn_norm != n_rank_ffn_norm)
  1432. || (lora.hparams.n_rank_w1 != n_rank_w1)
  1433. || (lora.hparams.n_rank_w2 != n_rank_w2)
  1434. || (lora.hparams.n_rank_w3 != n_rank_w3)
  1435. || (lora.hparams.n_rank_tok_embeddings != n_rank_tok_embeddings)
  1436. || (lora.hparams.n_rank_norm != n_rank_norm)
  1437. || (lora.hparams.n_rank_output != n_rank_output)
  1438. );
  1439. const bool opt_past_changed = opt->params.past != params.common.opt_past;
  1440. if (opt_param_count_changed) {
  1441. print_lora_params(&lora.hparams);
  1442. die("Provided rank differs from checkpoint file. To use different rank start finetune from scratch with empty input checkpoint, e.g --checkpoint-in ''. Aborting.");
  1443. // need to discard previous optimizer gradient statistics and opt_init with new shapes
  1444. // TODO
  1445. }
  1446. if (opt_past_changed) {
  1447. die("Optimizer parameter '--opt-past N' differs from checkpoint file. To use different value finetune from scratch with empty input checkpoint, e.g --checkpoint-in ''. Aborting");
  1448. // need to discard previous optimizer past function value statistics and opt_init with new shapes
  1449. // TODO
  1450. }
  1451. } else { // existed == false
  1452. init_lora(&model, &lora);
  1453. randomize_lora(&lora, params.common.seed, 0.0f, 1.0f, -1.0f, +1.0f);
  1454. if (!params.only_write_lora) {
  1455. ggml_opt_init(opt->ctx, opt, opt->params, get_parameter_count(&lora));
  1456. }
  1457. }
  1458. opt->iter = train->train_its;
  1459. print_params(&model.hparams);
  1460. print_lora_params(&lora.hparams);
  1461. printf("%s: total train_iterations %llu\n", __func__, (long long unsigned) train->train_its);
  1462. printf("%s: seen train_samples %llu\n", __func__, (long long unsigned) train->train_samples);
  1463. printf("%s: seen train_tokens %llu\n", __func__, (long long unsigned) train->train_tokens);
  1464. printf("%s: completed train_epochs %llu\n", __func__, (long long unsigned) train->train_epochs);
  1465. printf("%s: lora_size = %zu bytes (%.1f MB)\n", __func__, (ggml_used_mem(lora.ctx) + lora.data.size()), (float) (ggml_used_mem(lora.ctx) + lora.data.size()) / (1024.0f*1024.0f));
  1466. if (params.only_write_lora) {
  1467. save_train_files_data save_data;
  1468. save_data.fn_checkpoint_out = "";
  1469. save_data.fn_lora_out = params.fn_lora_out;
  1470. save_data.pattern_fn_it = params.common.pattern_fn_it;
  1471. save_data.fn_latest = params.common.fn_latest;
  1472. save_data.model = &model;
  1473. save_data.lora = &lora;
  1474. save_train_files(&save_data, train);
  1475. free_train_state(train);
  1476. ggml_free(lora.ctx);
  1477. llama_free(lctx);
  1478. llama_free_model(lmodel);
  1479. return 0;
  1480. }
  1481. printf("%s: opt_size = %zu bytes (%.1f MB)\n", __func__, ggml_get_mem_size(opt->ctx), (float) ggml_get_mem_size(opt->ctx) / (1024.0f*1024.0f));
  1482. printf("%s: opt iter %d\n", __func__, opt->iter);
  1483. int n_tokens = model.hparams.n_ctx;
  1484. int n_vocab = model.hparams.n_vocab;
  1485. int n_batch = params.common.n_batch;
  1486. std::vector<uint8_t> mem_input_data;
  1487. std::vector<uint8_t> mem_compute_data;
  1488. // context for input tensors without their data
  1489. struct ggml_init_params ctx_input_params = {
  1490. ggml_tensor_overhead() * 2, // mem_size
  1491. NULL, // mem_buffer
  1492. true, // no_alloc
  1493. };
  1494. struct ggml_context * ctx_input = ggml_init(ctx_input_params);
  1495. // the input tensors
  1496. struct ggml_tensor * tokens_input = ggml_new_tensor_2d(ctx_input, GGML_TYPE_I32, n_tokens, n_batch);
  1497. struct ggml_tensor * target_probs = ggml_new_tensor_3d(ctx_input, GGML_TYPE_F32, n_vocab, n_tokens, n_batch);
  1498. // measure required memory for input tensors
  1499. alloc = ggml_allocr_new_measure(tensor_alignment);
  1500. ggml_allocr_alloc(alloc, tokens_input);
  1501. ggml_allocr_alloc(alloc, target_probs);
  1502. size_t max_input_size = ggml_allocr_max_size(alloc) + tensor_alignment;
  1503. ggml_allocr_free(alloc);
  1504. printf("%s: input_size = %zu bytes (%.1f MB)\n", __func__, max_input_size, (float) max_input_size / (1024.0f*1024.0f));
  1505. // allocate input tensors
  1506. mem_input_data.resize(max_input_size);
  1507. alloc = ggml_allocr_new(mem_input_data.data(), mem_input_data.size(), tensor_alignment);
  1508. ggml_allocr_alloc(alloc, tokens_input);
  1509. ggml_allocr_alloc(alloc, target_probs);
  1510. ggml_allocr_free(alloc);
  1511. // context for compute tensors without their data
  1512. size_t estimated_compute_size_wo_data = (
  1513. ggml_tensor_overhead()*GGML_MAX_NODES*2
  1514. + (GGML_OBJECT_SIZE+GGML_GRAPH_SIZE)*(
  1515. params.common.use_checkpointing ? 3 : 2
  1516. )
  1517. );
  1518. struct ggml_init_params ctx_compute_params = {
  1519. estimated_compute_size_wo_data, // mem_size
  1520. NULL, // mem_buffer
  1521. true, // no_alloc
  1522. };
  1523. struct ggml_context * ctx_compute = NULL;
  1524. struct ggml_tensor * loss = NULL;
  1525. struct ggml_tensor * logits = NULL;
  1526. struct ggml_cgraph * gf = NULL;
  1527. struct ggml_cgraph * gb = NULL;
  1528. struct ggml_cgraph * gb_tmp = NULL;
  1529. // measure required memory for compute tensors
  1530. size_t best_compute_size = SIZE_MAX;
  1531. enum ggml_cgraph_eval_order best_order = GGML_CGRAPH_EVAL_ORDER_COUNT;
  1532. // find best evaluation order
  1533. for (unsigned order = 0; order < (unsigned) GGML_CGRAPH_EVAL_ORDER_COUNT; ++order) {
  1534. ctx_compute = ggml_init(ctx_compute_params);
  1535. alloc = ggml_allocr_new_measure(tensor_alignment);
  1536. gf = ggml_new_graph(ctx_compute);
  1537. gf->order = (enum ggml_cgraph_eval_order) order;
  1538. gb = ggml_new_graph(ctx_compute);
  1539. gb_tmp = params.common.use_checkpointing
  1540. ? ggml_new_graph(ctx_compute)
  1541. : NULL;
  1542. loss = llama_build_lora_finetune_graphs(
  1543. &model, &lora, alloc, ctx_compute,
  1544. gf, gb, gb_tmp,
  1545. &logits, tokens_input, target_probs,
  1546. n_tokens, n_batch,
  1547. params.common.use_flash,
  1548. params.common.use_checkpointing
  1549. );
  1550. size_t max_compute_size = ggml_allocr_max_size(alloc) + tensor_alignment;
  1551. if (max_compute_size < best_compute_size) {
  1552. best_compute_size = max_compute_size;
  1553. best_order = gf->order;
  1554. }
  1555. ggml_allocr_free(alloc);
  1556. ggml_free(ctx_compute);
  1557. }
  1558. size_t max_compute_size = best_compute_size;
  1559. printf("%s: compute_size = %zu bytes (%.1f MB)\n", __func__, max_compute_size, (float) max_compute_size / (1024.0f*1024.0f));
  1560. printf("%s: evaluation order = %s\n", __func__,
  1561. (best_order == GGML_CGRAPH_EVAL_ORDER_LEFT_TO_RIGHT) ? "LEFT_TO_RIGHT" :
  1562. (best_order == GGML_CGRAPH_EVAL_ORDER_RIGHT_TO_LEFT) ? "RIGHT_TO_LEFT" :
  1563. "invalid");
  1564. // allocate compute tensors
  1565. mem_compute_data.resize(max_compute_size);
  1566. ctx_compute = ggml_init(ctx_compute_params);
  1567. alloc = ggml_allocr_new(mem_compute_data.data(), mem_compute_data.size(), tensor_alignment);
  1568. gf = ggml_new_graph(ctx_compute);
  1569. gf->order = best_order;
  1570. gb = ggml_new_graph(ctx_compute);
  1571. gb_tmp = params.common.use_checkpointing
  1572. ? ggml_new_graph(ctx_compute)
  1573. : NULL;
  1574. loss = llama_build_lora_finetune_graphs(
  1575. &model, &lora, alloc, ctx_compute,
  1576. gf, gb, gb_tmp,
  1577. &logits, tokens_input, target_probs,
  1578. n_tokens, n_batch,
  1579. params.common.use_flash,
  1580. params.common.use_checkpointing
  1581. );
  1582. ggml_allocr_free(alloc);
  1583. // tokenize data
  1584. std::vector<llama_token> train_tokens;
  1585. std::vector<size_t> train_samples_begin;
  1586. std::vector<size_t> train_samples_size;
  1587. printf("%s: tokenize training data\n", __func__);
  1588. tokenize_file(lctx,
  1589. params.common.fn_train_data,
  1590. params.common.sample_start,
  1591. params.common.include_sample_start,
  1592. params.common.overlapping_samples,
  1593. n_tokens,
  1594. train_tokens,
  1595. train_samples_begin,
  1596. train_samples_size);
  1597. GGML_ASSERT(train_samples_begin.size() == train_samples_size.size());
  1598. printf("%s: number of training tokens: %zu\n", __func__, train_tokens.size());
  1599. std::vector<size_t> token_noccurs;
  1600. token_noccurs.resize(model.hparams.n_vocab, 0);
  1601. for (unsigned int i = 0; i < train_tokens.size(); ++i) {
  1602. ++token_noccurs[train_tokens[i]];
  1603. }
  1604. int n_unique_tokens = 0;
  1605. for (unsigned int i = 0; i < token_noccurs.size(); ++i) {
  1606. if (token_noccurs[i] == 0) continue;
  1607. ++n_unique_tokens;
  1608. }
  1609. printf("%s: number of unique tokens: %d\n", __func__, n_unique_tokens);
  1610. size_t shuffle_samples_hash = compute_samples_hash(params.common.fn_train_data, train_samples_begin.data(), train_samples_size.data(), train_samples_size.size());
  1611. const bool changed_train_data = (shuffle_samples_hash != train->shuffle_samples_hash) || (train->shuffle_sample_count != train_samples_size.size());
  1612. if (changed_train_data) {
  1613. printf("%s: train data seems to have changed. restarting shuffled epoch.\n", __func__);
  1614. }
  1615. if (params.common.force_reshuffle) {
  1616. printf("%s: forced reshuffling of data. restarting with newly shuffled epoch.\n", __func__);
  1617. }
  1618. if ((train->shuffle_rng_state_current == "") || changed_train_data || params.common.force_reshuffle) {
  1619. train->shuffle_rng_state_current = mt19937_seed_to_state(params.common.seed);
  1620. train->shuffle_sample_count = train_samples_size.size();
  1621. train->shuffle_next_sample = 0;
  1622. train->shuffle_samples_hash = shuffle_samples_hash;
  1623. }
  1624. std::vector<size_t> train_shuffled_samples_offs;
  1625. std::vector<size_t> train_shuffled_samples_begin;
  1626. std::vector<size_t> train_shuffled_samples_size;
  1627. train_shuffled_samples_offs.resize(train_samples_begin.size());
  1628. train_shuffled_samples_begin.resize(train_samples_begin.size());
  1629. train_shuffled_samples_size.resize(train_samples_size.size());
  1630. train->shuffle_rng_state_next = shuffle_samples(
  1631. train->shuffle_rng_state_current,
  1632. train_shuffled_samples_offs.data(),
  1633. train_shuffled_samples_begin.data(),
  1634. train_shuffled_samples_size.data(),
  1635. train_samples_begin.data(),
  1636. train_samples_size.data(),
  1637. train_samples_size.size());
  1638. printf("%s: begin training\n", __func__);
  1639. save_train_files_data save_data;
  1640. save_data.fn_checkpoint_out = params.common.fn_checkpoint_out;
  1641. save_data.fn_lora_out = params.fn_lora_out;
  1642. save_data.pattern_fn_it = params.common.pattern_fn_it;
  1643. save_data.fn_latest = params.common.fn_latest;
  1644. save_data.model = &model;
  1645. save_data.lora = &lora;
  1646. struct train_opt_callback_data opt_cb_data;
  1647. opt_cb_data.params = &params.common;
  1648. opt_cb_data.train = train;
  1649. opt_cb_data.save_cb = &save_train_files;
  1650. opt_cb_data.save_data = &save_data;
  1651. opt_cb_data.lctx = lctx;
  1652. opt_cb_data.last_save_iter = opt->iter;
  1653. opt_cb_data.tokens_data = train_tokens.data();
  1654. opt_cb_data.tokens_size = train_tokens.size();
  1655. opt_cb_data.samples_begin = train_samples_begin.data();
  1656. opt_cb_data.samples_size = train_samples_size.data();
  1657. opt_cb_data.shuffled_samples_offs = train_shuffled_samples_offs.data();
  1658. opt_cb_data.shuffled_samples_begin = train_shuffled_samples_begin.data();
  1659. opt_cb_data.shuffled_samples_size = train_shuffled_samples_size.data();
  1660. opt_cb_data.samples_count = train_samples_size.size();
  1661. opt_cb_data.tokens_input = tokens_input;
  1662. opt_cb_data.target_probs = target_probs;
  1663. opt_cb_data.first_iter = opt->iter;
  1664. opt_cb_data.first_epoch = train->train_epochs;
  1665. opt_cb_data.iter_at_last_epoch = -1;
  1666. opt_cb_data.last_time = ggml_time_ms();
  1667. opt_cb_data.millis_per_iter = 0.0;
  1668. // measure required memory for work buffer
  1669. size_t max_work_size = ggml_graph_plan(gb, params.common.n_threads).work_size + GGML_OBJECT_SIZE;
  1670. printf("%s: work_size = %zu bytes (%.1f MB)\n", __func__, max_work_size, (float) max_work_size / (1024.0f*1024.0f));
  1671. // context for work buffer
  1672. struct ggml_init_params ctx_work_params = {
  1673. max_work_size, // mem_size
  1674. NULL, // mem_buffer
  1675. false, // no_alloc
  1676. };
  1677. struct ggml_context * ctx_work = ggml_init(ctx_work_params);
  1678. int64_t t0 = ggml_time_ms();
  1679. ggml_opt_resume_g(ctx_work, opt, loss, gf, gb, &train_opt_callback, (void *) &opt_cb_data);
  1680. ggml_free(ctx_work);
  1681. ggml_free(ctx_compute);
  1682. ggml_free(ctx_input);
  1683. int64_t t1 = ggml_time_ms();
  1684. printf("%s: total training time: ", __func__);
  1685. print_duration((double) (t1 - t0));
  1686. printf("\n");
  1687. int new_iters = opt->iter - opt_cb_data.last_save_iter;
  1688. if (new_iters > 0) {
  1689. train->train_its += new_iters;
  1690. train->train_tokens += new_iters * opt->params.n_gradient_accumulation * n_batch * n_tokens;
  1691. save_train_files(&save_data, train);
  1692. opt_cb_data.last_save_iter = opt->iter;
  1693. }
  1694. ggml_free(opt->ctx);
  1695. free_train_state(train);
  1696. ggml_free(lora.ctx);
  1697. llama_free(lctx);
  1698. llama_free_model(lmodel);
  1699. return 0;
  1700. }