欧美中文字幕在线观看,亚洲女人天堂av,一区二区三区www

Linux内核VFS---rootfs文�g�pȝ��加蝲

bujiwu — Sun, 04 Jul 2010 08:58:00 GMT

对linux-2.6.34源码rootfs文�g�pȝ��加蝲学习(f��n)�W�记

1.内核启动调用start_kernel函数�q�行初始化�?

asmlinkage void __init start_kernel(void) //init\Main.c:528
{
    buffer_init();
    key_init();
    security_init();
    vfs_caches_init(totalram_pages);//678行，vfs初始�?/span>
    signals_init();
}

2.start_kernel调用vfs_caches_init对vfs�q�行初始化�?br>

//fs\Dcach.c:2354�?/span>
void __init vfs_caches_init(unsigned long mempages)
{
    .......
    dcache_init();
    inode_init();
    files_init(mempages);
    mnt_init(); //mnt初始�?/span>
    bdev_cache_init();
    chrdev_init();
}

3.在vfs_caches_init调用fs\namespace.c 2321行的mnt_init函数

void __init mnt_init(void)
{

    init_rootfs();    //初始化rootfs文�g�pȝ��
    init_mount_tree(); //初始化加载树(w��i)
}

4. fs\ramfs�W?08行的init_rootfs函数初始化rootfs文�g�pȝ��

int __init init_rootfs(void)
{
    int err;

    err = bdi_init(&ramfs_backing_dev_info);
    if (err)
        return err;

    err = register_filesystem(&rootfs_fs_type);//注册rootfs文�g�pȝ��
    if (err)
        bdi_destroy(&ramfs_backing_dev_info);

    return err;
}

rootfs文�g�pȝ��信息fs\ramfs�W?89�?

static struct file_system_type rootfs_fs_type = {
    .name        = "rootfs",
    .get_sb        = rootfs_get_sb,
    .kill_sb    = kill_litter_super,
};

5.调用register_filesystem函数��rootfs注册�?span style="font-weight: bold; color: #ff0000; font-family: 黑体;">file_systems文�g�pȝ��中�?br>

//fs\Filesystem.c�W?9行�?br>int register_filesystem(struct file_system_type * fs)
{
    int res = 0;
    struct file_system_type ** p;

    BUG_ON(strchr(fs->name, '.'));
    if (fs->next)
        return -EBUSY;
    INIT_LIST_HEAD(&fs->fs_supers);
    write_lock(&file_systems_lock);
    p = find_filesystem(fs->name, strlen(fs->name));//查找到文件系�l�加载位�|?br>    if (*p)
        res = -EBUSY;
    else
        *p = fs;
    write_unlock(&file_systems_lock);
    return res;
}

file_systems变量是所有文件系�l�链表的头指针。通过以上�q�程rootfs_fs_type��加入到�?ji��n)file_systems链表头的file_system_type�c�d��的链表中。可以通过file_systems指针遍历�q�个链表�Q�得到特定的文�g�pȝ��file_system_type 指针�?br>

bujiwu 2010-07-04 16:58 发表评论

[转蝲]top命��o(h��)详解

bujiwu — Tue, 27 Apr 2010 05:26:00 GMT

http://blog.chinaunix.net/u/12973/showart_637900.html

top命��o(h��)是Linux下常用的性能分析工具�Q�能够实时显�C�系�l�中各个�q�程的资源占用状况，�c�M��于Windows的�Q务管理器。下面详�l�介�l�它的��用方法�?

top - 01:06:48 up 1:22, 1 user, load average: 0.06, 0.60, 0.48
Tasks: 29 total,   1 running, 28 sleeping,   0 stopped,   0 zombie
Cpu(s): 0.3% us, 1.0% sy, 0.0% ni, 98.7% id, 0.0% wa, 0.0% hi, 0.0% si
Mem:    191272k total,   173656k used,    17616k free,    22052k buffers
Swap:   192772k total,        0k used,   192772k free,   123988k cached

   PID USER      PR NI VIRT RES SHR S %CPU %MEM    TIME+ COMMAND
1379 root      16   0 7976 2456 1980 S 0.7 1.3   0:11.03 sshd
14704 root      16   0 2128 980 796 R 0.7 0.5   0:02.72 top
     1 root      16   0 1992 632 544 S 0.0 0.3   0:00.90 init
     2 root      34 19     0    0    0 S 0.0 0.0   0:00.00 ksoftirqd/0
     3 root      RT   0     0    0    0 S 0.0 0.0   0:00.00 watchdog/0

�l�计信息�?/h4>
前五行是�pȝ��整体的统计信息。第一行是��d��队列信息�Q�同 uptime 命��o(h��)的执行结果。其内容如下�Q?/p>

01:06:48 当前旉��

up 1:22 �pȝ��q�行旉��Q�格式�ؓ(f��)�?�?/td>

1 user 当前��d��用户�?/td>

load average: 0.06, 0.60, 0.48 �pȝ��负蝲�Q�即��d��队列的��^均长度�?br> 三个数值分别�ؓ(f��) 1分钟�?分钟�?5分钟前到现在的��^均倹{�?/td>

�W�二、三行�ؓ(f��)�q�程和CPU的信息。当有多个CPU�Ӟ��q�些内容可能�?x��)超�q�两行。内容如下：(x��)

Tasks: 29 total �q�程��L��

1 running 正在�q�行的进�E�数

28 sleeping 睡眠的进�E�数

0 stopped 停止的进�E�数

0 zombie 僵尸�q�程�?/td>

Cpu(s): 0.3% us 用户�I�间占用CPU癑ֈ��?/td>

1.0% sy 内核�I�间占用CPU癑ֈ��?/td>

0.0% ni 用户�q�程�I�间内改变过优先�U�的�q�程占用CPU癑ֈ��?/td>

98.7% id �I�闲CPU癑ֈ��?/td>

0.0% wa �{�待输入输出的CPU旉��癑ֈ��?/td>

0.0% hi

0.0% si

最后两行�ؓ(f��)内存信息。内容如下：(x��)

Mem: 191272k total 物理内存总量

173656k used 使用的物理内存总量

17616k free �I�闲内存总量

22052k buffers 用作内核�~�存的内存量

Swap: 192772k total 交换区总量

0k used 使用的交换区总量

192772k free �I�闲交换区总量

123988k cached �~�冲的交换区总量�?br> 内存中的内容被换出到交换区，而后又被换入到内存，但��用过的交换区��未被覆盖，
该数值即��?strong>内容已存在于内存�?/strong>的交换区的大��?br> 相应的内存再�ơ被换出时可不必再对交换区写入�?/td>

�q�程信息�?/h4>
�l�计信息区域的下�Ҏ(gu��)��C�Z��(ji��n)各个�q�程的详�l�信息。首先来认识一下各列的含义�?/p>

序号列名含义

a PID �q�程id

b PPID 父进�E�id

c RUSER Real user name

d UID �q�程所有者的用户id

e USER �q�程所有者的用户�?/td>

f GROUP �q�程所有者的�l�名

g TTY 启动�q�程的终端名。不是从�l�端启动的进�E�则昄��??

h PR 优先�U?/td>

i NI nice倹{��负��D��C�高优先�U�，正��D��C�Z��优先�U?/td>

j P 最后��用的CPU�Q�仅在多CPU环境下有意义

k %CPU 上次更新到现在的CPU旉��占用癑ֈ��?/td>

l TIME �q�程使用的CPU旉��总计�Q�单位秒

m TIME+ �q�程使用的CPU旉��总计�Q�单�?/100�U?/td>

n %MEM �q�程使用�?strong>物理内存癑ֈ��?/td>

o VIRT �q�程使用的虚拟内存总量�Q�单位kb。VIRT=SWAP+RES

p SWAP �q�程使用的虚拟内存中�Q�被换出的大��，单位kb�?/td>

q RES �q�程使用的、未被换出的物理内存大小�Q�单位kb。RES=CODE+DATA

r CODE 可执行代码占用的物理内存大小�Q�单位kb

s DATA 可执行代码以外的部分(数据�D?�?占用�?strong>物理�? 存大��，单位kb

t SHR �׃�n内存大小�Q�单位kb

u nFLT ��面错误�ơ数

v nDRT 最后一�ơ写入到现在�Q�被修改�q�的��面数�?/td>

w S �q�程状态�?br> D=不可中断的睡眠状�?br> R=�q�行
S=睡眠
T=跟踪/停止
Z=僵尸�q�程

x COMMAND 命��o(h��)�?命��o(h��)�?/td>

y WCHAN 若该�q�程在睡眠，则显�C�睡眠中的系�l�函数名

z Flags ��d��标志�Q�参�?sched.h

默认情况下仅昄��比较重要�?PID、USER、PR、NI、VIRT、RES、SHR、S�?CPU�?MEM、TIME+、COMMAND 列。可以通过下面的快捷键来更�Ҏ(gu��)��C�内宏V�?/p>

序号	列名	含义
a	PID	�q�程id
b	PPID	父进�E�id
c	RUSER	Real user name
d	UID	�q�程所有者的用户id
e	USER	�q�程所有者的用户�?/td>
f	GROUP	�q�程所有者的�l�名
g	TTY	启动�q�程的终端名。不是从�l�端启动的进�E�则昄��??
h	PR	优先�U?/td>
i	NI	nice倹{��负��D��C�高优先�U�，正��D��C�Z��优先�U?/td>
j	P	最后��用的CPU�Q�仅在多CPU环境下有意义
k	%CPU	上次更新到现在的CPU旉��占用癑ֈ��?/td>
l	TIME	�q�程使用的CPU旉��总计�Q�单位秒
m	TIME+	�q�程使用的CPU旉��总计�Q�单�?/100�U?/td>
n	%MEM	�q�程使用�?strong>物理内存癑ֈ��?/td>
o	VIRT	�q�程使用的虚拟内存总量�Q�单位kb。VIRT=SWAP+RES
p	SWAP	�q�程使用的虚拟内存中�Q�被换出的大��，单位kb�?/td>
q	RES	�q�程使用的、未被换出的物理内存大小�Q�单位kb。RES=CODE+DATA
r	CODE	可执行代码占用的物理内存大小�Q�单位kb
s	DATA	可执行代码以外的部分(数据�D?�?占用�?strong>物理�? 存大��，单位kb
t	SHR	�׃�n内存大小�Q�单位kb
u	nFLT	��面错误�ơ数
v	nDRT	最后一�ơ写入到现在�Q�被修改�q�的��面数�?/td>
w	S	�q�程状态�?br> D=不可中断的睡眠状�?br> R=�q�行 S=睡眠 T=跟踪/停止 Z=僵尸�q�程
x	COMMAND	命��o(h��)�?命��o(h��)�?/td>
y	WCHAN	若该�q�程在睡眠，则显�C�睡眠中的系�l�函数名
z	Flags	��d��标志�Q�参�?sched.h

更改昄��内容

通过 f 键可以选择昄��的内宏V��按 f 键之后会(x��)昄��列的列表�Q�按 a-z 卛_��昄��或隐藏对应的列，最后按回�R键确定�?/p>

�?o 键可以改变列的显�C�顺序。按��写�?a-z 可以��相应的列向右移动，而大写的 A-Z 可以��相应的列向左移动。最后按回�R键确定�?/p>

按大写的 F �?O 键，然后�?a-z 可以��进�E�按照相应的列进行排序。而大写的 R 键可以将当前的排序倒�{�?/p>

命��o(h��)使用

1�Q?工具�Q�命令）(j��)名称
top
2�Q�工��P��命��o(h��)�Q�作�?br> 昄��pȝ��当前的进�E�和其他状况�Q? top是一个动态显�C��E?卛_��以通过用户按键来不断刷新当前状�?如果在前台执行该命��o(h��),它将独占前台,直到用户�l�止该程序�ؓ(f��)�? 比较准确的说,top命��o(h��)提供�?ji��n)实时的对系�l�处理器的状态监�?它将昄��pȝ��中CPU最“敏感”的�Q务列�?该命令可以按CPU使用.内存使用和执行时�? 对�Q务进行排序；而且该命令的很多�Ҏ(gu��)��都可以通过交互式命令或者在个�h定制文�g中进行设�?
3�Q�环境设�|?br> 在Linux下��用�?br> 4�Q��用方�?br> 4�Q?使用格式
top [-] [d] [p] [q] [c] [C] [S] [s] [n]
4�Q?参数说明
d 指定每两�ơ屏�q�信息刷��C��间的旉��间隔。当然用户可以��用s交互命��o(h��)来改变之�?br> p 通过指定监控�q�程ID来仅仅监控某个进�E�的状态�?br> q该选项��top没有��M��延迟的进行刷新。如果调用程序有��用户权限�Q�那么top��以 ��可能高的优先��q�行�?br> S 指定累计模式
s 使top命��o(h��)在安全模式中�q�行。这��去除交互命令所带来的潜在危险�?br> i 使top不显�C�Z�Q何闲�|�或者僵死进�E��?br> c 昄��整个命��o(h��)行而不只是昄��命��o(h��)�?br> 4.3其他
下面介绍在top命��o(h��)执行�q�程中可以��用的一些交互命令。从使用角度来看�Q�熟�l�的掌握�q�些命��o(h��)比掌握选项�q�重要一些。这些命令都是单字母的，如果在命令行选项中��用了(ji��n)s选项�Q�则可能其中一些命令会(x��)被屏蔽掉�?br> Ctrl+L 擦除�q�且重写屏幕�?br> h或�? 昄��帮助画面�Q�给��Z��些简短的命��o(h��)�ȝ��说明�?br> k �l�止一个进�E�。系�l�将提示用户输入需要终止的�q�程PID�Q�以�?qi��ng)需要发送给该进�E�什么样的信受��一般的�l�止�q�程可以使用15信号�Q�如果不能正常结束那��׃��? 信号9强制�l�束该进�E�。默认值是信号15。在安全模式中此命��o(h��)被屏蔽�?br> i 忽略闲置和僵死进�E�。这是一个开兛_��命��o(h��)�?br> q 退出程序�?br> r 重新安排一个进�E�的优先�U�别。系�l�提�C�用戯��入需要改变的�q�程PID以及(qi��ng)需要设�|�的 �q�程优先�U�倹{��输入一个正值将使优先��降低�Q�反之则可以使该�q�程拥有更高的优先权。默认值是10�?br> S 切换到篏计模式�?br> s 改变两次��h��之间的�g�q�时间。系�l�将提示用户输入新的旉��Q�单位�ؓ(f��)s。如果有��数�Q? ��换��成m s。输�?值则�pȝ��不断刷斎ͼ�默认值是5 s。需要注意的是如果设�|�太��的旉��Q�很可能�?x��)引起不断刷斎ͼ�从而根本来不及(qi��ng)看清昄��的情况，而且�pȝ��负蝲也会(x��)大大增加�?br> f或者F 从当前显�C�Z��d��或者删除项目�?br> o或者O 改变昄��目的顺序�?br> l 切换昄��q�_��负蝲和启动时间信息�?br> m 切换昄��内存信息�?br> t 切换昄��q�程和CPU状态信息�?br> c 切换昄��命��o(h��)名称和完整命令行�?br> 　M �Ҏ(gu��)��ȝ��内存大小�q�行排序�?br> P �Ҏ(gu��)��CPU使用癑ֈ�比大��进行排序�?br> T �Ҏ(gu��)��旉��/累计旉��q�行排序�?br> W ��当前设�|�写入~/.toprc文�g中。这是写top配置文�g的推荐方法�?/span>

bujiwu 2010-04-27 13:26 发表评论

bujiwu — Fri, 15 Jan 2010 09:52:00 GMT

转蝲链接:http://blog.chinaunix.net/u2/76292/showart_1845022.html

1 #include <stdlib.h>
2 #include <stdio.h>
3 #include <ctype.h>
4
5 long my_atol(const char *nptr)
6 {
7     int c; /* current char */
8     long total; /* current total */
9     int sign; /* if '-', then negative, otherwise positive */
10
11     /* skip whitespace */
12     while ( isspace((int)(unsigned char)*nptr) )
13     {
14         ++nptr;
15     }
16
17     c = (int)(unsigned char)*nptr++;
18     sign = c; /* save sign indication */
19     if (c == '-' || c == '+')
20     {
21         c = (int)(unsigned char)*nptr++; /* skip sign */
22     }
23
24     total = 0;
25
26     while (isdigit(c))
27     {
28         total = 10 * total + (c - '0'); /* accumulate digit */
29         c = (int)(unsigned char)*nptr++; /* get next char */
30     }
31
32     if (sign == '-')
33     {
34        return -total;
35     }
36     else
37     {
38         return total; /* return result, negated if necessary */
39     }
40 }
41
42 int  main(int argc, char* argv[])
43 {
44     if( argc < 2 )
45     {
46         return -1;
47     }
48
49     int i = my_atol(argv[1]);
50     printf("[%s]====>[%d]\n", argv[1], i);
51
52     int j = atoi(argv[1]);
53     printf("[%s]====>[%d]\n", argv[1], j);
54
55     return 0;
56 }
57

http://m.shnenglu.com/Files/bujiwu/atoi.rar

bujiwu 2010-01-15 17:52 发表评论

Unix Network Programming - Vol2 ��M��W�记(Chapter 9. Record Locking)

bujiwu — Fri, 18 Dec 2009 07:57:00 GMT

使用Record Locking只启动一个进�E�实例。通过记录锁锁文�g方式实现�?br>

#include <sys/types.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#define FILE_PATH   "LockFile.txt"
#define MAXLINE     4096    /* max text line length */
#define FILE_MODE   (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)

int LockSet(int fd, int Type)
{
    struct flock lock;

    lock.l_type = Type;        /* F_RDLCK, F_WRLCK, F_UNLCK */
    lock.l_start = 0;          /* byte offset, relative to l_whence */
    lock.l_whence = SEEK_END;  /* SEEK_SET, SEEK_CUR, SEEK_END */
    lock.l_len = 0;            /* #bytes (0 means to EOF) */

    return fcntl( fd, F_SETLK, &lock);
}

int main(int argc, char **argv)
{
    char line[MAXLINE] = {0};

    int fd = open(FILE_PATH, O_RDWR | O_CREAT| O_APPEND , FILE_MODE);

    if ( LockSet(fd, F_WRLCK) < 0 )
    {
        if (errno == EACCES || errno == EAGAIN)
        {
            printf("This program has running!\n");
            close(fd);
        }
        else
        {
            printf("call fcntl function error.%s\n", strerror(errno) );
        }

        exit(1);
    }

    printf("lock file [%s] successful\n", FILE_PATH);

    snprintf(line, sizeof(line), "%ld\n", (long) getpid());

    lseek(fd, 0, SEEK_END);
    write(fd, line, strlen(line));

    getchar();

    if ( LockSet(fd, F_UNLCK) < 0 )
    {
        printf("call fcntl function error.%s\n", strerror(errno) );
    }

    close(fd);

    return 0;
}

http://m.shnenglu.com/Files/bujiwu/RecordLocking.rar

bujiwu 2009-12-18 15:57 发表评论

boost::filestream�l��g��装

bujiwu — Mon, 23 Nov 2009 05:44:00 GMT

��Z��(ji��n)方便日常使用boost::filestream�l��g�Q�将boost::filestream�l��g的基本封装�?br>

/**
* @file FileSystem.h
* @brief Operation file or diretory
* @author Jiwu Bu
* @version 1.0.0
* @date 2009-11-23
*/
#ifndef FILESYSTEM_H_H
#define FILESYSTEM_H_H

#include <iostream>
#include <vector>

using namespace std;

class CFileSystem
{
public:
    /**
     * @brief Gets an array of dirctories from current direcoty,
     *        using Recur value to determine whether to search
     *        subdirectories.
     * @param SubDirVec Ouput parameter, return the search result
     * @param DirPath
     * @param Recur  Whether search subdirectories.
     *
     * @return
     */
    static bool GetDirectories(vector<string>& SubDirVec,
        const string& DirPath, bool Recur = false);

    /**
     * @brief Get the names of files in the specified directory that
     *        match the specified extensive name, using a value to
     *        determine whether to search subdirectories.
     *
     * @param FileVec Ouput parameter, return the search result
     * @param DirPath
     * @param ExeName Extensive name, if ExeName equal  "*.*"  search all file
     * @param Recur   Whether search subdirectories
     *
     * @return
     */
    static bool GetFiles(vector<string>& FileVec, const string& DirPath,
        const string& ExeName, bool Recur = false);

    /**
     * @brief Create a new directory.
     *
     * @param Dir  New directory path. Example:/home/bujiwu/test
     *
     * @return  true, if success
     *          false, if failed
     */
    static bool CreateDirectory(const string & Dir);

    /**
     * @brief Judge whether this file or diretory exists.
     *
     * @param Path
     *
     * @return  true, if exists
     *          false, if not exists
     */
    static bool Exists(const string& Path);

    /**
     * @brief Delete this file or directory
     *
     * @param Path
     */
    static void Delete(const string& Path);

    /**
     * @brief Move file or directory from FromPath to ToPath.
     *
     * @param FromPath
     * @param ToPath
     */
    static void Move(const string& FromPath, const string& ToPath);

    /**
     * @brief Copy file or directory from FromPath to ToPath.
     *
     * @param FromPath
     * @param ToPath
     */
    static void Copy(const string& FromPath, const string& ToPath);

    /**
     * @brief Get file size
     *
     * @param FilePath
     *
     * @return
     */
    static unsigned long GetFileSize(const string& FilePath);
};

#endif

��试用例�Q?br>

#include "../FileSystem/FileSystem.h"
#include <algorithm>
#include <iterator>
#include <string>

using namespace std;

int main(int argc, char* argv[])
{
    vector<string> MyVec;

    string Path = "/home/bujiwu/EncapDirectory";

    CFileSystem::Copy("/home/bujiwu/epoll", Path);

    CFileSystem::GetFiles(MyVec, Path, "*.*", true);

    copy(MyVec.begin(), MyVec.end(), ostream_iterator<string>(cout , "\n") );

    return 0;
}

http://m.shnenglu.com/Files/bujiwu/FileSystem.rar

bujiwu 2009-11-23 13:44 发表评论

在Linux与Winodws下编译boost

bujiwu — Mon, 23 Nov 2009 05:31:00 GMT

需要编译的库：(x��)
date_time
filesystem
function_types
graph
iostreams
math
mpi
program_options
python
regex
serialization
signals
system
test
thread
wave

Windows:
1、开始菜�?-Microsoft Visual Studio 2008--Visual Studio Tools---Open Visual Studio 2008 Command Prompt 打开命��o(h��)行窗�?br>3、利用cd命��o(h��)�q�入刎ͼ�(x��)boost->toos->jam->src目录
4、编译，vc 2008输入命��o(h��)�Q�build vc9
5、把生成的bjam.exe(bin.ntx86目录�?拯��到Boost根目录下�Q�输入命令：(x��)
6、bjam --with-regex

Linux:
$cd path/to/boost_1_40_0
$ ./bootstrap.sh
产生bjam文�g

$ ./bjam install 安装所�?br> $./bjam --with-regex 安装特定的库
$./bjam --with-filesystem

#./bjam --with-filesystem "-sTOOLS=gcc" "--includedir=/usr/include" "--libdir=/usr/lib/boost" install

bujiwu 2009-11-23 13:31 发表评论

semaphore信号学习(f��n)�W�记

bujiwu — Tue, 17 Nov 2009 05:28:00 GMT

使用信号量sem_t实现生��者与消费者实例。主要用��C��下几个函�?
sem_init()
sem_destroy()
sem_post()
sem_wait()

//g++ -o semaphore semaphore.cpp  -lpthread
#include <semaphore.h>
#include <errno.h>
#include <unistd.h>
#include <pthread.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include "ThreadMutex.h"

#define MAXSIZE 10

sem_t g_sem_max;
sem_t g_sem_zero;

CThreadMutex g_mutex;

int g_count = 0;

int sem_wait_i(sem_t* psem)
{
    int rv = 0;

    while ( 0 != ( rv = sem_wait(psem) ) )
    {
        if ( errno == EINTR )
        {
            continue;
        }
        else
        {
            printf("sem_wait %s\n", strerror(errno) );
            break;
        }
    }

    return rv;
}

void* producer_thread(void* Parameter)
{
    while( true )
    {
        sleep(2);

        if( sem_wait_i(&g_sem_max) != 0 )
        {
            break;
        }

        g_mutex.Lock();

        g_count++;

        printf("Producer=%d\n", g_count);

        sem_post(&g_sem_zero);

        g_mutex.UnLock();
    }

    return NULL;
}

void* consumer_thread(void* Parameter)
{
    while( true )
    {
        sleep(3);

        if( sem_wait_i(&g_sem_zero) != 0 )
        {
            break;
        }

        g_mutex.Lock();

        g_count--;

        printf("Consumer=%d\n", g_count);

        sem_post(&g_sem_max);

        g_mutex.UnLock();
    }

    return NULL;
}

int main(int argc, char* argv[])
{
    if ( sem_init(&g_sem_zero, 0, 0) != 0 )
    {
        printf("sem_init %s\n", strerror(errno) );

        return -1;
    }

    if ( sem_init(&g_sem_max, 0, MAXSIZE) != 0 )
    {
        printf("sem_init %s\n", strerror(errno) );

        return -1;
    }

    pthread_t pro_thread;
    pthread_t sum_thread;

    if ( pthread_create( &sum_thread, NULL, consumer_thread, NULL) != 0 )
    {
        printf("pthread_create%s\n", strerror(errno) );

        return -1;
    }

    if ( pthread_create( &pro_thread, NULL, producer_thread, NULL) != 0 )
    {
        printf("pthread_create%s\n", strerror(errno) );

        return -1;
    }

    if ( pthread_join(pro_thread, NULL) != 0 )
    {
        printf("pthread_join %s\n", strerror(errno) );

        return -1;
    }

    if ( pthread_join(sum_thread, NULL) != 0 )
    {
        printf("pthread_join %s\n", strerror(errno) );

        return -1;
    }

    sem_destroy(&g_sem_zero);
    sem_destroy(&g_sem_max);

    return 0;
}

http://m.shnenglu.com/Files/bujiwu/semaphore.rar

bujiwu 2009-11-17 13:28 发表评论

setitimer函数使用�W�记

bujiwu — Mon, 16 Nov 2009 05:50:00 GMT

函数原型 int setitimer(int which, const struct itimerval *value,
                     struct itimerval *ovalue);

DESCRIPTION
       The system provides each process with three interval timers, each decrementing in a distinct time domain. When any timer expires, a
       signal is sent to the process, and the timer (potentially) restarts.

       ITIMER_REAL    decrements in real time, and delivers SIGALRM upon expiration.

       ITIMER_VIRTUAL decrements only when the process is executing, and delivers SIGVTALRM upon expiration.

       ITIMER_PROF    decrements both when the process executes and when the system is executing on behalf of the process.   Coupled with
                      ITIMER_VIRTUAL, this timer is usually used to profile the time spent by the application in user and kernel space. SIG-
                      PROF is delivered upon expiration.

       Timer values are defined by the following structures:

            struct itimerval {
                struct timeval it_interval; /* next value */
                struct timeval it_value;    /* current value */
            };
            struct timeval {
                long tv_sec;                /* seconds */
                long tv_usec;               /* microseconds */
            };

#include <stdio.h>
#include <unistd.h>
#include <signal.h>
#include <string.h>
#include <sys/time.h>
#include <errno.h>

void PrintMsg(int Num)
{
    printf("%s\n", "Hello World");

    return;
}

int main(int argc, char* argv[])
{
    signal(SIGALRM, PrintMsg);

    struct itimerval tick;
    tick.it_value.tv_sec = 10;  //十秒钟后��启动定时器
    tick.it_value.tv_usec = 0;
    tick.it_interval.tv_sec  =1; //定时器启动后�Q�每�?�U�将执行相应的函�?/span>
    tick.it_interval.tv_usec = 0;

    //setitimer��触发SIGALRM信号
    int ret = setitimer(ITIMER_REAL, &tick, NULL);

    if ( ret != 0)
    {
        printf("Set timer error. %s \n", strerror(errno) );

        return -1;
    }

    printf("Wait!\n");

    getchar();

    return 0;
}

bujiwu 2009-11-16 13:50 发表评论

pthread_mutex_t��装

bujiwu — Sun, 08 Nov 2009 12:57:00 GMT

常常需要��用pthread_mutex�U�程同步�Q�每�ơ都要��用pthread_mutex_init, pthread_mutex_lock, pthread_unlock, pthread_mutex_destroy�q�几个函敎ͼ��q�脆��装一下，以便以后重用�?br>

//Mutex.cpp
#include <pthread.h>
#include <iostream>
using namespace std;

class ThreadMutex
{
public:
    ThreadMutex()
    {
        pthread_mutex_init(&mtx, NULL);
    }

    ~ThreadMutex()
    {
        pthread_mutex_destroy( &mtx );
    }

    inline void Lock()
    {
        pthread_mutex_lock( &mtx );
    }

    inline void UnLock()
    {
        pthread_mutex_unlock( &mtx );
    }

private:
    pthread_mutex_t mtx;
};

//以下为测试用�?br>ThreadMutex g_Mutex;

void *PrintMsg(void *lpPara)
{
    char *msg = (char *)lpPara;

    g_Mutex.Lock();

    for(int i=0; i< 5; i++ )
    {
        cout << msg << endl;
        sleep( 1 );
    }

    g_Mutex.UnLock();

    return NULL;
}

int main()
{
    pthread_t t1,t2;

    //创徏两个工作�U�程�Q�第1个线�E�打�?0�?�Q�第2个线�E�打�?0�?�?/span>
    pthread_create( &t1, NULL, &PrintMsg, (void *)"First print thread" );
    pthread_create( &t2, NULL, &PrintMsg, (void *)"Second print thread" );

    //�{�待�U�程�l�束
    pthread_join( t1, NULL);
    pthread_join( t2, NULL);

    return 0;
}

通过g++ -o Mutex Mutex.cpp -lpthread�~�译�?br>

bujiwu 2009-11-08 20:57 发表评论

�q�程间通讯--System V �׃�n内存

bujiwu — Sun, 08 Nov 2009 01:39:00 GMT

�q�程一��数据写入共享内存，�q�程二从�׃�n内存��d��数据

#include <sys/ipc.h>
#include <sys/shm.h>
#include <unistd.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>

using namespace std;

int main(int argc, char* argv[])
{
    key_t key = ftok("/etc/passwd", 'a');
    if( -1 == key )
    {
        fprintf(stderr, "Creat Key Error:%s\n", strerror(errno));
        return -1;
    }

    /*
     if your IPC are used by processes related bya fork()
    (parent-children-grandchildren) use IPC_PRIVATE as the key
    */
    int shm_id=shmget( key, 1024, IPC_CREAT |0660);

    if( shm_id == -1 )
    {
        if ( shmctl(shm_id, IPC_RMID, NULL) == -1 )
        {
            fprintf(stderr, "shmctl remove shmid error:%s\n", strerror(errno ));
            return -1;
        }

        shm_id=shmget( key, 1024, IPC_CREAT |0660);
        if( shm_id == -1 )
        {
            fprintf(stderr, "shmget create error:%s\n", strerror(errno) );
            return -1;
        }
    }

    char* pMap = (char *)shmat(shm_id, NULL, 0);

    if( (int)pMap == -1)
    {
        fprintf(stderr, "shmat create error:%s\n", strerror(errno) );
        shmctl(shm_id, IPC_RMID, NULL);
        return -1;
    }

    strcpy( pMap, "Bujiwu Swallow");

    getchar();

    shmdt(pMap);
    shmctl(shm_id, IPC_RMID, NULL);

    return 0;
}

#include <sys/ipc.h>
#include <sys/shm.h>
#include <unistd.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <sys/types.h>

using namespace std;

int main(int argc, char* argv[])
{
    key_t key = ftok("/etc/passwd", 'a');
    if( -1 == key )
    {
        fprintf(stderr, "Creat Key Error:%s\n", strerror(errno));
        return -1;
    }

    /*
     if your IPC are used by processes related bya fork()
    (parent-children-grandchildren) use IPC_PRIVATE as the key
    */
    int shm_id=shmget( key, 1024, IPC_CREAT|0660);

    if( shm_id == -1 )
    {
        if ( shmctl(shm_id, IPC_RMID, NULL) == -1 )
        {
            fprintf(stderr, "shmctl remove shmid error:%s\n", strerror(errno ));
            return -1;
        }

        shm_id=shmget( key, 1024, IPC_CREAT |0660);
        if( shm_id == -1 )
        {
            fprintf(stderr, "shmget create error:%s\n", strerror(errno) );
            return -1;
        }
    }
    char* pMap = (char *)shmat(shm_id, NULL, 0);

    if( (int)pMap == -1)
    {
        fprintf(stderr, "shmat create error:%s\n", strerror(errno) );
        shmctl(shm_id, IPC_RMID, NULL);
        return -1;
    }

    printf("Shared  memory::%s\n", pMap);

    shmdt(pMap);
    shmctl(shm_id, IPC_RMID, NULL);

    return 0;
}

http://m.shnenglu.com/Files/bujiwu/ShareMemory.rar

bujiwu 2009-11-08 09:39 发表评论

01:06:48	当前旉��
up 1:22	�pȝ��q�行旉��Q�格式�ؓ(f��)�?�?/td>
1 user	当前��d��用户�?/td>
load average: 0.06, 0.60, 0.48	�pȝ��负蝲�Q�即��d��队列的��^均长度�?br> 三个数值分别�ؓ(f��) 1分钟�?分钟�?5分钟前到现在的��^均倹{�?/td>

Tasks: 29 total	�q�程��L��
1 running	正在�q�行的进�E�数
28 sleeping	睡眠的进�E�数
0 stopped	停止的进�E�数
0 zombie	僵尸�q�程�?/td>
Cpu(s): 0.3% us	用户�I�间占用CPU癑ֈ��?/td>
1.0% sy	内核�I�间占用CPU癑ֈ��?/td>
0.0% ni	用户�q�程�I�间内改变过优先�U�的�q�程占用CPU癑ֈ��?/td>
98.7% id	�I�闲CPU癑ֈ��?/td>
0.0% wa	�{�待输入输出的CPU旉��癑ֈ��?/td>
0.0% hi
0.0% si

Mem: 191272k total	物理内存总量
173656k used	使用的物理内存总量
17616k free	�I�闲内存总量
22052k buffers	用作内核�~�存的内存量
Swap: 192772k total	交换区总量
0k used	使用的交换区总量
192772k free	�I�闲交换区总量
123988k cached	�~�冲的交换区总量�?br> 内存中的内容被换出到交换区，而后又被换入到内存，但��用过的交换区��未被覆盖，该数值即��?strong>内容已存在于内存�?/strong>的交换区的大��?br> 相应的内存再�ơ被换出时可不必再对交换区写入�?/td>