wangbojing / ntyco Goto Github PK

纯c版本的协程实现，汇编切换，调度器实现，包含服务器端案例，客户端并发测试案例

Makefile 3.72% C 93.83% HTML 1.60% Perl 0.79% CMake 0.06%

ntyco's Introduction

My Working Thought

struct Offering {
  void *doc;
  void *code;
  void *paper;
  void *video;
  void *ppt;
  void *question;
};

Project * getExcellentOpenSource(CodeWorld *w) {
  
  if (your.interest) {
    if (email("[email protected]") || submit(issue)) {
      return getYourExcellentOpenSource();
    }
  }
  return top(w->star) == NULL ? top(w->fork) : top(w->star);
}

struct Offering * produce(Project *p) {

  Offering *o = malloc(sizeof(struct Offering));
  o->doc = arrangeDocument(p);
  o->code = produceExampleCode(p);
  o->video = produceVideo(p);
  o->paper = arrangePaper(p); //https://www.usenix.org/
  o->ppt = arrangePPTpdf(p);
  o->question = arrangeQuestionList(p);
  
  return o;
}

void produceRepo(struct Offering *o) {
  setRepoOrg0voice(o); // https://github.com/0voice
  free(o);
}

int main() {
  CodeWorld world;  // network, OS, storage, SDN, virtual, kernel, RISC-V, etc. (code with c/c++)
  
#pragma omp parallel num_threads(worker_nums)  
  {
    while(1) {
      Project *p = getExcellentOpenSource(world);
      //Project: dpdk, rocksdb, spdk, vpp, ovs, userstack, coroutine, virtio, nginx, redis, zmq, bpf/ebpf, io_uring, etc.

      struct Offering *o = produce(p);
      produceRepo(o);
    }
  }
}

ntyco's People

Contributors

Stargazers

Watchers

Forkers

yyuit2015 wipeher skyformat99 mingruizhou google6 blovesea qiuhaonan yangfei812 hgy1125 jevstein bamboolight potatoelf wumh1610 huashegn shixiaoxu chawlau johnneycat wqliceman jinjiangd wenkangyi flyfish2222 bobo-peng hs1995916123 akun1993 qiankunbo zcszw0504 mamengchen yonggeshidai easycoderwei willku1024 chenyufei kimer0907 panda-k misaka-wsx liuzhezhe123 aicken-wang iceorchid palmip zhengyang3 kuangye098 lufengjiang apporon zenghongjun jangocheng tianying484 ilovenaibao damon-ke polar9527 cutegugu yunnet gavin-ma xunshuidezhu laiyongqin asdlei99 liuyongqiang6 cugxchen jiehuali xxyyboy liululoveqian dongzhongshu chenxiaoran1206 dangerouspan gitter-badger geek-leeqc yejinlei top-jia chrisweizhy fly542 one2ter roger-hoo3 crixalis2013 xunmenging liuyan20149295 hlpjay imives tangyiyong zhaosj1991 pksophiya wangye2020 qingyou11 awen162 xuwa1300 jhonhasen 864811699 tianyibing xsong0411 zhuangkecheng qqsskk blueskydata ygyangguang dongjiye355 dehengxu atnightly zhyubi123 mywnlb flying1314 decwang jac0bwang shenhzou654321 zyq634455388

ntyco's Issues

nty_coroutine_sleep is not working

nty_coroutine_sleep is not working
nty_coroutine.c

nty_close happened.

nty_server_mulcore: nty_schedule.c:172: nty_schedule_sched_wait: Assertion `co_tmp == ((void *)0)' failed.
Aborted (core dumped)

nty_server.c:117 传入了一个栈变量

nty_coroutine_create(&read_co, server_reader, &cli_fd) cli_fd 为栈变量,复制给co->arg 栈对象的地址不会有问题么?

void server(void *arg) {

	unsigned short port = *(unsigned short *)arg;
	free(arg);

	int fd = nty_socket(AF_INET, SOCK_STREAM, 0);
	if (fd < 0) return ;

	struct sockaddr_in local, remote;
	local.sin_family = AF_INET;
	local.sin_port = htons(port);
	local.sin_addr.s_addr = INADDR_ANY;
	bind(fd, (struct sockaddr*)&local, sizeof(struct sockaddr_in));

	listen(fd, 20);
	printf("listen port : %d\n", port);

	struct timeval tv_begin;
	gettimeofday(&tv_begin, NULL);

	while (1) {
		socklen_t len = sizeof(struct sockaddr_in);
		int cli_fd = nty_accept(fd, (struct sockaddr*)&remote, &len);
		if (cli_fd % 1000 == 999) {

			struct timeval tv_cur;
			memcpy(&tv_cur, &tv_begin, sizeof(struct timeval));
			
			gettimeofday(&tv_begin, NULL);
			int time_used = TIME_SUB_MS(tv_begin, tv_cur);
			
			printf("client fd : %d, time_used: %d\n", cli_fd, time_used);
		}
		printf("new client comming\n");

		nty_coroutine *read_co;
		// arg 传入一个栈上变量?
		nty_coroutine_create(&read_co, server_reader, &cli_fd);
	}
}

nty_poll_inner happend

nty_socket.c: nty_poll_inner: Calling nty_poll_inner function to pass in more than one FD will cause the abort problem.

debug info:
nty_schedule_sched_wait (co=0x55555575e260, fd=6, events=28, timeout=1) at /root/clang/core/nty_schedule.c:152
152 if (co->status & BIT(NTY_COROUTINE_STATUS_WAIT_READ) ||
(gdb) n
155 co->id, co->fd, co->status);
(gdb)
154 printf("Unexpected event. lt id %"PRIu64" fd %"PRId32" already in %"PRId32" state\n",
(gdb)
Unexpected event. lt id 0 fd 5 already in 9 state
156 assert(0);

stack info:
#0 nty_schedule_sched_wait (co=0x55555575e260, fd=6, events=28, timeout=1) at /root/clang/core/nty_schedule.c:156
#1 0x0000555555555fa1 in nty_poll_inner (fds=0x555555762f30, nfds=2, timeout=1) at /root/clang/sample/nty_client_mult.c:91
#2 0x0000555555556179 in init_client () at /root/clang/sample/nty_client_mult.c:134
#3 0x00005555555561bc in client (arg=0x0) at /root/clang/sample/nty_client_mult.c:143
#4 0x0000555555556360 in _exec (lt=0x55555575e260) at /root/clang/core/nty_coroutine.c:116
#5 0x0000000000000000 in ?? ()

这句话什么意思

f1(){
        sleep(99999999)
}
f2(){
        println("hello")
}

main(){
        f1()
        f2()
}

与lthrad的差异

我阅读了一下NtyCo的源代码，发现其核心代码与lthread很相似，请问一下NtyCo借用了lthread的哪些内容，做了哪些改进和优化？

wangbojing / ntyco Goto Github PK

ntyco's Introduction

My Working Thought

ntyco's People

Contributors

Stargazers

Watchers

Forkers

ntyco's Issues

求大佬解释一下

Recommend Projects

Recommend Topics

Recommend Org