mirrors/mastodont-c
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Get data

Browse source 
FossilOrigin-Name: 7bdc242974926428c4d45f9bd4a6afab9cbb23d8211f4670d27ba47108866f42
This commit is contained in:
nekobit 2022-10-31 17:13:28 +00:00
parent b8a2395248
commit dfb0a2e230
2 changed files with 14 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
include/mastodont_fetch.h
View file

@ -81,11 +81,14 @@ int mstdnt_fetch_curl_async(mastodont_t* mstdnt,
* @param mstdnt Mastodont struct
* @param opt Option, MSTDNT_AWAIT_ALL means it will keep going until
* there are no more transfers. MSTDNT_AWAIT_ONCE will run
* @param extra_fds Set of file descriptors to poll alongside
* the mastodont data.
* @param nfds Length of extra_fds
* @return 1 on error
*/
int mstdnt_poll(mastodont_t* mstdnt,
enum mstdnt_fetch_await opt,
struct mstdnt_fd extra_fds[],
size_t nfds);
int mstdnt_await(mastodont_t* mstdnt,
enum mstdnt_fetch_await opt,
struct mstdnt_fd extra_fds[],
size_t nfds);
#endif /* MASTODONT_FETCH_H */

14
src/fetch.c
View file

@ -36,8 +36,6 @@ size_t mstdnt_curl_write_callback(char* ptr, size_t _size, size_t nmemb, void* _
memcpy(&(res->response[res->size]), ptr, size);
res->size += size;
res->response[res->size] = 0;
res->callback(NULL, res->callback_args);
return size;
}
@ -122,14 +120,13 @@ int mstdnt_fetch_curl_async(mastodont_t* mstdnt,
return running;
}
int mstdnt_poll(mastodont_t* mstdnt,
enum mstdnt_fetch_await opt,
struct mstdnt_fd extra_fds[],
size_t nfds)
int mstdnt_await(mastodont_t* mstdnt,
enum mstdnt_fetch_await opt,
struct mstdnt_fd extra_fds[],
size_t nfds)
{
CURLMsg* msg;
int msgs_left = 1;
struct mstdnt_fetch_data* data;
int res;
struct curl_waitfd* fds = NULL;
@ -146,6 +143,8 @@ int mstdnt_poll(mastodont_t* mstdnt,
}
res = curl_multi_poll(mstdnt->curl, fds, nfds, 0, NULL);
struct mstdnt_fetch_data* data;
// Check if our socket is done
do
@ -156,6 +155,7 @@ int mstdnt_poll(mastodont_t* mstdnt,
{
// Get easy info
curl_easy_getinfo(msg->easy_handle, CURLINFO_PRIVATE, &data);
data->callback(NULL, data->callback_args);
mstdnt_fetch_data_cleanup(data);
curl_multi_remove_handle(mstdnt->curl, msg->easy_handle);