cmu15-445-project0,1

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

# !/usr/bin/bash

lab="$1"
msg="$2"

check(){
    if [ $? -ne 0 ]; then
        echo "command error."
        exit 10
    else
        echo "ok"
    fi
}

if [ "$lab" = "check" ] ; then
    cd build
    make format
    make check-lint
    make check-clang-tidy
    cd ..
    exit 0
fi

if [ "$lab" = "" ] || [ "$msg" == "" ] ; then
    echo "lab or msg error."
    exit 10
fi

cd build
make format
cd ..

check

git add .
git commit -m "$msg"
git push origin dev

check

lab0File="test/primer/starter_test.cpp"
lab1File="src/include/buffer/lru_replacer.h \
        src/buffer/lru_replacer.cpp \
        src/include/buffer/buffer_pool_manager_instance.h \
        src/buffer/buffer_pool_manager_instance.cpp \
        src/include/buffer/parallel_buffer_pool_manager.h \
        src/buffer/parallel_buffer_pool_manager.cpp\
        src/include/common/logger.h"
lab2File="$lab1File src/include/storage/page/hash_table_directory_page.h \
        src/storage/page/hash_table_directory_page.cpp \
        src/include/storage/page/hash_table_bucket_page.h \
        src/storage/page/hash_table_bucket_page.cpp \
        src/include/container/hash/extendible_hash_table.h \
        src/container/hash/extendible_hash_table.cpp \
        src/include/storage/page/tmp_tuple_page.h"
lab3File="$lab2File src/include/execution/execution_engine.h \
        src/include/execution/executors/seq_scan_executor.h \
        src/include/execution/executors/insert_executor.h \
        src/include/execution/executors/update_executor.h \
        src/include/execution/executors/delete_executor.h \
        src/include/execution/executors/nested_loop_join_executor.h \
        src/include/execution/executors/hash_join_executor.h \
        src/include/execution/executors/aggregation_executor.h \
        src/include/execution/executors/limit_executor.h \
        src/include/execution/executors/distinct_executor.h \
        src/execution/seq_scan_executor.cpp \
        src/execution/insert_executor.cpp \
        src/execution/update_executor.cpp \
        src/execution/delete_executor.cpp \
        src/execution/nested_loop_join_executor.cpp \
        src/execution/hash_join_executor.cpp \
        src/execution/aggregation_executor.cpp \
        src/execution/limit_executor.cpp \
        src/execution/distinct_executor.cpp"
lab4File="$lab3File src/concurrency/lock_manager.cpp\
        src/include/concurrency/lock_manager.h"

if [ "$lab" = "l0" ] ; then
    labFile = lab0File
elif [ "$lab" = "l1" ] ; then
    labFile = lab1File
elif [ "$lab" = "l2" ] ; then
    labFile = lab2File
elif [ "$lab" = "l3" ] ; then
    labFile = lab3File
elif [ "$lab" = "l4" ] ; then
    labFile = lab4File
fi

if [ "$msg" != "" ] ; then
    git checkout -b "$lab"
    git reset --hard dev
    git rm -r --cached .
    git add $labFile
    git commit -m "$msg"
    git push -f origin "$lab"
    git checkout dev -f
fi

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

    // src/include/buffer/buffer_pool_manager_instance.h
	
	/** Array of buffer pool pages. */
	// 堆内存
    Page *pages_;
    /** Pointer to the disk manager. */
    // 没有实现wal，只是简单的文件读写
    DiskManager *disk_manager_ __attribute__((__unused__));
    /** Pointer to the log manager. */
    LogManager *log_manager_ __attribute__((__unused__));
    /** Page table for keeping track of buffer pool pages. */
    std::unordered_map<page_id_t, frame_id_t> page_table_;
    /** Replacer to find unpinned pages for replacement. */
    Replacer *replacer_;
    /** List of free pages. */
    std::list<frame_id_t> free_list_;
    /** This latch protects shared data structures. We recommend updating this comment to describe what it protects. */
    /** Protect free_list_, page_table_*/
    std::mutex latch_;

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

  // src/include/storage/page/page.h
  /** Zeroes out the data that is held within the page. */
  inline void ResetMemory() { memset(data_, OFFSET_PAGE_START, PAGE_SIZE); }

  /** The actual data that is stored within a page. */
  char data_[PAGE_SIZE]{};
  /** The ID of this page. */
  page_id_t page_id_ = INVALID_PAGE_ID;
  /** The pin count of this page. */
  int pin_count_ = 0;
  /** True if the page is dirty, i.e. it is different from its corresponding page on disk. */
  bool is_dirty_ = false;
  /** Page latch. */
  ReaderWriterLatch rwlatch_;