| 313 | } |
| 314 | |
| 315 | static int _BulkInsert_ProcessTokens |
| 316 | ( |
| 317 | GraphContext* gc, |
| 318 | int token_count, |
| 319 | RedisModuleString** argv, |
| 320 | SchemaType type |
| 321 | ) { |
| 322 | for (int i = 0; i < token_count; i++) { |
| 323 | size_t len; |
| 324 | // retrieve a pointer to the next binary stream and record its length |
| 325 | const char* data = RedisModule_StringPtrLen(argv[i], &len); |
| 326 | int rc = (type == SCHEMA_NODE) |
| 327 | ? _BulkInsert_ProcessNodeFile(gc, data, len) |
| 328 | : _BulkInsert_ProcessEdgeFile(gc, data, len); |
| 329 | UNUSED(rc); |
| 330 | ASSERT(rc == BULK_OK); |
| 331 | } |
| 332 | |
| 333 | return BULK_OK; |
| 334 | } |
| 335 | |
| 336 | int BulkInsert |
| 337 | ( |
no test coverage detected