Skip to content

Commit

Permalink
style: format
Browse files Browse the repository at this point in the history
  • Loading branch information
@jinbooooom
jinbooooom committed Jul 23, 2024
1 parent 16334b7 commit 83f05e7
Show file tree
Hide file tree
Showing 77 changed files with 2,407 additions and 2,263 deletions.
5 changes: 3 additions & 2 deletions tests/3rd/json/deserialization.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -59,8 +59,9 @@ int main()

for (int i = 0; i < data.objectArray.size(); ++i)
{
printf("objectArray[%d]: name = %s, object.currency = %s, object.value = %lf\n", i, data.objectArray[i].name.c_str(),
data.objectArray[i].object.currency.c_str(), data.objectArray[i].object.value);
printf("objectArray[%d]: name = %s, object.currency = %s, object.value = %lf\n", i,
data.objectArray[i].name.c_str(), data.objectArray[i].object.currency.c_str(),
data.objectArray[i].object.value);
}

return 0;
Expand Down
23 changes: 12 additions & 11 deletions tests/3rd/md5/testMd5.cpp
View file
Original file line number Diff line number Diff line change
@@ -1,24 +1,25 @@
#include "md5/md5.h"
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <stdint.h>
#include <iostream>
#include <chrono>
#include <iostream>
#include <string>
#include "md5/md5.h"

int main(int argc, char **argv) {
int main(int argc, char **argv)
{

int i;
uint8_t result[16]; // mds number
char resultstr[32]; // 128 bit / 4 = 32 Hexadecimal character
const size_t size = 1 << 20; // 1MB buffer
uint8_t *buf = new uint8_t[size];
uint8_t result[16]; // mds number
char resultstr[32]; // 128 bit / 4 = 32 Hexadecimal character
const size_t size = 1 << 20; // 1MB buffer
uint8_t *buf = new uint8_t[size];
memset(buf, 1, size);

auto t1 = std::chrono::steady_clock::now();
md5(buf, size, result);
auto t2 = std::chrono::steady_clock::now();
auto t2 = std::chrono::steady_clock::now();
auto time = std::chrono::duration<double, std::milli>(t2 - t1).count();
printf("md5 %luB data spent time = %lfms\n", size, time);

Expand All @@ -31,7 +32,7 @@ int main(int argc, char **argv) {
}

/***
jinbo@fang:$ g++ md5.cpp -o md5 && ./md5
jinbo@fang:$ g++ md5.cpp -o md5 && ./md5
md5 1048576B data spent time = 15.864010ms
md5 hexadecimal character = d35bb2e58b602d94ccd9628f249ae7e
*/
12 changes: 6 additions & 6 deletions tests/3rd/spdlog/testSpdlog.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,17 +15,17 @@
#define loge(format, ...) SPDLOG_LOGGER_ERROR(&logger, format, ##__VA_ARGS__)
#define logc(format, ...) SPDLOG_LOGGER_CRITICAL(&logger, format, ##__VA_ARGS__)

int main() {
int valude = 99;
int main()
{
int valude = 99;
size_t size = 100;
void *p = &size;
void *p = &size;

auto console_sink = std::make_shared<spdlog::sinks::stdout_color_sink_mt>();
console_sink->set_level(spdlog::level::trace);
console_sink->set_pattern("%^%W %Y-%m-%d %H:%M:%S.%e %^%L %t %P [%s:%!:%#] %v%$");

auto file_sink =
std::make_shared<spdlog::sinks::basic_file_sink_mt>("mylogs/multisink.txt", true);
auto file_sink = std::make_shared<spdlog::sinks::basic_file_sink_mt>("mylogs/multisink.txt", true);
file_sink->set_level(spdlog::level::trace);
file_sink->set_pattern("%^%W %Y-%m-%d %H:%M:%S.%e %^%L %t %P [%s:%!:%#] %v%$");

Expand All @@ -52,5 +52,5 @@ int main() {
/**
g++ testSpdlog.cpp -I ../../3rdtools/include/
./a.out
*
*
*/
155 changes: 76 additions & 79 deletions tests/demo/tcpServerClient/iterServer.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,16 +2,15 @@
一个 TCP 迭代服务器的例子，处理客户端发送过来的数据，排好序后发送给客户端
*/

#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <ctype.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <string.h>
#include <arpa/inet.h>
#include <ctype.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#include <string.h>

#include "sort.h"
#include "utils.h"
Expand All @@ -21,82 +20,80 @@ int port = 8888;

int main(int argc, char **argv)
{
struct sockaddr_in sin, pin; // sockaddr_in: IPv4 地址，sockaddr_in6: IPv6 地址
int sock_descriptor, temp_sock_descriptor, address_size;
int i, len, on = 1;
char buf[BUF_SIZE];
struct sockaddr_in sin, pin; // sockaddr_in: IPv4 地址，sockaddr_in6: IPv6 地址
int sock_descriptor, temp_sock_descriptor, address_size;
int i, len, on = 1;
char buf[BUF_SIZE];

char sort_name = '\0';
char cmp = '0';
char sort_name = '\0';
char cmp = '0';

// 创建一个用于网络通信的套接字，并返回该套接字的整数描述符
sock_descriptor = socket(AF_INET, SOCK_STREAM, 0);
// 四次挥手时服务器处于 TIME_WAIT 状态，需要等待 2MSL 时间。
// 此时监听服务器试图绑定到该端口，操作系统不会允许，可以在 socket 和 bind 之间设置允许地址重用套接口选项
setsockopt(sock_descriptor, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
bzero(&sin, sizeof(sin)); // 置字符串的前 n 位为 0，无返回值
// 填写本机 socket 地址结构体
sin.sin_family = AF_INET;
sin.sin_addr.s_addr = INADDR_ANY; // 转换过来就是0.0.0.0，表示本机的所有IP，因为有些机子不止一块网卡
sin.sin_port = htons(port); // 调用 htons 对端口号进行字节序转换
// 将 socket 与 IP 和端口号绑定，组成三元组
if (bind(sock_descriptor, (struct sockaddr *)&sin, sizeof(sin)) == -1) // 返回 -1 为失败
{
perror("call to bind\n");
exit(1);
}
// 将 socket 转换为被动（监听）套接口，用于接收客户端的连接请求，连接请求的队列大小设置为 100
if (listen(sock_descriptor, 100) == -1)
{
perror("call to listen\n");
exit(1);
}
printf("Accepting connections...\n");
// 创建一个用于网络通信的套接字，并返回该套接字的整数描述符
sock_descriptor = socket(AF_INET, SOCK_STREAM, 0);
// 四次挥手时服务器处于 TIME_WAIT 状态，需要等待 2MSL 时间。
// 此时监听服务器试图绑定到该端口，操作系统不会允许，可以在 socket 和 bind 之间设置允许地址重用套接口选项
setsockopt(sock_descriptor, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
bzero(&sin, sizeof(sin)); // 置字符串的前 n 位为 0，无返回值
// 填写本机 socket 地址结构体
sin.sin_family = AF_INET;
sin.sin_addr.s_addr = INADDR_ANY; // 转换过来就是0.0.0.0，表示本机的所有IP，因为有些机子不止一块网卡
sin.sin_port = htons(port); // 调用 htons 对端口号进行字节序转换
// 将 socket 与 IP 和端口号绑定，组成三元组
if (bind(sock_descriptor, (struct sockaddr *)&sin, sizeof(sin)) == -1) // 返回 -1 为失败
{
perror("call to bind\n");
exit(1);
}
// 将 socket 转换为被动（监听）套接口，用于接收客户端的连接请求，连接请求的队列大小设置为 100
if (listen(sock_descriptor, 100) == -1)
{
perror("call to listen\n");
exit(1);
}
printf("Accepting connections...\n");

int arr[ARR_SIZE] = { 0 };
int size = 0; // 数组的长度
while (1)
{
address_size = sizeof(pin);
// 获取到了客户端的连接，使 temp_sock_descriptor 为一个完整的 5 元组，因此可通过该套接口收发数据
temp_sock_descriptor = accept(sock_descriptor, (struct sockaddr *)&pin, &address_size);
if (temp_sock_descriptor == -1)
{
perror("call to accept\n");
exit(1);
}
// 从 TCP 的另一端接收数据; 设置大小为 BUF_SIZE 的缓冲区 buf 用来接收收到的数据
if (recv(temp_sock_descriptor, buf, BUF_SIZE, 0) == -1)
{
perror("call to recv");
exit(1);
}
// 将二进制整数 －> 点分十进制
inet_ntop(AF_INET, &pin.sin_addr, host_name, sizeof(host_name));
printf("received data from client(%s): %s\n", host_name, buf + HEAD_SIZE);
int arr[ARR_SIZE] = {0};
int size = 0; // 数组的长度
while (1)
{
address_size = sizeof(pin);
// 获取到了客户端的连接，使 temp_sock_descriptor 为一个完整的 5 元组，因此可通过该套接口收发数据
temp_sock_descriptor = accept(sock_descriptor, (struct sockaddr *)&pin, &address_size);
if (temp_sock_descriptor == -1)
{
perror("call to accept\n");
exit(1);
}
// 从 TCP 的另一端接收数据; 设置大小为 BUF_SIZE 的缓冲区 buf 用来接收收到的数据
if (recv(temp_sock_descriptor, buf, BUF_SIZE, 0) == -1)
{
perror("call to recv");
exit(1);
}
// 将二进制整数 －> 点分十进制
inet_ntop(AF_INET, &pin.sin_addr, host_name, sizeof(host_name));
printf("received data from client(%s): %s\n", host_name, buf + HEAD_SIZE);

len = strlen(buf);
memset(arr, 0, sizeof(int) * ARR_SIZE);
size = 0;
stoa(buf + HEAD_SIZE, arr, &size); // 前面 HEAD_SIZE 个数据为包头，后面的才是真正的数据
unpack(buf, &sort_name, &cmp);
// printf("buf:%s\nsort_name:%s\ncmp:%c\n", buf, sort_name, cmp);
sort(arr, size, sort_name, cmp);
// show(arr, size);
// printf("\n%s\n", buf);

memset(buf, '\0', sizeof(buf));
atos(arr, size, buf);
printf("after sort：%s\n\n", buf);

if (send(temp_sock_descriptor, buf, len + 1, 0) == -1) // 向 TCP 另一端（客户端）发送数据
{
perror("call to send\n");
exit(1);
}
// sleep(5);
close(temp_sock_descriptor); // 结束通信
}
}
len = strlen(buf);
memset(arr, 0, sizeof(int) * ARR_SIZE);
size = 0;
stoa(buf + HEAD_SIZE, arr, &size); // 前面 HEAD_SIZE 个数据为包头，后面的才是真正的数据
unpack(buf, &sort_name, &cmp);
// printf("buf:%s\nsort_name:%s\ncmp:%c\n", buf, sort_name, cmp);
sort(arr, size, sort_name, cmp);
// show(arr, size);
// printf("\n%s\n", buf);

memset(buf, '\0', sizeof(buf));
atos(arr, size, buf);
printf("after sort：%s\n\n", buf);

if (send(temp_sock_descriptor, buf, len + 1, 0) == -1) // 向 TCP 另一端（客户端）发送数据
{
perror("call to send\n");
exit(1);
}
// sleep(5);
close(temp_sock_descriptor); // 结束通信
}
}
Loading

0 comments on commit 83f05e7

Please sign in to comment.