fifo


 
Thread Tools Search this Thread
Top Forums Programming fifo
# 1  
Old 08-28-2010
fifo

Dear friends
i'm want to implement a program which one file is split into fragments by the server (by some random size) and sent to some processes, so these processes get randomly the fragments of the original file from the server, then the downloader randomly connects to some of these processes and gets the fragments.
I want to know what technique to use, should i use message quees or i can simply use fifo and get the fragments using simple byte streams, what do u suggest?
Login or Register to Ask a Question

Previous Thread | Next Thread

10 More Discussions You Might Find Interesting

1. UNIX for Beginners Questions & Answers

Mplayer fifo.

Hi all, First of all, sorry for the pastebin link. The code tags aren't working for me. #!/bin/bash # while-menu-dialog: a menu driven - Pastebin.com This is a channel "changer" shell script i'm working on. It uses dialog to display the menus. It... (3 Replies)
Discussion started by: ignatius
3 Replies

2. UNIX and Linux Applications

FIFO

Hello , I am working on unix FIFO IPC. i have a doubt regarding that. If the fifo is updated(write()) through one process....can we able to send any signal that fifo is updated and ready to get read...to other process.?? (0 Replies)
Discussion started by: Harry443
0 Replies

3. Programming

Help With FIFO problem...

=server.c= #include <stdio.h> #include <stdlib.h> #include <sys/stat.h> #include <sys/types.h> #include <unistd.h> #include <errno.h> #include <fcntl.h> #include <string.h> #include <signal.h> #define MSGSIZE 50 (1 Reply)
Discussion started by: sponge
1 Replies

4. Programming

How to see a FIFO from all the threads?

Hello C programming fellows!!! I'm doing a program with multiple threads in gnu/linux, ubuntu for beeing precise... This program consist in multiple threads, as logical each thread do different things and communicate to each other using IPC. The problem is that in "process 1" I have a... (1 Reply)
Discussion started by: Sandia_man
1 Replies

5. Programming

help About fifo and thread

hi, my problem is i have 10 thread for produces double two dimensional array these will produces 2d array 400 times ,then i have a thread to takes a two dimensional array then it inverse , and most 10 array can be in the fifo , and threads given takes one by one, now my problem is , i cant... (0 Replies)
Discussion started by: bblackened
0 Replies

6. Programming

FIFO's and asynchronousity?

Hello, I have a FIFO which i would like to open O_WDWR | O_NONBLOCK | O_ASYNC and have a SIGIO signal generated when there is input on the FIFO, but there a re a bunch of bugs surrounding this (like for instance i read somewhere that you have to set O_ASYNC with fcntl etc. is this even... (0 Replies)
Discussion started by: davo666
0 Replies

7. UNIX for Dummies Questions & Answers

Doubts on FIFO

Hi , I m beginner for Unix and i want to use FIFO in my 2 Scripts . I want 1 script to read data from FIFO and other will write into FIFO. Despite reading so many articles/posts i am still unable sunchronize my scripts. My doubts are 1> Do We require both scripts as daemons to use... (0 Replies)
Discussion started by: Akshay
0 Replies

8. Programming

how to use fifo

hi, I have a problem. I've done a lil program which gets from the server the given persons username a personal folder. I made it with a pipe calling popen with a command, but how can i make the same thing using fifo. I make the fifo with mkfifo() func. and than what. How do I tell the sertver using... (3 Replies)
Discussion started by: atticus
3 Replies

9. UNIX for Advanced & Expert Users

FIFO Pipes

Hi...Can anyone please guide me on FIFO Pipes in UNIX.I have lerant things like creating fifo pipes,using them for reads and writes etc.I want to know what is the maximum amount of memory that such a pipe may have? Also can anyone guide me on where to get info on this topic from? (4 Replies)
Discussion started by: tej.buch
4 Replies

10. UNIX for Advanced & Expert Users

FIFO over NFS

Hi All L2000-44 HP-UX 11.00 I am attempting to setup a FIFO over NFS. Directing and reading from the FIFO works fine on the local machine - however when I direct to the FIFO from a server which has the directory NFS mounted it does not work. The a process to read from the FIFO on the local... (2 Replies)
Discussion started by: saabir
2 Replies
Login or Register to Ask a Question
mnesia_frag_hash(3erl)					     Erlang Module Definition					    mnesia_frag_hash(3erl)

NAME
mnesia_frag_hash - Defines mnesia_frag_hash callback behaviour DESCRIPTION
The module mnesia_frag_hash defines a callback behaviour for user defined hash functions of fragmented tables. Which module that is selected to implement the mnesia_frag_hash behaviour for a particular fragmented table is specified together with the other frag_properties . The hash_module defines the module name. The hash_state defines the initial hash state. It implements dynamic hashing which is a kind of hashing that grows nicely when new fragments are added. It is well suited for scalable hash tables EXPORTS
init_state(Tab, State) -> NewState | abort(Reason) Types Tab = atom() State = term() NewState = term() Reason = term() This function is invoked when a fragmented table is created with mnesia:create_table/2 or when a normal (un-fragmented) table is converted to be a fragmented table with mnesia:change_table_frag/2 . Note that the add_frag/2 function will be invoked one time each for the rest of the fragments (all but number 1) as a part of the table creation procedure. State is the initial value of the hash_state frag_property . The NewState will be stored as hash_state among the other frag_proper- ties . add_frag(State) -> {NewState, IterFrags, AdditionalLockFrags} | abort(Reason) Types State = term() NewState = term() IterFrags = [integer()] AdditionalLockFrags = [integer()] Reason = term() In order to scale well, it is a good idea ensure that the records are evenly distributed over all fragments including the new one. The NewState will be stored as hash_state among the other frag_properties . As a part of the add_frag procedure, Mnesia will iterate over all fragments corresponding to the IterFrags numbers and invoke key_to_frag_number(NewState,RecordKey) for each record. If the new fragment differs from the old fragment, the record will be moved to the new fragment. As the add_frag procedure is a part of a schema transaction Mnesia will acquire a write locks on the affected tables. That is both the fragments corresponding to IterFrags and those corresponding to AdditionalLockFrags . del_frag(State) -> {NewState, IterFrags, AdditionalLockFrags} | abort(Reason) Types State = term() NewState = term() IterFrags = [integer()] AdditionalLockFrags = [integer()] Reason = term() The NewState will be stored as hash_state among the other frag_properties . As a part of the del_frag procedure, Mnesia will iterate over all fragments corresponding to the IterFrags numbers and invoke key_to_frag_number(NewState,RecordKey) for each record. If the new fragment differs from the old fragment, the record will be moved to the new fragment. Note that all records in the last fragment must be moved to another fragment as the entire fragment will be deleted. As the del_frag procedure is a part of a schema transaction Mnesia will acquire a write locks on the affected tables. That is both the fragments corresponding to IterFrags and those corresponding to AdditionalLockFrags . key_to_frag_number(State, Key) -> FragNum | abort(Reason) Types FragNum = integer()() Reason = term() This function is invoked whenever Mnesia needs to determine which fragment a certain record belongs to. It is typically invoked at read, write and delete. match_spec_to_frag_numbers(State, MatchSpec) -> FragNums | abort(Reason) Types MatcSpec = ets_select_match_spec() FragNums = [FragNum] FragNum = integer() Reason = term() This function is invoked whenever Mnesia needs to determine which fragments that needs to be searched for a MatchSpec. It is typi- cally invoked at select and match_object. SEE ALSO
mnesia(3erl) Ericsson AB mnesia 4.4.17 mnesia_frag_hash(3erl)