Author: dmacvicar
Date: Tue May 8 03:04:16 2007
New Revision: 5516
URL: http://svn.opensuse.org/viewcvs/zypp?rev=5516&view=rev
Log:
backup
Added:
trunk/libzypp/devel/devel.dmacvicar/CURLM_tp.cc
Added: trunk/libzypp/devel/devel.dmacvicar/CURLM_tp.cc
URL: http://svn.opensuse.org/viewcvs/zypp/trunk/libzypp/devel/devel.dmacvicar/CURLM_tp.cc?rev=5516&view=auto
==============================================================================
--- trunk/libzypp/devel/devel.dmacvicar/CURLM_tp.cc (added)
+++ trunk/libzypp/devel/devel.dmacvicar/CURLM_tp.cc Tue May 8 03:04:16 2007
@@ -0,0 +1,141 @@
+#include
+#include
+
+extern "C" {
+#include
+}
+#include <list>
+#include <sstream>
+#include "zypp/base/Exception.h"
+#include "zypp/base/Logger.h"
+#include "zypp/Pathname.h"
+#include "zypp/ExternalProgram.cc"
+//#include
+
+using namespace zypp;
+using namespace std;
+
+size_t write_data(void *buffer, size_t size, size_t nmemb, void *userp)
+{
+ MIL << "got data : " << size*nmemb << " bytes" << endl;
+ return size*nmemb;
+}
+
+int socket_callback(CURL *easy, curl_socket_t s, int what, void *userp, void *socketp)
+{
+ MIL << "socket : " << s << " : " << what << endl;
+ return 0;
+}
+
+struct Range
+{
+ Range( off_t f, off_t t)
+ : from(t), to(t)
+ {}
+
+ off_t from;
+ off_t to;
+};
+
+int main()
+{
+ FILE *f = fopen("piece", "w" );
+ curl_global_init(CURL_GLOBAL_ALL);
+ CURLM *curlm;
+ curlm = curl_multi_init();
+ //curl_multi_setopt( curlm, CURLMOPT_PIPELINING, 1);
+ curl_multi_setopt( curlm, CURLMOPT_SOCKETFUNCTION, socket_callback);
+
+// 0-1000
+// 1001-2000
+// 2001-3000
+//
+// 3000-4000
+// 4001-5000
+
+ int i=1;
+ for ( ; i < 10; i++ ) {
+ CURL *curl;
+ curl = curl_easy_init();
+ CURLcode success;
+ // http://download.opensuse.org/distribution/10.2/repo/oss/suse/setup/descr/pac...
+ if ( (success = curl_easy_setopt(curl, CURLOPT_URL, "http://ftp5.gwdg.de/pub/opensuse/distribution/10.2/repo/oss/suse/setup/descr...")) != CURLE_OK)
+ ZYPP_THROW(Exception("url"));
+
+ if ( (success = curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_data)) != CURLE_OK)
+ ZYPP_THROW(Exception("write data"));
+ //curl_easy_setopt(curl, CURLOPT_WRITEDATA, f);
+ stringstream rs;
+ int k=1;
+ for(; k<2; k++) {
+ rs << ( k!=1 ? "," : "") << (i*k)*1000 << "-" << ((i*k)*1000 + 1000);
+ }
+ MIL << "range: " << rs.str() << endl;
+ if ( (success = curl_easy_setopt(curl, CURLOPT_RANGE, rs.str().c_str())) != CURLE_OK)
+ ZYPP_THROW(Exception("write data"));
+
+ CURLMcode code;
+ if ( (code = curl_multi_add_handle( curlm, curl)) != CURLM_OK)
+ ZYPP_THROW(Exception("write data"));
+
+ }
+ int still_running = 0;
+ /* we start some action by calling perform right away */
+ while(CURLM_CALL_MULTI_PERFORM ==
+ curl_multi_perform(curlm, &still_running));
+
+ while(still_running) {
+ struct timeval timeout;
+ int rc; /* select() return code */
+
+ fd_set fdread;
+ fd_set fdwrite;
+ fd_set fdexcep;
+ int maxfd;
+
+ FD_ZERO(&fdread);
+ FD_ZERO(&fdwrite);
+ FD_ZERO(&fdexcep);
+
+ /* set a suitable timeout to play around with */
+ timeout.tv_sec = 1;
+ timeout.tv_usec = 0;
+
+ /* get file descriptors from the transfers */
+ curl_multi_fdset(curlm, &fdread, &fdwrite, &fdexcep, &maxfd);
+
+ /* In a real-world program you OF COURSE check the return code of the
+ function calls, *and* you make sure that maxfd is bigger than -1 so
+ that the call to select() below makes sense! */
+
+ rc = select(maxfd+1, &fdread, &fdwrite, &fdexcep, &timeout);
+
+ switch(rc) {
+ case -1:
+ /* select error */
+ still_running = 0;
+ ERR << "select() returns error, this is badness" << endl;
+ break;
+ case 0:
+ default:
+ /* timeout or readable/writable sockets */
+ while(CURLM_CALL_MULTI_PERFORM ==
+ curl_multi_perform(curlm, &still_running));
+ break;
+ }
+ }
+
+ int c=999;
+ CURLMsg *m;
+ while ( m = curl_multi_info_read( curlm, &c) )
+ {
+ MIL<< m->msg << " : " << curl_easy_strerror(m->data.result) << endl;
+ }
+ Pathname root("/home/duncan/suse/metadata-diff");
+
+
+ curl_multi_cleanup(curlm);
+ //curl_easy_cleanup(http_handle);
+
+ return 0;
+}
\ No newline at end of file
--
To unsubscribe, e-mail: zypp-commit+unsubscribe@opensuse.org
For additional commands, e-mail: zypp-commit+help@opensuse.org
