mirror of
https://github.com/CPunch/gopenfusion.git
synced 2024-09-19 18:58:20 +00:00
unknown
8f00a0c492
you should be able to view other players and jump around together, although while testing locally one of the clients would always trigger the "Some irregularities have been found with your connection to the server, so your game will be closed" speed check for some reason ??? really not sure, might just be my machine chunking uhhh works ? kind of, not tested for more than a few seconds before one of the clients disconnects
100 lines
2.5 KiB
Go
100 lines
2.5 KiB
Go
package shard
|
|
|
|
import (
|
|
"github.com/CPunch/gopenfusion/core/entity"
|
|
)
|
|
|
|
func (server *ShardServer) getChunk(pos entity.ChunkPosition) *entity.Chunk {
|
|
chunk, ok := server.chunks[pos]
|
|
if !ok {
|
|
chunk = entity.NewChunk(pos)
|
|
server.chunks[pos] = chunk
|
|
}
|
|
|
|
return chunk
|
|
}
|
|
|
|
func (server *ShardServer) getViewableChunks(pos entity.ChunkPosition) []*entity.Chunk {
|
|
chunks := make([]*entity.Chunk, 0, 9)
|
|
for _, pos := range server.getChunk(pos).GetAdjacentPositions() {
|
|
chunks = append(chunks, server.getChunk(pos))
|
|
}
|
|
|
|
return chunks
|
|
}
|
|
|
|
// sends a packet to all peers in the given chunks, excluding the given peer
|
|
func (server *ShardServer) sendOthersPacket(plr *entity.Player, typeID uint32, pkt ...interface{}) error {
|
|
chunks := server.getViewableChunks(plr.Chunk)
|
|
for _, chunk := range chunks {
|
|
chunk.SendPacketExclude(plr, typeID, pkt...)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (server *ShardServer) removeEntityFromChunks(chunks []*entity.Chunk, this entity.Entity) {
|
|
for _, chunk := range chunks {
|
|
for e, _ := range chunk.Entities {
|
|
if e == this {
|
|
continue
|
|
}
|
|
|
|
// notify other players we're leaving
|
|
if e.GetKind() == entity.ENTITY_KIND_PLAYER {
|
|
otherPlr := e.(*entity.Player)
|
|
this.DisappearFromViewOf(otherPlr.Peer)
|
|
}
|
|
|
|
// notify us they're leaving
|
|
if this.GetKind() == entity.ENTITY_KIND_PLAYER {
|
|
thisPlr := this.(*entity.Player)
|
|
e.DisappearFromViewOf(thisPlr.Peer)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func (server *ShardServer) addEntityToChunks(chunks []*entity.Chunk, this entity.Entity) {
|
|
for _, chunk := range chunks {
|
|
for e, _ := range chunk.Entities {
|
|
if e == this {
|
|
continue
|
|
}
|
|
|
|
// notify other players we're entering
|
|
if e.GetKind() == entity.ENTITY_KIND_PLAYER {
|
|
otherPlr := e.(*entity.Player)
|
|
this.EnterIntoViewOf(otherPlr.Peer)
|
|
}
|
|
|
|
// notify us they're entering
|
|
if this.GetKind() == entity.ENTITY_KIND_PLAYER {
|
|
thisPlr := this.(*entity.Player)
|
|
e.EnterIntoViewOf(thisPlr.Peer)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func (server *ShardServer) updateEntityChunk(e entity.Entity, from entity.ChunkPosition, to entity.ChunkPosition) {
|
|
// no change needed
|
|
if from == to {
|
|
return
|
|
}
|
|
|
|
oldViewables := server.getViewableChunks(from)
|
|
newViewables := server.getViewableChunks(to)
|
|
|
|
// compute differences
|
|
toExit := entity.ChunkSliceDifference(oldViewables, newViewables)
|
|
toEnter := entity.ChunkSliceDifference(newViewables, oldViewables)
|
|
|
|
// update chunks
|
|
server.removeEntityFromChunks(toExit, e)
|
|
server.addEntityToChunks(toEnter, e)
|
|
server.getChunk(from).RemoveEntity(e)
|
|
server.getChunk(to).AddEntity(e)
|
|
e.SetChunk(to)
|
|
}
|