05-22-2002
Stream Read And Write Queues
Is there any possibility that a Stream Read and Write queues will interchange messages of any kind. If so what are the different possiblites and under what circumstances ?
Thanks in advance.
10 More Discussions You Might Find Interesting
1. Shell Programming and Scripting
I have tried to show the file name whose size is greater than 200 byte in current directory.
Please help me.
ls -l | tr -s " " " " | cut -f 5,9 -d " " >out.txt
#set -a x `cat out.txt`
i=0
`cat out.txt` | while
do
read x
echo $x
#re=200
j=0
if }" < "200" ]
then
echo $j
j=`expr $j... (2 Replies)
Discussion started by: rinku
2 Replies
2. Shell Programming and Scripting
I need to find all the files that have group Read or Write permission or files that have user write permission.
This is what I have so far:
find . -exec ls -l {} \; | awk '/-...rw..w./ {print $1 " " $3 " " $4 " " $9}'
It shows me all files where group read = true, group write = true... (5 Replies)
Discussion started by: shunter63
5 Replies
3. Programming
Hi all,
I have a problem with some read/write functions.
I have a .bin file which contains a lot of structures as follows:
struct alumno
{
char id;
char apellido1;
char apellido2;
char nombre;
float nota1p;
float nota2p;
float notamedia;
char photofilename;
};
What I have... (3 Replies)
Discussion started by: Attenea
3 Replies
4. Programming
Hi @all,
i really stuck in programming a tool with bidirectional process communication (popen(cmd, "rw") ... something like that ;-)).
Here is the code:
if(pipe(p_stdin) != 0 || pipe(p_stdout) != 0) {
fprintf(stderr, "Aufruf von pipe() schlug fehl.\n");
exit(1);
}
... (6 Replies)
Discussion started by: jens.g
6 Replies
5. IP Networking
Hi,
We have smb client running on two of the linux boxes and smb server on another linux system. During a backup operation which uses smb, read of a file was allowed while write to the same file was going on.Also simultaneous writes to the same file were allowed.Following are the settings in the... (1 Reply)
Discussion started by: swatidas11
1 Replies
6. Shell Programming and Scripting
Hi
I used this command:
mplayer http://host/axis-cgi/mjpg/video.cgi -user root -passwd root \
-cache 1024 -fps 25.0 -nosound -vc ffh264 \
-demuxer 3 -dumpstream -dumpfile output.avi It's ok but...
Video Playing is very fast! Why? Is it a synch problem?
What parameter I have to use for... (1 Reply)
Discussion started by: takeo.kikuta
1 Replies
7. IP Networking
hi
am newbie to unix and socket programing
I am trying to figuring out syntax for read and write
to send data from server to client and client can read it
I have to send two integers
write(newsockfd,buffer,"%d %d",x,y,0) writing from client where x and y are two integers..
... (7 Replies)
Discussion started by: karthik1238
7 Replies
8. Programming
HI
I need to implement a client/server TCP application. the customer is the client and the bartender is the server.
When the customer enter the Bar, client connects to the server
Server should reply the client immediately. Other wise if the server is busy, it should send an update message... (10 Replies)
Discussion started by: lixiao1212
10 Replies
9. UNIX for Dummies Questions & Answers
I have a script that takes 2 parameters (say) as mandatory
script1.sh a b
The 3rd parameter can be filename which it should process or it can come through a pipeline stream
The script should work both ways:
script1.sh a b filec
or cat filec | script1.sh a b
How to put logic in the... (1 Reply)
Discussion started by: ysrini
1 Replies
10. Shell Programming and Scripting
I have got a file in following format:
AAAAAAA
BBBBBBBB
CCCCCCC
DDDDDDD
I am trying to read this file and out put it in following format:
AAAAAAA,BBBBBBB,CCCCCCC,DDDDDD
Preferred method is shell or Perl.
Any help appreciated. (11 Replies)
Discussion started by: Araoki
11 Replies
LEARN ABOUT DEBIAN
mojo::ioloop::stream
Mojo::IOLoop::Stream(3pm) User Contributed Perl Documentation Mojo::IOLoop::Stream(3pm)
NAME
Mojo::IOLoop::Stream - Non-blocking I/O stream
SYNOPSIS
use Mojo::IOLoop::Stream;
# Create stream
my $stream = Mojo::IOLoop::Stream->new($handle);
$stream->on(read => sub {
my ($stream, $chunk) = @_;
...
});
$stream->on(close => sub {
my $stream = shift;
...
});
$stream->on(error => sub {
my ($stream, $err) = @_;
...
});
# Start and stop watching for new data
$stream->start;
$stream->stop;
DESCRIPTION
Mojo::IOLoop::Stream is a container for I/O streams used by Mojo::IOLoop.
EVENTS
Mojo::IOLoop::Stream can emit the following events.
"close"
$stream->on(close => sub {
my $stream = shift;
...
});
Emitted safely if the stream gets closed.
"drain"
$stream->on(drain => sub {
my $stream = shift;
...
});
Emitted safely once all data has been written.
"error"
$stream->on(error => sub {
my ($stream, $err) = @_;
...
});
Emitted safely if an error happens on the stream.
"read"
$stream->on(read => sub {
my ($stream, $chunk) = @_;
...
});
Emitted safely if new data arrives on the stream.
"timeout"
$stream->on(timeout => sub {
my $stream = shift;
...
});
Emitted safely if the stream has been inactive for too long and will get closed automatically.
"write"
$stream->on(write => sub {
my ($stream, $chunk) = @_;
...
});
Emitted safely if new data has been written to the stream.
ATTRIBUTES
Mojo::IOLoop::Stream implements the following attributes.
"reactor"
my $reactor = $stream->reactor;
$stream = $stream->reactor(Mojo::Reactor::Poll->new);
Low level event reactor, defaults to the "reactor" attribute value of the global Mojo::IOLoop singleton.
"timeout"
my $timeout = $stream->timeout;
$stream = $stream->timeout(45);
Maximum amount of time in seconds stream can be inactive before getting closed automatically, defaults to 15. Setting the value to 0 will
allow this stream to be inactive indefinitely.
METHODS
Mojo::IOLoop::Stream inherits all methods from Mojo::EventEmitter and implements the following new ones.
"new"
my $stream = Mojo::IOLoop::Stream->new($handle);
Construct a new Mojo::IOLoop::Stream object.
"close"
$stream->close;
Close stream immediately.
"handle"
my $handle = $stream->handle;
Get handle for stream.
"is_readable"
my $success = $stream->is_readable;
Quick non-blocking check if stream is readable, useful for identifying tainted sockets.
"is_writing"
my $success = $stream->is_writing;
Check if stream is writing.
"start"
$stream->start;
Start watching for new data on the stream.
"stop"
$stream->stop;
Stop watching for new data on the stream.
"steal_handle"
my $handle = $stream->steal_handle;
Steal handle from stream and prevent it from getting closed automatically.
"write"
$stream->write('Hello!');
$stream->write('Hello!', sub {...});
Write data to stream, the optional drain callback will be invoked once all data has been written.
SEE ALSO
Mojolicious, Mojolicious::Guides, <http://mojolicio.us>.
perl v5.14.2 2012-09-05 Mojo::IOLoop::Stream(3pm)