 Da Zheng
|
3d1f2e870a
|
delete shared memory when receiving signals. (#2419)
* delete shared memory when receive signal.
* rename.
* fix lint.
* fix lint.
* fix compile.
* Fix.
* we need to report error if the shared memory exist.
* disable tensorflow test for shared memory.
* revert.
Co-authored-by: Ubuntu <ubuntu@ip-172-31-2-202.us-west-1.compute.internal>
Co-authored-by: Jinjing Zhou <VoVAllen@users.noreply.github.com>
|
2020-12-26 10:41:10 -08:00 |
|
|
Chao Ma
|
a4a7e02f5f
|
[BugFix] Fix a small bug on kvstore (#2058)
* small fix
* update
|
2020-08-19 14:57:45 +08:00 |
|
|
Chao Ma
|
15e3ff878c
|
[Distributed] Fix memory leak in kvstore (#2016)
* Fix memory leak
* update
* update
* update
* update
* update
* update
* update
|
2020-08-13 17:17:24 +08:00 |
|
|
Chao Ma
|
d340ea3aa8
|
[Distributed] Remove server_count from ip_config.txt (#1985)
* remove server_count from ip_config.txt
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* lint
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* Update dist_context.py
* fix lint.
* make it work for multiple spaces.
* update ip_config.txt.
* fix examples.
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* udpate
* update
* update
* update
* update
* update
Co-authored-by: Da Zheng <zhengda1936@gmail.com>
Co-authored-by: Ubuntu <ubuntu@ip-172-31-19-1.us-west-2.compute.internal>
|
2020-08-11 17:41:48 +08:00 |
|
|
Jinjing Zhou
|
4f499c7ffb
|
[Distributed] DistDataloader (#1901)
* 111
* 111
* fix
* 111
* fix
* 11
* fix
* lint
* Update __init__.py
* lint
* fix
* lint
* fix
* fix
* fix
* fix
* fix
* try fix
* try fix
* fix
* Revert "fix"
This reverts commit a0b954fd4e99b7df92b53db8334dcb583d6e1551.
* fixes.
* fix.
* fix test.
* fix exit.
* fix.
* fix
* fix
* lint
* lint
* lint
* fix
* Update .gitignore
* 111
* fix
* 111
* 111
* fff
* 1111
* 111
* 1325315
* ffff
* f???
* fff
* 1111
* 111
* fix
* 111
* asda
* 1111
* 11
* 123
* 啊啊啊啊啊啊啊啊啊啊啊啊啊啊啊啊
* spawn
* 1231231
* up
* 111
* fix
* fix
* Revert "fix"
This reverts commit 7373f95312fdcaa36d2fc330bf242339e89c045d.
* fix
* fix
* 1111
* fix
* fix tests
* start kvclient as early as possible.
* lint
* fix test
* lint
* 1111
* fix
* fix
* 111
* fix
* fix
* 1
* fix
* fix
* lint
* fix
* lint
* lint
* remove quit
* fix
* lint
* fix
* fix several
* lint
* fix minor
* fix
* lint
Co-authored-by: Da Zheng <zhengda1936@gmail.com>
Co-authored-by: xiang song(charlie.song) <classicxsong@gmail.com>
|
2020-08-05 17:43:17 +08:00 |
|
|
Da Zheng
|
a4c931a9bf
|
[Distributed] Support multiple servers (#1886)
* client init graph on the backup servers.
* fix.
* test multi-server.
* fix anonymous dist tensors.
* check #parts.
* fix init_data
* add multi-server multi-client tests.
* update tests in kvstore.
* fix.
* verify the loaded partition.
* fix a bug.
* fix lint.
* fix.
* fix example.
* fix rpc.
* fix pull/push handler for backup kvstore
* fix example readme.
* change ip.
* update docstring.
Co-authored-by: Ubuntu <ubuntu@ip-172-31-19-1.us-west-2.compute.internal>
|
2020-08-02 19:50:34 -07:00 |
|
|
Chao Ma
|
5b515cf667
|
[KVStore] Support group barrier (#1880)
* udpate
* update
* update
* update
* update
* update
* update
* update
* fix lint
* update
* update
* update
* update
* udpate
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
Co-authored-by: Da Zheng <zhengda1936@gmail.com>
|
2020-07-30 19:21:20 +08:00 |
|
|
Jinjing Zhou
|
71cf78652d
|
Revert "[Distributed] DistDataloader (#1870)" (#1876)
This reverts commit 6557291fdc.
|
2020-07-28 17:57:57 +08:00 |
|
|
Jinjing Zhou
|
6557291fdc
|
[Distributed] DistDataloader (#1870)
* 111
* 111
* fix
* 111
* fix
* 11
* fix
* lint
* Update __init__.py
* lint
* fix
* lint
* fix
* fix
* fix
* fix
* fix
* try fix
* try fix
* fix
* Revert "fix"
This reverts commit a0b954fd4e99b7df92b53db8334dcb583d6e1551.
* fixes.
* fix.
* fix test.
* fix exit.
* fix.
* fix
* fix
* lint
* lint
* lint
* fix
* Update .gitignore
Co-authored-by: Da Zheng <zhengda1936@gmail.com>
|
2020-07-28 16:36:37 +08:00 |
|
|
Jinjing Zhou
|
18a26fcfb1
|
[Data] Support HeteroGraph save/load (#1526)
* 111
* add history version test
* fix
* 111
* save
* ``
* fix1
* 111
* add save heterograph
* lint
* lint
* add tests
* minor fix
* fix
* docs
* add format tets
* use unique_ptr
* fix
* fix interface
* 111
* 111
* fix
* lint
* fix
* add support to s3
* fix
* fix
* fix leak
* fix
* fix docs
* fix
* linlt
* fix
* fix
* fix
* address comment
* address comment
Co-authored-by: Minjie Wang <wmjlyjemaine@gmail.com>
Co-authored-by: xiang song(charlie.song) <classicxsong@gmail.com>
|
2020-06-30 13:34:50 +08:00 |
|
|
Chao Ma
|
dd8d5289ef
|
[rpc] Add num_clients and sort client ID by machine-id (#1713)
* add num_clients to kvstore
* update
* update
* update
* update
* update
* update
* update
* fix lint
* update
* update
* update
* add test
* update
* update
* update
* update
* fix test
* update
* update
* update
* update
* update
* update
* update
Co-authored-by: Da Zheng <zhengda1936@gmail.com>
|
2020-06-28 18:40:38 -07:00 |
|
|
Da Zheng
|
45e1333e13
|
[Distributed] Optimize distributed sampling (#1700)
* optimize sampling neighbors from the local partition.
* fix minior bugs.
* fix lint
* overlap local sampling and remote sampling.
* fix.
* fix lint.
* fix a potential bug.
Co-authored-by: Chao Ma <mctt90@gmail.com>
|
2020-06-26 17:05:29 -07:00 |
|
|
Jinjing Zhou
|
fc7cd27598
|
[RPC] accelerate sampling RPC (#1669)
* support null ndarray
* speed up
* placeholder
* fix
* lint
* lint
* fix
* done
* comment
* Update sampling.py
* Update sampling.py
* Update sampling.py
Co-authored-by: Da Zheng <zhengda1936@gmail.com>
|
2020-06-22 11:05:06 -07:00 |
|
|
Chao Ma
|
8fccdaf60d
|
[RPC] HandleCtrlC Register for handling Ctrl+C event. (#1652)
* update
* update
* update
* update
* fix lint
|
2020-06-17 14:54:13 +08:00 |
|
|
Chao Ma
|
b372b3c796
|
[KVStore] Add fast-pull for kvstore (#1647)
* add fast-pull
* update
* add fast-pull
* update
* update
* update
* update test
* update
* update
* update
* update
* update
* update
* update
* update
* add omp
* update
* update
|
2020-06-17 13:50:25 +08:00 |
|
|
Chao Ma
|
a67ba946bc
|
[RPC] Add send_request_to_machine() and remote_call_to_machine() (#1619)
* add send_request_to_machine()
* update
* update
* update
* update
* update
* update
* fix lint
* update
|
2020-06-11 13:04:06 +08:00 |
|
|
Chao Ma
|
64f49703af
|
[KVStore] Re-write kvstore using DGL RPC infrastructure (#1569)
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update init_data
* update server_state
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* debug init_data
* update
* update
* update
* update
* update
* update
* test get_meta_data
* update
* update
* update
* update
* update
* debug push
* update
* update
* update
* update
* update
* update
* update
* update
* update
* use F.reverse_data_type_dict
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* fix lint
* update
* fix lint
* update
* fix lint
* update
* update
* update
* update
* fix test
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* set random seed
* update
|
2020-06-04 16:48:53 +08:00 |
|
|
Chao Ma
|
3e69692233
|
[RPC] New RPC infrastructure. (#1549)
* WIP: rpc components
* client & server
* move network package to rpc
* fix include
* fix compile
* c api
* wip: test
* add basic tests
* missing file
* [RPC] Zero copy serializer (#1517)
* zerocopy serialization
* add test for HeteroGraph
* fix lint
* remove unnecessary codes
* add comment
* lint
* lint
* disable pylint for now
* add include for win
* windows guard
* lint
* lint
* skip test on windows
* refactor
* add comment
* fix
* comment
* 1111
* fix
* Update Jenkinsfile
* [RPC] Implementation of RPC infra (#1544)
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* remove client.cc and server.cc
* fix lint
* update
* update
* fix linr
* update
* fix lint
* update
* update
* update
* update
* update
* update
* update test
* update
* update test
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update comment
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* fix lint
* fix lint
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
* update
Co-authored-by: Minjie Wang <wmjlyjemaine@gmail.com>
Co-authored-by: Jinjing Zhou <VoVAllen@users.noreply.github.com>
|
2020-05-22 18:48:37 +08:00 |
|