rpc-server.cpp 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. #ifdef GGML_USE_CUDA
  2. #include "ggml-cuda.h"
  3. #endif
  4. #ifdef GGML_USE_METAL
  5. #include "ggml-metal.h"
  6. #endif
  7. #include "ggml-rpc.h"
  8. #include <string>
  9. #include <stdio.h>
  10. static ggml_backend_t create_backend() {
  11. ggml_backend_t backend = NULL;
  12. #ifdef GGML_USE_CUDA
  13. fprintf(stderr, "%s: using CUDA backend\n", __func__);
  14. backend = ggml_backend_cuda_init(0); // init device 0
  15. if (!backend) {
  16. fprintf(stderr, "%s: ggml_backend_cuda_init() failed\n", __func__);
  17. }
  18. #elif GGML_USE_METAL
  19. fprintf(stderr, "%s: using Metal backend\n", __func__);
  20. backend = ggml_backend_metal_init();
  21. if (!backend) {
  22. fprintf(stderr, "%s: ggml_backend_metal_init() failed\n", __func__);
  23. }
  24. #endif
  25. // if there aren't GPU Backends fallback to CPU backend
  26. if (!backend) {
  27. fprintf(stderr, "%s: using CPU backend\n", __func__);
  28. backend = ggml_backend_cpu_init();
  29. }
  30. return backend;
  31. }
  32. static void get_backend_memory(size_t * free_mem, size_t * total_mem) {
  33. #ifdef GGML_USE_CUDA
  34. ggml_backend_cuda_get_device_memory(0, free_mem, total_mem);
  35. #else
  36. // TODO: implement for other backends
  37. *free_mem = 1;
  38. *total_mem = 1;
  39. #endif
  40. }
  41. int main(int argc, char * argv[]) {
  42. if (argc < 3) {
  43. fprintf(stderr, "Usage: %s <host> <port>\n", argv[0]);
  44. return 1;
  45. }
  46. const char * host = argv[1];
  47. int port = std::stoi(argv[2]);
  48. if (port <= 0 || port > 65535) {
  49. fprintf(stderr, "Invalid port number: %d\n", port);
  50. return 1;
  51. }
  52. ggml_backend_t backend = create_backend();
  53. if (!backend) {
  54. fprintf(stderr, "Failed to create backend\n");
  55. return 1;
  56. }
  57. printf("Starting RPC server on %s:%d\n", host, port);
  58. size_t free_mem, total_mem;
  59. get_backend_memory(&free_mem, &total_mem);
  60. std::string endpoint = std::string(host) + ":" + std::to_string(port);
  61. start_rpc_server(backend, endpoint.c_str(), free_mem, total_mem);
  62. ggml_backend_free(backend);
  63. return 0;
  64. }