Function thread_worker

example/couchbase_c++/multithreaded_couchbase_client.cpp:171–232

Simple thread worker function

// Simple thread worker function
void* thread_worker(void* arg) {
  ThreadArgs* args = static_cast<ThreadArgs*>(arg);

  std::cout << CYAN << "Thread " << args->thread_id << " starting on bucket "
            << args->bucket_name << RESET << std::endl;

  // Create CouchbaseOperations instance for this thread
  brpc::CouchbaseOperations couchbase_ops;

  // Authentication
  brpc::CouchbaseOperations::Result auth_result = couchbase_ops.authenticate(
      g_config.username, g_config.password, "127.0.0.1:11210", args->bucket_name);
  // for SSL authentication use below line instead
  // brpc::CouchbaseOperations::Result auth_result = couchbase_ops.authenticateSSL(username, password, "127.0.0.1:11210", args->bucket_name, "/path/to/cert.txt");
  
  if (!auth_result.success) {
    std::cout << RED << "Thread " << args->thread_id << ": Auth failed - "
              << auth_result.error_message << RESET << std::endl;
    return NULL;
  }

    // // Select bucket
    // brpc::CouchbaseOperations::Result bucket_result =
    //     couchbase_ops.selectBucket(args->bucket_name);

    // if (!bucket_result.success) {
    //   std::cout << RED << "Thread " << args->thread_id
    //             << ": Bucket selection failed - " << bucket_result.error_message
    //             << RESET << std::endl;
    //   return NULL;
    // }

  std::cout << GREEN << "Thread " << args->thread_id << " connected to bucket "
            << args->bucket_name << RESET << std::endl;

  // Perform operations - 10 times on default collection, 10 times on col1
  // collection
  for (int i = 0; i < 10; ++i) {
    std::string base_key =
        butil::string_printf("thread_%d_op_%d", args->thread_id, i);

    // CRUD operations on default collection
    perform_crud_operations_default(couchbase_ops, base_key, args->stats);

    // CRUD operations on col1 collection
    perform_crud_operations_col1(couchbase_ops, base_key, args->stats);

    // Small delay between operations
    bthread_usleep(10000);  // 10ms
  }

  int successful = args->stats->operations_successful.load();
  int attempted = args->stats->operations_attempted.load();
  int failed = args->stats->operations_failed.load();

  std::cout << GREEN << "Thread " << args->thread_id
            << " completed: " << successful << "/" << attempted
            << " operations successful, " << failed << " failed" << RESET