1 // manage a cache of RPC connections.
2 // assuming cid is a std::string holding the
3 // host:port of the RPC server you want
7 // rpcc *cl = h.safebind();
9 // ret = cl->call(...);
14 // if the calling program has not contacted
15 // cid before, safebind() will create a new
16 // connection, call bind(), and return
17 // an rpcc*, or 0 if bind() failed. if the
18 // program has previously contacted cid,
19 // safebind() just returns the previously
20 // created rpcc*. best not to hold any
21 // mutexes while calling safebind().
35 pthread_mutex_t cl_mutex;
42 handle(std::string m);
44 /* safebind will try to bind with the rpc server on the first call.
45 * Since bind may block, the caller probably should not hold a mutex
46 * when calling safebind.
49 * if the first safebind succeeded, all later calls would return
50 * a rpcc object; otherwise, all later calls would return NULL.
54 * XXX_protocol::status ret;
56 * ret = h.safebind()->call(...);
58 * if (!h.safebind() || ret != XXX_protocol::OK) {
67 pthread_mutex_t handle_mutex;
68 std::map<std::string, struct hinfo *> hmap;
71 struct hinfo *get_handle(std::string m);
72 void done_handle(struct hinfo *h);
73 void delete_handle(std::string m);
74 void delete_handle_wo(std::string m);
77 extern class handle_mgr mgr;