1
0

clip-impl.h 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359
  1. #include "ggml.h"
  2. #include "gguf.h"
  3. #include "clip.h"
  4. #include <climits>
  5. #include <cstdarg>
  6. #include <string>
  7. #include <map>
  8. #include <sstream>
  9. #include <vector>
  10. #include <memory>
  11. // Internal header for clip.cpp
  12. #define KEY_FTYPE "general.file_type"
  13. #define KEY_NAME "general.name"
  14. #define KEY_DESCRIPTION "general.description"
  15. #define KEY_MINICPMV_VERSION "clip.minicpmv_version"
  16. #define KEY_USE_GELU "clip.use_gelu"
  17. #define KEY_USE_SILU "clip.use_silu"
  18. #define KEY_N_EMBD "clip.vision.embedding_length"
  19. #define KEY_N_FF "clip.vision.feed_forward_length"
  20. #define KEY_N_BLOCK "clip.vision.block_count"
  21. #define KEY_N_HEAD "clip.vision.attention.head_count"
  22. #define KEY_LAYER_NORM_EPS "clip.vision.attention.layer_norm_epsilon"
  23. #define KEY_PROJ_DIM "clip.vision.projection_dim"
  24. #define KEY_IMAGE_SIZE "clip.vision.image_size"
  25. #define KEY_PATCH_SIZE "clip.vision.patch_size"
  26. #define KEY_IMAGE_MEAN "clip.vision.image_mean"
  27. #define KEY_IMAGE_STD "clip.vision.image_std"
  28. #define KEY_FEATURE_LAYER "clip.vision.feature_layer"
  29. #define KEY_PROJ_SCALE_FACTOR "clip.vision.projector.scale_factor"
  30. #define KEY_PROJ_TYPE "clip.projector_type"
  31. #define KEY_SPATIAL_MERGE_SIZE "clip.vision.spatial_merge_size"
  32. #define KEY_USE_GLU_MLP "clip.use_glu_mlp" // for qwen2.5vl
  33. #define KEY_USE_RMS_NORM "clip.use_rms_norm" // for qwen2.5vl
  34. #define KEY_MM_PATCH_MERGE_TYPE "clip.vision.mm_patch_merge_type"
  35. #define KEY_IMAGE_GRID_PINPOINTS "clip.vision.image_grid_pinpoints"
  36. #define KEY_IMAGE_CROP_RESOLUTION "clip.vision.image_crop_resolution"
  37. #define KEY_WIN_ATTN_PATTERN "clip.vision.n_wa_pattern"
  38. #define KEY_ATTN_WINDOW_SIZE "clip.vision.window_size"
  39. //
  40. // tensor name constants
  41. //
  42. #define TN_POS_EMBD "%s.position_embd.weight"
  43. #define TN_CLASS_EMBD "v.class_embd"
  44. #define TN_PATCH_EMBD "v.patch_embd.weight" // not rename tensor with ".0" postfix for backwrad compat
  45. #define TN_PATCH_EMBD_1 "v.patch_embd.weight.1"
  46. #define TN_PATCH_BIAS "v.patch_embd.bias"
  47. #define TN_ATTN_K "%s.blk.%d.attn_k.%s"
  48. #define TN_ATTN_Q "%s.blk.%d.attn_q.%s"
  49. #define TN_ATTN_V "%s.blk.%d.attn_v.%s"
  50. #define TN_ATTN_OUTPUT "%s.blk.%d.attn_out.%s"
  51. #define TN_FFN_DOWN "%s.blk.%d.ffn_down.%s"
  52. #define TN_FFN_GATE "%s.blk.%d.ffn_gate.%s"
  53. #define TN_FFN_UP "%s.blk.%d.ffn_up.%s"
  54. #define TN_FFN_GATE "%s.blk.%d.ffn_gate.%s"
  55. #define TN_LN_1 "%s.blk.%d.ln1.%s"
  56. #define TN_LN_2 "%s.blk.%d.ln2.%s"
  57. #define TN_LN_PRE "%s.pre_ln.%s"
  58. #define TN_LN_POST "%s.post_ln.%s"
  59. #define TN_LLAVA_PROJ "mm.%d.%s"
  60. #define TN_MVLM_PROJ_MLP "mm.model.mlp.%d.%s"
  61. #define TN_MVLM_PROJ_BLOCK "mm.model.mb_block.%d.block.%d.%s"
  62. #define TN_MVLM_PROJ_PEG "mm.model.peg.%d.%s"
  63. #define TN_IMAGE_NEWLINE "model.image_newline"
  64. #define TN_MM_INP_NORM "mm.input_norm.weight"
  65. #define TN_MM_INP_PROJ "mm.input_projection.weight" // gemma3
  66. #define TN_MM_SOFT_EMB_N "mm.soft_emb_norm.weight" // gemma3
  67. #define TN_MM_PROJECTOR "mm.model.fc.weight" // idefics3
  68. #define TN_MM_PATCH_MERGER "mm.patch_merger.weight" // mistral small 3.1
  69. #define TN_TOK_IMG_BREAK "v.token_embd.img_break" // pixtral
  70. #define TN_TOK_GLM_BOI "adapter.boi" // glm-edge (these embeddings are not in text model)
  71. #define TN_TOK_GLM_EOI "adapter.eoi" // glm-edge (these embeddings are not in text model)
  72. // mimicpmv
  73. #define TN_MINICPMV_POS_EMBD_K "resampler.pos_embed_k"
  74. #define TN_MINICPMV_QUERY "resampler.query"
  75. #define TN_MINICPMV_PROJ "resampler.proj.weight"
  76. #define TN_MINICPMV_KV_PROJ "resampler.kv.weight"
  77. #define TN_MINICPMV_ATTN "resampler.attn.%s.%s"
  78. #define TN_MINICPMV_LN "resampler.ln_%s.%s"
  79. #define TN_GLM_ADAPER_CONV "adapter.conv.%s"
  80. #define TN_GLM_ADAPTER_LINEAR "adapter.linear.linear.%s"
  81. #define TN_GLM_ADAPTER_NORM_1 "adapter.linear.norm1.%s"
  82. #define TN_GLM_ADAPTER_D_H_2_4H "adapter.linear.dense_h_to_4h.%s"
  83. #define TN_GLM_ADAPTER_GATE "adapter.linear.gate.%s"
  84. #define TN_GLM_ADAPTER_D_4H_2_H "adapter.linear.dense_4h_to_h.%s"
  85. enum projector_type {
  86. PROJECTOR_TYPE_MLP,
  87. PROJECTOR_TYPE_MLP_NORM,
  88. PROJECTOR_TYPE_LDP,
  89. PROJECTOR_TYPE_LDPV2,
  90. PROJECTOR_TYPE_MINICPMV,
  91. PROJECTOR_TYPE_GLM_EDGE,
  92. PROJECTOR_TYPE_QWEN2VL,
  93. PROJECTOR_TYPE_GEMMA3,
  94. PROJECTOR_TYPE_IDEFICS3,
  95. PROJECTOR_TYPE_PIXTRAL,
  96. PROJECTOR_TYPE_QWEN25VL,
  97. PROJECTOR_TYPE_UNKNOWN,
  98. };
  99. static std::map<projector_type, std::string> PROJECTOR_TYPE_NAMES = {
  100. { PROJECTOR_TYPE_MLP, "mlp" },
  101. { PROJECTOR_TYPE_LDP, "ldp" },
  102. { PROJECTOR_TYPE_LDPV2, "ldpv2"},
  103. { PROJECTOR_TYPE_MINICPMV, "resampler"},
  104. { PROJECTOR_TYPE_GLM_EDGE, "adapter"},
  105. { PROJECTOR_TYPE_QWEN2VL, "qwen2vl_merger"},
  106. { PROJECTOR_TYPE_QWEN25VL, "qwen2.5vl_merger"},
  107. { PROJECTOR_TYPE_GEMMA3, "gemma3"},
  108. { PROJECTOR_TYPE_IDEFICS3, "idefics3"},
  109. { PROJECTOR_TYPE_PIXTRAL, "pixtral"},
  110. };
  111. static projector_type clip_projector_type_from_string(const std::string & str) {
  112. for (const auto & pair : PROJECTOR_TYPE_NAMES) {
  113. if (pair.second == str) {
  114. return pair.first;
  115. }
  116. }
  117. return PROJECTOR_TYPE_UNKNOWN;
  118. }
  119. // RGB uint8 image
  120. struct clip_image_u8 {
  121. int nx;
  122. int ny;
  123. std::vector<uint8_t> buf;
  124. };
  125. // RGB float32 image (NHWC)
  126. // Memory layout: RGBRGBRGB...
  127. struct clip_image_f32 {
  128. int nx;
  129. int ny;
  130. std::vector<float> buf;
  131. };
  132. //
  133. // logging
  134. //
  135. static void clip_log_callback_default(enum ggml_log_level level, const char * text, void * user_data) {
  136. (void) level;
  137. (void) user_data;
  138. fputs(text, stderr);
  139. fflush(stderr);
  140. }
  141. struct clip_logger_state {
  142. ggml_log_level verbosity_thold;
  143. ggml_log_callback log_callback;
  144. void * log_callback_user_data;
  145. };
  146. extern struct clip_logger_state g_logger_state;
  147. static void clip_log_internal_v(enum ggml_log_level level, const char * format, va_list args) {
  148. if (format == NULL) {
  149. return;
  150. }
  151. va_list args_copy;
  152. va_copy(args_copy, args);
  153. char buffer[128];
  154. int len = vsnprintf(buffer, 128, format, args);
  155. if (len < 128) {
  156. g_logger_state.log_callback(level, buffer, g_logger_state.log_callback_user_data);
  157. } else {
  158. char * buffer2 = (char *) calloc(len + 1, sizeof(char));
  159. vsnprintf(buffer2, len + 1, format, args_copy);
  160. buffer2[len] = 0;
  161. g_logger_state.log_callback(level, buffer2, g_logger_state.log_callback_user_data);
  162. free(buffer2);
  163. }
  164. va_end(args_copy);
  165. }
  166. static void clip_log_internal(enum ggml_log_level level, const char * format, ...) {
  167. va_list args;
  168. va_start(args, format);
  169. clip_log_internal_v(level, format, args);
  170. va_end(args);
  171. }
  172. #define LOG_TMPL(level, ...) \
  173. do { \
  174. if ((level) >= g_logger_state.verbosity_thold) { \
  175. clip_log_internal((level), __VA_ARGS__); \
  176. } \
  177. } while (0)
  178. #define LOG_INF(...) LOG_TMPL(GGML_LOG_LEVEL_INFO, __VA_ARGS__)
  179. #define LOG_WRN(...) LOG_TMPL(GGML_LOG_LEVEL_WARN, __VA_ARGS__)
  180. #define LOG_ERR(...) LOG_TMPL(GGML_LOG_LEVEL_ERROR, __VA_ARGS__)
  181. #define LOG_DBG(...) LOG_TMPL(GGML_LOG_LEVEL_DEBUG, __VA_ARGS__)
  182. #define LOG_CNT(...) LOG_TMPL(GGML_LOG_LEVEL_CONT, __VA_ARGS__)
  183. //
  184. // cpp wrappers
  185. //
  186. // wrapper for clip_image_size
  187. struct clip_image_size_deleter {
  188. void operator()(clip_image_size * val) { clip_image_size_free(val); }
  189. };
  190. typedef std::unique_ptr<clip_image_size, clip_image_size_deleter> clip_image_size_ptr;
  191. // wrapper for clip_image_u8
  192. struct clip_image_u8_deleter {
  193. void operator()(clip_image_u8 * val) { clip_image_u8_free(val); }
  194. };
  195. typedef std::unique_ptr<clip_image_u8, clip_image_u8_deleter> clip_image_u8_ptr;
  196. // wrapper for clip_image_f32
  197. struct clip_image_f32_deleter {
  198. void operator()(clip_image_f32 * val) { clip_image_f32_free(val); }
  199. };
  200. typedef std::unique_ptr<clip_image_f32, clip_image_f32_deleter> clip_image_f32_ptr;
  201. struct clip_image_u8_batch {
  202. std::vector<clip_image_u8_ptr> entries;
  203. };
  204. struct clip_image_f32_batch {
  205. std::vector<clip_image_f32_ptr> entries;
  206. clip_image_f32_batch clone() const {
  207. clip_image_f32_batch new_batch;
  208. new_batch.entries.reserve(entries.size());
  209. for (const auto & entry : entries) {
  210. new_batch.entries.emplace_back(new clip_image_f32(*entry));
  211. }
  212. return new_batch;
  213. }
  214. };
  215. //
  216. // common utils
  217. //
  218. static std::string string_format(const char * fmt, ...) {
  219. va_list ap;
  220. va_list ap2;
  221. va_start(ap, fmt);
  222. va_copy(ap2, ap);
  223. int size = vsnprintf(NULL, 0, fmt, ap);
  224. GGML_ASSERT(size >= 0 && size < INT_MAX); // NOLINT
  225. std::vector<char> buf(size + 1);
  226. int size2 = vsnprintf(buf.data(), size + 1, fmt, ap2);
  227. GGML_ASSERT(size2 == size);
  228. va_end(ap2);
  229. va_end(ap);
  230. return std::string(buf.data(), buf.size());
  231. }
  232. static void string_replace_all(std::string & s, const std::string & search, const std::string & replace) {
  233. if (search.empty()) {
  234. return;
  235. }
  236. std::string builder;
  237. builder.reserve(s.length());
  238. size_t pos = 0;
  239. size_t last_pos = 0;
  240. while ((pos = s.find(search, last_pos)) != std::string::npos) {
  241. builder.append(s, last_pos, pos - last_pos);
  242. builder.append(replace);
  243. last_pos = pos + search.length();
  244. }
  245. builder.append(s, last_pos, std::string::npos);
  246. s = std::move(builder);
  247. }
  248. // split string by a `std::string delim` instead of `char delim`
  249. static std::vector<std::string> string_split_str(std::string s, const std::string & delimiter) {
  250. std::vector<std::string> tokens;
  251. size_t pos = 0;
  252. std::string token;
  253. while ((pos = s.find(delimiter)) != std::string::npos) {
  254. token = s.substr(0, pos);
  255. tokens.push_back(token);
  256. s.erase(0, pos + delimiter.length());
  257. }
  258. tokens.push_back(s);
  259. return tokens;
  260. }
  261. //
  262. // gguf utils
  263. //
  264. static std::string gguf_data_to_str(enum gguf_type type, const void * data, int i) {
  265. switch (type) {
  266. case GGUF_TYPE_UINT8: return std::to_string(((const uint8_t *)data)[i]);
  267. case GGUF_TYPE_INT8: return std::to_string(((const int8_t *)data)[i]);
  268. case GGUF_TYPE_UINT16: return std::to_string(((const uint16_t *)data)[i]);
  269. case GGUF_TYPE_INT16: return std::to_string(((const int16_t *)data)[i]);
  270. case GGUF_TYPE_UINT32: return std::to_string(((const uint32_t *)data)[i]);
  271. case GGUF_TYPE_INT32: return std::to_string(((const int32_t *)data)[i]);
  272. case GGUF_TYPE_UINT64: return std::to_string(((const uint64_t *)data)[i]);
  273. case GGUF_TYPE_INT64: return std::to_string(((const int64_t *)data)[i]);
  274. case GGUF_TYPE_FLOAT32: return std::to_string(((const float *)data)[i]);
  275. case GGUF_TYPE_FLOAT64: return std::to_string(((const double *)data)[i]);
  276. case GGUF_TYPE_BOOL: return ((const bool *)data)[i] ? "true" : "false";
  277. default: return string_format("unknown type %d", type);
  278. }
  279. }
  280. static std::string gguf_kv_to_str(const struct gguf_context * ctx_gguf, int i) {
  281. const enum gguf_type type = gguf_get_kv_type(ctx_gguf, i);
  282. switch (type) {
  283. case GGUF_TYPE_STRING:
  284. return gguf_get_val_str(ctx_gguf, i);
  285. case GGUF_TYPE_ARRAY:
  286. {
  287. const enum gguf_type arr_type = gguf_get_arr_type(ctx_gguf, i);
  288. int arr_n = gguf_get_arr_n(ctx_gguf, i);
  289. const void * data = arr_type == GGUF_TYPE_STRING ? nullptr : gguf_get_arr_data(ctx_gguf, i);
  290. std::stringstream ss;
  291. ss << "[";
  292. for (int j = 0; j < arr_n; j++) {
  293. if (arr_type == GGUF_TYPE_STRING) {
  294. std::string val = gguf_get_arr_str(ctx_gguf, i, j);
  295. // escape quotes
  296. string_replace_all(val, "\\", "\\\\");
  297. string_replace_all(val, "\"", "\\\"");
  298. ss << '"' << val << '"';
  299. } else if (arr_type == GGUF_TYPE_ARRAY) {
  300. ss << "???";
  301. } else {
  302. ss << gguf_data_to_str(arr_type, data, j);
  303. }
  304. if (j < arr_n - 1) {
  305. ss << ", ";
  306. }
  307. }
  308. ss << "]";
  309. return ss.str();
  310. }
  311. default:
  312. return gguf_data_to_str(type, gguf_get_val_data(ctx_gguf, i), 0);
  313. }
  314. }
  315. //
  316. // API used internally with mtmd
  317. //
  318. projector_type clip_get_projector_type(const struct clip_ctx * ctx);