search for: receive_data

Short question: is there way to tell EM to actually send data after send_data call? I''m building a file transferring app. I send Mashal.dump''ed metadata first, and then - the file contents (chunked). I found a silly bug: receive_data() gets marshalled metadata and the first chunk of the file in a single variable. Like that: c1.send_data("meta") c1.send_data("chunk1") c1.send_data("chunk2") receiver.receive_data(data): data == "metachunk1chunk2" I have two possible solutions: 1) Some k...

Dear List, I'm trying to get diff/removed data and it's offset out. So I write a functions in receive_data. When I run backup, I found there is a weird behavior which I don't understand. i = recv_token(f_in, &data) will receive (i = -1, offset2 = 0) some where in the middle of the transfer procedure. That's to say, it's going to transfer the first data block from sender, but I have been...

...nectToApp method. This sets up 2 connections, which works. I had to place them in a Thread, because the gui obviously has to resume during the event loop of EventMachine. When the other app that has the debugger server gets to a breakpoint, it sends data to the client. This works as it should, the receive_data method of the DebuggerClient module gets called and sends the data to the received_client_data method of the Controller class. This method then assigns the data to the gui. So far so good.... However, sending data back to the debugger is a problem. What happens is this; the gui calls the send_clie...

I am using eventmachine 0.8.1 on windows XP and am having very odd problems. This snippet of code gives the error that follows it. class EchoServer def receive_data data puts data send_data ">>>you sent: #{data}" if data =~ /quit/i puts "quitting" close_connection EventMachine::stop_event_loop end end end EventMachine::run { EventMachine::open_datagram_socket "127.0.0.99&...

...ansmit undefined method `send_request'' for nil:NilClass /vendor/plugins/backgroundrb/framework/packet/packet_master.rb:43:in `ask_worker'' /vendor/plugins/backgroundrb/server/master_worker.rb:105:in `process_work'' /vendor/plugins/backgroundrb/server/master_worker.rb:37:in `receive_data'' /vendor/plugins/backgroundrb/lib/../framework/packet/bin_parser.rb:29:in `call'' /vendor/plugins/backgroundrb/lib/../framework/packet/bin_parser.rb:29:in `extract'' /vendor/plugins/backgroundrb/server/master_worker.rb:33:in `receive_data'' /vendor/plugins/backgroun...

...@ } else { set_perms(fname,file,NULL,0); } + +#ifdef HAVE_LINK + if (link_by_hash_dir) + link_by_hash(fname,file); +#endif } patchwork diff receiver.c --- receiver.c 2004-02-09 15:42:40.000000000 -0500 +++ receiver.c 2004-02-09 15:42:40.000000000 -0500 @@ -237,10 +237,11 @@ static int receive_data(int f_in,struct map_struct *buf,int fd,char *fname, - OFF_T total_size) + OFF_T total_size,char *md4) { int i; struct sum_struct sum; + struct mdfour mdfour_data; unsigned int len; OFF_T offset = 0; OFF_T offset2; @@ -250,6 +251,8 @@ char *map=NULL; read_sum_head(f_in, &su...

...void init_hard_links(struct file_list *flist); int hard_link_check(struct file_struct *file, int skip); void do_hard_links(void); patchwork diff receiver.c --- receiver.c 2004-02-23 10:22:51.000000000 -0500 +++ receiver.c 2004-02-23 10:22:51.000000000 -0500 @@ -186,10 +186,11 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, - OFF_T total_size) + OFF_T total_size,char *md4) { int i; struct sum_struct sum; + struct mdfour mdfour_data; unsigned int len; OFF_T offset = 0; OFF_T offset2; @@ -199,7 +200,9 @@ char *map=NULL; read_sum_head(f_in, &...

...void init_hard_links(struct file_list *flist); int hard_link_check(struct file_struct *file, int skip); void do_hard_links(void); patchwork diff receiver.c --- receiver.c 2004-02-17 10:36:44.000000000 -0500 +++ receiver.c 2004-02-17 13:10:23.000000000 -0500 @@ -186,10 +186,11 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, - OFF_T total_size) + OFF_T total_size,char *md4) { int i; struct sum_struct sum; + struct mdfour mdfour_data; unsigned int len; OFF_T offset = 0; OFF_T offset2; @@ -199,7 +200,9 @@ char *map=NULL; read_sum_head(f_in, &...

...void init_hard_links(struct file_list *flist); int hard_link_check(struct file_struct *file, int skip); void do_hard_links(void); patchwork diff receiver.c --- receiver.c 2004-02-23 10:22:51.000000000 -0500 +++ receiver.c 2004-02-23 10:22:51.000000000 -0500 @@ -186,10 +186,11 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, - OFF_T total_size) + OFF_T total_size,char *md4) { int i; struct sum_struct sum; + struct mdfour mdfour_data; unsigned int len; OFF_T offset = 0; OFF_T offset2; @@ -199,7 +200,9 @@ char *map=NULL; read_sum_head(f_in, &...

...void init_hard_links(struct file_list *flist); int hard_link_check(struct file_struct *file, int skip); void do_hard_links(void); patchwork diff receiver.c --- receiver.c 2004-02-16 10:24:39.000000000 -0500 +++ receiver.c 2004-02-16 10:19:41.000000000 -0500 @@ -186,10 +186,11 @@ static int receive_data(int f_in,struct map_struct *mapbuf,int fd,char *fname, - OFF_T total_size) + OFF_T total_size,char *md4) { int i; struct sum_struct sum; + struct mdfour mdfour_data; unsigned int len; OFF_T offset = 0; OFF_T offset2; @@ -199,7 +200,9 @@ char *map=NULL; read_sum_head(f_in, &...

...s that worker does not see our Report class from Rails, throws a: /var/apps/ror_trunk/vendor/plugins/backgroundrb/server/master_worker.rb:22:in `load'': undefined class/module Report (ArgumentError) from /var/apps/ror_trunk/vendor/plugins/backgroundrb/server/master_worker.rb:22:in `receive_data'' And the other is - does this new release work on Windows which some of our developers use? I know that last releases did not work because of fork() issues, but the new rewrite has a new networking model, so do you think it might work with some workarounds? thanks for your help!

...r < EventMachine::Connection attr_accessor :chunked_data,:client_status def valid_protocol? data return false unless data =~ /(\d{3})([^<>]*)<([^><]*)>##(.*?)##/ return true end # method is a callback, gets called whenever data is there in socket to read def receive_data data data.chomp! while data && data.length > 0 data_array = data.split(/\r?\n/m,2) @chunked_data << data_array[0] data = data_array[1] # two level of protocol handling if @chunked_data =~ /(\d{3})(.*)<(.*)?>(##(.*)##)/ if valid_...

...t I'm not qualified enough on autoconf. - the openlog() and syslog() functions are exported by libbe.so (which is a GUI library, really dunno who put that here). - getpass() doesn't exist, but I have a (yet unreleased) library (libmoreposix) that provides a working version. - the function receive_data() is reserved by the OS as part of the native IPC mechanism, so I had to rename the static func receive_data() to resolve the namespace collision. - I_SEXEC isn't defined (don't ask me why :) Please CC me on answers as I'm not subscribed to this list. Fran?ois. ---- BeOS si dead. Ug...

...-----8<----- #0 0x0003123b in map_ptr (map=0x0, offset=0, len=32768) at fileio.c:192 192 if (offset >= map->p_offset && offset+len <= map->p_offset+map->p_len) (gdb) bt #0 0x0003123b in map_ptr (map=0x0, offset=0, len=32768) at fileio.c:192 #1 0x00011e54 in receive_data (f_in=5, fname_r=0x0, fd_r=-1, size_r=0, fname=0x0, fd=-1, total_size=50263) at receiver.c:202 #2 0x00012271 in discard_receive_data (f_in=<value temporarily unavailable, due to optimizations>, length=<value temporarily unavailable, due to optimizations>) at receiver.c:321 #3 0x000133...

Hello ! 1) I have this error logged by bdrb: undefined method `send_request'' for nil:NilClass framework/packet_master.rb:58:in `ask_worker'' backgroundrb/server/master_worker.rb:59:in `process_work'' backgroundrb/server/master_worker.rb:16:in `receive_data'' backgroundrb/framework/bin_parser.rb:29:in `call'' backgroundrb/framework/bin_parser.rb:29:in `extract'' backgroundrb/server/master_worker.rb:12:in `receive_data'' backgroundrb/framework/core.rb:191:in `read_external_socket'' backgroundrb/framework/core.rb:...

...t, other processes are given ample time to call the pages back to the active list, eliminating the need for the previous mincore() hack. Here is my attempt at adding fadvise support to rsync (against v3.0.7). I do this in both the sender (hinting after match_sums()) and the receiver (hinting after receive_data()). In principle we could get better granularity if this was hooked up within match_sums() (or even the map_ptr() interface) and the receive loop in receive_data(), but I wanted to keep things simple at first (any comments on these ideas?) . At the moment is for little more than testing. Considerin...

...ers can answer: - In direct-write mode, I open without O_EXCL, as the file likely does exist. Should the destination file be deleted instead? (I do not know what exactly the race condition is) - There is a section after the assignment of fnametmp, and before the open that does do_mktemp, then receive_data. What is the purpose of this part? I skip it for direct-write, and it works, but what do I know? -don -------------- next part -------------- Only in rsync-2.4.6-direct-write/lib: dummy diff -ru rsync-2.4.6/options.c rsync-2.4.6-direct-write/options.c --- rsync-2.4.6/options.c Tue Sep 5 19:46:4...

...k_worker'' /Users/brent/near-time/near-time.net-exp-rescue-princexml-5504/vendor/plugins/backgroundrb/server/lib/master_worker.rb:123:in `get_result_object'' /Users/brent/near-time/near-time.net-exp-rescue-princexml-5504/vendor/plugins/backgroundrb/server/lib/master_worker.rb:39:in `receive_data'' /opt/local/lib/ruby/gems/1.8/gems/packet-0.1.10/lib/packet/packet_parser.rb:44:in `extract'' /opt/local/lib/ruby/gems/1.8/gems/packet-0.1.10/lib/packet/packet_parser.rb:26:in `loop'' /opt/local/lib/ruby/gems/1.8/gems/packet-0.1.10/lib/packet/packet_parser.rb:26:in `extract...

Hi, Is it possible to start a worker with job_key and then ask_status of that specific worker with the job_key? MiddleMan.ask_work(:worker => :auth_worker, :job_key=>''1'', :worker_method => :auth) and then MiddleMan.ask_status(:worker => :auth_worker, :job_key=>''1'') >From my testing of the new backgroundrb, asking status using job key

...b/packet/ packet_master.rb:44:in `ask_worker'' /Users/sweiss/Documents/workspace/RACE-local/vendor/plugins/ backgroundrb/server/lib/master_worker.rb:104:in `process_work'' /Users/sweiss/Documents/workspace/RACE-local/vendor/plugins/ backgroundrb/server/lib/master_worker.rb:35:in `receive_data'' /usr/local/lib/ruby/gems/1.8/gems/packet-0.1.5/lib/packet/ packet_parser.rb:29:in `call'' /usr/local/lib/ruby/gems/1.8/gems/packet-0.1.5/lib/packet/ packet_parser.rb:29:in `extract'' /Users/sweiss/Documents/workspace/RACE-local/vendor/plugins/ backgroundrb/server/lib/ma...