semafors

Posted on July 18, 2012June 25, 2015 by coder

[<<Previous Entry] [^^Up^^] [Next Entry>>] [Menu] [About The Guide]

Производитель и Потребитель буфера

ПРОИЗВОДИТЕЛЬ БУФЕРА, prod_onebuf.c :

 /* producer program:
 producer program sets up a buffer to be read by a consumer
 semaphores are used to ensure that producer doesn't
 overwrite an unread buffer and consumer doesn't
 the same data more than once.
 */
 #include <sys/types.h>
 #include <unistd.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <sys/ipc.h>
 #include <sys/sem.h>
 #include <sys/shm.h>
 #define MSG_SIZE 30
 #define MAX 5

 main()
 {
 key_t key;
 /* two semaphores in a set
 index 0 -incremented when producer has reset buffer
 -tested and decremented by consumer to check
 if buffer has been reset
 index 1 -incremented when consumer has read buffer
 -tested and decremented by producer to check
 if consumer is done
 */
 static struct sembuf wait_consumed = { 1, -1, 0};
 static struct sembuf signal_produced = { 0, 1, 0};
 int semid, shmid, i;
 char *message;

 if((key = ftok( getenv("HOME"), 'u')) == -1){
 fprintf(stderr,"ftok key formation error\n");

 exit(1);
 }

 if((semid=semget(key, 2, IPC_CREAT | 0660)) == -1){
 perror("producer semget():");
 exit(2);
 }

 if((shmid=shmget(key, MSG_SIZE, IPC_CREAT | 0660)) == -1) {
 perror("producer shmget():");
 exit(3);
 }

 message=shmat(shmid, 0, 0);

 for(i=1; i < MAX; i++) {
 /* producer has to go first */
if(i > 1)
 semop(semid,&wait_consumed,1);
 sprintf(message, "message %d", i);
 semop(semid, &signal_produced, 1);
 }
 shmdt(message);
 sleep(5); /* allow consumer to digest last message */

 /* alternatively a DELIMITER string could be placed in
 shared memory when seen by the consumer, it would exit.
 the producer would do shmctl(...,IPC_STAT,...)
 and when shm_attach==1
 it would remove the two IPC facilities
 */
 shmctl(shmid, IPC_RMID, NULL);
 semctl(semid, 0, IPC_RMID ,0);
 }
NОТРЕБИТЕЛЬ БУФЕРА, cons_onebuf.c :

 /* consumer program:
producer program sets up a buffer to be read by a consumer.
semaphores are used to ensure that producer doesn't
 overwrite an unread buffer and consumer doesn't
 read the same data more than once.
 */
 #include <sys/types.h>
 #include <stdio.h>
 #include <stdlib.h>
 #include <sys/ipc.h>
 #include <sys/sem.h>
 #include <sys/shm.h>
 #define MSG_SIZE 30

 main(int argc, char *argv[])
 {
 key_t key;
 /* two semaphores in a set
 index 0 - incremented when producer has reset buffer
 - tested and decremented by consumer to check
 if buffer has been reset
 index 1 - incremented when consumer has read buffer
 - tested and decremented by producer to check
 if consumer is done
 */
 static struct sembuf wait_produced = { 0, -1, 0};
 static struct sembuf signal_consumed = { 1, 1, 0};
 int semid, shmid, rtn;
 char *message;

 if((key = ftok( getenv("HOME"), 'u')) == -1){
 fprintf(stderr,"ftok key formation error\n");
 exit(1);
 }

 /* either producer or consumer might be the creator
 but producer will be the remover of the IPC resources.
 producer and consumer's effective uid must be the same.
 */
 if ((semid=semget(key, 2, IPC_CREAT | 0660)) == -1) {
 perror("consumer semget():");
 exit(2);
}

 if ((shmid=shmget(key, MSG_SIZE, IPC_CREAT | 0660)) == -1) {
 perror("producer shmget():");
 exit(3);
 }

 message=shmat(shmid, (char *)0, SHM_RDONLY);

 while(1){
 rtn=semop(semid,&wait_produced,1);
 /* when producer is done semid will be IPC_RMID forcing break */
 if(rtn == -1){
 perror("consumer - semop on wait_consumed");
 break;
 }
 printf("%s received: %s\n", argv[0], message);
 semop(semid, &signal_consumed, 1);
 }
 shmdt(message);
 exit(0);
 }

ВЫЗОВ:
$ prod_onebuf&
14649
$ cons_onebuf
cons_onebuf received: message 1
cons_onebuf received: message 2
cons_onebuf received: message 3
cons_onebuf received: message 4
consumer-semop on wait_consumed:Identifier removed

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

[<<Previous Entry] [^^Up^^] [Next Entry>>] [Menu] [About The Guide]

Производитель и Потребитель буфера

ПРОИЗВОДИТЕЛЬ БУФЕРА, prod_onebuf.c :

/* producer program:

producer program sets up a buffer to be read by a consumer

semaphores are used to ensure that producer doesn't

overwrite an unread buffer and consumer doesn't

the same data more than once.

#include <sys/types.h>

#include <unistd.h>

#include <stdio.h>

#include <stdlib.h>

#include <sys/ipc.h>

#include <sys/sem.h>

#include <sys/shm.h>

#define MSG_SIZE 30

#define MAX 5

main()

{

key_t key;

/* two semaphores in a set

index 0 -incremented when producer has reset buffer

-tested and decremented by consumer to check

if buffer has been reset

index 1 -incremented when consumer has read buffer

-tested and decremented by producer to check

if consumer is done

static struct sembuf wait_consumed = { 1, -1, 0};

static struct sembuf signal_produced = { 0, 1, 0};

int semid, shmid, i;

char *message;

if((key = ftok( getenv("HOME"), 'u')) == -1){

fprintf(stderr,"ftok key formation error\n");

exit(1);

}

if((semid=semget(key, 2, IPC_CREAT | 0660)) == -1){

perror("producer semget():");

exit(2);

}

if((shmid=shmget(key, MSG_SIZE, IPC_CREAT | 0660)) == -1) {

perror("producer shmget():");

exit(3);

}

message=shmat(shmid, 0, 0);

for(i=1; i < MAX; i++) {

/* producer has to go first */

if(i > 1)

semop(semid,&wait_consumed,1);

sprintf(message, "message %d", i);

semop(semid, &signal_produced, 1);

}

shmdt(message);

sleep(5); /* allow consumer to digest last message */

/* alternatively a DELIMITER string could be placed in

shared memory when seen by the consumer, it would exit.

the producer would do shmctl(...,IPC_STAT,...)

and when shm_attach==1

it would remove the two IPC facilities

shmctl(shmid, IPC_RMID, NULL);

semctl(semid, 0, IPC_RMID ,0);

}

NОТРЕБИТЕЛЬ БУФЕРА, cons_onebuf.c :

/* consumer program:

producer program sets up a buffer to be read by a consumer.

semaphores are used to ensure that producer doesn't

overwrite an unread buffer and consumer doesn't

read the same data more than once.

#include <sys/types.h>

#include <stdio.h>

#include <stdlib.h>

#include <sys/ipc.h>

#include <sys/sem.h>

#include <sys/shm.h>

#define MSG_SIZE 30

main(int argc, char *argv[])

{

key_t key;

/* two semaphores in a set

index 0 - incremented when producer has reset buffer

- tested and decremented by consumer to check

if buffer has been reset

index 1 - incremented when consumer has read buffer

- tested and decremented by producer to check

if consumer is done

static struct sembuf wait_produced = { 0, -1, 0};

static struct sembuf signal_consumed = { 1, 1, 0};

int semid, shmid, rtn;

char *message;

if((key = ftok( getenv("HOME"), 'u')) == -1){

fprintf(stderr,"ftok key formation error\n");

exit(1);

}

/* either producer or consumer might be the creator

but producer will be the remover of the IPC resources.

producer and consumer's effective uid must be the same.

if ((semid=semget(key, 2, IPC_CREAT | 0660)) == -1) {

perror("consumer semget():");

exit(2);

}

if ((shmid=shmget(key, MSG_SIZE, IPC_CREAT | 0660)) == -1) {

perror("producer shmget():");

exit(3);

}

message=shmat(shmid, (char *)0, SHM_RDONLY);

while(1){

rtn=semop(semid,&wait_produced,1);

/* when producer is done semid will be IPC_RMID forcing break */

if(rtn == -1){

perror("consumer - semop on wait_consumed");

break;

}

printf("%s received: %s\n", argv[0], message);

semop(semid, &signal_consumed, 1);

}

shmdt(message);

exit(0);

}

ВЫЗОВ:

$ prod_onebuf&

14649

$ cons_onebuf

cons_onebuf received: message 1

cons_onebuf received: message 2

cons_onebuf received: message 3

cons_onebuf received: message 4

consumer-semop on wait_consumed:Identifier removed

matrix fork using c++

Posted on July 17, 2012June 25, 2015 by coder

[c]
#include <stdio.h>
#include <iostream>
#include <cstdio>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/wait.h>
#include <string>
#include <vector>
#include <cstring>
#include <cstdlib>
#include<fstream>
#include <time.h>
// Kutay ZORLU

using namespace std;
void readfile();

vector<string> satirlar(9);
vector<string> sonuc(9);
vector <int> A(16);
vector<int > B(16);
vector<int > C(16);
int main (){

string str = "SOMEload";
double start = clock();

bool okudumu=false;
int fork_id = fork();
while (!okudumu)
{
switch (fork_id) { // forkun durumuna gore asagidaki kodlar gerceklestirilecek

case -1: // -1 hata durumu idi
perror("fork");
return 3;

default:

if(!okudumu){
readfile();
okudumu = true;
}
else{
cout << "babadayım "<<endl;
//wait(0); // let the child finish
C[0] = A[0]*B[0]+ A[1]*B[4] + A[2]*B[8] + A[3]*B[12];
C[1] = A[0]*B[1]+ A[1]*B[5] + A[2]*B[9] + A[3]*B[13];
C[2] = A[0]*B[2]+ A[1]*B[6] + A[2]*B[10] + A[3]*B[14];
C[3] = A[0]*B[3]+ A[1]*B[7] + A[2]*B[11] + A[3]*B[15];
C[4] = A[4]*B[0]+ A[5]*B[4] + A[6]*B[8] + A[7]*B[12];
C[5] = A[4]*B[1]+ A[5]*B[5] + A[6]*B[9] + A[7]*B[13];
C[6] = A[4]*B[2]+ A[5]*B[6] + A[6]*B[10] + A[7]*B[14];
C[7] = A[4]*B[3]+ A[5]*B[7] + A[6]*B[11] + A[7]*B[15];
cout << "DEFAULT 1 içindeuim"<< endl;
}

break;
// break olana kadar default calisiyor

case 0:

//bebe
cout << "CASE 0 içindeyim"<< endl;

if(okudumu){
cout << "C carpti" ;
C[8] = A[8]*B[0]+ A[9]*B[4] + A[10]*B[8] + A[11]*B[12];
C[9] = A[8]*B[1]+ A[9]*B[5] + A[10]*B[9] + A[11]*B[13];
C[10] = A[8]*B[2]+ A[9]*B[6] + A[10]*B[10] + A[11]*B[14];
C[11] = A[8]*B[3]+ A[9]*B[7] + A[10]*B[11] + A[11]*B[15];
C[12] = A[12]*B[0]+ A[13]*B[4] + A[14]*B[8] + A[15]*B[12];
C[13] = A[12]*B[1]+ A[13]*B[5] + A[14]*B[9] + A[15]*B[13];
C[14] = A[12]*B[2]+ A[13]*B[6] + A[14]*B[10] + A[15]*B[14];
C[15] = A[12]*B[3]+ A[13]*B[7] + A[14]*B[11] + A[15]*B[15];
}

break;
}
}

//
//
//
cout << str << endl;
//
double finish = clock();

int sure_time = (double(finish-start)/CLOCKS_PER_SEC);
cout << "SURE : "<<sure_time << endl;
return 1;
}

void readfile(){

ifstream myfile,myfile_2;

myfile.open ("veri.dat");

//
char output[100];
int i=0;
if (myfile.is_open()) {
while (!myfile.eof()) {
//
myfile.getline(output,100) ;
cout << output << "[" << i << "]" <<endl;
i++;

}
}
myfile.close();

myfile_2.open ("veri.dat");

//

i=0; char xx[100];
if (myfile_2.is_open())
{
while (!myfile_2.eof())
{
if(i<1) { myfile_2 >> xx;}
else
{
myfile_2 >> A[i-1];
cout << "A["<<i-1 << "]:" << A[i-1] <<endl;
if((i-1)>15)
{
B[i-17] = A[i-1]; //b2 4
cout <<"B["<<i-17<< "]" << B[i-17]<< endl;
}

}
i++;
}
}
myfile_2.close();
//myfile << "Writing this to a file.\n";
}

[/c]

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

[c]

#include <stdio.h>

#include <iostream>

#include <cstdio>

#include <unistd.h>

#include <sys/types.h>

#include <sys/ipc.h>

#include <sys/shm.h>

#include <sys/wait.h>

#include <string>

#include <vector>

#include <cstring>

#include <cstdlib>

#include<fstream>

#include <time.h>

// Kutay ZORLU

using namespace std;

void readfile();

vector<string> satirlar(9);

vector<string> sonuc(9);

vector <int> A(16);

vector<int > B(16);

vector<int > C(16);

int main (){

string str = "SOMEload";

double start = clock();

bool okudumu=false;

int fork_id = fork();

while (!okudumu)

{

switch (fork_id) { // forkun durumuna gore asagidaki kodlar gerceklestirilecek

case -1: // -1 hata durumu idi

perror("fork");

return 3;

default:

if(!okudumu){

readfile();

okudumu = true;

}

else{

cout << "babadayım "<<endl;

//wait(0); // let the child finish

C[0] = A[0]*B[0]+ A[1]*B[4] + A[2]*B[8] + A[3]*B[12];

C[1] = A[0]*B[1]+ A[1]*B[5] + A[2]*B[9] + A[3]*B[13];

C[2] = A[0]*B[2]+ A[1]*B[6] + A[2]*B[10] + A[3]*B[14];

C[3] = A[0]*B[3]+ A[1]*B[7] + A[2]*B[11] + A[3]*B[15];

C[4] = A[4]*B[0]+ A[5]*B[4] + A[6]*B[8] + A[7]*B[12];

C[5] = A[4]*B[1]+ A[5]*B[5] + A[6]*B[9] + A[7]*B[13];

C[6] = A[4]*B[2]+ A[5]*B[6] + A[6]*B[10] + A[7]*B[14];

C[7] = A[4]*B[3]+ A[5]*B[7] + A[6]*B[11] + A[7]*B[15];

cout << "DEFAULT 1 içindeuim"<< endl;

}

break;

// break olana kadar default calisiyor

case 0:

//bebe

cout << "CASE 0 içindeyim"<< endl;

if(okudumu){

cout << "C carpti" ;

C[8] = A[8]*B[0]+ A[9]*B[4] + A[10]*B[8] + A[11]*B[12];

C[9] = A[8]*B[1]+ A[9]*B[5] + A[10]*B[9] + A[11]*B[13];

C[10] = A[8]*B[2]+ A[9]*B[6] + A[10]*B[10] + A[11]*B[14];

C[11] = A[8]*B[3]+ A[9]*B[7] + A[10]*B[11] + A[11]*B[15];

C[12] = A[12]*B[0]+ A[13]*B[4] + A[14]*B[8] + A[15]*B[12];

C[13] = A[12]*B[1]+ A[13]*B[5] + A[14]*B[9] + A[15]*B[13];

C[14] = A[12]*B[2]+ A[13]*B[6] + A[14]*B[10] + A[15]*B[14];

C[15] = A[12]*B[3]+ A[13]*B[7] + A[14]*B[11] + A[15]*B[15];

}

break;

}

cout << str << endl;

double finish = clock();

int sure_time = (double(finish-start)/CLOCKS_PER_SEC);

cout << "SURE : "<<sure_time << endl;

return 1;

}

void readfile(){

ifstream myfile,myfile_2;

myfile.open ("veri.dat");

char output[100];

int i=0;

if (myfile.is_open()) {

while (!myfile.eof()) {

myfile.getline(output,100) ;

cout << output << "[" << i << "]" <<endl;

i++;

}

myfile.close();

myfile_2.open ("veri.dat");

i=0; char xx[100];

if (myfile_2.is_open())

{

while (!myfile_2.eof())

{

if(i<1) { myfile_2 >> xx;}

else

{

myfile_2 >> A[i-1];

cout << "A["<<i-1 << "]:" << A[i-1] <<endl;

if((i-1)>15)

{

B[i-17] = A[i-1]; //b2 4

cout <<"B["<<i-17<< "]" << B[i-17]<< endl;

}

i++;

}

myfile_2.close();

//myfile << "Writing this to a file.\n";

}

[/c]

qt paint class

Posted on July 16, 2012June 25, 2015 by coder

class xxxx : public QAbstractItemDelegate
{
public:
xxxx( QObject *parent = 0 );

void paint( QPainter *painter, const QStyleOptionViewItem &option, const QModelIndex &index ) const;
QSize sizeHint( const QStyleOptionViewItem &option, const QModelIndex &index ) const;
};

class xxxx : public QAbstractItemDelegate

{

public:

xxxx( QObject *parent = 0 );

void paint( QPainter *painter, const QStyleOptionViewItem &option, const QModelIndex &index ) const;

QSize sizeHint( const QStyleOptionViewItem &option, const QModelIndex &index ) const;

};

Search in directories on ubuntu

Posted on July 14, 2012July 28, 2015 by coder

Locating Files by Name

The most common use of find is in the search for a specific file by use of its name. The following command searches the home directory and all of its subdirectories looking for the file mysong.ogg:

find $HOME -name 'mysong.ogg'

1	find $HOME -name 'mysong.ogg'

It is important to get into the habit of quoting patterns in your search as seen above or your search results can be a little unpredictable. Such a search can be much more sophisticated though. For example if you wished to search for all of the ogg files in your home directory, some of which you think might be named ‘OGG’ rather than ‘ogg’, you would run:

find $HOME -iname '*.ogg'

1	find $HOME -iname '*.ogg'

Here the option ‘-iname’ performs a case-insensitive search while the wildcard character ‘*’ matches any character, or number of characters, or zero characters. To perform the same search on your entire drive you would run:

sudo find / -iname '*.ogg'

1	sudo find / -iname '*.ogg'

This could be a slow search depending on the number of directories, sub-directories and files on your system. This highlights an important difference in the way that find operates in that it examines the system directly each time unlike programs like locate or slocate which actually examine a regularly updated database of filnames and locations.

casio ae1000w – 1bvef , 1b user manual

Posted on July 6, 2012June 25, 2015 by coder

.Download İt maual, Click Here!

1- casio-ae1000w-user-manual-Download-Click

Page 2 of 2

« 1 2